Webhook

import { defineCapabilityWebhook } from "@scrydon/sdk-authoring/extensions/authoring/define";

const webhookCapability = defineCapabilityWebhook({
  async verify(request) {
    const signature = request.headers["x-webhook-signature"];
    const valid = verifyHmac(request.rawBody, signature, request.secret);
    return { valid, error: valid ? undefined : "Invalid signature" };
  },

  async transform(body, context) {
    const event = body as { id: string; type: string; data: unknown };
    return { id: event.id, eventType: event.type, data: event.data };
  },

  async challengeHandler(request) {
    const token = new URL(request.url).searchParams.get("challenge");
    return token ? new Response(token, { status: 200 }) : null;
  },

  matchEvent(event, trigger) {
    return event.eventType === trigger.config.eventType;
  },

  subscription: {
    async subscribe(request) {
      return createVendorSubscription(request);
    },
    async renew(subscriptionId, request) {
      return renewVendorSubscription(subscriptionId, request);
    },
    async unsubscribe(subscriptionId, credentials) {
      await deleteVendorSubscription(subscriptionId, credentials.accessToken);
    },
  },

  extractIdempotencyKey(headers) {
    return headers["x-webhook-delivery-id"] ?? null;
  },

  async buildTestPayload(request) {
    return {
      status: 200,
      payload: { type: "webhook.test", webhookId: request.webhookId },
    };
  },

  polling: {
    async initialize(request) {
      return { cursor: { since: new Date().toISOString() } };
    },
    async poll(request) {
      return pollVendorEvents(request.credentials.accessToken, request.cursor);
    },
  },

  responseFormatter: {
    formatSuccess() {
      return new Response(null, { status: 202 });
    },
    formatError(error) {
      return Response.json({ error: error.message }, { status: 400 });
    },
  },
});