Function buildUserFilters

apps/sim/lib/webhooks/polling/hubspot.ts:533–581

(
  config: HubSpotWebhookConfig,
  logger?: Logger,
  requestId?: string
)

}

function buildUserFilters(
  config: HubSpotWebhookConfig,
  logger?: Logger,
  requestId?: string
): FilterClause[] {
  const filters: FilterClause[] = []

  // Shortcut fields translate to common HubSpot filter conditions.
  if (config.pipelineId?.trim()) {
    const property = config.objectType === 'ticket' ? 'hs_pipeline' : 'pipeline'
    filters.push({ propertyName: property, operator: 'EQ', value: config.pipelineId.trim() })
  }
  if (config.stageId?.trim()) {
    const property = config.objectType === 'ticket' ? 'hs_pipeline_stage' : 'dealstage'
    filters.push({ propertyName: property, operator: 'EQ', value: config.stageId.trim() })
  }
  if (config.ownerId?.trim()) {
    filters.push({ propertyName: 'hubspot_owner_id', operator: 'EQ', value: config.ownerId.trim() })
  }

  const raw = config.filters
  if (raw) {
    try {
      const parsed = typeof raw === 'string' ? JSON.parse(raw) : raw
      if (Array.isArray(parsed)) {
        for (const entry of parsed) {
          if (!entry || typeof entry !== 'object') continue
          const propertyName = String((entry as FilterClause).propertyName ?? '').trim()
          const operator = String((entry as FilterClause).operator ?? '').trim()
          if (!propertyName || !VALID_OPERATORS.has(operator)) continue
          const clause: FilterClause = { propertyName, operator }
          if (Array.isArray((entry as FilterClause).values)) {
            clause.values = (entry as FilterClause).values
          } else if ((entry as FilterClause).value !== undefined) {
            clause.value = String((entry as FilterClause).value)
          }
          filters.push(clause)
        }
      }
    } catch (error) {
      logger?.warn(
        `[${requestId ?? ''}] Could not parse user filters as JSON, ignoring:`,
        getErrorMessage(error, 'parse error')
      )
    }
  }

  return filters
}

function resolvePropertySnapshot(
  config: HubSpotWebhookConfig,