improvement(codebase): apply @sim/utils conventions to staging-introduced files

Author: waleedlatif1

apps/sim/app/api/v1/admin/outbox/[id]/requeue/route.ts

@@ -1,6 +1,7 @@
 import { db } from '@sim/db'
 import { outboxEvent } from '@sim/db/schema'
 import { createLogger } from '@sim/logger'
+import { toError } from '@sim/utils/errors'
 import { and, eq } from 'drizzle-orm'
 import { NextResponse } from 'next/server'
 import { withAdminAuthParams } from '@/app/api/v1/admin/middleware'
@@ -56,16 +57,7 @@ export const POST = withAdminAuthParams<{ id: string }>(async (_request, { param
       requeued: result[0],
     })
   } catch (error) {
-    logger.error('Failed to requeue outbox event', {
-      eventId: id,
-      error: error instanceof Error ? error.message : error,
-    })
-    return NextResponse.json(
-      {
-        success: false,
-        error: error instanceof Error ? error.message : 'Unknown error',
-      },
-      { status: 500 }
-    )
+    logger.error('Failed to requeue outbox event', { eventId: id, error: toError(error).message })
+    return NextResponse.json({ success: false, error: toError(error).message }, { status: 500 })
   }
 })

apps/sim/app/api/v1/admin/outbox/route.ts

@@ -1,6 +1,7 @@
 import { db } from '@sim/db'
 import { outboxEvent } from '@sim/db/schema'
 import { createLogger } from '@sim/logger'
+import { toError } from '@sim/utils/errors'
 import { and, desc, eq, sql } from 'drizzle-orm'
 import { type NextRequest, NextResponse } from 'next/server'
 import { withAdminAuth } from '@/app/api/v1/admin/middleware'
@@ -77,15 +78,7 @@ export const GET = withAdminAuth(async (request: NextRequest) => {
       counts,
     })
   } catch (error) {
-    logger.error('Failed to list outbox events', {
-      error: error instanceof Error ? error.message : error,
-    })
-    return NextResponse.json(
-      {
-        success: false,
-        error: error instanceof Error ? error.message : 'Unknown error',
-      },
-      { status: 500 }
-    )
+    logger.error('Failed to list outbox events', { error: toError(error).message })
+    return NextResponse.json({ success: false, error: toError(error).message }, { status: 500 })
   }
 })

apps/sim/app/api/webhooks/outbox/process/route.ts

@@ -1,4 +1,5 @@
 import { createLogger } from '@sim/logger'
+import { toError } from '@sim/utils/errors'
 import { type NextRequest, NextResponse } from 'next/server'
 import { verifyCronAuth } from '@/lib/auth/internal'
 import { billingOutboxHandlers } from '@/lib/billing/webhooks/outbox-handlers'
@@ -33,16 +34,9 @@ export async function GET(request: NextRequest) {
       result,
     })
   } catch (error) {
-    logger.error('Outbox processing failed', {
-      requestId,
-      error: error instanceof Error ? error.message : error,
-    })
+    logger.error('Outbox processing failed', { requestId, error: toError(error).message })
     return NextResponse.json(
-      {
-        success: false,
-        requestId,
-        error: error instanceof Error ? error.message : 'Unknown error',
-      },
+      { success: false, requestId, error: toError(error).message },
       { status: 500 }
     )
   }

apps/sim/executor/handlers/agent/agent-handler.ts

@@ -2,6 +2,7 @@ import { db } from '@sim/db'
 import { mcpServers } from '@sim/db/schema'
 import { createLogger } from '@sim/logger'
 import { toError } from '@sim/utils/errors'
+import { sleep } from '@sim/utils/helpers'
 import { and, eq, inArray, isNull } from 'drizzle-orm'
 import { createMcpToolId } from '@/lib/mcp/utils'
 import { getCustomToolById } from '@/lib/workflows/custom-tools/operations'
@@ -456,7 +457,7 @@ export class AgentBlockHandler implements BlockHandler {
             logger.warn(
               `[AgentHandler] Session error discovering tools from ${serverId}, retrying (attempt ${attempt + 1})`
             )
-            await new Promise((r) => setTimeout(r, 100))
+            await sleep(100)
             continue
           }
           throw new Error(`Failed to discover tools: ${response.status} ${errorText}`)
@@ -475,7 +476,7 @@ export class AgentBlockHandler implements BlockHandler {
             `[AgentHandler] Retryable error discovering tools from ${serverId} (attempt ${attempt + 1}):`,
             error
           )
-          await new Promise((r) => setTimeout(r, 100))
+          await sleep(100)
           continue
         }
         throw error

apps/sim/lib/core/outbox/service.ts

@@ -1,6 +1,7 @@
 import { db } from '@sim/db'
 import { outboxEvent } from '@sim/db/schema'
 import { createLogger } from '@sim/logger'
+import { toError } from '@sim/utils/errors'
 import { generateId } from '@sim/utils/id'
 import { and, asc, eq, inArray, lte } from 'drizzle-orm'
 
@@ -250,7 +251,7 @@ async function runHandler(
   } catch (error) {
     const nextAttempts = event.attempts + 1
     const isDead = nextAttempts >= event.maxAttempts
-    const errMsg = error instanceof Error ? error.message : String(error)
+    const errMsg = toError(error).message
 
     if (isDead) {
       const updated = await updateIfLeaseHeld(event, {

apps/sim/lib/table/__tests__/update-row.test.ts

@@ -3,8 +3,8 @@
  */
 import { databaseMock } from '@sim/testing'
 import { beforeEach, describe, expect, it, vi } from 'vitest'
-import { updateRow } from '../service'
-import type { TableDefinition } from '../types'
+import { updateRow } from '@/lib/table/service'
+import type { TableDefinition } from '@/lib/table/types'
 
 const EXISTING_ROW = {
   id: 'row-1',