Revert "Merge pull request #88 from decocms/chore/fix-llm-streaming"

This reverts commit 9fab04a, reversing
changes made to 2eb4dc6.

Author: tlgimenes

bun.lock

@@ -12,11 +12,11 @@
     "check": "tsc --noEmit"
   },
   "dependencies": {
-    "@ai-sdk/provider": "^3.0.2",
-    "@ai-sdk/provider-utils": "^4.0.4",
+    "@ai-sdk/provider": "^3.0.0",
+    "@ai-sdk/provider-utils": "^4.0.1",
     "@decocms/bindings": "^1.0.6",
     "@decocms/runtime": "^1.1.0",
-    "@openrouter/ai-sdk-provider": "^1.5.4",
+    "@openrouter/ai-sdk-provider": "^1.2.0",
     "@openrouter/sdk": "^0.1.11",
     "ai": "^6.0.3",
     "zod": "^4.0.0"

openrouter/package.json

@@ -9,10 +9,9 @@
  * - LLM_DO_GENERATE: Generates complete non-streaming responses
  */
 
-import {
-  APICallError,
-  type LanguageModelV2CallOptions,
-  type LanguageModelV2StreamPart,
+import type {
+  LanguageModelV2CallOptions,
+  LanguageModelV2StreamPart,
 } from "@ai-sdk/provider";
 import {
   LANGUAGE_MODEL_BINDING,
@@ -468,12 +467,6 @@ const getUsageFromStream = (
   ];
 };
 
-const isAPICallError = (error: unknown): error is APICallError =>
-  typeof error === "object" &&
-  error !== null &&
-  Symbol.for("vercel.ai.error") in error &&
-  Symbol.for("vercel.ai.error.AI_APICallError") in error;
-
 /**
  * LLM_DO_STREAM - Streams a language model response in real-time
  */
@@ -495,27 +488,16 @@ export const createLLMStreamTool = (env: Env) =>
       const apiKey = getOpenRouterApiKey(env);
       // Create OpenRouter provider
       const openrouter = createOpenRouter({ apiKey });
-      const model = openrouter(modelId);
+      const model = openrouter.languageModel(modelId);
 
-      try {
-        const callResponse = await model.doStream(
-          callOptions as LanguageModelV2CallOptions,
-        );
+      const callResponse = await model.doStream(
+        callOptions as LanguageModelV2CallOptions,
+      );
+      const [_, stream] = getUsageFromStream(callResponse.stream);
+      const response = streamToResponse(stream);
 
-        const [_, stream] = getUsageFromStream(callResponse.stream);
-        const response = streamToResponse(stream);
-
-        // Return the data stream response
-        return response;
-      } catch (error) {
-        if (isAPICallError(error)) {
-          return new Response(error.responseBody, {
-            status: error.statusCode,
-            headers: error.responseHeaders,
-          });
-        }
-        return new Response(String(error ?? "Unknown error"), { status: 500 });
-      }
+      // Return the data stream response
+      return response;
     },
   });