Method #createWithFetch

integrations/shopify/src/webhooks.ts:22–70

(
    key: IntegrationTaskKey,
    params: {
      topic: WebhookTopic;
      address: string;
      fields?: string[];
    }
  )

  // just an example using raw fetch with error handling
  #createWithFetch(
    key: IntegrationTaskKey,
    params: {
      topic: WebhookTopic;
      address: string;
      fields?: string[];
    }
  ): Promise<WebhookSubscription> {
    return this.runTask(
      key,
      async (client, task, io) => {
        const resource = {
          webhook: {
            topic: params.topic,
            address: params.address,
            fields: params.fields,
          },
        };

        const request = new Request(new URL("webhooks.json", this.#apiUrl(client)), {
          method: "POST",
          headers: {
            "X-Shopify-Access-Token": client.config.adminApiAccessToken,
            "Content-Type": "application/json",
          },
          body: JSON.stringify(resource),
        });

        const response = await fetch(request.clone());

        if (!response.ok) {
          await handleWebhookError("WEBHOOK_CREATE", request, response);
        }

        const webhook = await response.json();
        const parsed = WebhookSubscriptionDataSchema.parse(webhook);

        return parsed.webhook;
      },
      {
        name: "Create Webhook with Fetch",
        params,
        properties: [
          { label: "Webhook URL", text: params.address },
          { label: "Topic", text: params.topic },
        ],
      }
    );
  }
}

export function createWebhookEventSource(integration: Shopify) {