Function pollSearchBased

apps/sim/lib/webhooks/polling/hubspot.ts:208–348

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

}

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

  const objectType = resolveObjectType(config)
  const eventType = config.eventType
  if (!objectType) {
    throw new Error(`HubSpot webhook ${webhookId} is missing objectType`)
  }
  if (eventType !== 'created' && eventType !== 'updated' && eventType !== 'property_changed') {
    throw new Error(`HubSpot webhook ${webhookId} is missing or has invalid eventType`)
  }
  if (eventType === 'property_changed' && !config.targetPropertyName?.trim()) {
    throw new Error(
      `HubSpot webhook ${webhookId} uses property_changed event but has no targetPropertyName`
    )
  }

  // property_changed walks the modified-date stream and diffs the watched property locally.
  const filterProperty =
    eventType === 'created' ? 'createdate' : resolveModifiedDateProperty(objectType)
  const nowMs = Date.now()

  if (!config.lastSeenTimestampMs) {
    await updateWebhookProviderConfig(
      webhookId,
      {
        lastSeenTimestampMs: String(nowMs),
        lastCheckedTimestamp: new Date(nowMs).toISOString(),
        ...(eventType === 'property_changed'
          ? {
              propertySnapshot: {
                property: config.targetPropertyName?.trim() ?? '',
                entries: [],
              },
            }
          : {}),
      },
      logger
    )
    await markWebhookSuccess(webhookId, logger)
    logger.info(
      `[${requestId}] Seeded HubSpot webhook ${webhookId} watermark to ${nowMs} (${objectType}/${eventType}/${filterProperty})`
    )
    return 'success'
  }

  const watermarkMs = Number(config.lastSeenTimestampMs)
  if (!Number.isFinite(watermarkMs)) {
    throw new Error(
      `HubSpot webhook ${webhookId} has corrupt watermark ${config.lastSeenTimestampMs}`
    )
  }