feat: implement sandbox management and MCP client integration

- Added functionality to start and stop sandboxes for executing commands in isolated environments.
- Integrated MCP client management for handling server connections and tool initialization.
- Enhanced the chat route to generate titles for new chats and manage server states.
- Updated the MCP server manager component to include server control actions and status indicators.
- Introduced a new context for managing MCP server states and sandbox references.
- Improved error handling and logging for better debugging and user feedback.

app/actions.ts

@@ -3,6 +3,11 @@
 import { openai } from "@ai-sdk/openai";
 import { generateObject } from "ai";
 import { z } from "zod";
+import { startMcpSandbox } from '@/lib/mcp-sandbox';
+
+// Use a global map to store active sandbox instances across requests
+const activeSandboxes = (global as any).activeSandboxes || new Map();
+(global as any).activeSandboxes = activeSandboxes;
 
 // Helper to extract text content from a message regardless of format
 function getMessageText(message: any): string {
@@ -64,3 +69,96 @@ export async function generateTitle(messages: any[]) {
 
   return object.title;
 }
+
+export interface KeyValuePair {
+  key: string;
+  value: string;
+}
+
+/**
+ * Server action to start a sandbox
+ */
+export async function startSandbox(params: {
+  id: string;
+  command: string;
+  args: string[];
+  env?: KeyValuePair[];
+}): Promise<{ url: string }> {
+  const { id, command, args, env } = params;
+  
+  // Validate required fields
+  if (!id || !command || !args) {
+    throw new Error('Missing required fields');
+  }
+  
+  // Check if we already have a sandbox for this ID
+  if (activeSandboxes.has(id)) {
+    // If we do, get the URL and return it without creating a new sandbox
+    const existingSandbox = activeSandboxes.get(id);
+    return { url: existingSandbox.url };
+  }
+  
+  // Build the command string
+  let cmd: string;
+  
+  // Prepare the command based on the type of executable
+  if (command === 'uvx') {
+    // For uvx, use the direct format
+    const toolName = args[0];
+    cmd = `uvx ${toolName} ${args.slice(1).join(' ')}`;
+  } else if (command.includes('python')) {
+    // For python commands
+    cmd = `${command} ${args.join(' ')}`;
+  } else {
+    // For node or other commands
+    cmd = `${command} ${args.join(' ')}`;
+  }
+  
+  // Convert env array to object if needed
+  const envs: Record<string, string> = {};
+  if (env && env.length > 0) {
+    env.forEach((envVar) => {
+      if (envVar.key) envs[envVar.key] = envVar.value || '';
+    });
+  }
+  
+  // Start the sandbox
+  console.log(`Starting sandbox for ${id} with command: ${cmd}`);
+  const sandbox = await startMcpSandbox({ cmd, envs });
+  const url = await sandbox.getUrl();
+  
+  // Store the sandbox in our map
+  activeSandboxes.set(id, { sandbox, url });
+  
+  return { url };
+}
+
+/**
+ * Server action to stop a sandbox
+ */
+export async function stopSandbox(id: string): Promise<{ success: boolean }> {
+  if (!id) {
+    throw new Error('Missing sandbox ID');
+  }
+  
+  // Check if we have a sandbox with this ID
+  if (!activeSandboxes.has(id)) {
+    throw new Error(`No active sandbox found with ID: ${id}`);
+  }
+  
+  // Stop the sandbox
+  const { sandbox } = activeSandboxes.get(id);
+  
+  try {
+    await sandbox.stop();
+    console.log(`Stopped sandbox with ID: ${id}`);
+  } catch (stopError) {
+    console.error(`Error stopping sandbox ${id}:`, stopError);
+    // Continue to remove from the map even if stop fails
+  }
+  
+  // Remove from our map
+  activeSandboxes.delete(id);
+  
+  return { success: true };
+}

app/api/chat/route.ts

@@ -1,32 +1,20 @@
 import { model, type modelID } from "@/ai/providers";
-import { streamText, type UIMessage } from "ai";
+import { smoothStream, streamText, type UIMessage } from "ai";
 import { appendResponseMessages } from 'ai';
 import { saveChat, saveMessages, convertToDBMessages } from '@/lib/chat-store';
 import { nanoid } from 'nanoid';
 import { db } from '@/lib/db';
 import { chats } from '@/lib/db/schema';
 import { eq, and } from 'drizzle-orm';
+import { initializeMCPClients, type MCPServerConfig } from '@/lib/mcp-client';
+import { generateTitle } from '@/app/actions';
 
-import { experimental_createMCPClient as createMCPClient, MCPTransport } from 'ai';
-import { Experimental_StdioMCPTransport as StdioMCPTransport } from 'ai/mcp-stdio';
-import { spawn } from "child_process";
+export const runtime = 'nodejs';
 
 // Allow streaming responses up to 30 seconds
 export const maxDuration = 120;
 
-interface KeyValuePair {
-  key: string;
-  value: string;
-}
-
-interface MCPServerConfig {
-  url: string;
-  type: 'sse' | 'stdio';
-  command?: string;
-  args?: string[];
-  env?: KeyValuePair[];
-  headers?: KeyValuePair[];
-}
+export const dynamic = 'force-dynamic';
 
 export async function POST(req: Request) {
   const {
@@ -53,7 +41,7 @@ export async function POST(req: Request) {
   const id = chatId || nanoid();
 
   // Check if chat already exists for the given ID
-  // If not, we'll create it in onFinish
+  // If not, create it now
   let isNewChat = false;
   if (chatId) {
     try {
@@ -66,7 +54,6 @@ export async function POST(req: Request) {
       isNewChat = !existingChat;
     } catch (error) {
       console.error("Error checking for existing chat:", error);
-      // Continue anyway, we'll create the chat in onFinish
       isNewChat = true;
     }
   } else {
@@ -74,125 +61,44 @@ export async function POST(req: Request) {
     isNewChat = true;
   }
 
-  // Initialize tools
-  let tools = {};
-  const mcpClients: any[] = [];
-
-  // Process each MCP server configuration
-  for (const mcpServer of mcpServers) {
+  // If it's a new chat, save it immediately
+  if (isNewChat && messages.length > 0) {
     try {
-      // Create appropriate transport based on type
-      let transport: MCPTransport | { type: 'sse', url: string, headers?: Record<string, string> };
-
-      if (mcpServer.type === 'sse') {
-        // Convert headers array to object for SSE transport
-        const headers: Record<string, string> = {};
-        if (mcpServer.headers && mcpServer.headers.length > 0) {
-          mcpServer.headers.forEach(header => {
-            if (header.key) headers[header.key] = header.value || '';
-          });
-        }
-
-        transport = {
-          type: 'sse' as const,
-          url: mcpServer.url,
-          headers: Object.keys(headers).length > 0 ? headers : undefined
-        };
-      } else if (mcpServer.type === 'stdio') {
-        // For stdio transport, we need command and args
-        if (!mcpServer.command || !mcpServer.args || mcpServer.args.length === 0) {
-          console.warn("Skipping stdio MCP server due to missing command or args");
-          continue;
-        }
-
-        // Convert env array to object for stdio transport
-        const env: Record<string, string> = {};
-        if (mcpServer.env && mcpServer.env.length > 0) {
-          mcpServer.env.forEach(envVar => {
-            if (envVar.key) env[envVar.key] = envVar.value || '';
-          });
-        }
-
-        // Check for uvx pattern and transform to python3 -m uv run
-        if (mcpServer.command === 'uvx') {
-          // install uv
-          const subprocess = spawn('pip3', ['install', 'uv']);
-          subprocess.on('close', (code: number) => {
-            if (code !== 0) {
-              console.error(`Failed to install uv: ${code}`);
-            }
-          });
-          // wait for the subprocess to finish
-          await new Promise((resolve) => {
-            subprocess.on('close', resolve);
-            console.log("installed uv");
-          });
-          console.log("Detected uvx pattern, transforming to python3 -m uv run");
-          mcpServer.command = 'python3';
-          // Get the tool name (first argument)
-          const toolName = mcpServer.args[0];
-          // Replace args with the new pattern
-          mcpServer.args = ['-m', 'uv', 'run', toolName, ...mcpServer.args.slice(1)];
-        }
-        // if python is passed in the command, install the python package mentioned in args after -m with subprocess or use regex to find the package name
-        else if (mcpServer.command.includes('python3')) {
-          const packageName = mcpServer.args[mcpServer.args.indexOf('-m') + 1];
-          console.log("installing python package", packageName);
-          const subprocess = spawn('pip3', ['install', packageName]);
-          subprocess.on('close', (code: number) => {
-            if (code !== 0) {
-              console.error(`Failed to install python package: ${code}`);
-            }
-          });
-          // wait for the subprocess to finish
-          await new Promise((resolve) => {
-            subprocess.on('close', resolve);
-            console.log("installed python package", packageName);
-          });
+      // Generate a title based on first user message
+      const userMessage = messages.find(m => m.role === 'user');
+      let title = 'New Chat';
+      
+      if (userMessage) {
+        try {
+          title = await generateTitle([userMessage]);
+        } catch (error) {
+          console.error("Error generating title:", error);
         }
-
-        transport = new StdioMCPTransport({
-          command: mcpServer.command,
-          args: mcpServer.args,
-          env: Object.keys(env).length > 0 ? env : undefined
-        });
-      } else {
-        console.warn(`Skipping MCP server with unsupported transport type: ${mcpServer.type}`);
-        continue;
       }
-
-      const mcpClient = await createMCPClient({ transport });
-      mcpClients.push(mcpClient);
-
-      const mcptools = await mcpClient.tools();
-
-      console.log(`MCP tools from ${mcpServer.type} transport:`, Object.keys(mcptools));
-
-      // Add MCP tools to tools object
-      tools = { ...tools, ...mcptools };
+      
+      // Save the chat immediately so it appears in the sidebar
+      await saveChat({
+        id,
+        userId,
+        title,
+        messages: [],
+      });
     } catch (error) {
-      console.error("Failed to initialize MCP client:", error);
-      // Continue with other servers instead of failing the entire request
+      console.error("Error saving new chat:", error);
     }
   }
 
-  // Register cleanup for all clients
-  if (mcpClients.length > 0) {
-    req.signal.addEventListener('abort', async () => {
-      for (const client of mcpClients) {
-        try {
-          await client.close();
-        } catch (error) {
-          console.error("Error closing MCP client:", error);
-        }
-      }
-    });
-  }
+  // Initialize MCP clients using the already running persistent SSE servers
+  // mcpServers now only contains SSE configurations since stdio servers
+  // have been converted to SSE in the MCP context
+  const { tools, cleanup } = await initializeMCPClients(mcpServers, req.signal);
 
   console.log("messages", messages);
   console.log("parts", messages.map(m => m.parts.map(p => p)));
 
-  // If there was an error setting up MCP clients but we at least have composio tools, continue
+  // Track if the response has completed
+  let responseCompleted = false;
+
   const result = streamText({
     model: model.languageModel(selectedModel),
     system: `You are a helpful assistant with access to a variety of tools.
@@ -233,10 +139,15 @@ export async function POST(req: Request) {
         },
       } 
     },
+    experimental_transform: smoothStream({
+      delayInMs: 5, // optional: defaults to 10ms
+      chunking: 'line', // optional: defaults to 'word'
+    }),
     onError: (error) => {
       console.error(JSON.stringify(error, null, 2));
     },
     async onFinish({ response }) {
+      responseCompleted = true;
       const allMessages = appendResponseMessages({
         messages,
         responseMessages: response.messages,
@@ -250,16 +161,32 @@ export async function POST(req: Request) {
 
       const dbMessages = convertToDBMessages(allMessages, id);
       await saveMessages({ messages: dbMessages });
-      // close all mcp clients
-      // for (const client of mcpClients) {
-      //   await client.close();
-      // }
+      
+      // Clean up resources - now this just closes the client connections
+      // not the actual servers which persist in the MCP context
+      await cleanup();
+    }
+  });
+
+  // Ensure cleanup happens if the request is terminated early
+  req.signal.addEventListener('abort', async () => {
+    if (!responseCompleted) {
+      console.log("Request aborted, cleaning up resources");
+      try {
+        await cleanup();
+      } catch (error) {
+        console.error("Error during cleanup on abort:", error);
+      }
     }
   });
 
   result.consumeStream()
+  // Add chat ID to response headers so client can know which chat was created
   return result.toDataStreamResponse({
     sendReasoning: true,
+    headers: {
+      'X-Chat-ID': id
+    },
     getErrorMessage: (error) => {
       if (error instanceof Error) {
         if (error.message.includes("Rate limit")) {
@@ -270,4 +197,4 @@ export async function POST(req: Request) {
       return "An error occurred.";
     },
   });
-}
+}

components/mcp-server-manager.tsx

@@ -24,7 +24,10 @@ import {
     Cog,
     Edit2,
     Eye,
-    EyeOff
+    EyeOff,
+    AlertTriangle,
+    RefreshCw,
+    Power
 } from "lucide-react";
 import { toast } from "sonner";
 import {
@@ -33,7 +36,7 @@ import {
     AccordionItem,
     AccordionTrigger
 } from "./ui/accordion";
-import { KeyValuePair, MCPServer } from "@/lib/context/mcp-context";
+import { KeyValuePair, MCPServer, ServerStatus, useMCP } from "@/lib/context/mcp-context";
 
 // Default template for a new MCP server
 const INITIAL_NEW_SERVER: Omit<MCPServer, 'id'> = {
@@ -76,6 +79,44 @@ const maskValue = (value: string): string => {
     return value.substring(0, 3) + '•'.repeat(Math.min(10, value.length - 4)) + value.substring(value.length - 1);
 };
 
+const StatusIndicator = ({ status, onClick }: { status?: ServerStatus, onClick?: () => void }) => {
+    const isClickable = !!onClick;
+    
+    const className = `flex-shrink-0 flex items-center gap-1 ${isClickable ? 'cursor-pointer hover:underline' : ''}`;
+    
+    switch (status) {
+        case 'connected':
+            return (
+                <div className={className} onClick={onClick}>
+                    <div className="w-2 h-2 rounded-full bg-green-500 animate-pulse" />
+                    <span className="text-xs text-green-500">Connected</span>
+                </div>
+            );
+        case 'connecting':
+            return (
+                <div className={className} onClick={onClick}>
+                    <RefreshCw className="w-3 h-3 text-amber-500 animate-spin" />
+                    <span className="text-xs text-amber-500">Connecting</span>
+                </div>
+            );
+        case 'error':
+            return (
+                <div className={className} onClick={onClick}>
+                    <AlertTriangle className="w-3 h-3 text-red-500" />
+                    <span className="text-xs text-red-500">Error</span>
+                </div>
+            );
+        case 'disconnected':
+        default:
+            return (
+                <div className={className} onClick={onClick}>
+                    <div className="w-2 h-2 rounded-full bg-gray-400" />
+                    <span className="text-xs text-muted-foreground">Disconnected</span>
+                </div>
+            );
+    }
+};
+
 export const MCPServerManager = ({
     servers,
     onServersChange,
@@ -95,6 +136,9 @@ export const MCPServerManager = ({
     const [editingHeaderIndex, setEditingHeaderIndex] = useState<number | null>(null);
     const [editedEnvValue, setEditedEnvValue] = useState<string>('');
     const [editedHeaderValue, setEditedHeaderValue] = useState<string>('');
+    
+    // Add access to the MCP context for server control
+    const { startServer, stopServer, updateServerStatus } = useMCP();
 
     const resetAndClose = () => {
         setView('list');
@@ -356,6 +400,57 @@ export const MCPServerManager = ({
         setShowSensitiveHeaderValues({});
     };
 
+    // Add functions to control servers
+    const toggleServerStatus = async (server: MCPServer, e: React.MouseEvent) => {
+        e.stopPropagation();
+        
+        if (!server.status || server.status === 'disconnected' || server.status === 'error') {
+            // Start the server
+            try {
+                const success = await startServer(server.id);
+                if (success) {
+                    toast.success(`Started server: ${server.name}`);
+                } else {
+                    toast.error(`Failed to start server: ${server.name}`);
+                }
+            } catch (error) {
+                toast.error(`Error starting server: ${error instanceof Error ? error.message : String(error)}`);
+            }
+        } else {
+            // Stop the server
+            try {
+                await stopServer(server.id);
+                toast.success(`Stopped server: ${server.name}`);
+            } catch (error) {
+                toast.error(`Error stopping server: ${error instanceof Error ? error.message : String(error)}`);
+            }
+        }
+    };
+
+    // Add function to restart a server
+    const restartServer = async (server: MCPServer, e: React.MouseEvent) => {
+        e.stopPropagation();
+        
+        try {
+            // First stop it if it's running
+            if (server.status === 'connected' || server.status === 'connecting') {
+                await stopServer(server.id);
+            }
+            
+            // Then start it again
+            updateServerStatus(server.id, 'connecting');
+            const success = await startServer(server.id);
+            
+            if (success) {
+                toast.success(`Restarted server: ${server.name}`);
+            } else {
+                toast.error(`Failed to restart server: ${server.name}`);
+            }
+        } catch (error) {
+            toast.error(`Error restarting server: ${error instanceof Error ? error.message : String(error)}`);
+        }
+    };
+
     return (
         <Dialog open={open} onOpenChange={onOpenChange}>
             <DialogContent className="sm:max-w-[480px] max-h-[85vh] overflow-hidden flex flex-col">
@@ -396,6 +491,8 @@ export const MCPServerManager = ({
                                             })
                                             .map((server) => {
                                             const isActive = selectedServers.includes(server.id);
+                                            const isRunning = server.status === 'connected' || server.status === 'connecting';
+
                                             return (
                                                 <div
                                                     key={server.id}
@@ -406,7 +503,7 @@ export const MCPServerManager = ({
                                                             : 'border-border hover:border-primary/30 hover:bg-primary/5'}
                           `}
                                                 >
-                                                    {/* Server Header with Type Badge and Delete Button */}
+                                                    {/* Server Header with Type Badge and Actions */}
                                                     <div className="flex items-center justify-between mb-2">
                                                         <div className="flex items-center gap-2">
                                                             {server.type === 'sse' ? (
@@ -414,7 +511,7 @@ export const MCPServerManager = ({
                                                             ) : (
                                                                 <Terminal className={`h-4 w-4 ${isActive ? 'text-primary' : 'text-muted-foreground'} flex-shrink-0`} />
                                                             )}
-                                                            <h4 className="text-sm font-medium truncate max-w-[220px]">{server.name}</h4>
+                                                            <h4 className="text-sm font-medium truncate max-w-[160px]">{server.name}</h4>
                                                             {hasAdvancedConfig(server) && (
                                                                 <span className="flex-shrink-0">
                                                                     <Cog className="h-3 w-3 text-muted-foreground" />
@@ -425,20 +522,52 @@ export const MCPServerManager = ({
                                                             <span className="text-xs px-2 py-0.5 rounded-full bg-secondary text-secondary-foreground">
                                                                 {server.type.toUpperCase()}
                                                             </span>
-                                                            <button
-                                                                onClick={(e) => removeServer(server.id, e)}
-                                                                className="p-1 rounded-full hover:bg-muted/70"
-                                                                aria-label="Remove server"
-                                                            >
-                                                                <Trash2 className="h-3.5 w-3.5 text-muted-foreground" />
-                                                            </button>
-                                                            <button
-                                                                onClick={() => startEditing(server)}
-                                                                className="p-1 rounded-full hover:bg-muted/50"
-                                                                aria-label="Edit server"
-                                                            >
-                                                                <Edit2 className="h-3.5 w-3.5 text-muted-foreground" />
-                                                            </button>
+                                                            
+                                                            {/* Status indicator */}
+                                                            <StatusIndicator 
+                                                                status={server.status} 
+                                                                onClick={() => server.errorMessage && toast.error(server.errorMessage)}
+                                                            />
+                                                            
+                                                            {/* Server actions */}
+                                                            <div className="flex items-center">
+                                                                <button
+                                                                    onClick={(e) => toggleServerStatus(server, e)}
+                                                                    className="p-1 rounded-full hover:bg-muted/70"
+                                                                    aria-label={isRunning ? "Stop server" : "Start server"}
+                                                                    title={isRunning ? "Stop server" : "Start server"}
+                                                                >
+                                                                    <Power className={`h-3.5 w-3.5 ${isRunning ? 'text-red-500' : 'text-green-500'}`} />
+                                                                </button>
+                                                                
+                                                                <button
+                                                                    onClick={(e) => restartServer(server, e)}
+                                                                    className="p-1 rounded-full hover:bg-muted/70"
+                                                                    aria-label="Restart server"
+                                                                    title="Restart server"
+                                                                    disabled={server.status === 'connecting'}
+                                                                >
+                                                                    <RefreshCw className={`h-3.5 w-3.5 text-muted-foreground ${server.status === 'connecting' ? 'opacity-50' : ''}`} />
+                                                                </button>
+                                                                
+                                                                <button
+                                                                    onClick={(e) => removeServer(server.id, e)}
+                                                                    className="p-1 rounded-full hover:bg-muted/70"
+                                                                    aria-label="Remove server"
+                                                                    title="Remove server"
+                                                                >
+                                                                    <Trash2 className="h-3.5 w-3.5 text-muted-foreground" />
+                                                                </button>
+                                                                
+                                                                <button
+                                                                    onClick={() => startEditing(server)}
+                                                                    className="p-1 rounded-full hover:bg-muted/50"
+                                                                    aria-label="Edit server"
+                                                                    title="Edit server"
+                                                                >
+                                                                    <Edit2 className="h-3.5 w-3.5 text-muted-foreground" />
+                                                                </button>
+                                                            </div>
                                                         </div>
                                                     </div>
 

lib/context/mcp-context.tsx

@@ -1,8 +1,9 @@
 "use client";
 
-import React, { createContext, useContext, useEffect, useState } from "react";
+import React, { createContext, useContext, useEffect, useState, useRef } from "react";
 import { useLocalStorage } from "@/lib/hooks/use-local-storage";
 import { STORAGE_KEYS } from "@/lib/constants";
+import { startSandbox, stopSandbox } from "@/app/actions";
 
 // Define types for MCP server
 export interface KeyValuePair {
@@ -10,6 +11,8 @@ export interface KeyValuePair {
   value: string;
 }
 
+export type ServerStatus = 'disconnected' | 'connecting' | 'connected' | 'error';
+
 export interface MCPServer {
   id: string;
   name: string;
@@ -20,28 +23,54 @@ export interface MCPServer {
   env?: KeyValuePair[];
   headers?: KeyValuePair[];
   description?: string;
+  status?: ServerStatus;
+  errorMessage?: string;
 }
 
 // Type for processed MCP server config for API
 export interface MCPServerApi {
-  type: 'sse' | 'stdio';
+  type: 'sse';
   url: string;
-  command?: string;
-  args?: string[];
-  env?: KeyValuePair[];
   headers?: KeyValuePair[];
 }
 
+interface SandboxInfo {
+  id: string;
+  url: string;
+}
+
 interface MCPContextType {
   mcpServers: MCPServer[];
   setMcpServers: (servers: MCPServer[]) => void;
   selectedMcpServers: string[];
   setSelectedMcpServers: (serverIds: string[]) => void;
   mcpServersForApi: MCPServerApi[];
+  startServer: (serverId: string) => Promise<boolean>;
+  stopServer: (serverId: string) => Promise<void>;
+  updateServerStatus: (serverId: string, status: ServerStatus, errorMessage?: string) => void;
 }
 
 const MCPContext = createContext<MCPContextType | undefined>(undefined);
 
+// Helper function to wait for server readiness
+async function waitForServerReady(url: string, maxAttempts = 15) {
+  for (let i = 0; i < maxAttempts; i++) {
+    try {
+      const response = await fetch(url);
+      if (response.status === 200) {
+        console.log(`Server ready at ${url} after ${i + 1} attempts`);
+        return true;
+      }
+      console.log(`Server not ready yet (attempt ${i + 1}), status: ${response.status}`);
+    } catch {
+      console.log(`Server connection failed (attempt ${i + 1})`);
+    }
+    // Wait between attempts
+    await new Promise(resolve => setTimeout(resolve, 6000));
+  }
+  return false;
+}
+
 export function MCPProvider(props: { children: React.ReactNode }) {
   const { children } = props;
   const [mcpServers, setMcpServers] = useLocalStorage<MCPServer[]>(
@@ -53,6 +82,157 @@ export function MCPProvider(props: { children: React.ReactNode }) {
     []
   );
   const [mcpServersForApi, setMcpServersForApi] = useState<MCPServerApi[]>([]);
+  
+  // Keep a ref to active sandboxes (only their IDs and URLs)
+  const sandboxesRef = useRef<SandboxInfo[]>([]);
+
+  // Update server status
+  const updateServerStatus = (serverId: string, status: ServerStatus, errorMessage?: string) => {
+    setMcpServers(current => 
+      current.map(server => 
+        server.id === serverId 
+          ? { ...server, status, errorMessage: errorMessage || undefined } 
+          : server
+      )
+    );
+  };
+  
+  // Start a server (if it's stdio type) using server actions
+  const startServer = async (serverId: string): Promise<boolean> => {
+    const server = mcpServers.find(s => s.id === serverId);
+    if (!server) return false;
+    
+    // If it's already an SSE server, just update the status
+    if (server.type === 'sse') {
+      updateServerStatus(serverId, 'connecting');
+      
+      try {
+        const isReady = await waitForServerReady(server.url);
+        updateServerStatus(serverId, isReady ? 'connected' : 'error', 
+          isReady ? undefined : 'Could not connect to server');
+        return isReady;
+      } catch (error) {
+        updateServerStatus(serverId, 'error', `Connection error: ${error instanceof Error ? error.message : String(error)}`);
+        return false;
+      }
+    }
+    
+    // For stdio type, start a sandbox via the server action
+    if (server.type === 'stdio' && server.command && server.args?.length) {
+      updateServerStatus(serverId, 'connecting');
+      
+      try {
+        // Check if we already have a sandbox for this server
+        const existingSandbox = sandboxesRef.current.find(s => s.id === serverId);
+        if (existingSandbox) {
+          try {
+            // Test if the existing sandbox is still responsive
+            const isReady = await waitForServerReady(existingSandbox.url);
+            if (isReady) {
+              updateServerStatus(serverId, 'connected');
+              return true;
+            }
+            // If not responsive, we'll create a new one below
+          } catch {
+            // Sandbox wasn't responsive, continue to create a new one
+          }
+        }
+        
+        // Call the server action to create a sandbox
+        const { url } = await startSandbox({
+          id: serverId,
+          command: server.command,
+          args: server.args,
+          env: server.env,
+        });
+        
+        // Wait for the server to become ready
+        const isReady = await waitForServerReady(url);
+        if (!isReady) {
+          updateServerStatus(serverId, 'error', 'Server failed to start in time');
+          
+          // Attempt to stop the sandbox since it's not working correctly
+          try {
+            await stopSandbox(serverId);
+          } catch (stopError) {
+            console.error('Failed to stop non-responsive sandbox:', stopError);
+          }
+          
+          return false;
+        }
+        
+        // Store the sandbox reference
+        // Remove any existing sandbox for this server first
+        sandboxesRef.current = sandboxesRef.current.filter(s => s.id !== serverId);
+        sandboxesRef.current.push({ id: serverId, url });
+        
+        // Update the server URL to point to the sandbox SSE URL
+        setMcpServers(current => 
+          current.map(s => 
+            s.id === serverId 
+              ? { ...s, status: 'connected', errorMessage: undefined, url } 
+              : s
+          )
+        );
+        
+        return true;
+      } catch (error) {
+        console.error('Error starting server:', error);
+        updateServerStatus(serverId, 'error', `Startup error: ${error instanceof Error ? error.message : String(error)}`);
+        return false;
+      }
+    }
+    
+    return false;
+  };
+  
+  // Stop a server using the server action
+  const stopServer = async (serverId: string): Promise<void> => {
+    // Find the sandbox for this server
+    const sandboxIndex = sandboxesRef.current.findIndex(s => s.id === serverId);
+    if (sandboxIndex >= 0) {
+      try {
+        // Call server action to stop the sandbox
+        await stopSandbox(serverId);
+        console.log(`Stopped sandbox for server ${serverId}`);
+      } catch (error) {
+        console.error(`Error stopping sandbox for server ${serverId}:`, error);
+      }
+      
+      // Remove from our tracking
+      sandboxesRef.current.splice(sandboxIndex, 1);
+    }
+    
+    // Update server status
+    updateServerStatus(serverId, 'disconnected');
+  };
+
+  // Auto-start selected servers when they're added to the selection
+  useEffect(() => {
+    const startSelectedServers = async () => {
+      for (const serverId of selectedMcpServers) {
+        const server = mcpServers.find(s => s.id === serverId);
+        if (server && (!server.status || server.status === 'disconnected')) {
+          await startServer(serverId);
+        }
+      }
+    };
+    
+    startSelectedServers();
+    
+    // Cleanup on unmount
+    return () => {
+      // Stop all running sandboxes
+      sandboxesRef.current.forEach(async ({ id }) => {
+        try {
+          await stopSandbox(id);
+        } catch (error) {
+          console.error('Error stopping sandbox during cleanup:', error);
+        }
+      });
+      sandboxesRef.current = [];
+    };
+  }, [selectedMcpServers]);
 
   // Process MCP servers for API consumption whenever server data changes
   useEffect(() => {
@@ -65,11 +245,9 @@ export function MCPProvider(props: { children: React.ReactNode }) {
       .map(id => mcpServers.find(server => server.id === id))
       .filter((server): server is MCPServer => Boolean(server))
       .map(server => ({
-        type: server.type,
+        // All servers are exposed as SSE type to the API
+        type: 'sse',
         url: server.url,
-        command: server.command,
-        args: server.args,
-        env: server.env,
         headers: server.headers
       }));
     
@@ -83,7 +261,10 @@ export function MCPProvider(props: { children: React.ReactNode }) {
         setMcpServers, 
         selectedMcpServers, 
         setSelectedMcpServers,
-        mcpServersForApi 
+        mcpServersForApi,
+        startServer,
+        stopServer,
+        updateServerStatus
       }}
     >
       {children}

lib/mcp-client.ts

@@ -0,0 +1,105 @@
+import { experimental_createMCPClient as createMCPClient } from 'ai';
+
+
+export interface KeyValuePair {
+  key: string;
+  value: string;
+}
+
+export interface MCPServerConfig {
+  url: string;
+  type: 'sse' | 'stdio';
+  command?: string;
+  args?: string[];
+  env?: KeyValuePair[];
+  headers?: KeyValuePair[];
+}
+
+export interface MCPClientManager {
+  tools: Record<string, any>;
+  clients: any[];
+  cleanup: () => Promise<void>;
+}
+
+async function waitForServerReady(url: string, maxAttempts = 5) {
+  for (let i = 0; i < maxAttempts; i++) {
+    try {
+      const response = await fetch(url)
+      if (response.status === 200) {
+        console.log(`Server ready at ${url} after ${i + 1} attempts`)
+        return true
+      }
+      console.log(`Server not ready yet (attempt ${i + 1}), status: ${response.status}`)
+    } catch {
+      console.log(`Server connection failed (attempt ${i + 1})`)
+    }
+    // Wait 6 seconds between attempts
+    await new Promise(resolve => setTimeout(resolve, 6000))
+  }
+  return false
+}
+
+/**
+ * Initialize MCP clients for API calls
+ * This uses the already running persistent SSE servers
+ */
+export async function initializeMCPClients(
+  mcpServers: MCPServerConfig[] = [],
+  abortSignal?: AbortSignal
+): Promise<MCPClientManager> {
+  // Initialize tools
+  let tools = {};
+  const mcpClients: any[] = [];
+
+  // Process each MCP server configuration
+  for (const mcpServer of mcpServers) {
+    try {
+      // All servers are handled as SSE
+      const transport = {
+        type: 'sse' as const,
+        url: mcpServer.url,
+        headers: mcpServer.headers?.reduce((acc, header) => {
+          if (header.key) acc[header.key] = header.value || '';
+          return acc;
+        }, {} as Record<string, string>)
+      };
+
+      const mcpClient = await createMCPClient({ transport });
+      mcpClients.push(mcpClient);
+
+      const mcptools = await mcpClient.tools();
+
+      console.log(`MCP tools from ${mcpServer.url}:`, Object.keys(mcptools));
+
+      // Add MCP tools to tools object
+      tools = { ...tools, ...mcptools };
+    } catch (error) {
+      console.error("Failed to initialize MCP client:", error);
+      // Continue with other servers instead of failing the entire request
+    }
+  }
+
+  // Register cleanup for all clients if an abort signal is provided
+  if (abortSignal && mcpClients.length > 0) {
+    abortSignal.addEventListener('abort', async () => {
+      await cleanupMCPClients(mcpClients);
+    });
+  }
+
+  return {
+    tools,
+    clients: mcpClients,
+    cleanup: async () => await cleanupMCPClients(mcpClients)
+  };
+}
+
+async function cleanupMCPClients(clients: any[]): Promise<void> {
+  // Clean up the MCP clients
+  for (const client of clients) {
+    try {
+      await client.close();
+    } catch (error) {
+      console.error("Error closing MCP client:", error);
+    }
+  }
+} 

lib/mcp-sandbox.ts

@@ -0,0 +1,101 @@
+// import Sandbox from "@e2b/code-interpreter";
+import { Daytona, Sandbox, SandboxTargetRegion } from "@daytonaio/sdk";
+
+export const startMcpSandbox = async ({
+  cmd,
+  envs = {},
+}: {
+  cmd: string
+  envs?: Record<string, string>
+}) => {
+  console.log("Creating sandbox...");
+  const daytona = new Daytona();
+  const sandbox = await daytona.create({
+    resources: {
+      cpu: 2,
+      memory: 4,
+      disk: 5,
+    },
+    public: true,
+    autoStopInterval: 0, // 24 hours
+    timeout: 1000 * 300, // 5 minutes
+    envVars: {
+      ...envs,
+    },
+  });
+
+  const host = await sandbox.getPreviewLink(3000);
+  const url = host.url;
+  const token = host.token;
+  console.log("url", url);
+  console.log("token", token);
+
+  const sessionId = Math.random().toString(36).substring(2, 30);
+  await sandbox.process.createSession(sessionId);
+  // python -m mcp_server_time --local-timezone=Asia/Kolkata
+  const isPythonCommand = cmd.startsWith('python') || cmd.startsWith('python3');
+  let installResult = null;
+  
+  if (isPythonCommand) {
+    const packageName = cmd.split("-m ")[1]?.split(" ")[0] || "";
+    if (packageName) {
+      console.log(`Installing Python package: ${packageName}`);
+      const installUv = await sandbox.process.executeSessionCommand(sessionId, {
+        // Install python package from the command after -m in the command
+        command: `pip install ${packageName}`,
+        runAsync: true,
+      },
+        1000 * 300 // 5 minutes
+      );
+      console.log("install result", installUv.output);
+      if (installUv.exitCode !== 0) {
+        console.error("Failed to install package");
+      }
+      installResult = installUv;
+    }
+  }
+  
+  console.log("Starting mcp server...");
+  // generate a session with random id
+  const mcpServer = await sandbox.process.executeSessionCommand(sessionId,
+    {
+      command: `npx -y supergateway --base-url ${url} --header "x-daytona-preview-token: ${token}" --port 3000 --cors --stdio "${cmd}"`,
+      runAsync: true,
+    },
+    1000 * 300 // 5 minutes
+  );
+  console.log("mcp server result", mcpServer.output);
+  const session = await sandbox.process.getSession(sessionId);
+  console.log(`Session ${sessionId}:`);
+  for (const command of session.commands || []) {
+    console.log(`Command: ${command.command}, Exit Code: ${command.exitCode}`);
+  }
+  if (mcpServer.exitCode !== 0) {
+    console.error("Failed to start mcp server. Exit code:", mcpServer.exitCode);
+  }
+
+  console.log("MCP server started at:", url + "/sse");
+  return new McpSandbox(sandbox);
+}
+
+class McpSandbox {
+  public sandbox: Sandbox;
+
+  constructor(sandbox: Sandbox) {
+    this.sandbox = sandbox;
+  }
+
+  async getUrl(): Promise<string> {
+    if (!this.sandbox) {
+      throw new Error("Sandbox not initialized");
+    }
+    const host = await this.sandbox.getPreviewLink(3000);
+    return `${host.url}/sse`;
+  }
+
+  async stop(): Promise<void> {
+    await this.sandbox.delete();
+  }
+}
+
+export type { McpSandbox };

package.json

@@ -13,13 +13,14 @@
     "db:studio": "drizzle-kit studio"
   },
   "dependencies": {
-    "@ai-sdk/anthropic": "^1.2.10",
-    "@ai-sdk/cohere": "^1.2.9",
-    "@ai-sdk/google": "^1.2.12",
-    "@ai-sdk/groq": "^1.2.8",
-    "@ai-sdk/openai": "^1.3.16",
-    "@ai-sdk/react": "^1.2.9",
-    "@ai-sdk/xai": "^1.2.14",
+    "@ai-sdk/anthropic": "^1.2.11",
+    "@ai-sdk/google": "^1.2.17",
+    "@ai-sdk/groq": "^1.2.9",
+    "@ai-sdk/openai": "^1.3.22",
+    "@ai-sdk/react": "^1.2.12",
+    "@ai-sdk/xai": "^1.2.16",
+    "@daytonaio/sdk": "^0.17.0",
+    "@e2b/code-interpreter": "^1.5.0",
     "@neondatabase/serverless": "^1.0.0",
     "@radix-ui/react-accordion": "^1.2.7",
     "@radix-ui/react-avatar": "^1.1.6",

pnpm-lock.yaml

@@ -9,26 +9,29 @@ importers:
   .:
     dependencies:
       '@ai-sdk/anthropic':
-        specifier: ^1.2.10
-        version: 1.2.10([email protected])
-      '@ai-sdk/cohere':
-        specifier: ^1.2.9
-        version: 1.2.9([email protected])
+        specifier: ^1.2.11
+        version: 1.2.11([email protected])
       '@ai-sdk/google':
-        specifier: ^1.2.12
-        version: 1.2.12([email protected])
+        specifier: ^1.2.17
+        version: 1.2.17([email protected])
       '@ai-sdk/groq':
-        specifier: ^1.2.8
-        version: 1.2.8([email protected])
+        specifier: ^1.2.9
+        version: 1.2.9([email protected])
       '@ai-sdk/openai':
-        specifier: ^1.3.16
-        version: 1.3.16([email protected])
+        specifier: ^1.3.22
+        version: 1.3.22([email protected])
       '@ai-sdk/react':
-        specifier: ^1.2.9
-        version: 1.2.9([email protected])([email protected])
+        specifier: ^1.2.12
+        version: 1.2.12([email protected])([email protected])
       '@ai-sdk/xai':
-        specifier: ^1.2.14
-        version: 1.2.14([email protected])
+        specifier: ^1.2.16
+        version: 1.2.16([email protected])
+      '@daytonaio/sdk':
+        specifier: ^0.17.0
+        version: 0.17.0
+      '@e2b/code-interpreter':
+        specifier: ^1.5.0
+        version: 1.5.0
       '@neondatabase/serverless':
         specifier: ^1.0.0
         version: 1.0.0
@@ -186,44 +189,44 @@ importers:
 
 packages:
 
-  '@ai-sdk/[email protected].10':
-    resolution: {integrity: sha512-PyE7EC2fPjs9DnzRAHDrPQmcnI2m2Eojr8pfhckOejOlDEh2w7NnSJr1W3qe5hUWzKr+6d7NG1ZKR9fhmpDdEQ==}
+  '@ai-sdk/[email protected].11':
+    resolution: {integrity: sha512-lZLcEMh8MXY4NVSrN/7DyI2rnid8k7cn/30nMmd3bwJrnIsOuIuuFvY8f0nj+pFcTi6AYK7ujLdqW5dQVz1YQw==}
     engines: {node: '>=18'}
     peerDependencies:
       zod: ^3.0.0
 
-  '@ai-sdk/cohere@1.2.9':
-    resolution: {integrity: sha512-ENbQT2bDt1FN+DOLkoFT9n+cojLv7zdN5GCaDtkaqJUuRa+6lHqNO4tRvB79Jg8DY03mhDermty9EhJW2zHoTA==}
+  '@ai-sdk/google@1.2.17':
+    resolution: {integrity: sha512-mLFLDMCJaDK+j1nvoqeNszazSZIyeSMPi5X+fs5Wh3xWZljGGE0WmFg32RNkFujRB+UnM63EnhPG70WdqOx/MA==}
     engines: {node: '>=18'}
     peerDependencies:
       zod: ^3.0.0
 
-  '@ai-sdk/google@1.2.12':
-    resolution: {integrity: sha512-A8AYqCmBs9SJFiAOP6AX0YEDHWTDrCaUDiRY2cdMSKjJiEknvwnPrAAKf3idgVqYaM2kS0qWz5v9v4pBzXDx+w==}
+  '@ai-sdk/groq@1.2.9':
+    resolution: {integrity: sha512-7MoDaxm8yWtiRbD1LipYZG0kBl+Xe0sv/EeyxnHnGPZappXdlgtdOgTZVjjXkT3nWP30jjZi9A45zoVrBMb3Xg==}
     engines: {node: '>=18'}
     peerDependencies:
       zod: ^3.0.0
 
-  '@ai-sdk/groq@1.2.8':
-    resolution: {integrity: sha512-DRq0b4twVUh52DFnIhVC4F14Po8w+76sCdigMRRIcAiSmGRr9I3Vyot36tun1q4tBZMYSvQUss60W3eiaoa6mg==}
+  '@ai-sdk/openai-compatible@0.2.14':
+    resolution: {integrity: sha512-icjObfMCHKSIbywijaoLdZ1nSnuRnWgMEMLgwoxPJgxsUHMx0aVORnsLUid4SPtdhHI3X2masrt6iaEQLvOSFw==}
     engines: {node: '>=18'}
     peerDependencies:
       zod: ^3.0.0
 
-  '@ai-sdk/openai-compatible@0.2.12':
-    resolution: {integrity: sha512-WGk3hTYMOkExgKqBZPWgow/2lp8JLYeJiiO/T/SxBa1NolxNcV+fPaZVvIyqeHGV0/AIXHqNtqI95CFblM47iA==}
+  '@ai-sdk/openai@1.3.22':
+    resolution: {integrity: sha512-QwA+2EkG0QyjVR+7h6FE7iOu2ivNqAVMm9UJZkVxxTk5OIq5fFJDTEI/zICEMuHImTTXR2JjsL6EirJ28Jc4cw==}
     engines: {node: '>=18'}
     peerDependencies:
       zod: ^3.0.0
 
-  '@ai-sdk/openai@1.3.16':
-    resolution: {integrity: sha512-pjtiBKt1GgaSKZryTbM3tqgoegJwgAUlp1+X5uN6T+VPnI4FLSymV65tyloWzDlyqZmi9HXnnSRPu76VoL5D5g==}
+  '@ai-sdk/provider-utils@2.2.7':
+    resolution: {integrity: sha512-kM0xS3GWg3aMChh9zfeM+80vEZfXzR3JEUBdycZLtbRZ2TRT8xOj3WodGHPb06sUK5yD7pAXC/P7ctsi2fvUGQ==}
     engines: {node: '>=18'}
     peerDependencies:
-      zod: ^3.0.0
+      zod: ^3.23.8
 
-  '@ai-sdk/[email protected].7':
-    resolution: {integrity: sha512-kM0xS3GWg3aMChh9zfeM+80vEZfXzR3JEUBdycZLtbRZ2TRT8xOj3WodGHPb06sUK5yD7pAXC/P7ctsi2fvUGQ==}
+  '@ai-sdk/[email protected].8':
+    resolution: {integrity: sha512-fqhG+4sCVv8x7nFzYnFo19ryhAa3w096Kmc3hWxMQfW/TubPOmt3A6tYZhl4mUfQWWQMsuSkLrtjlWuXBVSGQA==}
     engines: {node: '>=18'}
     peerDependencies:
       zod: ^3.23.8
@@ -232,6 +235,16 @@ packages:
     resolution: {integrity: sha512-qZMxYJ0qqX/RfnuIaab+zp8UAeJn/ygXXAffR5I4N0n1IrvA6qBsjc8hXLmBiMV2zoXlifkacF7sEFnYnjBcqg==}
     engines: {node: '>=18'}
 
+  '@ai-sdk/[email protected]':
+    resolution: {integrity: sha512-jK1IZZ22evPZoQW3vlkZ7wvjYGYF+tRBKXtrcolduIkQ/m/sOAVcVeVDUDvh1T91xCnWCdUGCPZg2avZ90mv3g==}
+    engines: {node: '>=18'}
+    peerDependencies:
+      react: ^18 || ^19 || ^19.0.0-rc
+      zod: ^3.23.8
+    peerDependenciesMeta:
+      zod:
+        optional: true
+
   '@ai-sdk/[email protected]':
     resolution: {integrity: sha512-/VYm8xifyngaqFDLXACk/1czDRCefNCdALUyp+kIX6DUIYUWTM93ISoZ+qJ8+3E+FiJAKBQz61o8lIIl+vYtzg==}
     engines: {node: '>=18'}
@@ -242,14 +255,20 @@ packages:
       zod:
         optional: true
 
+  '@ai-sdk/[email protected]':
+    resolution: {integrity: sha512-3zcwCc8ezzFlwp3ZD15wAPjf2Au4s3vAbKsXQVyhxODHcmu0iyPO2Eua6D/vicq/AUm/BAo60r97O6HU+EI0+w==}
+    engines: {node: '>=18'}
+    peerDependencies:
+      zod: ^3.23.8
+
   '@ai-sdk/[email protected]':
     resolution: {integrity: sha512-nls/IJCY+ks3Uj6G/agNhXqQeLVqhNfoJbuNgCny+nX2veY5ADB91EcZUqVeQ/ionul2SeUswPY6Q/DxteY29Q==}
     engines: {node: '>=18'}
     peerDependencies:
       zod: ^3.23.8
 
-  '@ai-sdk/[email protected].14':
-    resolution: {integrity: sha512-ZxGjI/D1heIOX6XqyAwrqyBSkICP2mge2La7qHmr5RRcqw9+vWU+2cAg2y1FqCw8FpN/pGFZI81Dm473cYwlpg==}
+  '@ai-sdk/[email protected].16':
+    resolution: {integrity: sha512-UOZT8td9PWwMi2dF9a0U44t/Oltmf6QmIJdSvrOcLG4mvpRc1UJn6YJaR0HtXs3YnW6SvY1zRdIDrW4GFpv4NA==}
     engines: {node: '>=18'}
     peerDependencies:
       zod: ^3.0.0
@@ -262,12 +281,46 @@ packages:
     resolution: {integrity: sha512-VtPOkrdPHZsKc/clNqyi9WUA8TINkZ4cGk63UUE3u4pmB2k+ZMQRDuIOagv8UVd6j7k0T3+RRIb7beKTebNbcw==}
     engines: {node: '>=6.9.0'}
 
+  '@bufbuild/[email protected]':
+    resolution: {integrity: sha512-WK6zH4MtBp/uesX8KGCnwDDRVnEVHUvwjsigKXcSR57Oo8Oyv1vRS9qyUlSP+6KWRl5z8tNAU5qpf3QodeVYxA==}
+
   '@cloudflare/[email protected]':
     resolution: {integrity: sha512-uu8gZ8P6teFsyfJOIXBrNC4ZsjLWPUEMeDqbQCdJ8OA6Rs/8QoUYD7ZSLW2kxsO/6upcbZir1WGrWp8088aVWg==}
 
+  '@connectrpc/[email protected]':
+    resolution: {integrity: sha512-w88P8Lsn5CCsA7MFRl2e6oLY4J/5toiNtJns/YJrlyQaWOy3RO8pDgkz+iIkG98RPMhj2thuBvsd3Cn4DKKCkw==}
+    peerDependencies:
+      '@bufbuild/protobuf': ^2.2.0
+      '@connectrpc/connect': 2.0.0-rc.3
+
+  '@connectrpc/[email protected]':
+    resolution: {integrity: sha512-ARBt64yEyKbanyRETTjcjJuHr2YXorzQo0etyS5+P6oSeW8xEuzajA9g+zDnMcj1hlX2dQE93foIWQGfpru7gQ==}
+    peerDependencies:
+      '@bufbuild/protobuf': ^2.2.0
+
+  '@daytonaio/[email protected]':
+    resolution: {integrity: sha512-XvnvZkS/i207CxvVR8LuyUkmsCj0Z202l6SD/G9TnUl15PJsmu3OuOQcUJ/PjS1bhaGzKDvEOlHJGZHMwCDAVg==}
+
+  '@daytonaio/[email protected]':
+    resolution: {integrity: sha512-1tolkjpAsW0Byqvf6C0SYMr6yEM/v4MkEjrcIK3w13J1c2zM9ubRtzNC6/b9zWnLapX19SaWsMIzVLFfOjRmsg==}
+
+  '@dotenvx/[email protected]':
+    resolution: {integrity: sha512-Z8XjM75aWZ/ekUzBjlr/OqQsLWtJY4nVtruxopAt+FlYHfY0/gKl85nD16aEqbTkU53kJcm5psID0L2/sQMmuw==}
+    hasBin: true
+
   '@drizzle-team/[email protected]':
     resolution: {integrity: sha512-z33Il7l5dKjUgGULTqBsQBQwckHh5AbIuxhdsIxDDiZAzBOrZO6q9ogcWC65kU382AfynTfgNumVcNIjuIua6w==}
 
+  '@e2b/[email protected]':
+    resolution: {integrity: sha512-9uO8Q5Hfhi6f2rSt0lcshLyhNF6pfh+36StE1dO8RrcMwi3F7MNSyWhKm0/KV9AJjviLZ8lSFFlwXi5/iKyLEA==}
+    engines: {node: '>=18'}
+
+  '@ecies/[email protected]':
+    resolution: {integrity: sha512-tapn6XhOueMwht3E2UzY0ZZjYokdaw9XtL9kEyjhQ/Fb9vL9xTFbOaI+fV0AWvTpYu4BNloC6getKW6NtSg4mA==}
+    engines: {bun: '>=1', deno: '>=2', node: '>=16'}
+    peerDependencies:
+      '@noble/ciphers': ^1.0.0
+
   '@emnapi/[email protected]':
     resolution: {integrity: sha512-4m62DuCE07lw01soJwPiBGC0nAww0Q+RY70VZ+n49yDIO13yyinhbWCeNnaob0lakDtWQzSdtNWzJeOJt2ma+g==}
 
@@ -815,6 +868,18 @@ packages:
     cpu: [x64]
     os: [win32]
 
+  '@noble/[email protected]':
+    resolution: {integrity: sha512-2I0gnIVPtfnMw9ee9h1dJG7tp81+8Ob3OJb3Mv37rx5L40/b0i7djjCVvGOVqc9AEIQyvyu1i6ypKdFw8R8gQw==}
+    engines: {node: ^14.21.3 || >=16}
+
+  '@noble/[email protected]':
+    resolution: {integrity: sha512-7YDlXiNMdO1YZeH6t/kvopHHbIZzlxrCV9WLqCY6QhcXOoXiNCMDqJIglZ9Yjx5+w7Dz30TITFrlTjnRg7sKEg==}
+    engines: {node: ^14.21.3 || >=16}
+
+  '@noble/[email protected]':
+    resolution: {integrity: sha512-jCs9ldd7NwzpgXDIf6P3+NrHh9/sD6CQdxHyjQI+h/6rDNo88ypBxxz45UDuZHz9r3tNz7N/VInSVoVdtXEI4A==}
+    engines: {node: ^14.21.3 || >=16}
+
   '@nodelib/[email protected]':
     resolution: {integrity: sha512-vq24Bq3ym5HEQm2NKCr3yXDwjc7vTsEThRDnkp2DK9p1uqLR+DHurm/NOTo0KG7HYHU7eppKZj3MyqYuMBf62g==}
     engines: {node: '>= 8'}
@@ -1827,6 +1892,9 @@ packages:
     resolution: {integrity: sha512-Xm7bpRXnDSX2YE2YFfBk2FnF0ep6tmG7xPh8iHee8MIcrgq762Nkce856dYtJYLkuIoYZvGfTs/PbZhideTcEg==}
     engines: {node: '>=4'}
 
+  [email protected]:
+    resolution: {integrity: sha512-re4CqKTJaURpzbLHtIi6XpDv20/CnpXOtjRY5/CU32L8gU8ek9UIivcfvSWvmKEngmVbrUtPpdDwWDWL7DNHvg==}
+
   [email protected]:
     resolution: {integrity: sha512-qIj0G9wZbMGNLjLmg1PT6v2mE9AH2zlnADJD/2tC6E00hgmhUOfEB6greHPAfLRSufHqROIUTkw6E+M3lH0PTQ==}
     engines: {node: '>= 0.4'}
@@ -1927,6 +1995,13 @@ packages:
   [email protected]:
     resolution: {integrity: sha512-Fu4hJdvzeylCfQPp9SGWidpzrMs7tTrlu6Vb8XGaRGck8QSNZJJp538Wrb60Lax4fPwR64ViY468OIUTbRlGZg==}
 
+  [email protected]:
+    resolution: {integrity: sha512-yPVavfyCcRhmorC7rWlkHn15b4wDVgVmBA7kV4QVBsF7kv/9TKJAbAXVTxvTnwP8HHKjRCJDClKbciiYS7p0DQ==}
+    engines: {node: '>=16'}
+
+  [email protected]:
+    resolution: {integrity: sha512-4hm4VPpIecmlg59CHXnRDnqGplJFrbLG4aFEl5vl6cK1u76ws3LLvX7ikFnTDl5vo39sjWD6AaDPYodJp/NNHg==}
+
   [email protected]:
     resolution: {integrity: sha512-/Srv4dswyQNBfohGpz9o6Yb3Gz3SrUDqBH5rTuhGR7ahtlbYKnVxw2bCFMRljaA7EXHaXZ8wsHdodFvbkhKmqg==}
 
@@ -2113,6 +2188,14 @@ packages:
     resolution: {integrity: sha512-KIN/nDJBQRcXw0MLVhZE9iQHmG68qAVIBg9CqmUYjmQIhgij9U5MFvrqkUL5FbtyyzZuOeOt0zdeRe4UY7ct+A==}
     engines: {node: '>= 0.4'}
 
+  [email protected]:
+    resolution: {integrity: sha512-KGe5F5UI+1PZ82OBjPHsYqpbw33ck7j0xgcJRSS56mAOWMX/Z6xllXqbZj66Xg6kkO32GmSGXjCAZL4FMSfyug==}
+    engines: {node: '>=18'}
+
+  [email protected]:
+    resolution: {integrity: sha512-eJAgf9pdv214Hn98FlUzclRMYWF7WfoLlkS9nWMTm1qcCwn6Ad4EGD9lr9HXMBfSrZhYQujRE+p0adPRkctC6A==}
+    engines: {bun: '>=1', deno: '>=2', node: '>=16'}
+
   [email protected]:
     resolution: {integrity: sha512-L18DaJsXSUk2+42pv8mLs5jJT2hqFkFE4j21wOmgbUqsZ2hL72NsUU785g9RXgo3s0ZNgVl42TiHp3ZtOv/Vyg==}
 
@@ -2298,6 +2381,10 @@ packages:
     resolution: {integrity: sha512-i/2XbnSz/uxRCU6+NdVJgKWDTM427+MqYbkQzD321DuCQJUqOuJKIA0IM2+W2xtYHdKOmZ4dR6fExsd4SXL+WQ==}
     engines: {node: '>=6'}
 
+  [email protected]:
+    resolution: {integrity: sha512-8uSpZZocAZRBAPIEINJj3Lo9HyGitllczc27Eh5YYojjMFMn8yHMDMaUHE2Jqfq05D/wucwI4JGURyXt1vchyg==}
+    engines: {node: '>=10'}
+
   [email protected]:
     resolution: {integrity: sha512-fjquC59cD7CyW6urNXK0FBufkZcoiGG80wTuPujX590cB5Ttln20E2UB4S/WARVqhXffZl2LNgS+gQdPIIim/g==}
 
@@ -2348,6 +2435,15 @@ packages:
   [email protected]:
     resolution: {integrity: sha512-GX+ysw4PBCz0PzosHDepZGANEuFCMLrnRTiEy9McGjmkCQYwRq4A/X786G/fjM/+OjsWSU1ZrY5qyARZmO/uwg==}
 
+  [email protected]:
+    resolution: {integrity: sha512-gew4GsXizNgdoRyqmyfMHyAmXsZDk6mHkSxZFCzW9gwlbtOW44CDtYavM+y+72qD/Vq2l550kMF52DT8fOLJqQ==}
+    engines: {node: '>=4.0'}
+    peerDependencies:
+      debug: '*'
+    peerDependenciesMeta:
+      debug:
+        optional: true
+
   [email protected]:
     resolution: {integrity: sha512-dKx12eRCVIzqCxFGplyFKJMPvLEWgmNtUrpTiJIR5u97zEhRG8ySrtboPHZXx7daLxQVrl643cTzbab2tkQjxg==}
     engines: {node: '>= 0.4'}
@@ -2399,6 +2495,10 @@ packages:
     resolution: {integrity: sha512-sTSfBjoXBp89JvIKIefqw7U2CCebsc74kiY6awiGogKtoSGbgjYE/G/+l9sF3MWFPNc9IcoOC4ODfKHfxFmp0g==}
     engines: {node: '>= 0.4'}
 
+  [email protected]:
+    resolution: {integrity: sha512-ts6Wi+2j3jQjqi70w5AlN8DFnkSwC+MqmxEzdEALB2qXZYV3X/b1CTfgPLGJNMeAWxdPfU8FO1ms3NUfaHCPYg==}
+    engines: {node: '>=10'}
+
   [email protected]:
     resolution: {integrity: sha512-w9UMqWwJxHNOvoNzSJ2oPF5wvYcvP7jUvYzhp67yEhTi17ZDBBC1z9pTdGuzjD+EFIqLSYRweZjqfiPzQ06Ebg==}
     engines: {node: '>= 0.4'}
@@ -2471,6 +2571,10 @@ packages:
   [email protected]:
     resolution: {integrity: sha512-ol6UPyBWqsrO6EJySPz2O7ZSr856WDrEzM5zMqp+FJJLGMW35cLYmmZnl0vztAZxRUoNZJFTCohfjuIJ8I4QBQ==}
 
+  [email protected]:
+    resolution: {integrity: sha512-B4FFZ6q/T2jhhksgkbEW3HBvWIfDW85snkQgawt07S7J5QXTk6BkNV+0yAeZrM5QpMAdYlocGoljn0sJ/WQkFw==}
+    engines: {node: '>=10.17.0'}
+
   [email protected]:
     resolution: {integrity: sha512-Fl70vYtsAFb/C06PTS9dZBo7ihau+Tu/DNCk/OyHhea07S+aeMWpFFkUaXRa8fI+ScZbEI8dfSxwY7gxZ9SAVQ==}
 
@@ -2587,6 +2691,10 @@ packages:
     resolution: {integrity: sha512-ISWac8drv4ZGfwKl5slpHG9OwPNty4jOWPRIhBpxOoD+hqITiwuipOQ2bNthAzwA3B4fIjO4Nln74N0S9byq8A==}
     engines: {node: '>= 0.4'}
 
+  [email protected]:
+    resolution: {integrity: sha512-hFoiJiTl63nn+kstHGBtewWSKnQLpyb155KHheA1l39uvtO9nWIop1p3udqPcUd/xbF1VLMO4n7OI6p7RbngDg==}
+    engines: {node: '>=8'}
+
   [email protected]:
     resolution: {integrity: sha512-BtEeSsoaQjlSPBemMQIrY1MY0uM6vnS1g5fmufYOtnxLGUZM2178PKbhsk7Ffv58IX+ZtcvoGwccYsh0PglkAA==}
     engines: {node: '>= 0.4'}
@@ -2617,6 +2725,10 @@ packages:
   [email protected]:
     resolution: {integrity: sha512-RHxMLp9lnKHGHRng9QFhRCMbYAcVpn69smSGcq3f36xjgVVWThj4qqLbTLlq7Ssj8B+fIQ1EuCEGI2lKsyQeIw==}
 
+  [email protected]:
+    resolution: {integrity: sha512-LpB/54B+/2J5hqQ7imZHfdU31OlgQqx7ZicVlkm9kzg9/w8GKLEcFfJl/t7DCEDueOyBAD6zCCwTO6Fzs0NoEQ==}
+    engines: {node: '>=16'}
+
   [email protected]:
     resolution: {integrity: sha512-H0dkQoCa3b2VEeKQBOxFph+JAbcrQdE7KC0UkqwpLmv2EC4P41QXP+rqo9wYodACiG5/WM5s9oDApTU8utwj9g==}
     engines: {node: '>= 0.4'}
@@ -2813,6 +2925,9 @@ packages:
   [email protected]:
     resolution: {integrity: sha512-0H44vDimn51F0YwvxSJSm0eCDOJTRlmN0R1yBh4HLj9wiV1Dn0QoXGbvFAWj2hSItVTlCmBF1hqKlIyUBVFLPg==}
 
+  [email protected]:
+    resolution: {integrity: sha512-abv/qOcuPfk3URPfDzmZU1LKmuw8kT+0nIHvKrKgFrwifol/doWcdA4ZqsWQ8ENrFKkd67Mfpo/LovbIUsbt3w==}
+
   [email protected]:
     resolution: {integrity: sha512-8q7VEgMJW4J8tcfVPy8g09NcQwZdbwFEqhe/WZkoIzjn/3TGDwtOCYtXGxA3O8tPzpczCCDgv+P2P5y00ZJOOg==}
     engines: {node: '>= 8'}
@@ -2913,6 +3028,10 @@ packages:
     resolution: {integrity: sha512-ZDY+bPm5zTTF+YpCrAU9nK0UgICYPT0QtT1NZWFv4s++TNkcgVaT0g6+4R2uI4MjQjzysHB1zxuWL50hzaeXiw==}
     engines: {node: '>= 0.6'}
 
+  [email protected]:
+    resolution: {integrity: sha512-OqbOk5oEQeAZ8WXWydlu9HJjz9WVdEIvamMCcXmuqUYjTknH/sqsWvhQ3vgwKFRR1HpjvNBKQ37nbJgYzGqGcg==}
+    engines: {node: '>=6'}
+
   [email protected]:
     resolution: {integrity: sha512-J7p63hRiAjw1NDEww1W7i37+ByIrOWO5XQQAzZ3VOcL0PNybwpfmV/N05zFAzwQ9USyEcX6t3UO+K5aqBQOIHw==}
 
@@ -3013,6 +3132,10 @@ packages:
       encoding:
         optional: true
 
+  [email protected]:
+    resolution: {integrity: sha512-S48WzZW777zhNIrn7gxOlISNAqi9ZC/uQFnRdbeIHhZhCA6UqpkOT8T1G7BvfdgP4Er8gF4sUbaS0i7QvIfCWw==}
+    engines: {node: '>=8'}
+
   [email protected]:
     resolution: {integrity: sha512-a5ERWK1kh38ExDEfoO6qUHJb32rd7aYmPHuyCu3Fta/cnICvYmgd2uhuKXvPD+PXB+gCEYYEaQdIRAjCOwAKNA==}
 
@@ -3032,6 +3155,10 @@ packages:
     resolution: {integrity: sha512-NuAESUOUMrlIXOfHKzD6bpPu3tYt3xvjNdRIQ+FeT0lNb4K8WR70CaDxhuNguS2XG+GjkyMwOzsN5ZktImfhLA==}
     engines: {node: '>= 0.4'}
 
+  [email protected]:
+    resolution: {integrity: sha512-EFVjAYfzWqWsBMRHPMAXLCDIJnpMhdWAqR7xG6M6a2cs6PMFpl/+Z20w9zDW4vkxOFfddegBKq9Rehd0bxWE7A==}
+    engines: {node: '>= 10'}
+
   [email protected]:
     resolution: {integrity: sha512-nK28WOo+QIjBkDduTINE4JkF/UJJKyf2EJxvJKfblDpyg0Q+pkOHNTL0Qwy6NP6FhE/EnzV73BxxqcJaXY9anw==}
     engines: {node: '>= 0.4'}
@@ -3059,6 +3186,16 @@ packages:
     resolution: {integrity: sha512-y0W+X7Ppo7oZX6eovsRkuzcSM40Bicg2JEJkDJ4irIt1wsYAP5MLSNv+QAogO8xivMffw/9OvV3um1pxXgt1uA==}
     engines: {node: ^10.13.0 || >=12.0.0}
 
+  [email protected]:
+    resolution: {integrity: sha512-kbpaSSGJTWdAY5KPVeMOKXSrPtr8C8C7wodJbcsd51jRnmD+GZu8Y0VoU6Dm5Z4vWr0Ig/1NKuWRKf7j5aaYSg==}
+    engines: {node: '>=6'}
+
+  [email protected]:
+    resolution: {integrity: sha512-zM6elH0EZStD/gSiNlcPrzXcVQ/pZo3BDvC6CDwRDUt1dDzxlshpmQnpD6cZaJ39THaSmwVCxxRrPKNM1hHrDg==}
+
+  [email protected]:
+    resolution: {integrity: sha512-1eNjQtbfNi5Z/kFhagDIaIRj6qqDzhjNJKz8cmMW0CVdGwT6e1GLbAfgI0d28VTJa1A8jz82jm/4dG8qNoNS8g==}
+
   [email protected]:
     resolution: {integrity: sha512-jDBPgSVfTnkIh71Hg9pRvtJc6wTwqjRkN88+gCFtYWrlP4Yx2Dsrow8uPi3qLr/aeymPF3o2+dS+wOpglK04ew==}
 
@@ -3152,6 +3289,9 @@ packages:
     resolution: {integrity: sha512-M7BAV6Rlcy5u+m6oPhAPFgJTzAioX/6B0DxyvDlo9l8+T3nLKbrczg2WLUyzd45L8RqfUMyGPzekbMvX2Ldkwg==}
     engines: {node: '>=12'}
 
+  [email protected]:
+    resolution: {integrity: sha512-fnWVljUchTro6RiCFvCXBbNhJc2NijN7oIQxbwsyL0buWJPG85v81ehlHI9fXrJsMNgTofEoWIQeClKpgxFLrg==}
+
   [email protected]:
     resolution: {integrity: sha512-/+5VFTchJDoVj3bhoqi6UeymcD00DAwb1nJwamzPvHEszJ4FpF6SNNbUbOS8yI56qHzdV8eK0qEfOSiodkTdxg==}
     engines: {node: '>= 0.4'}
@@ -3220,6 +3360,9 @@ packages:
   [email protected]:
     resolution: {integrity: sha512-7D/qOz/+Y4X/rzSB6jKxKUsQnphO046ei8qxG59mtM3RG3DHgTK81HrxrmoDVINJb8NKT5ZsRbwHvQ6B68Iyhg==}
 
+  [email protected]:
+    resolution: {integrity: sha512-D+zkORCbA9f1tdWRK0RaCR3GPv50cMxcrz4X8k5LTSUD1Dkw47mKJEZQNunItRTkWwgtaUSo1RVFRIG9ZXiFYg==}
+
   [email protected]:
     resolution: {integrity: sha512-vYt7UD1U9Wg6138shLtLOvdAu+8DsC/ilFtEVHcH+wydcSpNE20AfSOduf6MkRFahL5FY7X1oU7nKVZFtfq8Fg==}
     engines: {node: '>=6'}
@@ -3388,6 +3531,9 @@ packages:
     resolution: {integrity: sha512-ZX99e6tRweoUXqR+VBrslhda51Nh5MTQwou5tnUDgbtyM0dBgmhEDtWGP/xbKn6hqfPRHujUNwz5fy/wbbhnpw==}
     engines: {node: '>= 0.4'}
 
+  [email protected]:
+    resolution: {integrity: sha512-wnD2ZE+l+SPC/uoS0vXeE9L1+0wuaMqKlfz9AMUo38JsyLSBWSFcHR1Rri62LZc12vLr1gb3jl7iwQhgwpAbGQ==}
+
   [email protected]:
     resolution: {integrity: sha512-JA//kQgZtbuY83m+xT+tXJkmJncGMTFT+C+g2h2R9uxkYIrE2yy9sgmcLhCnw57/WSD+Eh3J97FPEDFnbXnDUg==}
 
@@ -3452,6 +3598,10 @@ packages:
     resolution: {integrity: sha512-vavAMRXOgBVNF6nyEEmL3DBK19iRpDcoIwW+swQ+CbGiu7lju6t+JklA1MHweoWtadgt4ISVUsXLyDq34ddcwA==}
     engines: {node: '>=4'}
 
+  [email protected]:
+    resolution: {integrity: sha512-BrpvfNAE3dcvq7ll3xVumzjKjZQ5tI1sEUIKr3Uoks0XUl45St3FlatVqef9prk4jRDzhW6WZg+3bk93y6pLjA==}
+    engines: {node: '>=6'}
+
   [email protected]:
     resolution: {integrity: sha512-6fPc+R4ihwqP6N/aIv2f1gMH8lOVtWQHoqC4yK6oSDVVocumAsfCqjkXnqiYMhmMwS/mEHLp7Vehlt3ql6lEig==}
     engines: {node: '>=8'}
@@ -3620,6 +3770,10 @@ packages:
     peerDependencies:
       react: ^16.8.0 || ^17.0.0 || ^18.0.0 || ^19.0.0
 
+  [email protected]:
+    resolution: {integrity: sha512-0/A9rDy9P7cJ+8w1c9WD9V//9Wj15Ce2MPz8Ri6032usz+NfePxx5AcN3bN+r6ZL6jEo066/yNYB3tn4pQEx+A==}
+    hasBin: true
+
   [email protected]:
     resolution: {integrity: sha512-+NYs2QeMWy+GWFOEm9xnn6HCDp0l7QBD7ml8zLUmJ+93Q5NF0NocErnwkTkXVFNiX3/fpC6afS8Dhb/gz7R7eg==}
     hasBin: true
@@ -3661,6 +3815,11 @@ packages:
     engines: {node: '>= 8'}
     hasBin: true
 
+  [email protected]:
+    resolution: {integrity: sha512-GlaYyEb07DPxYCKhKzplCWBJtvxZcZMrL+4UkrTSJHHPyZU4mYYTv3qaOe77H7EODLSSopAUFAc6W8U4yqvscg==}
+    engines: {node: ^16.13.0 || >=18.0.0}
+    hasBin: true
+
   [email protected]:
     resolution: {integrity: sha512-BN22B5eaMMI9UMtjrGd5g5eCYPpCPDUy0FJXbYsaT5zYxjFOckS53SQDE3pWkVoWpHXVb3BrYcEN4Twa55B5cA==}
     engines: {node: '>=0.10.0'}
@@ -3689,43 +3848,44 @@ packages:
 
 snapshots:
 
-  '@ai-sdk/[email protected].10([email protected])':
+  '@ai-sdk/[email protected].11([email protected])':
     dependencies:
       '@ai-sdk/provider': 1.1.3
-      '@ai-sdk/provider-utils': 2.2.7([email protected])
+      '@ai-sdk/provider-utils': 2.2.8([email protected])
       zod: 3.24.2
 
-  '@ai-sdk/cohere@1.2.9([email protected])':
+  '@ai-sdk/google@1.2.17([email protected])':
     dependencies:
       '@ai-sdk/provider': 1.1.3
-      '@ai-sdk/provider-utils': 2.2.7([email protected])
+      '@ai-sdk/provider-utils': 2.2.8([email protected])
       zod: 3.24.2
 
-  '@ai-sdk/google@1.2.12([email protected])':
+  '@ai-sdk/groq@1.2.9([email protected])':
     dependencies:
       '@ai-sdk/provider': 1.1.3
-      '@ai-sdk/provider-utils': 2.2.7([email protected])
+      '@ai-sdk/provider-utils': 2.2.8([email protected])
       zod: 3.24.2
 
-  '@ai-sdk/groq@1.2.8([email protected])':
+  '@ai-sdk/openai-compatible@0.2.14([email protected])':
     dependencies:
       '@ai-sdk/provider': 1.1.3
-      '@ai-sdk/provider-utils': 2.2.7([email protected])
+      '@ai-sdk/provider-utils': 2.2.8([email protected])
       zod: 3.24.2
 
-  '@ai-sdk/openai-compatible@0.2.12([email protected])':
+  '@ai-sdk/openai@1.3.22([email protected])':
     dependencies:
       '@ai-sdk/provider': 1.1.3
-      '@ai-sdk/provider-utils': 2.2.7([email protected])
+      '@ai-sdk/provider-utils': 2.2.8([email protected])
       zod: 3.24.2
 
-  '@ai-sdk/openai@1.3.16([email protected])':
+  '@ai-sdk/provider-utils@2.2.7([email protected])':
     dependencies:
       '@ai-sdk/provider': 1.1.3
-      '@ai-sdk/provider-utils': 2.2.7(zod@3.24.2)
+      nanoid: 3.3.11
+      secure-json-parse: 2.7.0
       zod: 3.24.2
 
-  '@ai-sdk/[email protected].7([email protected])':
+  '@ai-sdk/[email protected].8([email protected])':
     dependencies:
       '@ai-sdk/provider': 1.1.3
       nanoid: 3.3.11
@@ -3736,6 +3896,16 @@ snapshots:
     dependencies:
       json-schema: 0.4.0
 
+  '@ai-sdk/[email protected]([email protected])([email protected])':
+    dependencies:
+      '@ai-sdk/provider-utils': 2.2.8([email protected])
+      '@ai-sdk/ui-utils': 1.2.11([email protected])
+      react: 19.1.0
+      swr: 2.3.3([email protected])
+      throttleit: 2.1.0
+    optionalDependencies:
+      zod: 3.24.2
+
   '@ai-sdk/[email protected]([email protected])([email protected])':
     dependencies:
       '@ai-sdk/provider-utils': 2.2.7([email protected])
@@ -3746,6 +3916,13 @@ snapshots:
     optionalDependencies:
       zod: 3.24.2
 
+  '@ai-sdk/[email protected]([email protected])':
+    dependencies:
+      '@ai-sdk/provider': 1.1.3
+      '@ai-sdk/provider-utils': 2.2.8([email protected])
+      zod: 3.24.2
+      zod-to-json-schema: 3.24.5([email protected])
+
   '@ai-sdk/[email protected]([email protected])':
     dependencies:
       '@ai-sdk/provider': 1.1.3
@@ -3753,11 +3930,11 @@ snapshots:
       zod: 3.24.2
       zod-to-json-schema: 3.24.5([email protected])
 
-  '@ai-sdk/[email protected].14([email protected])':
+  '@ai-sdk/[email protected].16([email protected])':
     dependencies:
-      '@ai-sdk/openai-compatible': 0.2.12([email protected])
+      '@ai-sdk/openai-compatible': 0.2.14([email protected])
       '@ai-sdk/provider': 1.1.3
-      '@ai-sdk/provider-utils': 2.2.7([email protected])
+      '@ai-sdk/provider-utils': 2.2.8([email protected])
       zod: 3.24.2
 
   '@alloc/[email protected]': {}
@@ -3766,11 +3943,57 @@ snapshots:
     dependencies:
       regenerator-runtime: 0.14.1
 
+  '@bufbuild/[email protected]': {}
+
   '@cloudflare/[email protected]':
     optional: true
 
+  '@connectrpc/[email protected](@bufbuild/[email protected])(@connectrpc/[email protected](@bufbuild/[email protected]))':
+    dependencies:
+      '@bufbuild/protobuf': 2.3.0
+      '@connectrpc/connect': 2.0.0-rc.3(@bufbuild/[email protected])
+
+  '@connectrpc/[email protected](@bufbuild/[email protected])':
+    dependencies:
+      '@bufbuild/protobuf': 2.3.0
+
+  '@daytonaio/[email protected]':
+    dependencies:
+      axios: 1.9.0
+    transitivePeerDependencies:
+      - debug
+
+  '@daytonaio/[email protected]':
+    dependencies:
+      '@daytonaio/api-client': 0.18.1
+      '@dotenvx/dotenvx': 1.43.0
+      axios: 1.9.0
+      uuid: 11.1.0
+    transitivePeerDependencies:
+      - debug
+
+  '@dotenvx/[email protected]':
+    dependencies:
+      commander: 11.1.0
+      dotenv: 16.5.0
+      eciesjs: 0.4.14
+      execa: 5.1.1
+      fdir: 6.4.3([email protected])
+      ignore: 5.3.2
+      object-treeify: 1.1.33
+      picomatch: 4.0.2
+      which: 4.0.0
+
   '@drizzle-team/[email protected]': {}
 
+  '@e2b/[email protected]':
+    dependencies:
+      e2b: 1.4.0
+
+  '@ecies/[email protected](@noble/[email protected])':
+    dependencies:
+      '@noble/ciphers': 1.3.0
+
   '@emnapi/[email protected]':
     dependencies:
       '@emnapi/wasi-threads': 1.0.2
@@ -4136,6 +4359,14 @@ snapshots:
   '@next/[email protected]':
     optional: true
 
+  '@noble/[email protected]': {}
+
+  '@noble/[email protected]':
+    dependencies:
+      '@noble/hashes': 1.8.0
+
+  '@noble/[email protected]': {}
+
   '@nodelib/[email protected]':
     dependencies:
       '@nodelib/fs.stat': 2.0.5
@@ -5133,6 +5364,14 @@ snapshots:
 
   [email protected]: {}
 
+  [email protected]:
+    dependencies:
+      follow-redirects: 1.15.9
+      form-data: 4.0.2
+      proxy-from-env: 1.1.0
+    transitivePeerDependencies:
+      - debug
+
   [email protected]: {}
 
   [email protected]: {}
@@ -5228,6 +5467,10 @@ snapshots:
 
   [email protected]: {}
 
+  [email protected]: {}
+
+  [email protected]: {}
+
   [email protected]: {}
 
   [email protected]: {}
@@ -5329,6 +5572,22 @@ snapshots:
       es-errors: 1.3.0
       gopd: 1.2.0
 
+  [email protected]:
+    dependencies:
+      '@bufbuild/protobuf': 2.3.0
+      '@connectrpc/connect': 2.0.0-rc.3(@bufbuild/[email protected])
+      '@connectrpc/connect-web': 2.0.0-rc.3(@bufbuild/[email protected])(@connectrpc/[email protected](@bufbuild/[email protected]))
+      compare-versions: 6.1.1
+      openapi-fetch: 0.9.8
+      platform: 1.3.6
+
+  [email protected]:
+    dependencies:
+      '@ecies/ciphers': 0.2.3(@noble/[email protected])
+      '@noble/ciphers': 1.3.0
+      '@noble/curves': 1.9.0
+      '@noble/hashes': 1.8.0
+
   [email protected]: {}
 
   [email protected]:
@@ -5699,6 +5958,18 @@ snapshots:
 
   [email protected]: {}
 
+  [email protected]:
+    dependencies:
+      cross-spawn: 7.0.6
+      get-stream: 6.0.1
+      human-signals: 2.1.0
+      is-stream: 2.0.1
+      merge-stream: 2.0.0
+      npm-run-path: 4.0.1
+      onetime: 5.1.2
+      signal-exit: 3.0.7
+      strip-final-newline: 2.0.0
+
   [email protected]: {}
 
   [email protected]: {}
@@ -5751,6 +6022,8 @@ snapshots:
 
   [email protected]: {}
 
+  [email protected]: {}
+
   [email protected]:
     dependencies:
       is-callable: 1.2.7
@@ -5811,6 +6084,8 @@ snapshots:
       dunder-proto: 1.0.1
       es-object-atoms: 1.1.1
 
+  [email protected]: {}
+
   [email protected]:
     dependencies:
       call-bound: 1.0.4
@@ -5902,6 +6177,8 @@ snapshots:
 
   [email protected]: {}
 
+  [email protected]: {}
+
   [email protected]:
     dependencies:
       ms: 2.1.3
@@ -6022,6 +6299,8 @@ snapshots:
     dependencies:
       call-bound: 1.0.4
 
+  [email protected]: {}
+
   [email protected]:
     dependencies:
       call-bound: 1.0.4
@@ -6052,6 +6331,8 @@ snapshots:
 
   [email protected]: {}
 
+  [email protected]: {}
+
   [email protected]:
     dependencies:
       define-data-property: 1.1.4
@@ -6333,6 +6614,8 @@ snapshots:
     dependencies:
       '@types/mdast': 4.0.4
 
+  [email protected]: {}
+
   [email protected]: {}
 
   [email protected]:
@@ -6537,6 +6820,8 @@ snapshots:
     dependencies:
       mime-db: 1.52.0
 
+  [email protected]: {}
+
   [email protected]:
     dependencies:
       brace-expansion: 1.1.11
@@ -6621,6 +6906,10 @@ snapshots:
     dependencies:
       whatwg-url: 5.0.0
 
+  [email protected]:
+    dependencies:
+      path-key: 3.1.1
+
   [email protected]: {}
 
   [email protected]: {}
@@ -6631,6 +6920,8 @@ snapshots:
 
   [email protected]: {}
 
+  [email protected]: {}
+
   [email protected]:
     dependencies:
       call-bind: 1.0.8
@@ -6671,6 +6962,16 @@ snapshots:
 
   [email protected]: {}
 
+  [email protected]:
+    dependencies:
+      mimic-fn: 2.1.0
+
+  [email protected]:
+    dependencies:
+      openapi-typescript-helpers: 0.0.8
+
+  [email protected]: {}
+
   [email protected]:
     dependencies:
       jose: 4.15.9
@@ -6776,6 +7077,8 @@ snapshots:
 
   [email protected]: {}
 
+  [email protected]: {}
+
   [email protected]: {}
 
   [email protected]:
@@ -6831,6 +7134,8 @@ snapshots:
 
   [email protected]: {}
 
+  [email protected]: {}
+
   [email protected]: {}
 
   [email protected]: {}
@@ -7078,6 +7383,8 @@ snapshots:
       side-channel-map: 1.0.1
       side-channel-weakmap: 1.0.2
 
+  [email protected]: {}
+
   [email protected]:
     dependencies:
       is-arrayish: 0.3.2
@@ -7162,6 +7469,8 @@ snapshots:
 
   [email protected]: {}
 
+  [email protected]: {}
+
   [email protected]: {}
 
   [email protected]:
@@ -7354,6 +7663,8 @@ snapshots:
     dependencies:
       react: 19.1.0
 
+  [email protected]: {}
+
   [email protected]: {}
 
   [email protected]:
@@ -7420,6 +7731,10 @@ snapshots:
     dependencies:
       isexe: 2.0.0
 
+  [email protected]:
+    dependencies:
+      isexe: 3.1.1
+
   [email protected]: {}
 
   [email protected]: {}