fix test and tsc error

Author: wangzuo

packages/fluent-ai/examples/ollama-chat.ts

@@ -5,13 +5,30 @@ const models = await ollama().models().run();
 console.log(models);
 
 const response = await ollama()
-  .chat(models[0].name)
+  .chat(models[0].id)
   .messages([
     {
       role: "user",
-      content: "What is the capital of France?",
+      text: "What is the capital of France?",
     },
   ])
   .run();
 
 console.log(response);
+
+const streamResponse = await ollama()
+  .chat(models[0].id)
+  .messages([
+    {
+      role: "user",
+      text: "What is the capital of Spain?",
+    },
+  ])
+  .stream()
+  .run();
+
+for await (const chunk of streamResponse) {
+  if (chunk.message?.text) {
+    process.stdout.write(chunk.message.text);
+  }
+}

packages/fluent-ai/examples/openrouter-chat.ts

@@ -7,8 +7,8 @@ const job: Job = {
   input: {
     model: "google/gemini-2.5-flash",
     messages: [
-      { role: "system", content: "You are a helpful assistant." },
-      { role: "user", content: "Hi" },
+      { role: "system", text: "You are a helpful assistant." },
+      { role: "user", text: "Hi" },
     ],
   },
 };

packages/fluent-ai/src/agent/agent.ts

@@ -90,10 +90,10 @@ export class Agent<TContext = any> {
           ? body.instructions()
           : body.instructions;
       const systemMessage = { role: "system", text: instructions };
-      const messages = [systemMessage].concat(
+      const messages = ([systemMessage] as Message[]).concat(
         initialMessages,
         newMessages,
-      ) as Message[];
+      );
       const tools = body.tools.map((tool) => ({
         name: tool.name,
         description: tool.description,

packages/fluent-ai/src/job/openai.ts

@@ -33,7 +33,15 @@ export const runner = {
 
     return createHTTPJob(request, async (response: Response) => {
       if (input.stream) {
-        return createStreamingGenerator(response);
+        return createStreamingGenerator(response, (chunk: any) => {
+          const choice = chunk.choices[0];
+          const delta = choice.delta;
+          return {
+            text: delta.content,
+            toolCalls: delta.tool_calls,
+            usage: transformUsageData(chunk.usage),
+          };
+        });
       }
 
       const data = await response.json();

packages/fluent-ai/src/job/openrouter.ts

@@ -33,7 +33,15 @@ export const runner = {
 
     return createHTTPJob(request, async (response: Response) => {
       if (input.stream) {
-        return createStreamingGenerator(response);
+        return createStreamingGenerator(response, (chunk: any) => {
+          const choice = chunk.choices[0];
+          const delta = choice.delta;
+          return {
+            text: delta.content,
+            toolCalls: delta.tool_calls,
+            usage: transformUsageData(chunk.usage),
+          };
+        });
       }
 
       const data = await response.json();

packages/fluent-ai/src/job/schema.ts

@@ -70,7 +70,7 @@ const chatToolSchema = z.object({
 
 const chatInputSchema = z.object({
   model: z.string(),
-  messages: z.array(z.any()), // TODO: fix any
+  messages: z.array(messagesSchema),
   temperature: z.number().optional(),
   maxTokens: z.number().optional(),
   stream: z.boolean().optional(),

packages/fluent-ai/test/job.test.ts

@@ -5,7 +5,6 @@ import {
   openai,
   fal,
   type Job,
-  user,
   voyage,
 } from "~/src/index";
 import { Runner } from "~/src/job/runner";
@@ -16,7 +15,7 @@ test("chat job", () => {
     type: "chat",
     input: {
       model: "test-model",
-      messages: [{ role: "user", content: "hello" }],
+      messages: [{ role: "user", text: "hello" }],
     },
   };
 
@@ -27,7 +26,7 @@ test("chat job", () => {
   expect(job).toEqual(
     openrouter()
       .chat("test-model")
-      .messages([user("hello")])
+      .messages([{ role: "user", text: "hello" }])
       .build(),
   );
 });
@@ -96,7 +95,7 @@ test("runner", () => {
     type: "chat",
     input: {
       model: "test-model",
-      messages: [{ role: "user", content: "hello" }],
+      messages: [{ role: "user", text: "hello" }],
     },
   };