server/agents/chef.ts

@@ -3,7 +3,7 @@ import { Agent } from "../types.js";
 export const chefAgent: Agent = {
   id: "chef",
   name: "Chef",
-  modelName: "mistralai/mistral-nemo",
+  modelName: "mistral/ministral-8b",
   systemMessage:
     "You are a master chef who is famous for his creative and original recipes, but also knows many standard, tried-and-true recipes.",
   description:

server/agents/personalAssistant.ts

@@ -7,8 +7,7 @@ export const personalAssistantAgent: Agent = {
   name: "Personal Assistant",
   // modelName: "qwen/qwen3-32b:free",
   // modelName: "mistral/ministral-8b",
-  // modelName: "google/gemini-2.5-flash-preview",
+  modelName: "google/gemini-2.5-flash-preview",
-  modelName: "mistralai/mistral-nemo",
   systemMessage:
     singleSpace(`You are a personal assistant Agent who is helpful, friendly, and 
     responsible. You are my liason to other Agents who have specialized 

server/tools.ts

@@ -1,10 +1,4 @@
-import {
+import { streamText } from "ai";
-  streamText,
-  generateText,
-  generateObject,
-  type Message,
-  jsonSchema,
-} from "ai";
 import { getAgentById, openrouter } from "./agentRegistry.js";
 
 // Define the tools with explicit type
@@ -39,59 +33,26 @@ const tools: ToolFunctions = {
     }
 
     try {
-      const conversation: { messages: Array<Omit<Message, "id">> } = {
+      // Generate a response from the agent using the prompt
+      const result = streamText({
+        model: openrouter(agent.modelName),
         messages: [
           { role: "system", content: agent.systemMessage },
           { role: "user", content: prompt },
         ],
-      };
+        tools: agent.tools,
-      let isConversationDone = false;
+      });
-      while (!isConversationDone) {
+
-        // Generate a response from the agent using the prompt
+      // Collect the response text
-        const result = await generateText({
+      let responseText = "";
-          model: openrouter(agent.modelName),
+
-          messages: conversation.messages,
+      // The textStream is already an AsyncIterable, no need to call it as a function
-          tools: agent.tools,
+      for await (const chunk of result.textStream) {
-        });
+        responseText += chunk;
-        conversation.messages.push({ role: "assistant", content: result.text });
-        const sentimentIsConversationDone = await generateObject<{
-          isConversationDone: boolean;
-        }>({
-          model: openrouter("mistralai/mistral-nemo"),
-          messages: [
-            {
-              role: "system",
-              content:
-                "You are a tool to determine whether a conversation is done or should continue with another reply.",
-            },
-            {
-              role: "user",
-              content: conversation.messages
-                .map((message) => `${message.role}: ${message.content}`)
-                .join("\n"),
-            },
-          ],
-          schema: jsonSchema({
-            type: "object",
-            properties: {
-              isConversationDone: {
-                type: "boolean",
-                description:
-                  "Whether the conversation is done or should continue and requires a reply.",
-              },
-            },
-          }),
-        });
-        isConversationDone =
-          sentimentIsConversationDone.object.isConversationDone;
       }
 
-      // const summaryText = await generateSummary();
+      // Return the agent's response
-      // // Return the agent's response
+      return responseText;
-      // return summaryText;
-      return conversation.messages
-        .map((message) => `${message.role}: ${message.content}`)
-        .join("\n");
     } catch (error: unknown) {
       const errorMessage =
         error instanceof Error ? error.message : "Unknown error";