Function pollWebhook

apps/sim/lib/webhooks/polling/hubspot.ts:188–205

(ctx: PollWebhookContext)

  label: 'HubSpot',

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

    try {
      const accessToken = await resolveOAuthCredential(webhookData, 'hubspot', requestId, logger)
      const config = getProviderConfig<HubSpotWebhookConfig>(webhookData.providerConfig)

      if (config.objectType === 'list_membership') {
        return await pollListMembership(ctx, config, accessToken)
      }
      return await pollSearchBased(ctx, config, accessToken)
    } catch (error) {
      logger.error(`[${requestId}] Error processing HubSpot webhook ${webhookId}:`, error)
      await markWebhookFailed(webhookId, logger)
      return 'failure'
    }
  },
}

async function pollSearchBased(