Subversion Repositories munaweb

<?php
// be sure include path contains current directory
ini_set('include_path', ini_get('include_path') . ':./php:../ebay/notifications');

// Load general helper classes for Shopify API
require_once 'eBay.php';
require_once 'shopifyConfig.php';
getShopifyConfig();

// Initialize data variable
$data = "";

// Get data and read it into a string
$dataFP = fopen('php://input' , 'rb');
while (!feof($dataFP)) { $data .= fread($dataFP, 4096); }
fclose($dataFP);

$hmac_header = $_SERVER['HTTP_X_SHOPIFY_HMAC_SHA256'];
$verified = verify_webhook($data, $hmac_header);

// Let Shopify know the request is malformed and exit
if (!$verified) {
    errorLog('Webhook verification', var_export($verified, true));
    header('HTTP/1.0 400 Bad request');
    exit();
}

// Let Shopify know the request has been received
ob_start();    // Buffer all upcoming output...
header('HTTP/1.0 200 OK');
header("Connection: close");    // Close the connection.
ob_end_flush();    // Flush all output.
ob_flush();
flush();
if(session_id()) session_write_close();    // Close current session (if it exists).

// Save Webhook action
$action = $_GET['action'];

// Create XML or JSON from data
if ($action == 'transactionCreate') {
  $json = json_decode($data);
  $output = print_r(json_decode($data, JSON_PRETTY_PRINT), true);
  $ext = 'json';
} else {
  $xml = new SimpleXMLElement($data);

  $dom = new DOMDocument('1.0');
  $dom->preserveWhiteSpace = false;
  $dom->formatOutput = true;
  $dom->loadXML($xml->asXML());
  $output = $dom->saveXML();

  $ext = 'xml';
}

// Save formatted XML/JSON in appropriate file
file_put_contents('captures/' . $action . '-' . date('Y-m-d-H.i.s') . '.' . $ext, $output, FILE_APPEND);

// Process XML/JSON
if (substr($action, 0, 5) === 'order') { // ----- Order -----
  // Get Order Name
  if ($action == "orderDelete") {
    $orderName = "Id " . trim($xml->id);
  } else {
    $orderName = trim($xml->name);
  }

  if ($action == "orderPaid") {
    $lockFile = ".lock/$orderName";
    $lockFileFlag = file_exists($lockFile);
        // prevent handling multiple notifications
        if (!$lockFileFlag) { file_put_contents($lockFile, ""); }
  }

  // Get titles, quantities and skus from line items
  $lineItems = array();
  foreach ($xml->{'line-items'}->{'line-item'} as $lineItem) {
    array_push($lineItems, array(trim($lineItem->title), trim($lineItem->quantity), trim($lineItem->sku)));
  }

  $last = count($lineItems) - 1;
  $str = "";
  foreach ($lineItems as $i => $row)
  {
    $isFirst = ($i == 0);
    $isLast = ($i == $last);

        if ($isFirst) {
                $str .= " (";
        } else {
                $str .= "; ";
        }

    $str .= "Title=\"" . $row[0] . "\" Qty=" . $row[1] . " SKU=" . $row[2];

        if ($isLast) {
                $str .= ")";
        }

    if ($action == "orderPaid" && !$lockFileFlag) {
          // Handle eBay Listing
      $list = eBayProductAdjust($row[0], intval($row[1]));
      webhookLog($action, "eBay adjust " . $row[0] . ": " . $list[1]);
          if ($list[0] == false) {
        errorLog($action, "eBay adjust " . $row[0] . ": " . $list[1]);
          }
    }
  }

  webhookLog($action, "Order $orderName" . $str);
} else if (substr($action, 0, 7) === 'product') { // ----- Product -----
  $productId = trim($xml->id);
  // xxxxx Title

  if ($action == "productCreate") {
  } else if ($action == "productUpdate") {
  } else if ($action == "productDelete") {
  }

  webhookLog($action, "Id=$productId");
} else if (substr($action, 0, 8) === 'customer') { // ----- Customer -----
  $customerId = trim($xml->id);
  if ($action == "customerDelete") {
        $customerName= "";
  } else {
    $customerFirstName = trim($xml->{'first-name'});
    $customerLastName = trim($xml->{'last-name'});
        $customerName= ", Name=$customerFirstName $customerLastName";
  }

  webhookLog($action, "Id=$customerId" . $customerName);
} else if (substr($action, 0, 11) === 'fulfillment') { // ----- Fulfillment -----
  $orderName = trim($xml->name);

  if ($action == "fulfillmentCreate") {
  } else if ($action == "fulfillmentUpdate") {
  }

  webhookLog($action, "Order $orderName");
} else if ($action == 'transactionCreate') { // ----- Transaction -----
  $tranId = $json->id;
  $tranOrderId = $json->order_id;
  $tranKind = $json->kind;
  $tranStatus = $json->status;
  $tranAmount = $json->amount;
  //$tranCurrency = $json->currency;

  webhookLog($action, "Id=$tranId, Order Id=$tranOrderId, kind=$tranKind, status=$tranStatus, amount=$tranAmount");
} else if ($action == 'refundCreate') { // ----- Refund -----
  $refundId = trim($xml->id);
  $orderId = trim($xml->{'order-id'});

  webhookLog($action, "Id=$refundId, Order Id=$orderId");
} else if ($action == 'shopUpdate') { // ----- Shop -----
  $shopId = trim($xml->id);
  $shopName = trim($xml->name);

  webhookLog($action, "Id=$shopId, Name=$shopName");
}

function webhookLog($Action, $String) {
  $datestamp = "[" . date("d-M-Y H:i:s") . "] ";
  file_put_contents('webhook.log', $datestamp . $Action . ': ' . $String . "\n", FILE_APPEND);
}

function errorLog($Action, $String) {
  global $fromEmail;
  global $toEmail;

  $subject = "Shopify Webhook Alert";
  $headers = "MIME-Version: 1.0" . "\n";
  $headers .= "Content-type:text/html;charset=UTF-8" . "\n";
  $headers .= "From: Shopify Webhook <$fromEmail>" . "\n";
  $message = "
  <html>
    <head>
      <title>Shopify Webhook Alert</title>
    </head>
    <body>
      <h1>Alert</h1>
      <table>
        <tr>
          <th>Action</th>
          <th>Message</th>
        </tr>
        <tr>
          <td>" . $Action . "</td>
          <td>" . $String . "</td>
        </tr>
      </table>
    </body>
  </html>
  ";

  error_log($Action . ": " . $String);
  mail($toEmail,$subject,$message,$headers,"-f".$fromEmail);
}


exit();
?>