diff --git a/src/providers/claude/claude-core.js b/src/providers/claude/claude-core.js index b5f7a72..2f84a48 100644 --- a/src/providers/claude/claude-core.js +++ b/src/providers/claude/claude-core.js @@ -226,6 +226,12 @@ export class ClaudeApiService { * @returns {Promise} Claude API response (Claude compatible format). */ async generateContent(model, requestBody) { + // 临时存储 monitorRequestId + if (requestBody._monitorRequestId) { + this.config._monitorRequestId = requestBody._monitorRequestId; + delete requestBody._monitorRequestId; + } + const response = await this.callApi('/messages', requestBody); return response; } diff --git a/src/providers/claude/claude-kiro.js b/src/providers/claude/claude-kiro.js index 02ce9f3..7616503 100644 --- a/src/providers/claude/claude-kiro.js +++ b/src/providers/claude/claude-kiro.js @@ -1669,6 +1669,7 @@ async saveCredentialsToFile(filePath, newData) { // 临时存储 monitorRequestId if (requestBody._monitorRequestId) { this.config._monitorRequestId = requestBody._monitorRequestId; + delete requestBody._monitorRequestId; } // 检查 token 是否即将过期,如果是则推送到刷新队列 @@ -2031,6 +2032,7 @@ async saveCredentialsToFile(filePath, newData) { // 临时存储 monitorRequestId if (requestBody._monitorRequestId) { this.config._monitorRequestId = requestBody._monitorRequestId; + delete requestBody._monitorRequestId; } // 检查 token 是否即将过期,如果是则推送到刷新队列 diff --git a/src/providers/forward/forward-core.js b/src/providers/forward/forward-core.js index b2405b8..4e0da66 100644 --- a/src/providers/forward/forward-core.js +++ b/src/providers/forward/forward-core.js @@ -144,12 +144,24 @@ export class ForwardApiService { } async generateContent(model, requestBody) { + // 临时存储 monitorRequestId + if (requestBody._monitorRequestId) { + this.config._monitorRequestId = requestBody._monitorRequestId; + delete requestBody._monitorRequestId; + } + // Transparently pass the endpoint if provided in requestBody, otherwise use default const endpoint = requestBody.endpoint || ''; return this.callApi(endpoint, requestBody); } async *generateContentStream(model, requestBody) { + // 临时存储 monitorRequestId + if (requestBody._monitorRequestId) { + this.config._monitorRequestId = requestBody._monitorRequestId; + delete requestBody._monitorRequestId; + } + const endpoint = requestBody.endpoint || ''; yield* this.streamApi(endpoint, requestBody); } diff --git a/src/providers/gemini/antigravity-core.js b/src/providers/gemini/antigravity-core.js index bbef8c0..db22bbb 100644 --- a/src/providers/gemini/antigravity-core.js +++ b/src/providers/gemini/antigravity-core.js @@ -1305,6 +1305,12 @@ export class AntigravityApiService { async generateContent(model, requestBody) { logger.info(`[Antigravity Auth Token] Time until expiry: ${formatExpiryTime(this.authClient.credentials.expiry_date)}`); + // 临时存储 monitorRequestId + if (requestBody._monitorRequestId) { + this.config._monitorRequestId = requestBody._monitorRequestId; + delete requestBody._monitorRequestId; + } + // 检查 token 是否即将过期,如果是则推送到刷新队列 if (this.isExpiryDateNear()) { const poolManager = getProviderPoolManager(); @@ -1372,6 +1378,12 @@ export class AntigravityApiService { async * generateContentStream(model, requestBody) { logger.info(`[Antigravity Auth Token] Time until expiry: ${formatExpiryTime(this.authClient.credentials.expiry_date)}`); + // 临时存储 monitorRequestId + if (requestBody._monitorRequestId) { + this.config._monitorRequestId = requestBody._monitorRequestId; + delete requestBody._monitorRequestId; + } + // 检查 token 是否即将过期,如果是则推送到刷新队列 if (this.isExpiryDateNear()) { const poolManager = getProviderPoolManager(); diff --git a/src/providers/gemini/gemini-core.js b/src/providers/gemini/gemini-core.js index 14a3d41..6d2614f 100644 --- a/src/providers/gemini/gemini-core.js +++ b/src/providers/gemini/gemini-core.js @@ -640,6 +640,12 @@ export class GeminiApiService { async generateContent(model, requestBody) { logger.info(`[Auth Token] Time until expiry: ${formatExpiryTime(this.authClient.credentials.expiry_date)}`); + // 临时存储 monitorRequestId + if (requestBody._monitorRequestId) { + this.config._monitorRequestId = requestBody._monitorRequestId; + delete requestBody._monitorRequestId; + } + // 检查 token 是否即将过期,如果是则推送到刷新队列 if (this.isExpiryDateNear()) { const poolManager = getProviderPoolManager(); @@ -665,6 +671,12 @@ export class GeminiApiService { async * generateContentStream(model, requestBody) { logger.info(`[Auth Token] Time until expiry: ${formatExpiryTime(this.authClient.credentials.expiry_date)}`); + // 临时存储 monitorRequestId + if (requestBody._monitorRequestId) { + this.config._monitorRequestId = requestBody._monitorRequestId; + delete requestBody._monitorRequestId; + } + // 检查 token 是否即将过期,如果是则推送到刷新队列 if (this.isExpiryDateNear()) { const poolManager = getProviderPoolManager(); diff --git a/src/providers/openai/codex-core.js b/src/providers/openai/codex-core.js index fb1930e..74b0a50 100644 --- a/src/providers/openai/codex-core.js +++ b/src/providers/openai/codex-core.js @@ -129,6 +129,12 @@ export class CodexApiService { await this.initialize(); } + // 临时存储 monitorRequestId + if (requestBody._monitorRequestId) { + this.config._monitorRequestId = requestBody._monitorRequestId; + delete requestBody._monitorRequestId; + } + // 检查 token 是否即将过期,如果是则推送到刷新队列 if (this.isExpiryDateNear()) { const poolManager = getProviderPoolManager(); @@ -191,6 +197,12 @@ export class CodexApiService { await this.initialize(); } + // 临时存储 monitorRequestId + if (requestBody._monitorRequestId) { + this.config._monitorRequestId = requestBody._monitorRequestId; + delete requestBody._monitorRequestId; + } + // 检查 token 是否即将过期,如果是则推送到刷新队列 if (this.isExpiryDateNear()) { const poolManager = getProviderPoolManager(); diff --git a/src/providers/openai/iflow-core.js b/src/providers/openai/iflow-core.js index a4c0df3..31d5d89 100644 --- a/src/providers/openai/iflow-core.js +++ b/src/providers/openai/iflow-core.js @@ -997,6 +997,12 @@ export class IFlowApiService { if (!this.isInitialized) { await this.initialize(); } + + // 临时存储 monitorRequestId + if (requestBody._monitorRequestId) { + this.config._monitorRequestId = requestBody._monitorRequestId; + delete requestBody._monitorRequestId; + } // 检查 token 是否即将过期,如果是则推送到刷新队列 if (this.isExpiryDateNear()) { @@ -1019,6 +1025,12 @@ export class IFlowApiService { if (!this.isInitialized) { await this.initialize(); } + + // 临时存储 monitorRequestId + if (requestBody._monitorRequestId) { + this.config._monitorRequestId = requestBody._monitorRequestId; + delete requestBody._monitorRequestId; + } // 检查 token 是否即将过期,如果是则推送到刷新队列 if (this.isExpiryDateNear()) { diff --git a/src/providers/openai/openai-core.js b/src/providers/openai/openai-core.js index fbf7afb..065320f 100644 --- a/src/providers/openai/openai-core.js +++ b/src/providers/openai/openai-core.js @@ -189,10 +189,22 @@ export class OpenAIApiService { } async generateContent(model, requestBody) { + // 临时存储 monitorRequestId + if (requestBody._monitorRequestId) { + this.config._monitorRequestId = requestBody._monitorRequestId; + delete requestBody._monitorRequestId; + } + return this.callApi('/chat/completions', requestBody); } async *generateContentStream(model, requestBody) { + // 临时存储 monitorRequestId + if (requestBody._monitorRequestId) { + this.config._monitorRequestId = requestBody._monitorRequestId; + delete requestBody._monitorRequestId; + } + yield* this.streamApi('/chat/completions', requestBody); } diff --git a/src/providers/openai/openai-responses-core.js b/src/providers/openai/openai-responses-core.js index cbec8f4..bca7a03 100644 --- a/src/providers/openai/openai-responses-core.js +++ b/src/providers/openai/openai-responses-core.js @@ -157,10 +157,22 @@ export class OpenAIResponsesApiService { } async generateContent(model, requestBody) { + // 临时存储 monitorRequestId + if (requestBody._monitorRequestId) { + this.config._monitorRequestId = requestBody._monitorRequestId; + delete requestBody._monitorRequestId; + } + return this.callApi('/responses', requestBody); } async *generateContentStream(model, requestBody) { + // 临时存储 monitorRequestId + if (requestBody._monitorRequestId) { + this.config._monitorRequestId = requestBody._monitorRequestId; + delete requestBody._monitorRequestId; + } + yield* this.streamApi('/responses', requestBody); } diff --git a/src/providers/openai/qwen-core.js b/src/providers/openai/qwen-core.js index 753abca..a6bf582 100644 --- a/src/providers/openai/qwen-core.js +++ b/src/providers/openai/qwen-core.js @@ -651,6 +651,12 @@ export class QwenApiService { } async generateContent(model, requestBody) { + // 临时存储 monitorRequestId + if (requestBody._monitorRequestId) { + this.config._monitorRequestId = requestBody._monitorRequestId; + delete requestBody._monitorRequestId; + } + // 检查 token 是否即将过期,如果是则推送到刷新队列 if (this.isExpiryDateNear()) { const poolManager = getProviderPoolManager(); @@ -666,6 +672,12 @@ export class QwenApiService { } async *generateContentStream(model, requestBody) { + // 临时存储 monitorRequestId + if (requestBody._monitorRequestId) { + this.config._monitorRequestId = requestBody._monitorRequestId; + delete requestBody._monitorRequestId; + } + // 检查 token 是否即将过期,如果是则推送到刷新队列 if (this.isExpiryDateNear()) { const poolManager = getProviderPoolManager();