Function assertQstashMessage

apps/web/tests/webhooks/index.test.ts:118–147

(
  messageId: string,
  body: any,
  trigger: WebhookTrigger,
)

};

const assertQstashMessage = async (
  messageId: string,
  body: any,
  trigger: WebhookTrigger,
) => {
  const qstashMessage = await qstash.messages.get(messageId);

  const callbackUrl = new URL(qstashMessage.callback!);
  const failureCallbackUrl = new URL(qstashMessage.failureCallback!);
  const receivedBody = JSON.parse(qstashMessage.body!);

  expect(qstashMessage.url).toEqual(webhook.url);
  expect(qstashMessage.method).toEqual("POST");

  expect(callbackUrl.searchParams.get("webhookId")).toEqual(webhook.id);
  expect(callbackUrl.searchParams.get("event")).toEqual(trigger);
  expect(callbackUrl.searchParams.get("eventId")?.startsWith("evt_")).toBe(
    true,
  );

  expect(failureCallbackUrl.searchParams.get("webhookId")).toEqual(webhook.id);
  expect(failureCallbackUrl.searchParams.get("event")).toEqual(trigger);
  expect(
    failureCallbackUrl.searchParams.get("eventId")?.startsWith("evt_"),
  ).toBe(true);

  expect(receivedBody.event).toEqual(trigger);
  expect(receivedBody.data).toEqual(body);
  expect(eventSchemas[trigger].safeParse(receivedBody.data).success).toBe(true);
};

// TODO:
// Assert the signature is correct