Update index.js

index.js

@@ -185,7 +185,7 @@ class WebSocketUtils {
     static async createWebSocketClient(requestPayload) {
         // 检查当前连接数是否达到上限
         if (this.activeConnections.size >= this.MAX_CONNECTIONS) {
-            throw new Error(`当前连接数已达到上限 (${this.MAX_CONNECTIONS})，请稍后重试！`);
+            throw new Error(`当前连接数已达到上限 (${this.MAX_CONNECTIONS})，请稍后重试喵！`);
         }
 
         let timeoutId;
@@ -258,7 +258,8 @@ class WebSocketUtils {
                         case 'error':
                             console.error('WebSocket错误:', parsedMessage.payload[0].message);
                             ws.close();
-                            throw new Error(`WebSocket错误: ${parsedMessage.payload[0].message}`);
+                            reject(new Error(`WebSocket错误: ${parsedMessage.payload[0].message}`));
+                            break;
                     }
                 });
 
@@ -270,7 +271,7 @@ class WebSocketUtils {
                     if (ws.readyState === WebSocket.OPEN) {
                         ws.close();
                     }
-                    throw new Error(`WebSocket错误: ${err}`);
+                    reject(err);
                 });
 
                 ws.on('close', (code, reason) => {
@@ -279,7 +280,7 @@ class WebSocketUtils {
                     this.activeConnections.delete(ws);
                     console.log(`连接关闭，当前活跃连接数: ${this.activeConnections.size}/${this.MAX_CONNECTIONS}`);
                     if (!isComplete) {
-                        throw new Error('WebSocket closed unexpectedly');
+                        reject(new Error('WebSocket closed unexpectedly'));
                     }
                 });
             });
@@ -365,6 +366,7 @@ app.use(cors({
   allowedHeaders: ['Content-Type', 'Authorization']
 }));
 
+
 // 获取模型列表路由
 app.get('/hf/v1/models', (req, res) => {
   res.json({
@@ -405,7 +407,7 @@ app.post('/hf/v1/chat/completions', async (req, res) => {
       }
   } catch (error) {
       console.error('处理请求时发生错误:', error);
-      res.status(500).json({ error: "内部服务器错误", details: error.message });
+      res.status(500).json({ error: "内部服务器错误，请查询日志记录！", details: error.message });
   }
 });