Function pollWebhook

apps/sim/lib/webhooks/polling/google-sheets.ts:54–249

(ctx: PollWebhookContext)

  label: 'Google Sheets',

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

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

      const config = getProviderConfig<GoogleSheetsWebhookConfig>(webhookData.providerConfig)
      // Canonical keys (`spreadsheetId`/`sheetName`) first; the `manual*` keys are a transitional
      // basic-first fallback for configs deployed before the canonical key existed.
      const spreadsheetId = readCanonicalTriggerValue(
        config.spreadsheetId,
        config.manualSpreadsheetId
      )
      const sheetName = readCanonicalTriggerValue(config.sheetName, config.manualSheetName)
      const now = new Date()

      if (!spreadsheetId || !sheetName) {
        logger.error(`[${requestId}] Missing spreadsheetId or sheetName for webhook ${webhookId}`)
        await markWebhookFailed(webhookId, logger)
        return 'failure'
      }

      const { unchanged: skipPoll, currentModifiedTime } = await isDriveFileUnchanged(
        accessToken,
        spreadsheetId,
        config.lastModifiedTime,
        requestId,
        logger
      )

      if (skipPoll) {
        await updateWebhookProviderConfig(
          webhookId,
          { lastCheckedTimestamp: now.toISOString() },
          logger
        )
        await markWebhookSuccess(webhookId, logger)
        logger.info(`[${requestId}] Sheet not modified since last poll for webhook ${webhookId}`)
        return 'success'
      }

      const valueRender = config.valueRenderOption || 'FORMATTED_VALUE'
      const dateTimeRender = config.dateTimeRenderOption || 'SERIAL_NUMBER'

      const {
        rowCount: currentRowCount,
        headers,
        headerRowIndex,
      } = await fetchSheetState(
        accessToken,
        spreadsheetId,
        sheetName,