fix(dev): infinite get-session calls

apps/docs/content/docs/tools/supabase.mdx

@@ -142,7 +142,7 @@ Get a single row from a Supabase table based on filter criteria
 | Parameter | Type | Description |
 | --------- | ---- | ----------- |
 | `message` | string | Operation status message |
-| `results` | object | The row data if found, null if not found |
+| `results` | array | Array containing the row data if found, empty array if not found |
 
 ### `supabase_update`
 

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

@@ -107,6 +107,10 @@ describe('Copilot Chat API Route', () => {
         COPILOT_API_KEY: 'test-sim-agent-key',
         BETTER_AUTH_URL: 'http://localhost:3000',
       },
+      isTruthy: (value: string | boolean | number | undefined) =>
+        typeof value === 'string'
+          ? value.toLowerCase() === 'true' || value === '1'
+          : Boolean(value),
     }))
 
     global.fetch = vi.fn()

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

@@ -12,6 +12,9 @@ import {
 } from '@/lib/copilot/auth'
 import { getCopilotModel } from '@/lib/copilot/config'
 import { TITLE_GENERATION_SYSTEM_PROMPT, TITLE_GENERATION_USER_PROMPT } from '@/lib/copilot/prompts'
+import { getBlocksAndToolsTool } from '@/lib/copilot/tools/server-tools/blocks/get-blocks-and-tools'
+import { getEnvironmentVariablesTool } from '@/lib/copilot/tools/server-tools/user/get-environment-variables'
+import { getOAuthCredentialsTool } from '@/lib/copilot/tools/server-tools/user/get-oauth-credentials'
 import { env } from '@/lib/env'
 import { createLogger } from '@/lib/logs/console/logger'
 import { SIM_AGENT_API_URL_DEFAULT } from '@/lib/sim-agent'
@@ -89,6 +92,7 @@ const ChatMessageSchema = z.object({
   fileAttachments: z.array(FileAttachmentSchema).optional(),
   provider: z.string().optional().default('openai'),
   conversationId: z.string().optional(),
+  userWorkflow: z.string().optional(),
 })
 
 /**
@@ -206,6 +210,7 @@ export async function POST(req: NextRequest) {
       fileAttachments,
       provider,
       conversationId,
+      userWorkflow,
     } = ChatMessageSchema.parse(body)
 
     // Derive request origin for downstream service
@@ -243,6 +248,7 @@ export async function POST(req: NextRequest) {
       depth,
       prefetch,
       origin: requestOrigin,
+      hasUserWorkflow: !!userWorkflow,
     })
 
     // Handle chat context
@@ -409,6 +415,63 @@ export async function POST(req: NextRequest) {
       [...messages].reverse().find((m) => m?.role === 'user') || messages[messages.length - 1]
     const messagesForAgent = effectiveConversationId ? [latestUserMessage] : messages
 
+    // Prepare optional prefetch results
+    let prefetchResults: Record<string, any> | undefined
+    if (effectivePrefetch === true) {
+      try {
+        const [blocksAndToolsResp, envVarsResp, oauthResp] = await Promise.all([
+          getBlocksAndToolsTool.execute({}),
+          getEnvironmentVariablesTool.execute({ userId: authenticatedUserId, workflowId }),
+          getOAuthCredentialsTool.execute({ userId: authenticatedUserId }),
+        ])
+
+        prefetchResults = {}
+
+        if (blocksAndToolsResp.success) {
+          prefetchResults.get_blocks_and_tools = blocksAndToolsResp.data
+        } else {
+          logger.warn(`[${tracker.requestId}] Failed to prefetch get_blocks_and_tools`, {
+            error: blocksAndToolsResp.error,
+          })
+        }
+
+        if (envVarsResp.success) {
+          prefetchResults.get_environment_variables = envVarsResp.data
+        } else {
+          logger.warn(`[${tracker.requestId}] Failed to prefetch get_environment_variables`, {
+            error: envVarsResp.error,
+          })
+        }
+
+        if (oauthResp.success) {
+          prefetchResults.get_oauth_credentials = oauthResp.data
+        } else {
+          logger.warn(`[${tracker.requestId}] Failed to prefetch get_oauth_credentials`, {
+            error: oauthResp.error,
+          })
+        }
+
+        if (userWorkflow && typeof userWorkflow === 'string' && userWorkflow.trim().length > 0) {
+          prefetchResults.get_user_workflow = userWorkflow
+          const uwLength = userWorkflow.length
+          const uwPreview = userWorkflow.substring(0, 10000)
+          logger.info(`[${tracker.requestId}] Included client-provided userWorkflow in prefetch`, {
+            length: uwLength,
+            preview: `${uwPreview}${uwLength > 10000 ? '...' : ''}`,
+          })
+        }
+
+        logger.info(`[${tracker.requestId}] Prepared prefetchResults for streaming payload`, {
+          hasBlocksAndTools: !!prefetchResults.get_blocks_and_tools,
+          hasEnvVars: !!prefetchResults.get_environment_variables,
+          hasOAuthCreds: !!prefetchResults.get_oauth_credentials,
+          hasUserWorkflow: !!prefetchResults.get_user_workflow,
+        })
+      } catch (e) {
+        logger.error(`[${tracker.requestId}] Error while preparing prefetchResults`, e)
+      }
+    }
+
     const requestPayload = {
       messages: messagesForAgent,
       workflowId,
@@ -422,6 +485,7 @@ export async function POST(req: NextRequest) {
       ...(typeof effectivePrefetch === 'boolean' ? { prefetch: effectivePrefetch } : {}),
       ...(session?.user?.name && { userName: session.user.name }),
       ...(requestOrigin ? { origin: requestOrigin } : {}),
+      ...(prefetchResults ? { prefetchResults } : {}),
     }
 
     // Log the payload being sent to the streaming endpoint
@@ -438,10 +502,6 @@ export async function POST(req: NextRequest) {
         messagesCount: requestPayload.messages.length,
         ...(requestOrigin ? { origin: requestOrigin } : {}),
       })
-      // Full payload as JSON string
-      logger.info(
-        `[${tracker.requestId}] Full streaming payload: ${JSON.stringify(requestPayload)}`
-      )
     } catch (e) {
       logger.warn(`[${tracker.requestId}] Failed to log payload preview for streaming endpoint`, e)
     }
@@ -456,7 +516,11 @@ export async function POST(req: NextRequest) {
     })
 
     if (!simAgentResponse.ok) {
-      if (simAgentResponse.status === 401 || simAgentResponse.status === 402) {
+      if (
+        simAgentResponse.status === 401 ||
+        simAgentResponse.status === 402 ||
+        simAgentResponse.status === 429
+      ) {
         // Rethrow status only; client will render appropriate assistant message
         return new NextResponse(null, { status: simAgentResponse.status })
       }
@@ -622,6 +686,15 @@ export async function POST(req: NextRequest) {
                           if (event.data?.id) {
                             announcedToolCallIds.add(event.data.id)
                           }
+                          if (event.data?.name === 'get_user_workflow') {
+                            logger.info(
+                              `[${tracker.requestId}] get_user_workflow tool call received in stream; client will execute locally and post to /api/copilot/methods`,
+                              {
+                                toolCallId: event.data?.id,
+                                hasArgs: !!event.data?.arguments,
+                              }
+                            )
+                          }
                         }
                         break