Function pollWebhook

apps/sim/lib/webhooks/polling/gmail.ts:66–145

(ctx: PollWebhookContext)

  label: 'Gmail',

  async pollWebhook(ctx: PollWebhookContext): Promise<'success' | 'failure'> {
    const { webhookData, workflowData, requestId, logger } = ctx
    const webhookId = webhookData.id

    try {
      const accessToken = await resolveOAuthCredential(
        webhookData,
        'google-email',
        requestId,
        logger
      )

      const config = getProviderConfig<GmailWebhookConfig>(webhookData.providerConfig)
      const now = new Date()

      const { emails, latestHistoryId } = await fetchNewEmails(
        accessToken,
        config,
        requestId,
        logger
      )

      if (!emails || !emails.length) {
        await updateWebhookProviderConfig(
          webhookId,
          {
            lastCheckedTimestamp: now.toISOString(),
            ...(latestHistoryId || config.historyId
              ? { historyId: latestHistoryId || config.historyId }
              : {}),
          },
          logger
        )
        await markWebhookSuccess(webhookId, logger)
        logger.info(`[${requestId}] No new emails found for webhook ${webhookId}`)
        return 'success'
      }

      logger.info(`[${requestId}] Found ${emails.length} new emails for webhook ${webhookId}`)

      const { processedCount, failedCount } = await processEmails(
        emails,
        webhookData,
        workflowData,
        config,
        accessToken,
        requestId,
        logger
      )

      await updateWebhookProviderConfig(
        webhookId,
        {
          lastCheckedTimestamp: now.toISOString(),
          ...(latestHistoryId || config.historyId
            ? { historyId: latestHistoryId || config.historyId }
            : {}),
        },