Update index.js

index.js

@@ -591,6 +591,7 @@ async function handleResponse(response, model, res, isStream) {
             res.setHeader('Cache-Control', 'no-cache');
             res.setHeader('Connection', 'keep-alive');
         }
+        Logger.info("开始处理流式响应", 'Server');
 
         return new Promise((resolve, reject) => {
             stream.on('data', async (chunk) => {
@@ -605,7 +606,7 @@ async function handleResponse(response, model, res, isStream) {
                         const data = trimmedLine.substring(6);
                         try {
                             if (!data.trim()) continue;
-                            if (data === "[DONE]") continue;
+                            if (data === "[DONE]") continue;                     
                             const linejosn = JSON.parse(data);
                             if (linejosn?.error) {
                                 Logger.error(JSON.stringify(linejosn, null, 2), 'Server');
@@ -813,7 +814,8 @@ app.post('/hf/v1/chat/completions', async (req, res) => {
         let retryCount = 0;
         const grokClient = new GrokApiClient(req.body.model);
         const requestPayload = await grokClient.prepareChatRequest(req.body);
-        Logger.info(`当前请求体: ${JSON.stringify(requestPayload,null,2)}`, 'Server');
+        Logger.info(`请求体: ${JSON.stringify(requestPayload,null,2)}`, 'Server');
+
         while (retryCount < CONFIG.RETRY.MAX_ATTEMPTS) {
             retryCount++;
             if (!CONFIG.API.TEMP_COOKIE) {
@@ -844,9 +846,15 @@ app.post('/hf/v1/chat/completions', async (req, res) => {
                     }
                 })
             });
-
-            const responseText = await newMessageReq.json();
-            const conversationId = responseText.conversationId;
+            let conversationId;
+            var responseText2 = await newMessageReq.clone().text();
+            if (newMessageReq.status === 200) {
+                const responseText = await newMessageReq.json();
+                conversationId = responseText.conversationId;
+            } else {
+                Logger.error(`创建会话请求: ${responseText2}`, 'Server');
+                throw new Error(`创建会话响应错误: ${responseText2}`);
+            }
 
             const response = await fetch(`${CONFIG.API.BASE_URL}/api/conversations/${conversationId}/responses`, {
                 method: 'POST',
@@ -915,10 +923,8 @@ app.post('/hf/v1/chat/completions', async (req, res) => {
         Logger.error(error, 'ChatAPI');
         res.status(500).json({
             error: {
-                message: error.message,
-                type: 'server_error',
-                param: null,
-                code: error.code || null
+                message: error.message || error,
+                type: 'server_error'
             }
         });
     }