Update app.js

app.js

@@ -135,6 +135,8 @@ async function handleRequest(req, res) {
       body: JSON.stringify(requestBody)
     });
 
+    console.log('Response headers:', response.headers.raw());  // 打印所有响应头
+
     res.status(response.status);
     
     for (const [key, value] of response.headers.entries()) {
@@ -148,22 +150,29 @@ async function handleRequest(req, res) {
     res.setHeader('Access-Control-Allow-Headers', 'Content-Type, Authorization, x-api-key, anthropic-version, model');
 
     const contentEncoding = response.headers.get('content-encoding');
+    console.log('Content-Encoding:', contentEncoding);  // 打印内容编码
+
     if (contentEncoding === 'gzip') {
-      await pipeline(
-        response.body,
-        zlib.createGunzip(),
-        res
-      );
+      const gunzip = zlib.createGunzip();
+      gunzip.on('error', (err) => {
+        console.error('Gunzip error:', err);
+        res.status(500).json({
+          type: "error",
+          error: {
+            type: "decompression_error",
+            message: "Failed to decompress the response"
+          }
+        });
+      });
+
+      response.body.pipe(gunzip).pipe(res);
     } else {
-      await pipeline(
-        response.body,
-        res
-      );
+      response.body.pipe(res);
     }
 
     logRequest(req, response.status, `Request forwarded successfully for model: ${model}`);
   } catch (error) {
-    console.error('Error:', error);
+    console.error('Fetch error:', error);
     res.status(500).json({
       type: "error",
       error: {
@@ -175,6 +184,7 @@ async function handleRequest(req, res) {
   }
 }
 
+
 function handleOptions(res) {
   res.status(204);
   res.setHeader('Access-Control-Allow-Origin', '*');