Subversion Repositories munaweb

<?php
/*  (C) 2013 eBay Inc., All Rights Reserved */
/* Licensed under CDDL 1.0 -  http://opensource.org/licenses/cddl1.php */
?>
<?php
$DEBUG = false;
$capturePath = "captures/";

// be sure include path contains current and shopify directory
ini_set('include_path', ini_get('include_path') . ':.:../php:../../shopify/php');

// Load general helper classes for eBay SOAP API
require_once 'keys.php';
require_once 'eBaySOAP.php';
require_once 'Shopify.php';

function debug_string_backtrace() {
    ob_start();
    debug_print_backtrace();
    $trace = ob_get_contents();
    ob_end_clean();

    // Remove first item from backtrace as it's this function which is redundant.
    $trace = preg_replace('/^#0\s+' . __FUNCTION__ . "[^\n]*\n/", '', $trace, 1);

    return $trace;
}

class eBayPlatformNotificationListener extends eBayPlatformNotifications {
    protected $NotificationSignature;

    // Dispatch method to ensure signature validation
    public function __call($method, $args) {
        $s = "Called with $method";
        $this->carp($s);

        // Print backtrace and arguments
        $this->carp(debug_string_backtrace());
        $this->carp("args=" . print_r($args, true));

        if ($this->ValidateSignature($args[0])) {
            // strip off trailing "Request"
            $method = substr($method, 0, -8);
            if (method_exists($this, $method)) {
                return call_user_func_array(array(
                    $this,
                    $method
                ) , $args);
            }
            else {
                $this->errorLog("Unhandled Event: args=" . print_r($args, true));
            }
        }

        // Today is a good day to die.
        die("Death");
    }

    // Extract Signature for validation later
    // Can't validate here because we don't have access to the Timestamp
    public function RequesterCredentials($RequesterCredentials) {
        $this->NotificationSignature = $RequesterCredentials->NotificationSignature;
    }

    protected function ValidateSignature($Timestamp) {
        // Check for Signature Match
        $CalculatedSignature = $this->CalculateSignature($Timestamp);
        $NotificationSignature = $this->NotificationSignature;

        if ($CalculatedSignature != $NotificationSignature) {
            //bugbug                        $this->errorLog("Sig Mismatch: Calc: $CalculatedSignature, Note: $NotificationSignature");
            //bugbug                        return false;
            
        }
        else {
            $this->carp("Sig Match: $NotificationSignature");
        }

        // Check that Timestamp is within 10 minutes of now
        $tz = date_default_timezone_get();
        date_default_timezone_set('UTC');
        $then = strtotime($Timestamp);
        $now = time();
        date_default_timezone_set($tz);

        $drift = $now - $then;
        $ten_minutes = 60 * 10;
        if ($drift > $ten_minutes) {
            $this->errorLog("Time Drift is too large: $drift seconds, Note: $NotificationSignature");
            return false;
        }
        else {
            $this->carp("Time Drift is okay: $drift seconds");
        }

        return true;
    }

    // Arg order is brittle, assumes constant return ordering from eBay
    public function GetMemberMessages($Timestamp, $Ack, $CorrelationID, $Version, $Build, $NotificationEventName, $RecipientUserID, $SellerEIASToken, $MemberMessage, $PaginationResult, $HasMoreItems) {
        $ItemID = $MemberMessage
            ->MemberMessageExchange
            ->Item->ItemID;
        $Seller = $MemberMessage
            ->MemberMessageExchange
            ->Item
            ->Seller->UserID;
        $Sender = $MemberMessage
            ->MemberMessageExchange
            ->Question->SenderID;
        $this->notificationLog("$NotificationEventName: From $Sender to $Seller regarding Item $ItemID");

        return "";
    }

    public function GetItem($Timestamp, $Ack, $CorrelationID, $Version, $Build, $NotificationEventName, $RecipientUserID, $BuyerEIASToken, $Item) {

        $ItemID = $Item->ItemID;
        $Title = $Item->Title;

        $UPC = (isset($Item
            ->ProductListingDetails
            ->UPC) ? $Item
            ->ProductListingDetails->UPC : "");
        $SKU = (isset($Item->SKU) ? $Item->SKU : "");
        $this->notificationLog("$NotificationEventName: ItemId=$ItemID; Title=$Title; SKU=$SKU; UPC=$UPC");

        if ($NotificationEventName == "BidReceived") {
            $list = shopifyProductAdjust($Title, $SKU, 1);
            $this->notificationLog($list[1]);
            if ($list[0] == false) {
                $this->errorLog($list[1]);
            }
        }

        return "";
    }

    public function GetItemTransactions($Timestamp, $Ack, $CorrelationID, $Version, $Build, $NotificationEventName, $SellerName, $BuyerEIASToken, $PaginationResult, $HasMoreItems, $x1, $x2, $x3, $Item, $Transaction) {

        $ItemID = $Item->ItemID;
        $Title = $Item->Title;
        $SKU = (isset($Item->SKU) ? $Item->SKU : "");
        $Quantity = (isset($Transaction
            ->Transaction
            ->QuantityPurchased) ? $Transaction
            ->Transaction->QuantityPurchased : "1");
        $this->notificationLog("$NotificationEventName: ItemId=$ItemID; Title=$Title; SKU=$SKU; Quantity=$Quantity");

        //if ($NotificationEventName == "AuctionCheckoutComplete") {
        if ($NotificationEventName == "FixedPriceTransaction") {
            $list = shopifyProductAdjust($Title, $SKU, $Quantity);
            $this->notificationLog($list[1]);
            if ($list[0] == false) {
                $this->errorLog($list[1]);
            }
        }

        return "";
    }

    public function GetFeedback($Timestamp, $Ack, $CorrelationID, $Version, $Build, $NotificationEventName, $SellerName, $BuyerEIASToken, $Feedback, $x1, $BuyerScore, $PaginationResult, $x2, $x3) {

        $ItemID = $Feedback
            ->FeedbackDetail->ItemID;
        $Type = $Feedback
            ->FeedbackDetail->CommentType;
        $Role = $Feedback
            ->FeedbackDetail->Role;
        $Text = $Feedback
            ->FeedbackDetail->CommentText;
        $this->notificationLog("$Type $Role Feedback for Item $ItemID=$Text");

        return "";
    }

    public function GetMyMessages($Timestamp, $Ack, $CorrelationID, $Version, $Build, $NotificationEventName, $SellerName, $SenderEIASToken, $Message) {

        $Sender = $Message
            ->Message->Sender;
        $Recipient = $Message
            ->Message->RecipientUserID;
        $Subject = $Message
            ->Message->Subject;
        $this->notificationLog("Message from $Sender to $Recipient regarding $Subject");

        return "";
    }

    public function GetBestOffers($Timestamp, $Ack, $CorrelationID, $Version, $Build, $NotificationEventName, $SellerName, $SenderEIASToken, $BestOffer, $BuyItNow) {

        $Sender = $BestOffer
            ->BestOffer
            ->Buyer->UserID;
        $BestOfferAmount = $BestOffer
            ->BestOffer->Price;
        $Title = $BuyItNow->Title;
        $OriginalPrice = $BuyItNow->BuyItNowPrice;
        $ItemID = $BuyItNow->ItemID;

        $this->notificationLog("$NotificationEventName: $Sender offered $BestOfferAmount (originally $OriginalPrice) for $ItemID ($Title)");

        return "";
    }

}

// Create and configure session
$session = new eBaySession($dev, $app, $cert);

if ($DEBUG) {
    error_log(serialize(apache_request_headers()));
}

#$stdin = $GLOBALS['HTTP_RAW_POST_DATA'];
$stdin = file_get_contents("php://input");
if ($DEBUG) {
    error_log("STDIN: " . $stdin);
}

$action = basename(str_replace('"', '', $_SERVER['HTTP_SOAPACTION']));
file_put_contents($capturePath . $action . '.xml', $stdin . "\n\n", FILE_APPEND);
if ($DEBUG) {
    error_log('EVENT NAME: ' . $action);
}

$server = new SOAPServer(null, array(
    'uri' => 'urn:ebay:apis:eBLBaseComponents'
));
$server->setClass('eBayPlatformNotificationListener', $session, $DEBUG);
$server->handle();

?>