Function fireTableTrigger

apps/sim/lib/table/trigger.ts:49–163

(
  tableId: string,
  tableName: string,
  eventType: EventType,
  rows: TableRow[],
  oldRows: Map<string, RowData> | null,
  schema: TableSchema,
  requestId: string
)

 * @param oldRows - Map of row ID to previous data. Pass null for inserts.
 */
export async function fireTableTrigger(
  tableId: string,
  tableName: string,
  eventType: EventType,
  rows: TableRow[],
  oldRows: Map<string, RowData> | null,
  schema: TableSchema,
  requestId: string
): Promise<void> {
  try {
    // Lazy: the webhook utils/processor pull in the executor + blocks stack.
    // Eager imports would force every `lib/table/service` consumer (e.g. the
    // dispatcher) to pay that cold-start even when no trigger fires.
    const { fetchActiveWebhooks } = await import('@/lib/webhooks/polling/utils')
    const webhooks = await fetchActiveWebhooks('table')
    if (webhooks.length === 0) return

    const headers = schema.columns.map((c) => c.name)
    // The webhook payload is name-keyed (the workflow author references columns
    // by name); stored row data is id-keyed, so translate on the way out.
    const nameById = buildNameById(schema)

    // Filter to webhooks watching this table with a matching event type
    const matching = webhooks.filter((entry) => {
      const config = entry.webhook.providerConfig as WebhookConfig | null
      // Canonical key `tableId` first; `tableSelector`/`manualTableId` are a transitional
      // basic-first fallback for configs deployed before the canonical key was written.
      const configTableId = readCanonicalTriggerValue(
        config?.tableId,
        config?.tableSelector,
        config?.manualTableId
      )
      if (configTableId !== tableId) return false

      const configEventType = config?.eventType ?? 'insert'
      return configEventType === eventType
    })

    if (matching.length === 0) return

    const { processPolledWebhookEvent } = await import('@/lib/webhooks/processor')

    logger.info(
      `[${requestId}] Firing ${matching.length} trigger(s) for ${rows.length} ${eventType} event(s) in table ${tableId}`
    )

    for (const { webhook: webhookData, workflow: workflowData } of matching) {
      const config = webhookData.providerConfig as WebhookConfig | null
      const watchColumns = parseWatchColumns(config?.watchColumns)
      const includeHeaders = config?.includeHeaders !== false

      for (const row of rows) {
        const previousIdData = oldRows?.get(row.id) ?? null
        // Translate id-keyed stored data → name-keyed for the external payload.
        const rawRow = rowDataIdToName(row.data, nameById)
        const previousRow = previousIdData ? rowDataIdToName(previousIdData, nameById) : null
        const changedColumns = previousIdData
          ? detectChangedColumns(previousIdData, row.data)