如何在NestJS中添加对Shopify的WebHook验证详解

// 这是你从Shopify 上得到的接口校验密钥
const secret = 'xxxx';
const app = new Koa();
async function run() {
  // 其他的中间件的使用 / app.use...
  app.use(async (ctx, next) => {
    const isShopify = ctx.request.path.startsWith('设置在Shopify 上的WebHook url');
    if (!isShopify) {
      return koaBody({
        multipart: true,
        formidable: {
          maxFileSize: 2000 * 1024 * 1024, // 设置上传文件大小最大限制，默认2M
        },
      })(ctx, next);
    } else {
      let str = '';
      await new Promise((resolve, reject) => {
        try {
          ctx.req.on('data', function(data: string) {
            str += data;
          });
          ctx.req.on('end', function(chunk: string) {
            resolve(str);
          });
        } catch (e) {
          str = '{}';
          reject(e);
        }
      });
      const buf = Buffer.from(str);
      const hash = crypto.createHmac('sha256', secret).update(buf).digest('base64');
      const isOK = hash === ctx.request.headers['x-shopify-hmac-sha256'];
      ctx.request.body = JSON.parse(str);
      if (!isOK) {
        ctx.status = 403;
        ctx.body = 'Forbidden';
        return;
      }
      return await next();
    }
  })

// 这是你从Shopify 上得到的接口校验密钥
const secret = 'xxxx';
// 这是Shopify 响应返回的Buffer 体
const buf = '....'
// 这是从响应头里取出来的单次校验哈希
const hash = request.headers['x-shopify-hmac-sha256'];
const isOK = hash === crypto.createHmac('sha256', secret).update(buf).digest('base64')
// 如果isOK === false 则不对，如果是正常的Shopify 通知则为true.
// crypto 是原生Node 自带的库 import * as crypto from 'crypto'