feat: update dependencies and refactor stream encoding types for improved clarity

Author: hotlong

packages/services/service-ai/package.json

@@ -18,8 +18,10 @@
     "test": "vitest run"
   },
   "dependencies": {
+    "@ai-sdk/provider": "^2.0.0",
     "@objectstack/core": "workspace:*",
-    "@objectstack/spec": "workspace:*"
+    "@objectstack/spec": "workspace:*",
+    "ai": "^6.0.0"
   },
   "devDependencies": {
     "@types/node": "^25.5.0",

packages/services/service-ai/src/__tests__/vercel-stream-encoder.test.ts

@@ -44,10 +44,10 @@ describe('encodeStreamPart', () => {
     });
   });
 
-  it('should encode tool-call-streaming-start as "b:" frame', () => {
+  it('should encode tool-input-start as "b:" frame', () => {
     const part = {
-      type: 'tool-call-streaming-start',
-      toolCallId: 'call_2',
+      type: 'tool-input-start',
+      id: 'call_2',
       toolName: 'search',
     } as TextStreamPart<ToolSet>;
 
@@ -61,11 +61,11 @@ describe('encodeStreamPart', () => {
     });
   });
 
-  it('should encode tool-call-delta as "c:" frame', () => {
+  it('should encode tool-input-delta as "c:" frame', () => {
     const part = {
-      type: 'tool-call-delta',
-      toolCallId: 'call_2',
-      argsTextDelta: '{"query":',
+      type: 'tool-input-delta',
+      id: 'call_2',
+      delta: '{"query":',
     } as TextStreamPart<ToolSet>;
 
     const frame = encodeStreamPart(part);
@@ -83,7 +83,7 @@ describe('encodeStreamPart', () => {
       type: 'tool-result',
       toolCallId: 'call_1',
       toolName: 'get_weather',
-      result: { temperature: 72 },
+      output: { temperature: 72 },
     } as TextStreamPart<ToolSet>;
 
     const frame = encodeStreamPart(part);
@@ -112,20 +112,18 @@ describe('encodeStreamPart', () => {
     expect(payload.usage).toEqual({ promptTokens: 10, completionTokens: 20, totalTokens: 30 });
   });
 
-  it('should encode step-finish as "e:" frame', () => {
+  it('should encode finish-step as "e:" frame', () => {
     const part = {
-      type: 'step-finish',
+      type: 'finish-step',
       finishReason: 'tool-calls',
-      totalUsage: { promptTokens: 5, completionTokens: 10, totalTokens: 15 },
-      isContinued: true,
+      usage: { promptTokens: 5, completionTokens: 10, totalTokens: 15 },
     } as unknown as TextStreamPart<ToolSet>;
 
     const frame = encodeStreamPart(part);
     expect(frame.startsWith('e:')).toBe(true);
 
     const payload = JSON.parse(frame.slice(2));
     expect(payload.finishReason).toBe('tool-calls');
-    expect(payload.isContinued).toBe(true);
   });
 
   it('should return empty string for unknown event types', () => {
@@ -210,7 +208,7 @@ describe('encodeVercelDataStream', () => {
         type: 'tool-result',
         toolCallId: 'call_1',
         toolName: 'search',
-        result: { hits: 42 },
+        output: { hits: 42 },
       } as TextStreamPart<ToolSet>;
       yield {
         type: 'finish',

packages/services/service-ai/src/adapters/vercel-adapter.ts

@@ -9,7 +9,7 @@ import type {
 } from '@objectstack/spec/contracts';
 import type { LLMAdapter } from '@objectstack/spec/contracts';
 import type { AIToolDefinition } from '@objectstack/spec/contracts';
-import type { LanguageModelV3 } from '@ai-sdk/provider';
+import type { LanguageModelV2 } from '@ai-sdk/provider';
 import { generateText, streamText, tool as vercelTool, jsonSchema } from 'ai';
 
 /**
@@ -63,7 +63,7 @@ function buildVercelOptions(options?: AIRequestOptions): Record<string, unknown>
 export class VercelLLMAdapter implements LLMAdapter {
   readonly name = 'vercel';
 
-  private readonly model: LanguageModelV3;
+  private readonly model: LanguageModelV2;
 
   constructor(config: VercelLLMAdapterConfig) {
     this.model = config.model;
@@ -81,9 +81,9 @@ export class VercelLLMAdapter implements LLMAdapter {
       model: result.response?.modelId,
       toolCalls: result.toolCalls?.length ? result.toolCalls : undefined,
       usage: result.usage ? {
-        promptTokens: result.usage.promptTokens,
-        completionTokens: result.usage.completionTokens,
-        totalTokens: result.usage.totalTokens,
+        promptTokens: result.usage.inputTokens ?? 0,
+        completionTokens: result.usage.outputTokens ?? 0,
+        totalTokens: result.usage.totalTokens ?? 0,
       } : undefined,
     };
   }
@@ -99,9 +99,9 @@ export class VercelLLMAdapter implements LLMAdapter {
       content: result.text,
       model: result.response?.modelId,
       usage: result.usage ? {
-        promptTokens: result.usage.promptTokens,
-        completionTokens: result.usage.completionTokens,
-        totalTokens: result.usage.totalTokens,
+        promptTokens: result.usage.inputTokens ?? 0,
+        completionTokens: result.usage.outputTokens ?? 0,
+        totalTokens: result.usage.totalTokens ?? 0,
       } : undefined,
     };
   }
@@ -121,7 +121,7 @@ export class VercelLLMAdapter implements LLMAdapter {
     }
   }
 
-  async embed(input: string | string[]): Promise<number[][]> {
+  async embed(_input: string | string[]): Promise<number[][]> {
     // Vercel AI SDK uses a separate EmbeddingModel — not supported via this adapter.
     throw new Error(
       '[VercelLLMAdapter] Embeddings require a dedicated EmbeddingModel. ' +
@@ -144,5 +144,5 @@ export interface VercelLLMAdapterConfig {
    *
    * @example `openai('gpt-4o')` or `anthropic('claude-sonnet-4-20250514')`
    */
-  model: LanguageModelV3;
+  model: LanguageModelV2;
 }

packages/services/service-ai/src/stream/vercel-stream-encoder.ts

@@ -46,22 +46,22 @@ export function encodeStreamPart(part: TextStreamPart<ToolSet>): string {
         args: part.input,
       })}\n`;
 
-    case 'tool-call-streaming-start':
+    case 'tool-input-start':
       return `b:${JSON.stringify({
-        toolCallId: part.toolCallId,
+        toolCallId: part.id,
         toolName: part.toolName,
       })}\n`;
 
-    case 'tool-call-delta':
+    case 'tool-input-delta':
       return `c:${JSON.stringify({
-        toolCallId: part.toolCallId,
-        argsTextDelta: part.argsTextDelta,
+        toolCallId: part.id,
+        argsTextDelta: part.delta,
       })}\n`;
 
     case 'tool-result':
       return `a:${JSON.stringify({
         toolCallId: part.toolCallId,
-        result: part.result,
+        result: part.output,
       })}\n`;
 
     // ── Finish / Step ────────────────────────────────────────
@@ -71,11 +71,10 @@ export function encodeStreamPart(part: TextStreamPart<ToolSet>): string {
         usage: part.totalUsage ?? undefined,
       })}\n`;
 
-    case 'step-finish':
+    case 'finish-step':
       return `e:${JSON.stringify({
         finishReason: part.finishReason,
-        usage: part.totalUsage ?? undefined,
-        isContinued: part.isContinued ?? false,
+        usage: part.usage ?? undefined,
       })}\n`;
 
     // ── Unhandled types (silently skip) ──────────────────────