From 52820a7e49789142c89a4e8143bfdc1c26153eed Mon Sep 17 00:00:00 2001 From: Edric Li Date: Tue, 9 Sep 2025 04:14:27 +0800 Subject: [PATCH] =?UTF-8?q?style:=20=E4=BF=AE=E5=A4=8D=20Prettier=20?= =?UTF-8?q?=E6=A0=BC=E5=BC=8F=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 格式化 src/app.js - 格式化 src/services/claudeConsoleRelayService.js - 格式化 src/services/claudeRelayService.js --- src/app.js | 4 +-- src/services/claudeConsoleRelayService.js | 29 ++++++++++++++---- src/services/claudeRelayService.js | 37 +++++++++++++++-------- 3 files changed, 50 insertions(+), 20 deletions(-) diff --git a/src/app.js b/src/app.js index 67f26bfe..a1f06b36 100644 --- a/src/app.js +++ b/src/app.js @@ -537,7 +537,7 @@ class Application { logger.info( `🔄 Cleanup tasks scheduled every ${config.system.cleanupInterval / 1000 / 60} minutes` ) - + // 🚨 启动限流状态自动清理服务 // 每5分钟检查一次过期的限流状态，确保账号能及时恢复调度 const rateLimitCleanupService = require('./services/rateLimitCleanupService') @@ -563,7 +563,7 @@ class Application { } catch (error) { logger.error('❌ Error cleaning up pricing service:', error) } - + // 停止限流清理服务 try { const rateLimitCleanupService = require('./services/rateLimitCleanupService') diff --git a/src/services/claudeConsoleRelayService.js b/src/services/claudeConsoleRelayService.js index 1e040ee9..6a88166d 100644 --- a/src/services/claudeConsoleRelayService.js +++ b/src/services/claudeConsoleRelayService.js @@ -222,7 +222,10 @@ class ClaudeConsoleRelayService { throw new Error('Client disconnected') } - logger.error(`❌ Claude Console relay request failed (Account: ${account?.name || accountId}):`, error.message) + logger.error( + `❌ Claude Console relay request failed (Account: ${account?.name || accountId}):`, + error.message + ) // 不再因为模型不支持而block账号 @@ -297,7 +300,10 @@ class ClaudeConsoleRelayService { // 更新最后使用时间 await this._updateLastUsedTime(accountId) } catch (error) { - logger.error(`❌ Claude Console stream relay failed (Account: ${account?.name || accountId}):`, error) + logger.error( + `❌ Claude Console stream relay failed (Account: ${account?.name || accountId}):`, + error + ) throw error } } @@ -376,7 +382,9 @@ class ClaudeConsoleRelayService { // 错误响应处理 if (response.status !== 200) { - logger.error(`❌ Claude Console API returned error status: ${response.status} | Account: ${account?.name || accountId}`) + logger.error( + `❌ Claude Console API returned error status: ${response.status} | Account: ${account?.name || accountId}` + ) if (response.status === 401) { claudeConsoleAccountService.markAccountUnauthorized(accountId) @@ -528,7 +536,10 @@ class ClaudeConsoleRelayService { } } } catch (error) { - logger.error(`❌ Error processing Claude Console stream data (Account: ${account?.name || accountId}):`, error) + logger.error( + `❌ Error processing Claude Console stream data (Account: ${account?.name || accountId}):`, + error + ) if (!responseStream.destroyed) { responseStream.write('event: error\n') responseStream.write( @@ -570,7 +581,10 @@ class ClaudeConsoleRelayService { }) response.data.on('error', (error) => { - logger.error(`❌ Claude Console stream error (Account: ${account?.name || accountId}):`, error) + logger.error( + `❌ Claude Console stream error (Account: ${account?.name || accountId}):`, + error + ) if (!responseStream.destroyed) { responseStream.write('event: error\n') responseStream.write( @@ -590,7 +604,10 @@ class ClaudeConsoleRelayService { return } - logger.error(`❌ Claude Console stream request error (Account: ${account?.name || accountId}):`, error.message) + logger.error( + `❌ Claude Console stream request error (Account: ${account?.name || accountId}):`, + error.message + ) // 检查错误状态 if (error.response) { diff --git a/src/services/claudeRelayService.js b/src/services/claudeRelayService.js index 577c6236..658391b8 100644 --- a/src/services/claudeRelayService.js +++ b/src/services/claudeRelayService.js @@ -1015,7 +1015,9 @@ class ClaudeRelayService { logger.error('❌ Error in stream error handler:', err) }) - logger.error(`❌ Claude API returned error status: ${res.statusCode} | Account: ${account?.name || accountId}`) + logger.error( + `❌ Claude API returned error status: ${res.statusCode} | Account: ${account?.name || accountId}` + ) let errorData = '' res.on('data', (chunk) => { @@ -1024,7 +1026,10 @@ class ClaudeRelayService { res.on('end', () => { console.error(': ❌ ', errorData) - logger.error(`❌ Claude API error response (Account: ${account?.name || accountId}):`, errorData) + logger.error( + `❌ Claude API error response (Account: ${account?.name || accountId}):`, + errorData + ) if (!responseStream.destroyed) { // 发送错误事件 responseStream.write('event: error\n') @@ -1343,11 +1348,15 @@ class ClaudeRelayService { }) req.on('error', async (error) => { - logger.error(`❌ Claude stream request error (Account: ${account?.name || accountId}):`, error.message, { - code: error.code, - errno: error.errno, - syscall: error.syscall - }) + logger.error( + `❌ Claude stream request error (Account: ${account?.name || accountId}):`, + error.message, + { + code: error.code, + errno: error.errno, + syscall: error.syscall + } + ) // 根据错误类型提供更具体的错误信息 let errorMessage = 'Upstream request failed' @@ -1493,11 +1502,15 @@ class ClaudeRelayService { }) req.on('error', async (error) => { - logger.error(`❌ Claude stream request error (Account: ${account?.name || accountId}):`, error.message, { - code: error.code, - errno: error.errno, - syscall: error.syscall - }) + logger.error( + `❌ Claude stream request error (Account: ${account?.name || accountId}):`, + error.message, + { + code: error.code, + errno: error.errno, + syscall: error.syscall + } + ) // 根据错误类型提供更具体的错误信息 let errorMessage = 'Upstream request failed'