How to Synchronize Orders with Shopify Webhooks

const express = require("express");
const app = express();
const port = 3000;

// Shopify will send data as JSON, register the express JSON parser
app.use(express.json());

// Expose our endpoint
app.post("/webhooks/order", (req, res) => {
	console.log(req.body);
	res.send("Server receive a order!");
});

app.listen(port, () => {
  console.log(`Order service listening at http://localhost:${port}`);
});

hookdeck listen 3000

// npm install shopify-api-node
const ShopifyApi = require('shopify-api-node');

const shopify = new ShopifyApi({
  shopName: 'SHOPIFY_STORE_NAME',
  apiKey: 'SHOPIFY_API_KEY',
  password: 'SHOPIFY_PASSWORD',
  apiVersion: '2020-01'
});

shopify.webhook.create({ 
	topic: ['order/created', 'order/updated', 'order/deleted'], 
	address: 'HOOKDECK_HTTPS_HOSTNAME' + '/webhooks/order' 
})
.then(console.log)
.catch(e => {
  console.error('Shopify - Registration failed for:', topic);
});

const crypto = require("crypto");

// Secret provided by Shopify when creating the webhook
const secret = "YOUR_SECRET";

// Middleware to verify the signature
const verifyShopifyWebhookSignature = (req, res, next) => {
	// Retrieve hmac signature from headers
	const hmacHeader = req.get("X-Shopify-Hmac-Sha256");
	// Calculate hash from body and secret value using sha256
	const hash = crypto
	    .createHmac("sha256", secret)
	    .update(Buffer.from(req.body))
	    .digest("base64");

	// Fail with 401, Unauthorize
	if(hash !== hmacHeader) {
		res.sendStatus(401)
	} else {
   // Proceed
	 next();
	}
}

// Register the middleware for the endpoint
app.post("/webhooks/order", verifyShopifyWebhookSignature, (req, res) => {
	console.log(req.body);
	res.send("Server receive a order!");
});

// npm install @elastic/elasticsearch
const elasticsearch = require("@elastic/elasticsearch");

const client = new elasticsearch.Client({
  node: "ELASTICSEARCH_SEARCH_URL",
  auth: {
    username: "ELASTICSEARCH_USER",
    password: "ELASTICSEARCH_PASSWORD",
  },
});

const index = "ELASTICSEARCH_INDEX";

const syncToElastic = (topic, order) => {
  if (topic === "order/deleted") {
    return client.delete({ index, id }).catch((err) => {
      if (err.meta && err.meta.statusCode === 404) {
        // Order was not found, and therefore already deleted.
        // That's to be expected since you can receive the same webhook multiple times
        return null;
      }
      throw err;
    });
  }
  // Set order id as elastic entry id to make the request idempotent.
  // Subsequent create with the same id will act as an update
  return client.index({ index, body: order, id: order.id });
};

app.post("/webhooks/order", verifyShopifyWebhookSignature, (req, res) => {
  syncToElastic(req.headers["X-Shopify-Topic"], req.data)
    .then(() => {
      res.send("Server receive a order!");
    })
    .catch((e) => {
      console.error(e);
      res.sendStatus(500);
    });
});