shopify-serverless-sync-sanity.js

const sanityClient = require('@sanity/client');
const crypto = require('crypto');

const {
  SANITY_API_TOKEN,
  SANITY_PROJECT_ID,
  SANITY_DATASET,
  SHOPIFY_SECRET
} = process.env;

const client = sanityClient({
  projectId: SANITY_PROJECT_ID,
  dataset: SANITY_DATASET,
  token: SANITY_API_TOKEN,
});

exports.handler = async (event, context) => {
  if (event.httpMethod !== 'POST' || !event.body) {
    return {
      statusCode: 400,
      body: ''
    };
  }

  let data;
  let hasVariantsToSync = false;
  const hmac = event.headers['x-shopify-hmac-sha256']

  try {
    data = JSON.parse(event.body);
    const generatedHash = crypto
          .createHmac('sha256', SHOPIFY_SECRET)
          .update(event.body)
          .digest('base64')
    if (generatedHash !== hmac) {
      return {
        statusCode: 400,
        body: JSON.stringify({
          error: 'Bad Webhook Request'
        })
      }
    }
  } catch (error) {
    console.log('JSON parsing error:', error);

    return {
      statusCode: 400,
      body: JSON.stringify({
        error: 'Bad request body'
      })
    };
  }

  // Build our initial product
  const product = {
    _type: 'product',
    _id: data.id.toString(),
    productId: data.id,
    title: data.title,
    defaultPrice: data.variants[0].price,
    slug: {
      _type: 'slug',
      current: data.handle
    }
  };

  return client
    .transaction()
    .createIfNotExists(product)
    .patch(data.id.toString(), patch => patch.set(product))
    .commit()
    .then(res => {
      console.log(`Successfully updated/patched Product ${data.id} in Sanity`);

      if (data.variants.length > 1) {
        hasVariantsToSync = true;

        return Promise.all(data.variants.map(variant => {
          const variantData = {
            _type: 'productVariant',
            _id: variant.id.toString(),
            productId: data.id,
            variantId: variant.id,
            title: data.title,
            variantTitle: variant.title,
            sku: variant.sku,
            price: variant.price
          };

          return client
            .transaction()
            .createIfNotExists(variantData)
            .patch(variant.id.toString(), patch => patch.set(variantData))
            .commit()
            .then(response => {
              console.log(`Successfully updated/patched Variant ${variant.id} in Sanity`);
              return response;
            })
            .catch(error => {
              console.log('Sanity error:', error);
              return error;
            });
        })).then(result => {
          if (hasVariantsToSync) {
            return client
              .transaction()
              .createIfNotExists(product)
              .patch(data.id.toString(), patch => patch.set({
                variants: data.variants.map(variant => ({
                  _type: 'reference',
                  _ref: variant.id.toString(),
                  _key: variant.id.toString(),
                }))
              }))
              .commit()
              .then(response => {
                console.log(`Successfully added variant references to ${data.id} in Sanity`);
                return {
                  statusCode: 200,
                  body: JSON.stringify(response)
                };
              })
              .catch(error => {
                console.log('Sanity error:', error);
                return error;
              });
          } else {
            return {
              statusCode: 200,
              body: JSON.stringify(res)
            };
          }
        }).catch(error => {
          console.log('Sanity error:', error);

          return {
            statusCode: 500,
            body: JSON.stringify({
              error: 'An internal server error has occurred',
            })
          };
        });

      } else {
        return {
          statusCode: 200,
          body: JSON.stringify(res)
        };
      }
    })
    .catch(error => {
      console.log('Sanity error:', error);

      return {
        statusCode: 500,
        body: JSON.stringify({
          error: 'An internal server error has occurred',
        })
      };
    });
};

I’m doing that now but was hoping to avoid the call to sanity to read the product for the diff comparison. Don’t want the webhooks depleting the quotas. We have inventory stored in redis so I may compare against that value instead. If inventory values match assume product fields have changed and then run sanity diff.

…

On Oct 14, 2020, at 12:03 PM, Kevin Green ***@***.***> wrote: ***@***.*** commented on this gist. @alexcasche - what you are noticing is... a lovely feature of the Shopify Webhook, in which they do indeed trigger the rebuild with the inventory, and they do not specify in that webhook that the only thing that changed is inventory, and yes that thread discusses it further. I'm actually familiar with that post :) ANYWAY. I have a temp working example that you could rift off here: https://github.com/ctrl-alt-del-world/midway/blob/master/web/src/lambda/shopify-sync.ts#L218 I now do a fetch directly to sanity and do a simple diff on the title/handle/image/price and if any of those things change I trigger the transaction, if not it skips the update. — You are receiving this because you were mentioned. Reply to this email directly, view it on GitHub, or unsubscribe.

@alexcasche yeah I wish there was a better way to diff compare without a third party, and since shopify no longer sends inventory change it's pretty frustrating the hacks we need to implement to prevent the updates. But if I have to check sanity before updating i'd prefer that and prevent the rebuilding. I am experimenting with a different way to handle it that can also scale for users with hopefully low overhead. Also looking into Fauna as an option as it works pretty well with serverless and has pretty decent free plans.

@iamkevingreen yeah right now we’re doing SSR so we can handle some server tasks. But netlify add ons could easily replace the need soon. Background jobs and some redis integration would be awesome. Fauna looks really cool too