Function createWebhookSource

integrations/airtable/src/webhooks.ts:267–385

(
  integration: Airtable
)

};

export function createWebhookSource(
  integration: Airtable
): WebhookSource<
  Airtable,
  { baseId: string; tableId?: string },
  { dataTypes: WebhookDataType[]; fromSources?: WebhookFromSource[] }
> {
  return new WebhookSource({
    id: "airtable.webhook",
    schemas: {
      params: z.object({ baseId: z.string(), tableId: z.string().optional() }),
      config: z.object({
        dataTypes: z.array(WebhookDataTypeSchema),
        fromSources: z.array(WebhookFromSourceSchema).optional(),
      }),
    },
    version: "0.1.0",
    integration,
    filter: (params, options) => ({
      actionMetadata: {
        source: options?.fromSources ?? ["client", "anonymousUser", "formSubmission"],
      },
    }),
    key: (params) =>
      `airtable.webhook.${params.baseId}${params.tableId ? `.${params.tableId}` : ""}`,
    crud: {
      create: async ({ io, ctx }) => {
        const webhook = await io.integration.webhooks().create("create-webhook", {
          url: ctx.url,
          baseId: ctx.params?.baseId,
          options: getSpecification(ctx.config.desired, ctx.params),
        });

        await io.store.job.set("set-id", "webhook-id", webhook.id);
        await io.store.job.set("set-secret", "webhook-secret-base64", webhook.macSecretBase64);
      },
      read: async ({ io, ctx }) => {
        const listResponse = await io.integration.webhooks().list("list-webhooks", {
          baseId: ctx.params?.baseId,
        });

        const existingWebhook = listResponse.webhooks.find((w) => w.notificationUrl === ctx.url);

        if (!existingWebhook) {
          return await io.store.job.delete("delete-stale-webhook-id", "webhook-id");
        }

        await io.store.job.set("set-webhook-id", "webhook-id", existingWebhook.id);
      },
      delete: async ({ io, ctx }) => {
        const webhookId = await io.store.job.get<string>("get-webhook-id", "webhook-id");

        if (!webhookId) {
          throw new Error("Missing webhook ID for delete operation.");
        }

        await io.integration.webhooks().delete("delete-webhook", {
          baseId: ctx.params?.baseId,