Method create

integrations/airtable/src/webhooks.ts:83–128

(
    key: IntegrationTaskKey,
    { baseId, url, options }: { baseId: string; url: string; options: WebhookSpecification }
  )

  }

  create(
    key: IntegrationTaskKey,
    { baseId, url, options }: { baseId: string; url: string; options: WebhookSpecification }
  ): Promise<WebhookRegistrationData> {
    return this.runTask(
      key,
      async (client, task, io) => {
        const response = await fetch(`${apiUrl}/${baseId}/webhooks`, {
          method: "POST",
          headers: {
            Authorization: `Bearer ${client._apiKey}`,
            "Content-Type": "application/json",
          },
          body: JSON.stringify({
            notificationUrl: url,
            specification: {
              options: {
                ...options,
                includes: {
                  includePreviousCellValues: true,
                  includePreviousFieldDefinitions: true,
                },
              },
            },
          }),
          redirect: "follow",
        });

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

        const webhook = await response.json();
        const parsed = WebhookRegistrationDataSchema.parse(webhook);
        return parsed;
      },
      {
        name: "Create webhook",
        params: {
          baseId,
          url,
          options,
        },
      }
    );
  }

  list(key: IntegrationTaskKey, { baseId }: { baseId: string }): Promise<WebhookListData> {
    return this.runTask(