v0.5.77: room manager redis migration, tool outputs, ui fixes

* fix(subflows): tag dropdown + resolution logic (#2949)

* fix(subflows): tag dropdown + resolution logic

* fixes;

* revert parallel change

* chore(deps): bump posthog-js to 1.334.1 (#2948)

* fix(idempotency): add conflict target to atomicallyClaimDb query + remove redundant db namespace tracking (#2950)

* fix(idempotency): add conflict target to atomicallyClaimDb query

* delete needs to account for namespace

* simplify namespace filtering logic

* fix cleanup

* consistent target

* improvement(kb): add document filtering, select all, and React Query migration (#2951)

* improvement(kb): add document filtering, select all, and React Query migration

* test(kb): update tests for enabledFilter and removed userId params

* fix(kb): remove non-null assertion, add explicit guard

* improvement(logs): trace span, details (#2952)

* improvement(action-bar): ordering

* improvement(logs): details, trace span

* feat(blog): v0.5 release post (#2953)

* feat(blog): v0.5 post

* improvement(blog): simplify title and remove code block header

- Simplified blog title from Introducing Sim Studio v0.5 to Introducing Sim v0.5
- Removed language label header and copy button from code blocks for cleaner appearance

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

* ack PR comments

* small styling improvements

* created system to create post-specific components

* updated componnet

* cache invalidation

---------

Co-authored-by: Claude Opus 4.5 <noreply@anthropic.com>

* feat(admin): add credits endpoint to issue credits to users (#2954)

* feat(admin): add credits endpoint to issue credits to users

* fix(admin): use existing credit functions and handle enterprise seats

* fix(admin): reject NaN and Infinity in amount validation

* styling

* fix(admin): validate userId and email are strings

* improvement(copilot): fast mode, subagent tool responses and allow preferences (#2955)

* Improvements

* Fix actions mapping

* Remove console logs

* fix(billing): handle missing userStats and prevent crashes (#2956)

* fix(billing): handle missing userStats and prevent crashes

* fix(billing): correct import path for getFilledPillColor

* fix(billing): add Number.isFinite check to lastPeriodCost

* fix(logs): refresh logic to refresh logs details (#2958)

* fix(security): add authentication and input validation to API routes (#2959)

* fix(security): add authentication and input validation to API routes

* moved utils

* remove extraneous commetns

* removed unused dep

* improvement(helm): add internal ingress support and same-host path consolidation (#2960)

* improvement(helm): add internal ingress support and same-host path consolidation

* improvement(helm): clean up ingress template comments

Simplify verbose inline Helm comments and section dividers to match the
minimal style used in services.yaml.

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

* fix(helm): add missing copilot path consolidation for realtime host

When copilot.host equals realtime.host but differs from app.host,
copilot paths were not being routed. Added logic to consolidate
copilot paths into the realtime rule for this scenario.

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

* improvement(helm): follow ingress best practices

- Remove orphan comments that appeared when services were disabled
- Add documentation about path ordering requirements
- Paths rendered in order: realtime, copilot, app (specific before catch-all)
- Clean template output matching industry Helm chart standards

---------

Co-authored-by: Claude Opus 4.5 <noreply@anthropic.com>

* feat(blog): enterprise post (#2961)

* feat(blog): enterprise post

* added more images, styling

* more content

* updated v0-5 post

* remove unused transition

---------

Co-authored-by: Vikhyath Mondreti <vikhyath@simstudio.ai>

* fix(envvars): resolution standardized (#2957)

* fix(envvars): resolution standardized

* remove comments

* address bugbot

* fix highlighting for env vars

* remove comments

* address greptile

* address bugbot

* fix(copilot): mask credentials fix (#2963)

* Fix copilot masking

* Clean up

* Lint

* improvement(webhooks): remove dead code (#2965)

* fix(webhooks): subscription recreation path

* improvement(webhooks): remove dead code

* fix tests

* address bugbot comments

* fix restoration edge case

* fix more edge cases

* address bugbot comments

* fix gmail polling

* add warnings for UI indication for credential sets

* fix(preview): subblock values (#2969)

* fix(child-workflow): nested spans handoff (#2966)

* fix(child-workflow): nested spans handoff

* remove overly defensive programming

* update type check

* type more code

* remove more dead code

* address bugbot comments

* fix(security): restrict API key access on internal-only routes (#2964)

* fix(security): restrict API key access on internal-only routes

* test(security): update function execute tests for checkInternalAuth

* updated agent handler

* move session check higher in checkSessionOrInternalAuth

* extracted duplicate code into helper for resolving user from jwt

* fix(copilot): update copilot chat title (#2968)

* fix(hitl): fix condition blocks after hitl (#2967)

* fix(notes): ghost edges (#2970)

* fix(notes): ghost edges

* fix deployed state fallback

* fallback

* remove UI level checks

* annotation missing from autoconnect source check

* improvement(docs): loop and parallel var reference syntax (#2975)

* fix(blog): slash actions description (#2976)

* improvement(docs): loop and parallel var reference syntax

* fix(blog): slash actions description

* fix(auth): copilot routes (#2977)

* Fix copilot auth

* Fix

* Fix

* Fix

* fix(copilot): fix edit summary for loops/parallels (#2978)

* fix(integrations): hide from tool bar (#2544)

* fix(landing): ui (#2979)

* fix(edge-validation): race condition on collaborative add (#2980)

* fix(variables): boolean type support and input improvements (#2981)

* fix(variables): boolean type support and input improvements

* fix formatting

---------

Co-authored-by: Vikhyath Mondreti <vikhyathvikku@gmail.com>
Co-authored-by: Emir Karabeg <78010029+emir-karabeg@users.noreply.github.com>
Co-authored-by: Claude Opus 4.5 <noreply@anthropic.com>
Co-authored-by: Siddharth Ganesan <33737564+Sg312@users.noreply.github.com>
Co-authored-by: Vikhyath Mondreti <vikhyath@simstudio.ai>

apps/sim/app/(auth)/components/social-login-buttons.tsx

@@ -39,8 +39,18 @@ export function SocialLoginButtons({
     setIsGithubLoading(true)
     try {
       await client.signIn.social({ provider: 'github', callbackURL })
-    } catch (_err: unknown) {
-      // Error handling is done silently - user will see the OAuth error page if needed
+    } catch (err: any) {
+      let errorMessage = 'Failed to sign in with GitHub'
+
+      if (err.message?.includes('account exists')) {
+        errorMessage = 'An account with this email already exists. Please sign in instead.'
+      } else if (err.message?.includes('cancelled')) {
+        errorMessage = 'GitHub sign in was cancelled. Please try again.'
+      } else if (err.message?.includes('network')) {
+        errorMessage = 'Network error. Please check your connection and try again.'
+      } else if (err.message?.includes('rate limit')) {
+        errorMessage = 'Too many attempts. Please try again later.'
+      }
     } finally {
       setIsGithubLoading(false)
     }
@@ -52,8 +62,18 @@ export function SocialLoginButtons({
     setIsGoogleLoading(true)
     try {
       await client.signIn.social({ provider: 'google', callbackURL })
-    } catch (_err: unknown) {
-      // Error handling is done silently - user will see the OAuth error page if needed
+    } catch (err: any) {
+      let errorMessage = 'Failed to sign in with Google'
+
+      if (err.message?.includes('account exists')) {
+        errorMessage = 'An account with this email already exists. Please sign in instead.'
+      } else if (err.message?.includes('cancelled')) {
+        errorMessage = 'Google sign in was cancelled. Please try again.'
+      } else if (err.message?.includes('network')) {
+        errorMessage = 'Network error. Please check your connection and try again.'
+      } else if (err.message?.includes('rate limit')) {
+        errorMessage = 'Too many attempts. Please try again later.'
+      }
     } finally {
       setIsGoogleLoading(false)
     }

apps/sim/app/(auth)/login/login-form.tsx

@@ -158,7 +158,7 @@ export default function LoginPage({
     return () => {
       window.removeEventListener('keydown', handleKeyDown)
     }
-  }, [forgotPasswordOpen])
+  }, [forgotPasswordEmail, forgotPasswordOpen])
 
   const handleEmailChange = (e: React.ChangeEvent<HTMLInputElement>) => {
     const newEmail = e.target.value

apps/sim/app/(auth)/sso/sso-form.tsx

@@ -3,7 +3,7 @@
 import { useEffect, useState } from 'react'
 import { createLogger } from '@sim/logger'
 import Link from 'next/link'
-import { useSearchParams } from 'next/navigation'
+import { useRouter, useSearchParams } from 'next/navigation'
 import { Button } from '@/components/ui/button'
 import { Input } from '@/components/ui/input'
 import { Label } from '@/components/ui/label'
@@ -52,6 +52,7 @@ const validateCallbackUrl = (url: string): boolean => {
 }
 
 export default function SSOForm() {
+  const router = useRouter()
   const searchParams = useSearchParams()
   const [isLoading, setIsLoading] = useState(false)
   const [email, setEmail] = useState('')

apps/sim/app/(auth)/verify/use-verification.ts

@@ -196,7 +196,7 @@ export function useVerification({
 
       return () => clearTimeout(timeoutId)
     }
-  }, [otp, email, isLoading, isVerified, verifyCode])
+  }, [otp, email, isLoading, isVerified])
 
   useEffect(() => {
     if (typeof window !== 'undefined') {
@@ -220,7 +220,7 @@ export function useVerification({
         handleRedirect()
       }
     }
-  }, [isEmailVerificationEnabled, router, isInviteFlow, redirectUrl, refetchSession])
+  }, [isEmailVerificationEnabled, router, isInviteFlow, redirectUrl])
 
   return {
     otp,

apps/sim/app/(landing)/components/hero/components/landing-canvas/dot-pattern.tsx

@@ -118,7 +118,7 @@ export function DotPattern({
           <stop offset='100%' stopColor='currentColor' stopOpacity='0' />
         </radialGradient>
       </defs>
-      {dots.map((dot, _index) => (
+      {dots.map((dot, index) => (
         <circle
           key={`${dot.x}-${dot.y}`}
           cx={dot.x}

apps/sim/app/(landing)/components/hero/components/landing-canvas/landing-flow.tsx

@@ -106,8 +106,9 @@ export function LandingFlow({
       proOptions={{ hideAttribution: true }}
       fitView={false}
       defaultViewport={{ x: 0, y: 0, zoom: 1 }}
-      onInit={() => {
+      onInit={(instance) => {
         setRfReady(true)
+        // Expose limited viewport API for outer timeline to pan smoothly
         viewportApiRef.current = {
           panTo: (x: number, y: number, options?: { duration?: number }) => {
             setViewport({ x, y, zoom: 1 }, { duration: options?.duration ?? 0 })

apps/sim/app/(landing)/components/hero/hero.tsx

@@ -140,7 +140,7 @@ export default function Hero() {
    */
   const [rfNodes, setRfNodes] = React.useState<Node[]>([])
   const [rfEdges, setRfEdges] = React.useState<Edge[]>([])
-  const [groupBox] = React.useState<LandingGroupData | null>(null)
+  const [groupBox, setGroupBox] = React.useState<LandingGroupData | null>(null)
   const [worldWidth, setWorldWidth] = React.useState<number>(1000)
   const viewportApiRef = React.useRef<LandingViewportApi | null>(null)
 

apps/sim/app/api/a2a/serve/[agentId]/utils.ts

@@ -149,7 +149,7 @@ export function extractAgentContent(executeResult: {
   if (typeof executeResult.output === 'object' && executeResult.output !== null) {
     const keys = Object.keys(executeResult.output)
     // Skip empty objects or objects with only undefined values
-    if (keys.length > 0 && keys.some((k) => executeResult.output?.[k] !== undefined)) {
+    if (keys.length > 0 && keys.some((k) => executeResult.output![k] !== undefined)) {
       return JSON.stringify(executeResult.output)
     }
   }

apps/sim/app/api/auth/oauth/connections/route.ts

@@ -19,7 +19,7 @@ interface GoogleIdToken {
 /**
  * Get all OAuth connections for the current user
  */
-export async function GET(_request: NextRequest) {
+export async function GET(request: NextRequest) {
   const requestId = generateRequestId()
 
   try {

apps/sim/app/api/auth/oauth/token/route.test.ts

@@ -177,6 +177,7 @@ describe('OAuth Token API Routes', () => {
       const { POST } = await import('@/app/api/auth/oauth/token/route')
 
       const response = await POST(req)
+      const data = await response.json()
 
       expect(response.status).toBe(403)
     })

apps/sim/app/api/auth/oauth2/callback/shopify/route.ts

@@ -1,4 +1,4 @@
-import crypto from 'node:crypto'
+import crypto from 'crypto'
 import { createLogger } from '@sim/logger'
 import { type NextRequest, NextResponse } from 'next/server'
 import { getSession } from '@/lib/auth'

apps/sim/app/api/auth/trello/authorize/route.ts

@@ -8,7 +8,7 @@ const logger = createLogger('TrelloAuthorize')
 
 export const dynamic = 'force-dynamic'
 
-export async function GET(_request: NextRequest) {
+export async function GET(request: NextRequest) {
   try {
     const session = await getSession()
     if (!session?.user?.id) {

apps/sim/app/api/auth/trello/callback/route.ts

@@ -3,7 +3,7 @@ import { getBaseUrl } from '@/lib/core/utils/urls'
 
 export const dynamic = 'force-dynamic'
 
-export async function GET(_request: NextRequest) {
+export async function GET(request: NextRequest) {
   const baseUrl = getBaseUrl()
 
   return new NextResponse(

apps/sim/app/api/chat/[identifier]/otp/route.ts

@@ -1,4 +1,4 @@
-import { randomUUID } from 'node:crypto'
+import { randomUUID } from 'crypto'
 import { db } from '@sim/db'
 import { chat, verification } from '@sim/db/schema'
 import { createLogger } from '@sim/logger'

apps/sim/app/api/chat/[identifier]/route.ts

@@ -1,4 +1,4 @@
-import { randomUUID } from 'node:crypto'
+import { randomUUID } from 'crypto'
 import { db } from '@sim/db'
 import { chat, workflow } from '@sim/db/schema'
 import { createLogger } from '@sim/logger'

apps/sim/app/api/chat/route.ts

@@ -42,7 +42,7 @@ const chatSchema = z.object({
     .default([]),
 })
 
-export async function GET(_request: NextRequest) {
+export async function GET(request: NextRequest) {
   try {
     const session = await getSession()
 

apps/sim/app/api/copilot/api-keys/generate/route.ts

@@ -61,7 +61,7 @@ export async function POST(req: NextRequest) {
       { success: true, key: { id: data?.id || 'new', apiKey: data.apiKey } },
       { status: 201 }
     )
-  } catch (_error) {
+  } catch (error) {
     return NextResponse.json({ error: 'Failed to generate copilot API key' }, { status: 500 })
   }
 }

apps/sim/app/api/copilot/api-keys/route.ts

@@ -3,7 +3,7 @@ import { getSession } from '@/lib/auth'
 import { SIM_AGENT_API_URL_DEFAULT } from '@/lib/copilot/constants'
 import { env } from '@/lib/core/config/env'
 
-export async function GET(_request: NextRequest) {
+export async function GET(request: NextRequest) {
   try {
     const session = await getSession()
     if (!session?.user?.id) {
@@ -49,7 +49,7 @@ export async function GET(_request: NextRequest) {
     })
 
     return NextResponse.json({ keys }, { status: 200 })
-  } catch (_error) {
+  } catch (error) {
     return NextResponse.json({ error: 'Failed to get keys' }, { status: 500 })
   }
 }
@@ -89,7 +89,7 @@ export async function DELETE(request: NextRequest) {
     }
 
     return NextResponse.json({ success: true }, { status: 200 })
-  } catch (_error) {
+  } catch (error) {
     return NextResponse.json({ error: 'Failed to delete key' }, { status: 500 })
   }
 }

apps/sim/app/api/copilot/chat/route.ts

@@ -494,6 +494,20 @@ export async function POST(req: NextRequest) {
 
     // If streaming is requested, forward the stream and update chat later
     if (stream && simAgentResponse.body) {
+      // Create user message to save
+      const userMessage = {
+        id: userMessageIdToUse, // Consistent ID used for request and persistence
+        role: 'user',
+        content: message,
+        timestamp: new Date().toISOString(),
+        ...(fileAttachments && fileAttachments.length > 0 && { fileAttachments }),
+        ...(Array.isArray(contexts) && contexts.length > 0 && { contexts }),
+        ...(Array.isArray(contexts) &&
+          contexts.length > 0 && {
+            contentBlocks: [{ type: 'contexts', contexts: contexts as any, timestamp: Date.now() }],
+          }),
+      }
+
       // Create a pass-through stream that captures the response
       const transformedStream = new ReadableStream({
         async start(controller) {
@@ -501,11 +515,14 @@ export async function POST(req: NextRequest) {
           let assistantContent = ''
           const toolCalls: any[] = []
           let buffer = ''
+          const isFirstDone = true
+          let responseIdFromStart: string | undefined
           let responseIdFromDone: string | undefined
           // Track tool call progress to identify a safe done event
           const announcedToolCallIds = new Set<string>()
           const startedToolExecutionIds = new Set<string>()
           const completedToolExecutionIds = new Set<string>()
+          let lastDoneResponseId: string | undefined
           let lastSafeDoneResponseId: string | undefined
 
           // Send chatId as first event
@@ -547,15 +564,9 @@ export async function POST(req: NextRequest) {
           }
 
           // Forward the sim agent stream and capture assistant response
-          const reader = simAgentResponse.body?.getReader()
+          const reader = simAgentResponse.body!.getReader()
           const decoder = new TextDecoder()
 
-          if (!reader) {
-            logger.error(`[${tracker.requestId}] Failed to get reader from response body`)
-            controller.close()
-            return
-          }
-
           try {
             while (true) {
               const { done, value } = await reader.read()
@@ -636,11 +647,15 @@ export async function POST(req: NextRequest) {
                         break
 
                       case 'start':
+                        if (event.data?.responseId) {
+                          responseIdFromStart = event.data.responseId
+                        }
                         break
 
                       case 'done':
                         if (event.data?.responseId) {
                           responseIdFromDone = event.data.responseId
+                          lastDoneResponseId = responseIdFromDone
 
                           // Mark this done as safe only if no tool call is currently in progress or pending
                           const announced = announcedToolCallIds.size
@@ -675,7 +690,7 @@ export async function POST(req: NextRequest) {
                               `data: ${JSON.stringify({ type: 'content', data: formatted })}\n\n`
                             )
                           )
-                        } catch (_enqueueErr) {
+                        } catch (enqueueErr) {
                           reader.cancel()
                           break
                         }
@@ -684,7 +699,7 @@ export async function POST(req: NextRequest) {
                           controller.enqueue(
                             encoder.encode(`data: ${JSON.stringify({ type: 'done' })}\n\n`)
                           )
-                        } catch (_enqueueErr) {
+                        } catch (enqueueErr) {
                           reader.cancel()
                           break
                         }
@@ -694,7 +709,7 @@ export async function POST(req: NextRequest) {
                       // Forward original event to client
                       try {
                         controller.enqueue(encoder.encode(`data: ${jsonStr}\n\n`))
-                      } catch (_enqueueErr) {
+                      } catch (enqueueErr) {
                         reader.cancel()
                         break
                       }
@@ -752,17 +767,17 @@ export async function POST(req: NextRequest) {
                       controller.enqueue(
                         encoder.encode(`data: ${JSON.stringify({ type: 'done' })}\n\n`)
                       )
-                    } catch (_enqueueErr) {
+                    } catch (enqueueErr) {
                       reader.cancel()
                     }
                   } else {
                     try {
                       controller.enqueue(encoder.encode(`data: ${jsonStr}\n\n`))
-                    } catch (_enqueueErr) {
+                    } catch (enqueueErr) {
                       reader.cancel()
                     }
                   }
-                } catch (_e) {
+                } catch (e) {
                   logger.warn(`[${tracker.requestId}] Failed to parse final buffer: "${buffer}"`)
                 }
               }

apps/sim/app/api/copilot/checkpoints/revert/route.ts

@@ -113,7 +113,7 @@ export async function POST(request: NextRequest) {
       )
     }
 
-    const _result = await stateResponse.json()
+    const result = await stateResponse.json()
     logger.info(
       `[${tracker.requestId}] Successfully reverted workflow ${checkpoint.workflowId} to checkpoint ${checkpointId}`
     )

apps/sim/app/api/copilot/checkpoints/route.ts

@@ -63,7 +63,7 @@ export async function POST(req: NextRequest) {
     let parsedWorkflowState
     try {
       parsedWorkflowState = JSON.parse(workflowState)
-    } catch (_error) {
+    } catch (error) {
       return createBadRequestResponse('Invalid workflow state JSON')
     }
 

apps/sim/app/api/copilot/confirm/route.ts

@@ -121,6 +121,8 @@ export async function POST(req: NextRequest) {
       return createBadRequestResponse('Failed to update tool call status or tool call not found')
     }
 
+    const duration = tracker.getDuration()
+
     return NextResponse.json({
       success: true,
       message: message || `Tool call ${toolCallId} has been ${status.toLowerCase()}`,

apps/sim/app/api/copilot/feedback/route.ts

@@ -111,7 +111,7 @@ export async function POST(req: NextRequest) {
  * GET /api/copilot/feedback
  * Get all feedback records (for analytics)
  */
-export async function GET(_req: NextRequest) {
+export async function GET(req: NextRequest) {
   const tracker = createRequestTracker()
 
   try {

apps/sim/app/api/copilot/stats/route.ts

@@ -5,6 +5,7 @@ import {
   authenticateCopilotRequestSessionOnly,
   createBadRequestResponse,
   createInternalServerErrorResponse,
+  createRequestTracker,
   createUnauthorizedResponse,
 } from '@/lib/copilot/request-helpers'
 import { env } from '@/lib/core/config/env'
@@ -18,6 +19,7 @@ const BodySchema = z.object({
 })
 
 export async function POST(req: NextRequest) {
+  const tracker = createRequestTracker()
   try {
     const { userId, isAuthenticated } = await authenticateCopilotRequestSessionOnly()
     if (!isAuthenticated || !userId) {
@@ -60,7 +62,7 @@ export async function POST(req: NextRequest) {
     }
 
     return NextResponse.json({ success: true })
-  } catch (_error) {
+  } catch (error) {
     return createInternalServerErrorResponse('Failed to forward copilot stats')
   }
 }

apps/sim/app/api/copilot/user-models/route.ts

@@ -34,7 +34,7 @@ const DEFAULT_ENABLED_MODELS: Record<CopilotModelId, boolean> = {
 }
 
 // GET - Fetch user's enabled models
-export async function GET(_request: NextRequest) {
+export async function GET(request: NextRequest) {
   try {
     const session = await getSession()
 

apps/sim/app/api/creators/[id]/route.ts

@@ -46,7 +46,7 @@ async function hasPermission(userId: string, profile: any): Promise<boolean> {
 }
 
 // GET /api/creators/[id] - Get a specific creator profile
-export async function GET(_request: NextRequest, { params }: { params: Promise<{ id: string }> }) {
+export async function GET(request: NextRequest, { params }: { params: Promise<{ id: string }> }) {
   const requestId = generateRequestId()
   const { id } = await params
 
@@ -137,7 +137,7 @@ export async function PUT(request: NextRequest, { params }: { params: Promise<{
 
 // DELETE /api/creators/[id] - Delete a creator profile
 export async function DELETE(
-  _request: NextRequest,
+  request: NextRequest,
   { params }: { params: Promise<{ id: string }> }
 ) {
   const requestId = generateRequestId()

apps/sim/app/api/creators/[id]/verify/route.ts

@@ -12,7 +12,7 @@ const logger = createLogger('CreatorVerificationAPI')
 export const revalidate = 0
 
 // POST /api/creators/[id]/verify - Verify a creator (super users only)
-export async function POST(_request: NextRequest, { params }: { params: Promise<{ id: string }> }) {
+export async function POST(request: NextRequest, { params }: { params: Promise<{ id: string }> }) {
   const requestId = generateRequestId()
   const { id } = await params
 
@@ -62,7 +62,7 @@ export async function POST(_request: NextRequest, { params }: { params: Promise<
 
 // DELETE /api/creators/[id]/verify - Unverify a creator (super users only)
 export async function DELETE(
-  _request: NextRequest,
+  request: NextRequest,
   { params }: { params: Promise<{ id: string }> }
 ) {
   const requestId = generateRequestId()

apps/sim/app/api/creators/route.ts

@@ -30,6 +30,8 @@ const CreateCreatorProfileSchema = z.object({
 // GET /api/creators - Get creator profiles for current user
 export async function GET(request: NextRequest) {
   const requestId = generateRequestId()
+  const { searchParams } = new URL(request.url)
+  const userId = searchParams.get('userId')
 
   try {
     const session = await getSession()

apps/sim/app/api/credential-sets/[id]/invite/[invitationId]/route.ts

@@ -37,7 +37,7 @@ async function getCredentialSetWithAccess(credentialSetId: string, userId: strin
 }
 
 export async function POST(
-  _req: NextRequest,
+  req: NextRequest,
   { params }: { params: Promise<{ id: string; invitationId: string }> }
 ) {
   const session = await getSession()

apps/sim/app/api/credential-sets/[id]/invite/route.ts

@@ -41,7 +41,7 @@ async function getCredentialSetWithAccess(credentialSetId: string, userId: strin
   return { set, role: membership.role }
 }
 
-export async function GET(_req: NextRequest, { params }: { params: Promise<{ id: string }> }) {
+export async function GET(req: NextRequest, { params }: { params: Promise<{ id: string }> }) {
   const session = await getSession()
 
   if (!session?.user?.id) {

apps/sim/app/api/credential-sets/[id]/members/route.ts

@@ -33,7 +33,7 @@ async function getCredentialSetWithAccess(credentialSetId: string, userId: strin
   return { set, role: membership.role }
 }
 
-export async function GET(_req: NextRequest, { params }: { params: Promise<{ id: string }> }) {
+export async function GET(req: NextRequest, { params }: { params: Promise<{ id: string }> }) {
   const session = await getSession()
 
   if (!session?.user?.id) {

apps/sim/app/api/credential-sets/[id]/route.ts

@@ -43,7 +43,7 @@ async function getCredentialSetWithAccess(credentialSetId: string, userId: strin
   return { set, role: membership.role }
 }
 
-export async function GET(_req: NextRequest, { params }: { params: Promise<{ id: string }> }) {
+export async function GET(req: NextRequest, { params }: { params: Promise<{ id: string }> }) {
   const session = await getSession()
 
   if (!session?.user?.id) {
@@ -141,7 +141,7 @@ export async function PUT(req: NextRequest, { params }: { params: Promise<{ id:
   }
 }
 
-export async function DELETE(_req: NextRequest, { params }: { params: Promise<{ id: string }> }) {
+export async function DELETE(req: NextRequest, { params }: { params: Promise<{ id: string }> }) {
   const session = await getSession()
 
   if (!session?.user?.id) {

apps/sim/app/api/credential-sets/invite/[token]/route.ts

@@ -13,7 +13,7 @@ import { syncAllWebhooksForCredentialSet } from '@/lib/webhooks/utils.server'
 
 const logger = createLogger('CredentialSetInviteToken')
 
-export async function GET(_req: NextRequest, { params }: { params: Promise<{ token: string }> }) {
+export async function GET(req: NextRequest, { params }: { params: Promise<{ token: string }> }) {
   const { token } = await params
 
   const [invitation] = await db
@@ -61,7 +61,7 @@ export async function GET(_req: NextRequest, { params }: { params: Promise<{ tok
   })
 }
 
-export async function POST(_req: NextRequest, { params }: { params: Promise<{ token: string }> }) {
+export async function POST(req: NextRequest, { params }: { params: Promise<{ token: string }> }) {
   const { token } = await params
 
   const session = await getSession()

apps/sim/app/api/environment/route.ts

@@ -72,7 +72,7 @@ export async function POST(req: NextRequest) {
   }
 }
 
-export async function GET(_request: Request) {
+export async function GET(request: Request) {
   const requestId = generateRequestId()
 
   try {

apps/sim/app/api/files/authorization.ts

@@ -162,7 +162,7 @@ async function verifyWorkspaceFileAccess(
   cloudKey: string,
   userId: string,
   customConfig?: StorageConfig,
-  _isLocal?: boolean
+  isLocal?: boolean
 ): Promise<boolean> {
   try {
     // Priority 1: Check database (most reliable, works for both local and cloud)
@@ -228,7 +228,7 @@ async function verifyWorkspaceFileAccess(
 async function verifyExecutionFileAccess(
   cloudKey: string,
   userId: string,
-  _customConfig?: StorageConfig
+  customConfig?: StorageConfig
 ): Promise<boolean> {
   const parts = cloudKey.split('/')
 
@@ -493,7 +493,7 @@ async function verifyRegularFileAccess(
   cloudKey: string,
   userId: string,
   customConfig?: StorageConfig,
-  _isLocal?: boolean
+  isLocal?: boolean
 ): Promise<boolean> {
   try {
     // Priority 1: Check if this might be a workspace file (check database)

apps/sim/app/api/files/parse/route.test.ts

@@ -1,4 +1,4 @@
-import path from 'node:path'
+import path from 'path'
 /**
  * Tests for file parse API route
  *

apps/sim/app/api/files/parse/route.ts

@@ -1,7 +1,7 @@
-import { Buffer } from 'node:buffer'
-import { createHash } from 'node:crypto'
-import fsPromises, { readFile } from 'node:fs/promises'
-import path from 'node:path'
+import { Buffer } from 'buffer'
+import { createHash } from 'crypto'
+import fsPromises, { readFile } from 'fs/promises'
+import path from 'path'
 import { createLogger } from '@sim/logger'
 import binaryExtensionsList from 'binary-extensions'
 import { type NextRequest, NextResponse } from 'next/server'
@@ -899,7 +899,7 @@ Please use a PDF viewer for best results.`
  * Create error message for PDF parsing failure and make it more readable
  */
 function createPdfFailureMessage(
-  _pageCount: number,
+  pageCount: number,
   size: number,
   path: string,
   error: string

apps/sim/app/api/files/serve/[...path]/route.test.ts

@@ -131,7 +131,7 @@ describe('File Serve API Route', () => {
     expect(disposition).toContain('filename=')
     expect(disposition).toContain('test-file.txt')
 
-    const fs = await import('node:fs/promises')
+    const fs = await import('fs/promises')
     expect(fs.readFile).toHaveBeenCalled()
   })
 
@@ -196,7 +196,7 @@ describe('File Serve API Route', () => {
 
     expect(response.status).toBe(200)
 
-    const fs = await import('node:fs/promises')
+    const fs = await import('fs/promises')
     expect(fs.readFile).toHaveBeenCalledWith('/test/uploads/nested/path/file.txt')
   })
 

apps/sim/app/api/files/serve/[...path]/route.ts

@@ -1,4 +1,4 @@
-import { readFile } from 'node:fs/promises'
+import { readFile } from 'fs/promises'
 import { createLogger } from '@sim/logger'
 import type { NextRequest } from 'next/server'
 import { NextResponse } from 'next/server'

apps/sim/app/api/files/utils.ts

@@ -1,5 +1,5 @@
-import { existsSync } from 'node:fs'
-import { join, resolve, sep } from 'node:path'
+import { existsSync } from 'fs'
+import { join, resolve, sep } from 'path'
 import { createLogger } from '@sim/logger'
 import { NextResponse } from 'next/server'
 import { UPLOAD_DIR } from '@/lib/uploads/config'
@@ -119,7 +119,7 @@ export function extractFilename(path: string): string {
   return filename
 }
 
-function _sanitizeFilename(filename: string): string {
+function sanitizeFilename(filename: string): string {
   if (!filename || typeof filename !== 'string') {
     throw new Error('Invalid filename provided')
   }

apps/sim/app/api/folders/[id]/route.test.ts

@@ -321,7 +321,7 @@ describe('Individual Folder API Route', () => {
       await PUT(req, { params })
 
       expect(capturedUpdates).not.toBeNull()
-      expect(capturedUpdates?.name).toBe('Folder With Spaces')
+      expect(capturedUpdates!.name).toBe('Folder With Spaces')
     })
 
     it('should handle database errors gracefully', async () => {

apps/sim/app/api/folders/[id]/route.ts

@@ -106,7 +106,7 @@ export async function PUT(request: NextRequest, { params }: { params: Promise<{
 
 // DELETE - Delete a folder and all its contents
 export async function DELETE(
-  _request: NextRequest,
+  request: NextRequest,
   { params }: { params: Promise<{ id: string }> }
 ) {
   try {

apps/sim/app/api/folders/route.test.ts

@@ -551,7 +551,7 @@ describe('Folders API Route', () => {
       await POST(req)
 
       expect(capturedValues).not.toBeNull()
-      expect(capturedValues?.name).toBe('Test Folder With Spaces')
+      expect(capturedValues!.name).toBe('Test Folder With Spaces')
     })
 
     it('should use default color when not provided', async () => {
@@ -591,7 +591,7 @@ describe('Folders API Route', () => {
       await POST(req)
 
       expect(capturedValues).not.toBeNull()
-      expect(capturedValues?.color).toBe('#6B7280')
+      expect(capturedValues!.color).toBe('#6B7280')
     })
   })
 })

apps/sim/app/api/form/[identifier]/route.ts

@@ -1,4 +1,4 @@
-import { randomUUID } from 'node:crypto'
+import { randomUUID } from 'crypto'
 import { db } from '@sim/db'
 import { form, workflow, workflowBlocks } from '@sim/db/schema'
 import { createLogger } from '@sim/logger'
@@ -235,11 +235,28 @@ export async function POST(
       // For forms, we don't stream back - we wait for completion and return success
       // Consume the stream to wait for completion
       const reader = stream.getReader()
+      let lastOutput: any = null
 
       try {
         while (true) {
-          const { done } = await reader.read()
+          const { done, value } = await reader.read()
           if (done) break
+
+          // Parse SSE data if present
+          const text = new TextDecoder().decode(value)
+          const lines = text.split('\n')
+          for (const line of lines) {
+            if (line.startsWith('data: ')) {
+              try {
+                const data = JSON.parse(line.slice(6))
+                if (data.type === 'complete' || data.output) {
+                  lastOutput = data.output || data
+                }
+              } catch {
+                // Ignore parse errors
+              }
+            }
+          }
         }
       } finally {
         reader.releaseLock()

apps/sim/app/api/form/manage/[id]/route.ts

@@ -62,7 +62,7 @@ const updateFormSchema = z.object({
   isActive: z.boolean().optional(),
 })
 
-export async function GET(_request: NextRequest, { params }: { params: Promise<{ id: string }> }) {
+export async function GET(request: NextRequest, { params }: { params: Promise<{ id: string }> }) {
   try {
     const session = await getSession()
 
@@ -201,7 +201,7 @@ export async function PATCH(request: NextRequest, { params }: { params: Promise<
 }
 
 export async function DELETE(
-  _request: NextRequest,
+  request: NextRequest,
   { params }: { params: Promise<{ id: string }> }
 ) {
   try {

apps/sim/app/api/form/route.ts

@@ -64,7 +64,7 @@ const formSchema = z.object({
   showBranding: z.boolean().optional().default(true),
 })
 
-export async function GET(_request: NextRequest) {
+export async function GET(request: NextRequest) {
   try {
     const session = await getSession()
 

apps/sim/app/api/form/utils.test.ts

@@ -63,7 +63,7 @@ describe('Form API Utils', () => {
 
     it.concurrent('should validate tokens with password hash', async () => {
       const { validateAuthToken } = await import('@/lib/core/security/deployment')
-      const crypto = await import('node:crypto')
+      const crypto = await import('crypto')
 
       const formId = 'test-form-id'
       const encryptedPassword = 'encrypted-password-value'

apps/sim/app/api/function/execute/route.ts

@@ -292,7 +292,7 @@ function formatE2BError(
  */
 function createUserFriendlyErrorMessage(
   enhanced: EnhancedError,
-  _requestId: string,
+  requestId: string,
   userCode?: string
 ): string {
   let errorMessage = enhanced.message

apps/sim/app/api/knowledge/[id]/documents/[documentId]/chunks/[chunkId]/route.ts

@@ -1,4 +1,4 @@
-import { randomUUID } from 'node:crypto'
+import { randomUUID } from 'crypto'
 import { createLogger } from '@sim/logger'
 import { type NextRequest, NextResponse } from 'next/server'
 import { z } from 'zod'
@@ -14,7 +14,7 @@ const UpdateChunkSchema = z.object({
 })
 
 export async function GET(
-  _req: NextRequest,
+  req: NextRequest,
   { params }: { params: Promise<{ id: string; documentId: string; chunkId: string }> }
 ) {
   const requestId = randomUUID().slice(0, 8)
@@ -134,7 +134,7 @@ export async function PUT(
 }
 
 export async function DELETE(
-  _req: NextRequest,
+  req: NextRequest,
   { params }: { params: Promise<{ id: string; documentId: string; chunkId: string }> }
 ) {
   const requestId = randomUUID().slice(0, 8)

apps/sim/app/api/knowledge/[id]/documents/[documentId]/route.ts

@@ -47,7 +47,7 @@ const UpdateDocumentSchema = z.object({
 })
 
 export async function GET(
-  _req: NextRequest,
+  req: NextRequest,
   { params }: { params: Promise<{ id: string; documentId: string }> }
 ) {
   const requestId = generateRequestId()
@@ -123,6 +123,8 @@ export async function PUT(
     try {
       const validatedData = UpdateDocumentSchema.parse(body)
 
+      const updateData: any = {}
+
       if (validatedData.markFailedDueToTimeout) {
         const doc = accessCheck.document
 
@@ -218,7 +220,7 @@ export async function PUT(
 }
 
 export async function DELETE(
-  _req: NextRequest,
+  req: NextRequest,
   { params }: { params: Promise<{ id: string; documentId: string }> }
 ) {
   const requestId = generateRequestId()

apps/sim/app/api/knowledge/[id]/documents/[documentId]/tag-definitions/route.ts

@@ -1,4 +1,4 @@
-import { randomUUID } from 'node:crypto'
+import { randomUUID } from 'crypto'
 import { createLogger } from '@sim/logger'
 import { type NextRequest, NextResponse } from 'next/server'
 import { z } from 'zod'
@@ -31,7 +31,7 @@ const BulkTagDefinitionsSchema = z.object({
 
 // GET /api/knowledge/[id]/documents/[documentId]/tag-definitions - Get tag definitions for a document
 export async function GET(
-  _req: NextRequest,
+  req: NextRequest,
   { params }: { params: Promise<{ id: string; documentId: string }> }
 ) {
   const requestId = randomUUID().slice(0, 8)

apps/sim/app/api/knowledge/[id]/documents/route.ts

@@ -1,4 +1,4 @@
-import { randomUUID } from 'node:crypto'
+import { randomUUID } from 'crypto'
 import { createLogger } from '@sim/logger'
 import { type NextRequest, NextResponse } from 'next/server'
 import { z } from 'zod'

apps/sim/app/api/knowledge/[id]/next-available-slot/route.ts

@@ -1,4 +1,4 @@
-import { randomUUID } from 'node:crypto'
+import { randomUUID } from 'crypto'
 import { createLogger } from '@sim/logger'
 import { type NextRequest, NextResponse } from 'next/server'
 import { getSession } from '@/lib/auth'

apps/sim/app/api/knowledge/[id]/tag-definitions/[tagId]/route.ts

@@ -1,4 +1,4 @@
-import { randomUUID } from 'node:crypto'
+import { randomUUID } from 'crypto'
 import { createLogger } from '@sim/logger'
 import { type NextRequest, NextResponse } from 'next/server'
 import { getSession } from '@/lib/auth'
@@ -11,7 +11,7 @@ const logger = createLogger('TagDefinitionAPI')
 
 // DELETE /api/knowledge/[id]/tag-definitions/[tagId] - Delete a tag definition
 export async function DELETE(
-  _req: NextRequest,
+  req: NextRequest,
   { params }: { params: Promise<{ id: string; tagId: string }> }
 ) {
   const requestId = randomUUID().slice(0, 8)

apps/sim/app/api/knowledge/[id]/tag-definitions/route.ts

@@ -1,4 +1,4 @@
-import { randomUUID } from 'node:crypto'
+import { randomUUID } from 'crypto'
 import { createLogger } from '@sim/logger'
 import { type NextRequest, NextResponse } from 'next/server'
 import { z } from 'zod'

apps/sim/app/api/knowledge/[id]/tag-usage/route.ts

@@ -1,4 +1,4 @@
-import { randomUUID } from 'node:crypto'
+import { randomUUID } from 'crypto'
 import { createLogger } from '@sim/logger'
 import { type NextRequest, NextResponse } from 'next/server'
 import { getSession } from '@/lib/auth'
@@ -10,7 +10,7 @@ export const dynamic = 'force-dynamic'
 const logger = createLogger('TagUsageAPI')
 
 // GET /api/knowledge/[id]/tag-usage - Get usage statistics for all tag definitions
-export async function GET(_req: NextRequest, { params }: { params: Promise<{ id: string }> }) {
+export async function GET(req: NextRequest, { params }: { params: Promise<{ id: string }> }) {
   const requestId = randomUUID().slice(0, 8)
   const { id: knowledgeBaseId } = await params
 

apps/sim/app/api/knowledge/search/utils.ts

@@ -269,7 +269,7 @@ function getStructuredTagFilters(filters: StructuredFilter[], embeddingTable: an
     if (!filtersBySlot.has(slot)) {
       filtersBySlot.set(slot, [])
     }
-    filtersBySlot.get(slot)?.push(filter)
+    filtersBySlot.get(slot)!.push(filter)
   }
 
   // Build conditions: OR within same slot, AND across different slots

apps/sim/app/api/mcp/serve/[serverId]/route.ts

@@ -63,7 +63,7 @@ async function getServer(serverId: string) {
   return server
 }
 
-export async function GET(_request: NextRequest, { params }: { params: Promise<RouteParams> }) {
+export async function GET(request: NextRequest, { params }: { params: Promise<RouteParams> }) {
   const { serverId } = await params
 
   try {

apps/sim/app/api/mcp/servers/[id]/refresh/route.ts

@@ -140,7 +140,7 @@ async function syncToolSchemasToWorkflows(
 }
 
 export const POST = withMcpAuth<{ id: string }>('read')(
-  async (_request: NextRequest, { userId, workspaceId, requestId }, { params }) => {
+  async (request: NextRequest, { userId, workspaceId, requestId }, { params }) => {
     const { id: serverId } = await params
 
     try {

apps/sim/app/api/mcp/servers/route.ts

@@ -19,7 +19,7 @@ export const dynamic = 'force-dynamic'
  * GET - List all registered MCP servers for the workspace
  */
 export const GET = withMcpAuth('read')(
-  async (_request: NextRequest, { userId, workspaceId, requestId }) => {
+  async (request: NextRequest, { userId, workspaceId, requestId }) => {
     try {
       logger.info(`[${requestId}] Listing MCP servers for workspace ${workspaceId}`)
 

apps/sim/app/api/mcp/tools/stored/route.ts

@@ -12,7 +12,7 @@ const logger = createLogger('McpStoredToolsAPI')
 export const dynamic = 'force-dynamic'
 
 export const GET = withMcpAuth('read')(
-  async (_request: NextRequest, { userId, workspaceId, requestId }) => {
+  async (request: NextRequest, { userId, workspaceId, requestId }) => {
     try {
       logger.info(`[${requestId}] Fetching stored MCP tools for workspace ${workspaceId}`)
 

apps/sim/app/api/mcp/workflow-servers/[id]/route.ts

@@ -18,7 +18,7 @@ interface RouteParams {
  * GET - Get a specific workflow MCP server with its tools
  */
 export const GET = withMcpAuth<RouteParams>('read')(
-  async (_request: NextRequest, { userId, workspaceId, requestId }, { params }) => {
+  async (request: NextRequest, { userId, workspaceId, requestId }, { params }) => {
     try {
       const { id: serverId } = await params
 
@@ -127,7 +127,7 @@ export const PATCH = withMcpAuth<RouteParams>('write')(
  * DELETE - Delete a workflow MCP server and all its tools
  */
 export const DELETE = withMcpAuth<RouteParams>('admin')(
-  async (_request: NextRequest, { userId, workspaceId, requestId }, { params }) => {
+  async (request: NextRequest, { userId, workspaceId, requestId }, { params }) => {
     try {
       const { id: serverId } = await params
 

apps/sim/app/api/mcp/workflow-servers/[id]/tools/[toolId]/route.ts

@@ -20,7 +20,7 @@ interface RouteParams {
  * GET - Get a specific tool
  */
 export const GET = withMcpAuth<RouteParams>('read')(
-  async (_request: NextRequest, { userId, workspaceId, requestId }, { params }) => {
+  async (request: NextRequest, { userId, workspaceId, requestId }, { params }) => {
     try {
       const { id: serverId, toolId } = await params
 
@@ -131,7 +131,7 @@ export const PATCH = withMcpAuth<RouteParams>('write')(
  * DELETE - Remove a tool from an MCP server
  */
 export const DELETE = withMcpAuth<RouteParams>('write')(
-  async (_request: NextRequest, { userId, workspaceId, requestId }, { params }) => {
+  async (request: NextRequest, { userId, workspaceId, requestId }, { params }) => {
     try {
       const { id: serverId, toolId } = await params
 

apps/sim/app/api/mcp/workflow-servers/[id]/tools/route.ts

@@ -20,7 +20,7 @@ interface RouteParams {
  * GET - List all tools for a workflow MCP server
  */
 export const GET = withMcpAuth<RouteParams>('read')(
-  async (_request: NextRequest, { userId, workspaceId, requestId }, { params }) => {
+  async (request: NextRequest, { userId, workspaceId, requestId }, { params }) => {
     try {
       const { id: serverId } = await params
 

apps/sim/app/api/mcp/workflow-servers/route.ts

@@ -16,7 +16,7 @@ export const dynamic = 'force-dynamic'
  * GET - List all workflow MCP servers for the workspace
  */
 export const GET = withMcpAuth('read')(
-  async (_request: NextRequest, { userId, workspaceId, requestId }) => {
+  async (request: NextRequest, { userId, workspaceId, requestId }) => {
     try {
       logger.info(`[${requestId}] Listing workflow MCP servers for workspace ${workspaceId}`)
 

apps/sim/app/api/organizations/[id]/invitations/[invitationId]/route.ts

@@ -1,4 +1,4 @@
-import { randomUUID } from 'node:crypto'
+import { randomUUID } from 'crypto'
 import { db } from '@sim/db'
 import {
   invitation,

apps/sim/app/api/organizations/[id]/invitations/route.ts

@@ -1,4 +1,4 @@
-import { randomUUID } from 'node:crypto'
+import { randomUUID } from 'crypto'
 import { db } from '@sim/db'
 import {
   invitation,
@@ -42,7 +42,7 @@ interface WorkspaceInvitation {
  * GET /api/organizations/[id]/invitations
  * Get all pending invitations for an organization
  */
-export async function GET(_request: NextRequest, { params }: { params: Promise<{ id: string }> }) {
+export async function GET(request: NextRequest, { params }: { params: Promise<{ id: string }> }) {
   try {
     const session = await getSession()
 

apps/sim/app/api/organizations/[id]/members/[memberId]/route.ts

@@ -239,7 +239,7 @@ export async function PUT(
  * Remove member from organization
  */
 export async function DELETE(
-  _request: NextRequest,
+  request: NextRequest,
   { params }: { params: Promise<{ id: string; memberId: string }> }
 ) {
   try {

apps/sim/app/api/organizations/[id]/members/route.ts

@@ -1,4 +1,4 @@
-import { randomUUID } from 'node:crypto'
+import { randomUUID } from 'crypto'
 import { db } from '@sim/db'
 import { invitation, member, organization, user, userStats } from '@sim/db/schema'
 import { createLogger } from '@sim/logger'

apps/sim/app/api/permission-groups/[id]/members/route.ts

@@ -32,7 +32,7 @@ async function getPermissionGroupWithAccess(groupId: string, userId: string) {
   return { group, role: membership.role }
 }
 
-export async function GET(_req: NextRequest, { params }: { params: Promise<{ id: string }> }) {
+export async function GET(req: NextRequest, { params }: { params: Promise<{ id: string }> }) {
   const session = await getSession()
 
   if (!session?.user?.id) {

apps/sim/app/api/permission-groups/[id]/route.ts

@@ -70,7 +70,7 @@ async function getPermissionGroupWithAccess(groupId: string, userId: string) {
   return { group, role: membership.role }
 }
 
-export async function GET(_req: NextRequest, { params }: { params: Promise<{ id: string }> }) {
+export async function GET(req: NextRequest, { params }: { params: Promise<{ id: string }> }) {
   const session = await getSession()
 
   if (!session?.user?.id) {
@@ -195,7 +195,7 @@ export async function PUT(req: NextRequest, { params }: { params: Promise<{ id:
   }
 }
 
-export async function DELETE(_req: NextRequest, { params }: { params: Promise<{ id: string }> }) {
+export async function DELETE(req: NextRequest, { params }: { params: Promise<{ id: string }> }) {
   const session = await getSession()
 
   if (!session?.user?.id) {

apps/sim/app/api/providers/base/models/route.ts

@@ -5,7 +5,7 @@ export async function GET() {
   try {
     const allModels = Object.keys(getBaseModelProviders())
     return NextResponse.json({ models: allModels })
-  } catch (_error) {
+  } catch (error) {
     return NextResponse.json({ models: [], error: 'Failed to fetch models' }, { status: 500 })
   }
 }

apps/sim/app/api/resume/[workflowId]/[executionId]/[contextId]/route.ts

@@ -1,4 +1,4 @@
-import { randomUUID } from 'node:crypto'
+import { randomUUID } from 'crypto'
 import { createLogger } from '@sim/logger'
 import { type NextRequest, NextResponse } from 'next/server'
 import { generateRequestId } from '@/lib/core/utils/request'

apps/sim/app/api/templates/[id]/approve/route.ts

@@ -14,7 +14,7 @@ export const revalidate = 0
 /**
  * POST /api/templates/[id]/approve - Approve a template (super users only)
  */
-export async function POST(_request: NextRequest, { params }: { params: Promise<{ id: string }> }) {
+export async function POST(request: NextRequest, { params }: { params: Promise<{ id: string }> }) {
   const requestId = generateRequestId()
   const { id } = await params
 

apps/sim/app/api/templates/[id]/reject/route.ts

@@ -14,7 +14,7 @@ export const revalidate = 0
 /**
  * POST /api/templates/[id]/reject - Reject a template (super users only)
  */
-export async function POST(_request: NextRequest, { params }: { params: Promise<{ id: string }> }) {
+export async function POST(request: NextRequest, { params }: { params: Promise<{ id: string }> }) {
   const requestId = generateRequestId()
   const { id } = await params
 

apps/sim/app/api/templates/[id]/route.ts

@@ -16,7 +16,7 @@ const logger = createLogger('TemplateByIdAPI')
 
 export const revalidate = 0
 
-export async function GET(_request: NextRequest, { params }: { params: Promise<{ id: string }> }) {
+export async function GET(request: NextRequest, { params }: { params: Promise<{ id: string }> }) {
   const requestId = generateRequestId()
   const { id } = await params
 
@@ -234,7 +234,7 @@ export async function PUT(request: NextRequest, { params }: { params: Promise<{
 
 // DELETE /api/templates/[id] - Delete a template
 export async function DELETE(
-  _request: NextRequest,
+  request: NextRequest,
   { params }: { params: Promise<{ id: string }> }
 ) {
   const requestId = generateRequestId()

apps/sim/app/api/templates/[id]/star/route.ts

@@ -13,7 +13,7 @@ export const dynamic = 'force-dynamic'
 export const revalidate = 0
 
 // GET /api/templates/[id]/star - Check if user has starred this template
-export async function GET(_request: NextRequest, { params }: { params: Promise<{ id: string }> }) {
+export async function GET(request: NextRequest, { params }: { params: Promise<{ id: string }> }) {
   const requestId = generateRequestId()
   const { id } = await params
 
@@ -47,7 +47,7 @@ export async function GET(_request: NextRequest, { params }: { params: Promise<{
 }
 
 // POST /api/templates/[id]/star - Add a star to the template
-export async function POST(_request: NextRequest, { params }: { params: Promise<{ id: string }> }) {
+export async function POST(request: NextRequest, { params }: { params: Promise<{ id: string }> }) {
   const requestId = generateRequestId()
   const { id } = await params
 
@@ -120,7 +120,7 @@ export async function POST(_request: NextRequest, { params }: { params: Promise<
 
 // DELETE /api/templates/[id]/star - Remove a star from the template
 export async function DELETE(
-  _request: NextRequest,
+  request: NextRequest,
   { params }: { params: Promise<{ id: string }> }
 ) {
   const requestId = generateRequestId()

apps/sim/app/api/templates/[id]/use/route.ts

@@ -136,7 +136,7 @@ export async function POST(request: NextRequest, { params }: { params: Promise<{
     }
 
     // Use a transaction for template updates and deployment version
-    const _result = await db.transaction(async (tx) => {
+    const result = await db.transaction(async (tx) => {
       // Prepare template update data
       const updateData: any = {
         views: sql`${templates.views} + 1`,

apps/sim/app/api/templates/approved/sanitized/route.ts

@@ -20,6 +20,7 @@ export async function GET(request: NextRequest) {
   const requestId = generateRequestId()
 
   try {
+    const url = new URL(request.url)
     const hasApiKey = !!request.headers.get('x-api-key')
 
     // Check internal API key authentication
@@ -125,7 +126,7 @@ export async function GET(request: NextRequest) {
 }
 
 // Add a helpful OPTIONS handler for CORS preflight
-export async function OPTIONS(_request: NextRequest) {
+export async function OPTIONS(request: NextRequest) {
   const requestId = generateRequestId()
   logger.info(`[${requestId}] OPTIONS request received for /api/templates/approved/sanitized`)
 

apps/sim/app/api/tools/a2a/resubscribe/route.ts

@@ -9,7 +9,7 @@ import type {
 import { createLogger } from '@sim/logger'
 import { type NextRequest, NextResponse } from 'next/server'
 import { z } from 'zod'
-import { createA2AClient, isTerminalState } from '@/lib/a2a/utils'
+import { createA2AClient, extractTextContent, isTerminalState } from '@/lib/a2a/utils'
 import { checkHybridAuth } from '@/lib/auth/hybrid'
 import { generateRequestId } from '@/lib/core/utils/request'
 
@@ -50,12 +50,14 @@ export async function POST(request: NextRequest) {
     let taskId = validatedData.taskId
     let contextId: string | undefined
     let state: TaskState = 'working'
+    let content = ''
     let artifacts: Artifact[] = []
     let history: Message[] = []
 
     for await (const event of stream) {
       if (event.kind === 'message') {
         const msg = event as Message
+        content = extractTextContent(msg)
         taskId = msg.taskId || taskId
         contextId = msg.contextId || contextId
         state = 'completed'
@@ -66,6 +68,10 @@ export async function POST(request: NextRequest) {
         state = task.status.state
         artifacts = task.artifacts || []
         history = task.history || []
+        const lastAgentMessage = history.filter((m) => m.role === 'agent').pop()
+        if (lastAgentMessage) {
+          content = extractTextContent(lastAgentMessage)
+        }
       } else if ('status' in event) {
         const statusEvent = event as TaskStatusUpdateEvent
         state = statusEvent.status.state

apps/sim/app/api/tools/custom/route.test.ts

@@ -82,7 +82,7 @@ describe('Custom Tools API Routes', () => {
 
     mockSelect.mockReturnValue({ from: mockFrom })
     mockFrom.mockReturnValue({ where: mockWhere })
-    mockWhere.mockImplementation((_condition) => {
+    mockWhere.mockImplementation((condition) => {
       const queryBuilder = {
         orderBy: mockOrderBy,
         limit: mockLimit,
@@ -90,7 +90,7 @@ describe('Custom Tools API Routes', () => {
           resolve(sampleTools)
           return queryBuilder
         },
-        catch: (_reject: (error: Error) => void) => queryBuilder,
+        catch: (reject: (error: Error) => void) => queryBuilder,
       }
       return queryBuilder
     })
@@ -101,7 +101,7 @@ describe('Custom Tools API Routes', () => {
           resolve(sampleTools)
           return queryBuilder
         },
-        catch: (_reject: (error: Error) => void) => queryBuilder,
+        catch: (reject: (error: Error) => void) => queryBuilder,
       }
       return queryBuilder
     })
@@ -131,12 +131,12 @@ describe('Custom Tools API Routes', () => {
                 resolve(sampleTools)
                 return queryBuilder
               },
-              catch: (_reject: (error: Error) => void) => queryBuilder,
+              catch: (reject: (error: Error) => void) => queryBuilder,
             }
             return queryBuilder
           })
 
-          const txMockWhere = vi.fn().mockImplementation((_condition) => {
+          const txMockWhere = vi.fn().mockImplementation((condition) => {
             const queryBuilder = {
               orderBy: txMockOrderBy,
               limit: mockLimit,
@@ -144,7 +144,7 @@ describe('Custom Tools API Routes', () => {
                 resolve(sampleTools)
                 return queryBuilder
               },
-              catch: (_reject: (error: Error) => void) => queryBuilder,
+              catch: (reject: (error: Error) => void) => queryBuilder,
             }
             return queryBuilder
           })
@@ -274,14 +274,14 @@ describe('Custom Tools API Routes', () => {
 
       mockLimit.mockResolvedValueOnce([{ workspaceId: 'workspace-123' }])
 
-      mockWhere.mockImplementationOnce((_condition) => {
+      mockWhere.mockImplementationOnce((condition) => {
         const queryBuilder = {
           limit: mockLimit,
           then: (resolve: (value: typeof sampleTools) => void) => {
             resolve(sampleTools)
             return queryBuilder
           },
-          catch: (_reject: (error: Error) => void) => queryBuilder,
+          catch: (reject: (error: Error) => void) => queryBuilder,
         }
         return queryBuilder
       })

apps/sim/app/api/tools/dynamodb/introspect/route.ts

@@ -1,4 +1,4 @@
-import { randomUUID } from 'node:crypto'
+import { randomUUID } from 'crypto'
 import { createLogger } from '@sim/logger'
 import { type NextRequest, NextResponse } from 'next/server'
 import { z } from 'zod'

apps/sim/app/api/tools/microsoft-teams/teams/route.ts

@@ -1,6 +1,7 @@
 import { createLogger } from '@sim/logger'
 import { NextResponse } from 'next/server'
 import { authorizeCredentialUse } from '@/lib/auth/credential-access'
+import { generateRequestId } from '@/lib/core/utils/request'
 import { refreshAccessTokenIfNeeded } from '@/app/api/auth/oauth/utils'
 
 export const dynamic = 'force-dynamic'
@@ -19,6 +20,7 @@ export async function POST(request: Request) {
     }
 
     try {
+      const requestId = generateRequestId()
       const authz = await authorizeCredentialUse(request as any, {
         credentialId: credential,
         workflowId,

apps/sim/app/api/tools/microsoft_planner/tasks/route.ts

@@ -1,4 +1,4 @@
-import { randomUUID } from 'node:crypto'
+import { randomUUID } from 'crypto'
 import { db } from '@sim/db'
 import { account } from '@sim/db/schema'
 import { createLogger } from '@sim/logger'

apps/sim/app/api/tools/mongodb/delete/route.ts

@@ -1,13 +1,9 @@
-import { randomUUID } from 'node:crypto'
+import { randomUUID } from 'crypto'
 import { createLogger } from '@sim/logger'
 import { type NextRequest, NextResponse } from 'next/server'
 import { z } from 'zod'
 import { checkInternalAuth } from '@/lib/auth/hybrid'
-import {
-  createMongoDBConnection,
-  sanitizeCollectionName,
-  validateFilter,
-} from '@/app/api/tools/mongodb/utils'
+import { createMongoDBConnection, sanitizeCollectionName, validateFilter } from '../utils'
 
 const logger = createLogger('MongoDBDeleteAPI')
 
@@ -73,7 +69,7 @@ export async function POST(request: NextRequest) {
     let filterDoc
     try {
       filterDoc = JSON.parse(params.filter)
-    } catch (_error) {
+    } catch (error) {
       logger.warn(`[${requestId}] Invalid filter JSON: ${params.filter}`)
       return NextResponse.json({ error: 'Invalid JSON format in filter' }, { status: 400 })
     }

apps/sim/app/api/tools/mongodb/execute/route.ts

@@ -1,13 +1,9 @@
-import { randomUUID } from 'node:crypto'
+import { randomUUID } from 'crypto'
 import { createLogger } from '@sim/logger'
 import { type NextRequest, NextResponse } from 'next/server'
 import { z } from 'zod'
 import { checkInternalAuth } from '@/lib/auth/hybrid'
-import {
-  createMongoDBConnection,
-  sanitizeCollectionName,
-  validatePipeline,
-} from '@/app/api/tools/mongodb/utils'
+import { createMongoDBConnection, sanitizeCollectionName, validatePipeline } from '../utils'
 
 const logger = createLogger('MongoDBExecuteAPI')
 

apps/sim/app/api/tools/mongodb/insert/route.ts

@@ -1,9 +1,9 @@
-import { randomUUID } from 'node:crypto'
+import { randomUUID } from 'crypto'
 import { createLogger } from '@sim/logger'
 import { type NextRequest, NextResponse } from 'next/server'
 import { z } from 'zod'
 import { checkInternalAuth } from '@/lib/auth/hybrid'
-import { createMongoDBConnection, sanitizeCollectionName } from '@/app/api/tools/mongodb/utils'
+import { createMongoDBConnection, sanitizeCollectionName } from '../utils'
 
 const logger = createLogger('MongoDBInsertAPI')
 

apps/sim/app/api/tools/mongodb/introspect/route.ts

@@ -1,9 +1,9 @@
-import { randomUUID } from 'node:crypto'
+import { randomUUID } from 'crypto'
 import { createLogger } from '@sim/logger'
 import { type NextRequest, NextResponse } from 'next/server'
 import { z } from 'zod'
 import { checkInternalAuth } from '@/lib/auth/hybrid'
-import { createMongoDBConnection, executeIntrospect } from '@/app/api/tools/mongodb/utils'
+import { createMongoDBConnection, executeIntrospect } from '../utils'
 
 const logger = createLogger('MongoDBIntrospectAPI')
 

apps/sim/app/api/tools/mongodb/query/route.ts

@@ -1,13 +1,9 @@
-import { randomUUID } from 'node:crypto'
+import { randomUUID } from 'crypto'
 import { createLogger } from '@sim/logger'
 import { type NextRequest, NextResponse } from 'next/server'
 import { z } from 'zod'
 import { checkInternalAuth } from '@/lib/auth/hybrid'
-import {
-  createMongoDBConnection,
-  sanitizeCollectionName,
-  validateFilter,
-} from '@/app/api/tools/mongodb/utils'
+import { createMongoDBConnection, sanitizeCollectionName, validateFilter } from '../utils'
 
 const logger = createLogger('MongoDBQueryAPI')
 
@@ -87,7 +83,7 @@ export async function POST(request: NextRequest) {
     if (params.sort?.trim()) {
       try {
         sortCriteria = JSON.parse(params.sort)
-      } catch (_error) {
+      } catch (error) {
         logger.warn(`[${requestId}] Invalid sort JSON: ${params.sort}`)
         return NextResponse.json({ error: 'Invalid JSON format in sort criteria' }, { status: 400 })
       }

apps/sim/app/api/tools/mongodb/update/route.ts

@@ -1,13 +1,9 @@
-import { randomUUID } from 'node:crypto'
+import { randomUUID } from 'crypto'
 import { createLogger } from '@sim/logger'
 import { type NextRequest, NextResponse } from 'next/server'
 import { z } from 'zod'
 import { checkInternalAuth } from '@/lib/auth/hybrid'
-import {
-  createMongoDBConnection,
-  sanitizeCollectionName,
-  validateFilter,
-} from '@/app/api/tools/mongodb/utils'
+import { createMongoDBConnection, sanitizeCollectionName, validateFilter } from '../utils'
 
 const logger = createLogger('MongoDBUpdateAPI')
 
@@ -94,7 +90,7 @@ export async function POST(request: NextRequest) {
     try {
       filterDoc = JSON.parse(params.filter)
       updateDoc = JSON.parse(params.update)
-    } catch (_error) {
+    } catch (error) {
       logger.warn(`[${requestId}] Invalid JSON in filter or update`)
       return NextResponse.json(
         { error: 'Invalid JSON format in filter or update' },

apps/sim/app/api/tools/mongodb/utils.ts

@@ -72,7 +72,7 @@ export function validateFilter(filter: string): { isValid: boolean; error?: stri
     }
 
     return { isValid: true }
-  } catch (_error) {
+  } catch (error) {
     return {
       isValid: false,
       error: 'Invalid JSON format in filter',
@@ -113,7 +113,7 @@ export function validatePipeline(pipeline: string): { isValid: boolean; error?:
     }
 
     return { isValid: true }
-  } catch (_error) {
+  } catch (error) {
     return {
       isValid: false,
       error: 'Invalid JSON format in pipeline',

apps/sim/app/api/tools/mysql/delete/route.ts

@@ -1,4 +1,4 @@
-import { randomUUID } from 'node:crypto'
+import { randomUUID } from 'crypto'
 import { createLogger } from '@sim/logger'
 import { type NextRequest, NextResponse } from 'next/server'
 import { z } from 'zod'

apps/sim/app/api/tools/mysql/execute/route.ts

@@ -1,4 +1,4 @@
-import { randomUUID } from 'node:crypto'
+import { randomUUID } from 'crypto'
 import { createLogger } from '@sim/logger'
 import { type NextRequest, NextResponse } from 'next/server'
 import { z } from 'zod'

apps/sim/app/api/tools/mysql/insert/route.ts

@@ -1,4 +1,4 @@
-import { randomUUID } from 'node:crypto'
+import { randomUUID } from 'crypto'
 import { createLogger } from '@sim/logger'
 import { type NextRequest, NextResponse } from 'next/server'
 import { z } from 'zod'

apps/sim/app/api/tools/mysql/introspect/route.ts

@@ -1,4 +1,4 @@
-import { randomUUID } from 'node:crypto'
+import { randomUUID } from 'crypto'
 import { createLogger } from '@sim/logger'
 import { type NextRequest, NextResponse } from 'next/server'
 import { z } from 'zod'

apps/sim/app/api/tools/mysql/query/route.ts

@@ -1,4 +1,4 @@
-import { randomUUID } from 'node:crypto'
+import { randomUUID } from 'crypto'
 import { createLogger } from '@sim/logger'
 import { type NextRequest, NextResponse } from 'next/server'
 import { z } from 'zod'

apps/sim/app/api/tools/mysql/update/route.ts

@@ -1,4 +1,4 @@
-import { randomUUID } from 'node:crypto'
+import { randomUUID } from 'crypto'
 import { createLogger } from '@sim/logger'
 import { type NextRequest, NextResponse } from 'next/server'
 import { z } from 'zod'
@@ -29,7 +29,7 @@ const UpdateSchema = z.object({
             throw new Error('Data must be a JSON object')
           }
           return parsed
-        } catch (_e) {
+        } catch (e) {
           throw new Error('Invalid JSON format in data field')
         }
       }),

apps/sim/app/api/tools/mysql/utils.ts

@@ -271,7 +271,7 @@ export async function executeIntrospect(
           unique: row.NON_UNIQUE === 0,
         })
       }
-      indexMap.get(indexName)?.columns.push(row.COLUMN_NAME)
+      indexMap.get(indexName)!.columns.push(row.COLUMN_NAME)
     }
     const indexes = Array.from(indexMap.values())
 

apps/sim/app/api/tools/neo4j/create/route.ts

@@ -1,4 +1,4 @@
-import { randomUUID } from 'node:crypto'
+import { randomUUID } from 'crypto'
 import { createLogger } from '@sim/logger'
 import { type NextRequest, NextResponse } from 'next/server'
 import { z } from 'zod'

apps/sim/app/api/tools/neo4j/delete/route.ts

@@ -1,4 +1,4 @@
-import { randomUUID } from 'node:crypto'
+import { randomUUID } from 'crypto'
 import { createLogger } from '@sim/logger'
 import { type NextRequest, NextResponse } from 'next/server'
 import { z } from 'zod'