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'