perf: 添加流解析失败错误信息

dist/buildinfo.json

@@ -1 +1 @@
-{"sha": "9d714ee", "timestamp": 1696745505}
+{"sha": "12fa595", "timestamp": 1696745907}

dist/index.js

@@ -41,9 +41,9 @@ var ENV = {
   // 检查更新的分支
   UPDATE_BRANCH: "master",
   // 当前版本
-  BUILD_TIMESTAMP: 1696745505,
+  BUILD_TIMESTAMP: 1696745907,
   // 当前版本 commit id
-  BUILD_VERSION: "9d714ee",
+  BUILD_VERSION: "12fa595",
   I18N: null,
   LANGUAGE: "zh-cn",
   // 使用流模式
@@ -756,16 +756,21 @@ async function requestCompletionsFromOpenAI(message, history, context, onStream)
     let contentFull = "";
     let lengthDelta = 0;
     let updateStep = 20;
-    for await (const data of stream) {
-      const c = data.choices[0].delta?.content || "";
-      lengthDelta += c.length;
-      contentFull = contentFull + c;
-      if (lengthDelta > updateStep) {
-        lengthDelta = 0;
-        updateStep += 5;
-        await onStream(`${contentFull}
+    try {
+      for await (const data of stream) {
+        const c = data.choices[0].delta?.content || "";
+        lengthDelta += c.length;
+        contentFull = contentFull + c;
+        if (lengthDelta > updateStep) {
+          lengthDelta = 0;
+          updateStep += 5;
+          await onStream(`${contentFull}
 ${ENV.I18N.message.loading}...`);
+        }
       }
+    } catch (e) {
+      contentFull += `
+ERROR: ${e.message}`;
     }
     return contentFull;
   }

dist/timestamp

@@ -1 +1 @@
-1696745505
+1696745907

src/openai.js

@@ -1,7 +1,7 @@
 /* eslint-disable no-unused-vars */
 import {Context} from './context.js';
 import {DATABASE, ENV} from './env.js';
-import {Stream} from "./vendors/stream.js";
+import {Stream} from './vendors/stream.js';
 
 
 /**
@@ -55,19 +55,23 @@ export async function requestCompletionsFromOpenAI(message, history, context, on
     signal,
   });
   if (onStream && resp.ok && resp.headers.get('content-type').indexOf('text/event-stream') !== -1) {
-    const stream = new Stream(resp, controller)
+    const stream = new Stream(resp, controller);
     let contentFull = '';
     let lengthDelta = 0;
     let updateStep = 20;
-    for await (const data of stream) {
-      const c = data.choices[0].delta?.content || ''
-      lengthDelta += c.length;
-      contentFull = contentFull + c;
+    try {
+      for await (const data of stream) {
+        const c = data.choices[0].delta?.content || '';
+        lengthDelta += c.length;
+        contentFull = contentFull + c;
         if (lengthDelta > updateStep) {
-            lengthDelta = 0;
-            updateStep += 5;
-            await onStream(`${contentFull}\n${ENV.I18N.message.loading}...`);
+          lengthDelta = 0;
+          updateStep += 5;
+          await onStream(`${contentFull}\n${ENV.I18N.message.loading}...`);
         }
+      }
+    } catch (e) {
+      contentFull += `\nERROR: ${e.message}`;
     }
     return contentFull;
   }

src/vendors/stream.js

@@ -1,4 +1,5 @@
 /* eslint-disable */
+// https://github.com/openai/openai-node/blob/master/src/streaming.ts
 
 export class Stream {
     constructor(response, controller) {

src/workers-ai.js

@@ -7,7 +7,7 @@ import {Ai} from './vendors/cloudflare-ai.js';
  * @return {boolean}
  */
 export function isWorkersAIEnable(context) {
-    return AI && AI.fetch
+  return AI && AI.fetch;
 }