mirror of
https://github.com/Wei-Shaw/claude-relay-service.git
synced 2026-01-23 09:38:02 +00:00
style: 修复 Prettier 格式问题
- 格式化 src/app.js - 格式化 src/services/claudeConsoleRelayService.js - 格式化 src/services/claudeRelayService.js
This commit is contained in:
@@ -537,7 +537,7 @@ class Application {
|
|||||||
logger.info(
|
logger.info(
|
||||||
`🔄 Cleanup tasks scheduled every ${config.system.cleanupInterval / 1000 / 60} minutes`
|
`🔄 Cleanup tasks scheduled every ${config.system.cleanupInterval / 1000 / 60} minutes`
|
||||||
)
|
)
|
||||||
|
|
||||||
// 🚨 启动限流状态自动清理服务
|
// 🚨 启动限流状态自动清理服务
|
||||||
// 每5分钟检查一次过期的限流状态,确保账号能及时恢复调度
|
// 每5分钟检查一次过期的限流状态,确保账号能及时恢复调度
|
||||||
const rateLimitCleanupService = require('./services/rateLimitCleanupService')
|
const rateLimitCleanupService = require('./services/rateLimitCleanupService')
|
||||||
@@ -563,7 +563,7 @@ class Application {
|
|||||||
} catch (error) {
|
} catch (error) {
|
||||||
logger.error('❌ Error cleaning up pricing service:', error)
|
logger.error('❌ Error cleaning up pricing service:', error)
|
||||||
}
|
}
|
||||||
|
|
||||||
// 停止限流清理服务
|
// 停止限流清理服务
|
||||||
try {
|
try {
|
||||||
const rateLimitCleanupService = require('./services/rateLimitCleanupService')
|
const rateLimitCleanupService = require('./services/rateLimitCleanupService')
|
||||||
|
|||||||
@@ -222,7 +222,10 @@ class ClaudeConsoleRelayService {
|
|||||||
throw new Error('Client disconnected')
|
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账号
|
// 不再因为模型不支持而block账号
|
||||||
|
|
||||||
@@ -297,7 +300,10 @@ class ClaudeConsoleRelayService {
|
|||||||
// 更新最后使用时间
|
// 更新最后使用时间
|
||||||
await this._updateLastUsedTime(accountId)
|
await this._updateLastUsedTime(accountId)
|
||||||
} catch (error) {
|
} 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
|
throw error
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -376,7 +382,9 @@ class ClaudeConsoleRelayService {
|
|||||||
|
|
||||||
// 错误响应处理
|
// 错误响应处理
|
||||||
if (response.status !== 200) {
|
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) {
|
if (response.status === 401) {
|
||||||
claudeConsoleAccountService.markAccountUnauthorized(accountId)
|
claudeConsoleAccountService.markAccountUnauthorized(accountId)
|
||||||
@@ -528,7 +536,10 @@ class ClaudeConsoleRelayService {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
} catch (error) {
|
} 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) {
|
if (!responseStream.destroyed) {
|
||||||
responseStream.write('event: error\n')
|
responseStream.write('event: error\n')
|
||||||
responseStream.write(
|
responseStream.write(
|
||||||
@@ -570,7 +581,10 @@ class ClaudeConsoleRelayService {
|
|||||||
})
|
})
|
||||||
|
|
||||||
response.data.on('error', (error) => {
|
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) {
|
if (!responseStream.destroyed) {
|
||||||
responseStream.write('event: error\n')
|
responseStream.write('event: error\n')
|
||||||
responseStream.write(
|
responseStream.write(
|
||||||
@@ -590,7 +604,10 @@ class ClaudeConsoleRelayService {
|
|||||||
return
|
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) {
|
if (error.response) {
|
||||||
|
|||||||
@@ -1015,7 +1015,9 @@ class ClaudeRelayService {
|
|||||||
logger.error('❌ Error in stream error handler:', err)
|
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 = ''
|
let errorData = ''
|
||||||
|
|
||||||
res.on('data', (chunk) => {
|
res.on('data', (chunk) => {
|
||||||
@@ -1024,7 +1026,10 @@ class ClaudeRelayService {
|
|||||||
|
|
||||||
res.on('end', () => {
|
res.on('end', () => {
|
||||||
console.error(': ❌ ', errorData)
|
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) {
|
if (!responseStream.destroyed) {
|
||||||
// 发送错误事件
|
// 发送错误事件
|
||||||
responseStream.write('event: error\n')
|
responseStream.write('event: error\n')
|
||||||
@@ -1343,11 +1348,15 @@ class ClaudeRelayService {
|
|||||||
})
|
})
|
||||||
|
|
||||||
req.on('error', async (error) => {
|
req.on('error', async (error) => {
|
||||||
logger.error(`❌ Claude stream request error (Account: ${account?.name || accountId}):`, error.message, {
|
logger.error(
|
||||||
code: error.code,
|
`❌ Claude stream request error (Account: ${account?.name || accountId}):`,
|
||||||
errno: error.errno,
|
error.message,
|
||||||
syscall: error.syscall
|
{
|
||||||
})
|
code: error.code,
|
||||||
|
errno: error.errno,
|
||||||
|
syscall: error.syscall
|
||||||
|
}
|
||||||
|
)
|
||||||
|
|
||||||
// 根据错误类型提供更具体的错误信息
|
// 根据错误类型提供更具体的错误信息
|
||||||
let errorMessage = 'Upstream request failed'
|
let errorMessage = 'Upstream request failed'
|
||||||
@@ -1493,11 +1502,15 @@ class ClaudeRelayService {
|
|||||||
})
|
})
|
||||||
|
|
||||||
req.on('error', async (error) => {
|
req.on('error', async (error) => {
|
||||||
logger.error(`❌ Claude stream request error (Account: ${account?.name || accountId}):`, error.message, {
|
logger.error(
|
||||||
code: error.code,
|
`❌ Claude stream request error (Account: ${account?.name || accountId}):`,
|
||||||
errno: error.errno,
|
error.message,
|
||||||
syscall: error.syscall
|
{
|
||||||
})
|
code: error.code,
|
||||||
|
errno: error.errno,
|
||||||
|
syscall: error.syscall
|
||||||
|
}
|
||||||
|
)
|
||||||
|
|
||||||
// 根据错误类型提供更具体的错误信息
|
// 根据错误类型提供更具体的错误信息
|
||||||
let errorMessage = 'Upstream request failed'
|
let errorMessage = 'Upstream request failed'
|
||||||
|
|||||||
Reference in New Issue
Block a user