Spaces:
Paused
Paused
Update index.js
Browse files
index.js
CHANGED
|
@@ -107,6 +107,8 @@ class TokenManager {
|
|
| 107 |
if (wafToken) {
|
| 108 |
Tokens[currentIndex].aws_waf_token = wafToken;
|
| 109 |
await this.updateCacheTokens();
|
|
|
|
|
|
|
| 110 |
this.updateRedisTokens();
|
| 111 |
console.log("更新成功",)
|
| 112 |
return;
|
|
@@ -514,26 +516,29 @@ app.post('/hf/v1/chat/completions', async (req, res) => {
|
|
| 514 |
},
|
| 515 |
body: JSON.stringify(requestPayload)
|
| 516 |
});
|
|
|
|
|
|
|
| 517 |
reqStatus = response.status;
|
| 518 |
switch (reqStatus) {
|
| 519 |
case 200:
|
| 520 |
console.log("请求成功");
|
| 521 |
-
// 异步更新token
|
| 522 |
-
tokenManager.updateTokens(response)
|
| 523 |
// 处理响应
|
| 524 |
if (req.body.stream) {
|
| 525 |
await ResponseHandler.handleStreamResponse(response, req.body.model, res);
|
| 526 |
} else {
|
| 527 |
await ResponseHandler.handleNormalResponse(response, req.body.model, res);
|
| 528 |
}
|
|
|
|
| 529 |
return;
|
| 530 |
case 202:
|
| 531 |
console.log("请求受限,更新WAF");
|
| 532 |
await tokenManager.updateTokens(response, true);
|
| 533 |
break;
|
| 534 |
default:
|
|
|
|
| 535 |
throw new Error(`请求失败! status: ${response.status}`);
|
| 536 |
}
|
|
|
|
| 537 |
retryCount++;
|
| 538 |
if (retryCount >= CONFIG.RETRY.MAX_ATTEMPTS) {
|
| 539 |
throw new Error(`上游服务请求失败! status: ${response.status}`);
|
|
|
|
| 107 |
if (wafToken) {
|
| 108 |
Tokens[currentIndex].aws_waf_token = wafToken;
|
| 109 |
await this.updateCacheTokens();
|
| 110 |
+
console.log("更新后的token",JSON.stringify(Tokens[currentIndex],null,2));
|
| 111 |
+
console.log("更新后cookie",CONFIG.DEFAULT_HEADERS.Cookie);
|
| 112 |
this.updateRedisTokens();
|
| 113 |
console.log("更新成功",)
|
| 114 |
return;
|
|
|
|
| 516 |
},
|
| 517 |
body: JSON.stringify(requestPayload)
|
| 518 |
});
|
| 519 |
+
console.log("请求的头部",JSON.stringify(CONFIG.DEFAULT_HEADERS,null,2));
|
| 520 |
+
|
| 521 |
reqStatus = response.status;
|
| 522 |
switch (reqStatus) {
|
| 523 |
case 200:
|
| 524 |
console.log("请求成功");
|
|
|
|
|
|
|
| 525 |
// 处理响应
|
| 526 |
if (req.body.stream) {
|
| 527 |
await ResponseHandler.handleStreamResponse(response, req.body.model, res);
|
| 528 |
} else {
|
| 529 |
await ResponseHandler.handleNormalResponse(response, req.body.model, res);
|
| 530 |
}
|
| 531 |
+
await tokenManager.updateTokens(response);
|
| 532 |
return;
|
| 533 |
case 202:
|
| 534 |
console.log("请求受限,更新WAF");
|
| 535 |
await tokenManager.updateTokens(response, true);
|
| 536 |
break;
|
| 537 |
default:
|
| 538 |
+
console.log(await response.text());
|
| 539 |
throw new Error(`请求失败! status: ${response.status}`);
|
| 540 |
}
|
| 541 |
+
console.log("请求失败,重试中...");
|
| 542 |
retryCount++;
|
| 543 |
if (retryCount >= CONFIG.RETRY.MAX_ATTEMPTS) {
|
| 544 |
throw new Error(`上游服务请求失败! status: ${response.status}`);
|