Update app.js

app.js

@@ -84,6 +84,9 @@ function formatModelName(model) {
   return model;
 }
 
+const { promisify } = require('util');
+const gunzip = promisify(zlib.gunzip);
+
 async function handleRequest(req, res) {
   if (req.method === 'OPTIONS') {
     handleOptions(res);
@@ -135,7 +138,7 @@ async function handleRequest(req, res) {
       body: JSON.stringify(requestBody)
     });
 
-    console.log('Response headers:', response.headers.raw());  // 打印所有响应头
+    console.log('Response headers:', response.headers.raw());
 
     res.status(response.status);
     
@@ -150,29 +153,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);  // 打印内容编码
+    console.log('Content-Encoding:', contentEncoding);
 
-    if (contentEncoding === 'gzip') {
-      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"
-          }
-        });
-      });
+    // 读取整个响应体
+    const buffer = await response.buffer();
+    console.log('Response body length:', buffer.length);
 
-      response.body.pipe(gunzip).pipe(res);
+    let data;
+    if (contentEncoding === 'gzip') {
+      try {
+        data = await gunzip(buffer);
+      } catch (error) {
+        console.error('Gunzip error:', error);
+        console.log('First 100 bytes of response:', buffer.slice(0, 100).toString('hex'));
+        throw new Error('Failed to decompress the response');
+      }
     } else {
-      response.body.pipe(res);
+      data = buffer;
     }
 
+    res.send(data);
     logRequest(req, response.status, `Request forwarded successfully for model: ${model}`);
   } catch (error) {
-    console.error('Fetch error:', error);
+    console.error('Request error:', error);
     res.status(500).json({
       type: "error",
       error: {
@@ -185,6 +188,7 @@ async function handleRequest(req, res) {
 }
 
 
+
 function handleOptions(res) {
   res.status(204);
   res.setHeader('Access-Control-Allow-Origin', '*');