Function getPayload

integrations/airtable/src/webhooks.ts:422–446

(
  baseId: string,
  webhookId: string,
  sdk: AirtableSDK,
  cursor: number | undefined
)

}

async function getPayload(
  baseId: string,
  webhookId: string,
  sdk: AirtableSDK,
  cursor: number | undefined
) {
  const url = new URL(`${apiUrl}/${baseId}/webhooks/${webhookId}/payloads`);
  if (cursor) {
    url.searchParams.append("cursor", cursor.toString());
  }

  const response = await fetch(url.href, {
    headers: {
      Authorization: `Bearer ${sdk._apiKey}`,
    },
    redirect: "follow",
  });

  if (!response.ok) {
    throw new Error(`Failed to list webhooks: ${response.statusText}`);
  }

  const webhook = await response.json();
  return ListWebhooksResponseSchema.parse(webhook);
}

async function handleWebhookError(response: Response, errorType: string) {
  const rawErrorBody = await response.json();