Update app.js

app.js

@@ -131,7 +131,8 @@ async function handleRequest(req, res) {
         'Content-Type': 'application/json; charset=utf-8',
         'Accept-Encoding': 'gzip, deflate'
       },
-      body: JSON.stringify(requestBody)
+      body: JSON.stringify(requestBody),
+      compress: false
     });
 
     console.log('Response headers:', response.headers.raw());
@@ -159,17 +160,24 @@ async function handleRequest(req, res) {
       res.setHeader('Cache-Control', 'no-cache');
       res.setHeader('Connection', 'keep-alive');
 
-      const reader = response.body.getReader();
-      const decoder = new TextDecoder();
-
-      while (true) {
-        const { done, value } = await reader.read();
-        if (done) break;
-        const chunk = decoder.decode(value, { stream: true });
+      response.body.on('data', (chunk) => {
         res.write(chunk);
-      }
+      });
 
-      res.end();
+      response.body.on('end', () => {
+        res.end();
+      });
+
+      response.body.on('error', (err) => {
+        console.error('Stream error:', err);
+        res.status(500).json({
+          type: "error",
+          error: {
+            type: "stream_error",
+            message: "An error occurred while streaming the response."
+          }
+        });
+      });
     } else {
       // 非流式响应的处理
       const buffer = await response.buffer();