Function fetchTableColumns

apps/sim/triggers/table/poller.ts:11–36

(blockId: string)

import type { TriggerConfig } from '@/triggers/types'

async function fetchTableColumns(blockId: string): Promise<Array<{ label: string; id: string }>> {
  const activeWorkflowId = useWorkflowRegistry.getState().activeWorkflowId
  const workspaceId = useWorkflowRegistry.getState().hydration.workspaceId
  if (!activeWorkflowId || !workspaceId) return []

  const blockValues = useSubBlockStore.getState().workflowValues[activeWorkflowId]?.[blockId]
  const tableId = (blockValues?.tableSelector as string) || (blockValues?.manualTableId as string)
  if (!tableId) return []

  const tables = await getQueryClient().fetchQuery({
    queryKey: tableKeys.list(workspaceId),
    queryFn: async ({ signal }): Promise<TableDefinition[]> => {
      const response = await requestJson(listTablesContract, {
        query: { workspaceId, scope: 'active' },
        signal,
      })
      return (response.data.tables ?? []) as TableDefinition[]
    },
    staleTime: 60 * 1000,
  })

  const table = tables.find((t: TableDefinition) => t.id === tableId)
  if (!table?.schema?.columns) return []

  return table.schema.columns.map((col) => ({ id: col.name, label: col.name }))
}

export const tableNewRowTrigger: TriggerConfig = {
  id: 'table_new_row',