Function createWebhookEventSource

integrations/shopify/src/webhooks.ts:73–198

(integration: Shopify)

}

export function createWebhookEventSource(integration: Shopify) {
  return new WebhookSource({
    id: "shopify",
    schemas: {
      params: z.object({
        topic: WebhookTopicSchema,
        // disabled for now, doesn't seem useful and complicates things
        // fields: z.string().array().optional(),
      }),
      // config: z.record(z.string().array()),
    },
    version: "0.1.0",
    integration,
    key: (params) => params.topic,
    crud: {
      create: async ({ io, ctx }) => {
        try {
          const webhook = await io.integration.rest.Webhook.save("create-webhook", {
            fromData: {
              address: ctx.url,
              topic: ctx.params.topic,
              // fields: ctx.params.fields,
            },
          });

          if (!webhook.id) {
            throw new Error(
              "Failed to create webhook. Ensure your Shopfiy client configuration is correct. Have you set the correct access scopes? Are you using the primary myshopify.com domain?"
            );
          }

          const clientSecret = await io.integration.runTask(
            "get-client-secret",
            async (client) => client.config.apiSecretKey
          );

          await io.store.job.set("set-id", "webhook-id", webhook.id);
          await io.store.job.set("set-secret", "webhook-secret", clientSecret);
        } catch (error) {
          if (error instanceof Error) {
            await io.logger.error(`Failed to create webhook: ${error.message}`);
          } else {
            await io.logger.error("Failed to create webhook", { rawError: error });
          }
          throw error;
        }
      },
      delete: async ({ io, ctx }) => {
        const webhookId = await io.store.job.get<number>("get-webhook-id", "webhook-id");

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

        try {
          await io.integration.rest.Webhook.delete("delete-webhook", {
            id: webhookId,
          });