lambda.function

Shopify-Webhooks-How-to-Prep-Your-App-This-Black-Friday-Cyber-Monday.js

'use strict';
var AWS = require('aws-sdk');
var sqs = new AWS.SQS();
var crypto = require('crypto');

exports.handler = (event, context, callback) => {
  var client_secret = event.client_secret;
  delete event.client_secret;

  //calculate the hash
  var calculated_hash = crypto.createHmac("sha256", client_secret).update(new Buffer(event.body, "base64")).digest("base64");

  //reject the message if the hash doesn't match
  if (event["X-Shopify-Hmac-SHA256"] != calculated_hash) {
    console.log("calculated_hash: (" + calculated_hash + ") != X-Shopify-Hmac-SHA256: (" + event["X-Shopify-Hmac-SHA256"] + ")");
    return;
  }
  
  sqs.getQueueUrl({ QueueName: event.queue }, function(err, data) {
    if (err) {
      console.log('ERR', err);
      return;
    }

    var sqsMessageParams = {
      MessageBody: JSON.stringify(event),
      QueueUrl: data.QueueUrl
    };
    
    sqs.sendMessage(sqsMessageParams, function(err, data) {
      if (err) {
        console.log('ERR', err);
      }
    });
  });
};