simstudioai--sim/apps/sim/app/api/table/[tableId]/columns/run/route.ts

import { createLogger } from '@sim/logger'
import { type NextRequest, NextResponse } from 'next/server'
import { runColumnContract } from '@/lib/api/contracts/tables'
import { parseRequest } from '@/lib/api/server'
import { checkSessionOrInternalAuth } from '@/lib/auth/hybrid'
import { generateRequestId } from '@/lib/core/utils/request'
import { withRouteHandler } from '@/lib/core/utils/with-route-handler'
import { runWorkflowColumn } from '@/lib/table/workflow-columns'
import { accessError, checkAccess, tableFilterError } from '@/app/api/table/utils'

const logger = createLogger('TableRunColumnAPI')

interface RouteParams {
  params: Promise<{ tableId: string }>
}

/** POST /api/table/[tableId]/columns/run */
export const POST = withRouteHandler(async (request: NextRequest, { params }: RouteParams) => {
  const requestId = generateRequestId()
  try {
    const auth = await checkSessionOrInternalAuth(request, { requireWorkflowId: false })
    if (!auth.success || !auth.userId) {
      return NextResponse.json({ error: 'Authentication required' }, { status: 401 })
    }
    const parsed = await parseRequest(runColumnContract, request, { params })
    if (!parsed.success) return parsed.response
    const { tableId } = parsed.data.params
    const { workspaceId, groupIds, runMode, rowIds, filter, excludeRowIds, limit } =
      parsed.data.body
    const access = await checkAccess(tableId, auth.userId, 'write')
    if (!access.ok) return accessError(access, requestId, tableId)

    // Validate the filter up front (the dispatcher reuses it) so a bad field fails fast.
    const filterError = tableFilterError(filter, access.table.schema.columns)
    if (filterError) return filterError

    const { dispatchId } = await runWorkflowColumn({
      tableId,
      workspaceId,
      groupIds,
      mode: runMode,
      rowIds,
      filter,
      excludeRowIds,
      limit,
      requestId,
      triggeredByUserId: auth.userId,
    })

    return NextResponse.json({ success: true, data: { dispatchId } })
  } catch (error) {
    if (error instanceof Error && error.message === 'Invalid workspace ID') {
      return NextResponse.json({ error: 'Invalid workspace ID' }, { status: 400 })
    }
    logger.error(`run-column failed:`, error)
    return NextResponse.json({ error: 'Failed to run columns' }, { status: 500 })
  }
})