fix: wire schema columns through all buildFilterClause call sites

Author: Aries0d0f

apps/sim/app/api/table/[tableId]/rows/route.ts

@@ -266,8 +266,10 @@ export const GET = withRouteHandler(
         eq(userTableRows.workspaceId, validated.workspaceId),
       ]
 
+      const schema = table.schema as TableSchema
+
       if (validated.filter) {
-        const filterClause = buildFilterClause(validated.filter as Filter, USER_TABLE_ROWS_SQL_NAME)
+        const filterClause = buildFilterClause(validated.filter as Filter, USER_TABLE_ROWS_SQL_NAME, schema.columns)
         if (filterClause) {
           baseConditions.push(filterClause)
         }
@@ -286,7 +288,6 @@ export const GET = withRouteHandler(
         .where(and(...baseConditions))
 
       if (validated.sort) {
-        const schema = table.schema as TableSchema
         const sortClause = buildSortClause(validated.sort, USER_TABLE_ROWS_SQL_NAME, schema.columns)
         if (sortClause) {
           query = query.orderBy(sortClause) as typeof query
@@ -509,6 +510,7 @@ export const DELETE = withRouteHandler(
           limit: validated.limit,
           workspaceId: validated.workspaceId,
         },
+        table,
         requestId
       )
 

apps/sim/app/api/v1/tables/[tableId]/rows/route.ts

@@ -158,8 +158,10 @@ export const GET = withRouteHandler(async (request: NextRequest, context: TableR
       eq(userTableRows.workspaceId, validated.workspaceId),
     ]
 
+    const schema = table.schema as TableSchema
+
     if (validated.filter) {
-      const filterClause = buildFilterClause(validated.filter as Filter, USER_TABLE_ROWS_SQL_NAME)
+      const filterClause = buildFilterClause(validated.filter as Filter, USER_TABLE_ROWS_SQL_NAME, schema.columns)
       if (filterClause) {
         baseConditions.push(filterClause)
       }
@@ -177,7 +179,6 @@ export const GET = withRouteHandler(async (request: NextRequest, context: TableR
       .where(and(...baseConditions))
 
     if (validated.sort) {
-      const schema = table.schema as TableSchema
       const sortClause = buildSortClause(validated.sort, USER_TABLE_ROWS_SQL_NAME, schema.columns)
       if (sortClause) {
         query = query.orderBy(sortClause) as typeof query
@@ -490,6 +491,7 @@ export const DELETE = withRouteHandler(
           limit: validated.limit,
           workspaceId: validated.workspaceId,
         },
+        table,
         requestId
       )
 

apps/sim/lib/copilot/tools/server/table/user-table.ts

@@ -474,6 +474,11 @@ export const userTableServerTool: BaseServerTool<UserTableArgs, UserTableResult>
             return { success: false, message: 'Workspace ID is required' }
           }
 
+          const table = await getTableById(args.tableId)
+          if (!table) {
+            return { success: false, message: `Table not found: ${args.tableId}` }
+          }
+
           const requestId = generateId().slice(0, 8)
           const result = await queryRows(
             args.tableId,
@@ -483,6 +488,7 @@ export const userTableServerTool: BaseServerTool<UserTableArgs, UserTableResult>
               sort: args.sort,
               limit: args.limit,
               offset: args.offset,
+              columns: table.schema.columns,
             },
             requestId
           )
@@ -605,6 +611,11 @@ export const userTableServerTool: BaseServerTool<UserTableArgs, UserTableResult>
             return { success: false, message: 'Workspace ID is required' }
           }
 
+          const table = await getTableById(args.tableId)
+          if (!table) {
+            return { success: false, message: `Table not found: ${args.tableId}` }
+          }
+
           const requestId = generateId().slice(0, 8)
           assertNotAborted()
           const result = await deleteRowsByFilter(
@@ -614,6 +625,7 @@ export const userTableServerTool: BaseServerTool<UserTableArgs, UserTableResult>
               limit: args.limit,
               workspaceId,
             },
+            table,
             requestId
           )
 

apps/sim/lib/table/service.ts

@@ -1435,7 +1435,7 @@ export async function queryRows(
 
   let whereClause = baseConditions
   if (filter && Object.keys(filter).length > 0) {
-    const filterClause = buildFilterClause(filter, tableName)
+    const filterClause = buildFilterClause(filter, tableName, options.columns)
     if (filterClause) {
       whereClause = and(baseConditions, filterClause)
     }
@@ -1818,7 +1818,7 @@ export async function updateRowsByFilter(
 ): Promise<BulkOperationResult> {
   const tableName = USER_TABLE_ROWS_SQL_NAME
 
-  const filterClause = buildFilterClause(data.filter, tableName)
+  const filterClause = buildFilterClause(data.filter, tableName, (table.schema as TableSchema).columns)
   if (!filterClause) {
     throw new Error('Filter is required for bulk update')
   }
@@ -2119,17 +2119,19 @@ async function recompactPositions(tableId: string, trx: DbTransaction, minDelete
  * Deletes multiple rows matching a filter.
  *
  * @param data - Bulk delete data
+ * @param table - Table definition used to emit correct SQL casts in filter expressions
  * @param requestId - Request ID for logging
  * @returns Bulk operation result
  */
 export async function deleteRowsByFilter(
   data: BulkDeleteData,
+  table: TableDefinition,
   requestId: string
 ): Promise<BulkOperationResult> {
   const tableName = USER_TABLE_ROWS_SQL_NAME
 
   // Build filter clause
-  const filterClause = buildFilterClause(data.filter, tableName)
+  const filterClause = buildFilterClause(data.filter, tableName, (table.schema as TableSchema).columns)
   if (!filterClause) {
     throw new Error('Filter is required for bulk delete')
   }

apps/sim/lib/table/types.ts

@@ -227,6 +227,8 @@ export interface QueryOptions {
    * is returned as `null` to signal it was not computed.
    */
   includeTotal?: boolean
+  /** Column definitions used to emit correct SQL casts for date/number fields in filter expressions. */
+  columns?: ColumnDefinition[]
 }
 
 export interface QueryResult {