Spaces:
Paused
Paused
Update index.js
Browse files
index.js
CHANGED
|
@@ -636,12 +636,12 @@ app.post('/hf/v1/chat/completions', async (req, res) => {
|
|
| 636 |
|
| 637 |
if (response.ok) {
|
| 638 |
Logger.info(`请求成功`, 'Server');
|
| 639 |
-
CONFIG.SIGNATURE_INDEX = (CONFIG.SIGNATURE_INDEX + 1) % tokenManager.getTokenCount();
|
| 640 |
Logger.info(`当前剩余可用令牌数: ${tokenManager.getTokenCount()}`, 'Server');
|
| 641 |
try {
|
| 642 |
await (req.body.stream
|
| 643 |
? ResponseHandler.handleStreamResponse(response, req.body.model, res)
|
| 644 |
: ResponseHandler.handleNormalResponse(response, req.body.model, res));
|
|
|
|
| 645 |
return; // 成功后直接返回
|
| 646 |
} catch (error) {
|
| 647 |
tokenManager.removeTokenByIndex(CONFIG.SIGNATURE_INDEX);
|
|
@@ -659,11 +659,10 @@ app.post('/hf/v1/chat/completions', async (req, res) => {
|
|
| 659 |
if (!tokenManager.isRecoveryProcess) {
|
| 660 |
tokenManager.startTokenRecoveryProcess();
|
| 661 |
}
|
| 662 |
-
Logger.warn(`当前令牌失效,已移除令牌,剩余令牌数: ${tokenManager.getTokenCount()}`, 'Server');
|
| 663 |
-
// 更新签名索引
|
| 664 |
CONFIG.SIGNATURE_INDEX = (CONFIG.SIGNATURE_INDEX + 1) % tokenManager.getTokenCount();
|
| 665 |
-
Logger.warn(
|
| 666 |
} else {
|
|
|
|
| 667 |
// 非429错误直接抛出
|
| 668 |
throw new Error(`上游服务请求失败! status: ${response.status}`);
|
| 669 |
}
|
|
@@ -672,8 +671,8 @@ app.post('/hf/v1/chat/completions', async (req, res) => {
|
|
| 672 |
|
| 673 |
// 如果重试次数用完仍然是429
|
| 674 |
throw new Error('所有令牌都已耗尽,请求被限流');
|
| 675 |
-
|
| 676 |
} catch (error) {
|
|
|
|
| 677 |
Logger.error('Chat Completions Request Error', error, 'ChatAPI');
|
| 678 |
res.status(500).json({
|
| 679 |
error: {
|
|
|
|
| 636 |
|
| 637 |
if (response.ok) {
|
| 638 |
Logger.info(`请求成功`, 'Server');
|
|
|
|
| 639 |
Logger.info(`当前剩余可用令牌数: ${tokenManager.getTokenCount()}`, 'Server');
|
| 640 |
try {
|
| 641 |
await (req.body.stream
|
| 642 |
? ResponseHandler.handleStreamResponse(response, req.body.model, res)
|
| 643 |
: ResponseHandler.handleNormalResponse(response, req.body.model, res));
|
| 644 |
+
CONFIG.SIGNATURE_INDEX = (CONFIG.SIGNATURE_INDEX + 1) % tokenManager.getTokenCount();
|
| 645 |
return; // 成功后直接返回
|
| 646 |
} catch (error) {
|
| 647 |
tokenManager.removeTokenByIndex(CONFIG.SIGNATURE_INDEX);
|
|
|
|
| 659 |
if (!tokenManager.isRecoveryProcess) {
|
| 660 |
tokenManager.startTokenRecoveryProcess();
|
| 661 |
}
|
|
|
|
|
|
|
| 662 |
CONFIG.SIGNATURE_INDEX = (CONFIG.SIGNATURE_INDEX + 1) % tokenManager.getTokenCount();
|
| 663 |
+
Logger.warn(`当前令牌失效,已移除令牌,剩余令牌数: ${tokenManager.getTokenCount()}`, 'Server');
|
| 664 |
} else {
|
| 665 |
+
CONFIG.SIGNATURE_INDEX = (CONFIG.SIGNATURE_INDEX + 1) % tokenManager.getTokenCount();
|
| 666 |
// 非429错误直接抛出
|
| 667 |
throw new Error(`上游服务请求失败! status: ${response.status}`);
|
| 668 |
}
|
|
|
|
| 671 |
|
| 672 |
// 如果重试次数用完仍然是429
|
| 673 |
throw new Error('所有令牌都已耗尽,请求被限流');
|
|
|
|
| 674 |
} catch (error) {
|
| 675 |
+
CONFIG.SIGNATURE_INDEX = (CONFIG.SIGNATURE_INDEX + 1) % tokenManager.getTokenCount();
|
| 676 |
Logger.error('Chat Completions Request Error', error, 'ChatAPI');
|
| 677 |
res.status(500).json({
|
| 678 |
error: {
|