Function pollListMembership

apps/sim/lib/webhooks/polling/hubspot.ts:350–486

(
  ctx: PollWebhookContext,
  config: HubSpotWebhookConfig,
  accessToken: string
)

}

async function pollListMembership(
  ctx: PollWebhookContext,
  config: HubSpotWebhookConfig,
  accessToken: string
): Promise<'success' | 'failure'> {
  const { webhookData, workflowData, requestId, logger } = ctx
  const webhookId = webhookData.id

  const listId = config.listId?.trim()
  if (!listId) {
    throw new Error(`HubSpot list_membership trigger ${webhookId} is missing listId`)
  }
  const nowMs = Date.now()
  const seedComplete = config.membershipSeedComplete === true
  const maxRecords = Math.min(
    Math.max(config.maxRecordsPerPoll ?? DEFAULT_MAX_RECORDS, 1),
    MAX_MAX_RECORDS
  )

  // The HubSpot endpoint walks ASC by default. We resume from a stored `after` cursor —
  // empty cursor means "from the beginning of the list". During the seed pass we paginate
  // forward without emitting; once we reach the end (no `paging.next.after`) we mark the
  // seed complete and re-fetch from the cursor-to-last-page on each normal poll. New
  // members appended to the list show up on subsequent fetches; the idempotency layer
  // dedups the records we've already seen on the boundary page.
  const result = await fetchListMembershipPages({
    listId,
    accessToken,
    initialAfter: config.lastSeenMembershipCursor?.trim() || undefined,
    pageLimit: seedComplete ? maxRecords : MAX_PAGES_PER_POLL * HUBSPOT_PAGE_LIMIT,
    requestId,
    logger,
  })

  if (!seedComplete) {
    // Seed phase: don't emit. Just save the cursor and (when reached) flip the flag.
    const update: Record<string, unknown> = {
      lastCheckedTimestamp: new Date(nowMs).toISOString(),
      lastSeenMembershipCursor: result.resumeCursor ?? '',
    }
    if (result.reachedEnd) {
      update.membershipSeedComplete = true
      logger.info(
        `[${requestId}] HubSpot list_membership ${webhookId} seed complete (list=${listId})`
      )
    } else {
      logger.info(
        `[${requestId}] HubSpot list_membership ${webhookId} seed in progress (list=${listId}, scanned ${result.scanned})`
      )
    }
    await updateWebhookProviderConfig(webhookId, update, logger)
    await markWebhookSuccess(webhookId, logger)
    return 'success'
  }

  if (result.records.length === 0) {
    await updateWebhookProviderConfig(
      webhookId,