feat(logging): add SetTranslatedReasoningEffort to track reasoning levels in usage reporting

luispater · luispater · commit 11f0f906bd68 · 2026-05-28T02:19:45.000+08:00
- Introduced `SetTranslatedReasoningEffort` method in `UsageReporter` to capture and log reasoning efforts from translated payloads.
- Updated executors to incorporate the new reporting functionality for handling reasoning efforts across various providers.
- Enhanced logging for thinking level extraction with new helper function `ExtractTranslatedReasoningEffort`.
diff --git a/internal/runtime/executor/aistudio_executor.go b/internal/runtime/executor/aistudio_executor.go
@@ -135,6 +135,7 @@ func (e *AIStudioExecutor) Execute(ctx context.Context, auth *cliproxyauth.Auth,
 	if err != nil {
 		return resp, err
 	}
+	reporter.SetTranslatedReasoningEffort(body.payload, body.toFormat.String())
 
 	endpoint := e.buildEndpoint(baseModel, body.action, opts.Alt)
 	wsReq := &wsrelay.HTTPRequest{
@@ -199,6 +200,7 @@ func (e *AIStudioExecutor) ExecuteStream(ctx context.Context, auth *cliproxyauth
 	if err != nil {
 		return nil, err
 	}
+	reporter.SetTranslatedReasoningEffort(body.payload, body.toFormat.String())
 
 	endpoint := e.buildEndpoint(baseModel, body.action, opts.Alt)
 	wsReq := &wsrelay.HTTPRequest{
diff --git a/internal/runtime/executor/antigravity_executor.go b/internal/runtime/executor/antigravity_executor.go
@@ -523,6 +523,7 @@ func (e *AntigravityExecutor) Execute(ctx context.Context, auth *cliproxyauth.Au
 	requestedModel := helps.PayloadRequestedModel(opts, req.Model)
 	requestPath := helps.PayloadRequestPath(opts)
 	translated = helps.ApplyPayloadConfigWithRequest(e.cfg, baseModel, "antigravity", from.String(), "request", translated, originalTranslated, requestedModel, requestPath, opts.Headers)
+	reporter.SetTranslatedReasoningEffort(translated, to.String())
 
 	useCredits := cliproxyauth.AntigravityCreditsRequested(ctx) && antigravityCreditsRetryEnabled(e.cfg)
 
@@ -721,6 +722,7 @@ func (e *AntigravityExecutor) executeClaudeNonStream(ctx context.Context, auth *
 	requestedModel := helps.PayloadRequestedModel(opts, req.Model)
 	requestPath := helps.PayloadRequestPath(opts)
 	translated = helps.ApplyPayloadConfigWithRequest(e.cfg, baseModel, "antigravity", from.String(), "request", translated, originalTranslated, requestedModel, requestPath, opts.Headers)
+	reporter.SetTranslatedReasoningEffort(translated, to.String())
 
 	useCredits := cliproxyauth.AntigravityCreditsRequested(ctx) && antigravityCreditsRetryEnabled(e.cfg)
 
@@ -1182,6 +1184,7 @@ func (e *AntigravityExecutor) ExecuteStream(ctx context.Context, auth *cliproxya
 	requestedModel := helps.PayloadRequestedModel(opts, req.Model)
 	requestPath := helps.PayloadRequestPath(opts)
 	translated = helps.ApplyPayloadConfigWithRequest(e.cfg, baseModel, "antigravity", from.String(), "request", translated, originalTranslated, requestedModel, requestPath, opts.Headers)
+	reporter.SetTranslatedReasoningEffort(translated, to.String())
 
 	useCredits := cliproxyauth.AntigravityCreditsRequested(ctx) && antigravityCreditsRetryEnabled(e.cfg)
 
diff --git a/internal/runtime/executor/claude_executor.go b/internal/runtime/executor/claude_executor.go
@@ -200,6 +200,7 @@ func (e *ClaudeExecutor) Execute(ctx context.Context, auth *cliproxyauth.Auth, r
 	if oauthToken || experimentalCCHSigningEnabled(e.cfg, auth) {
 		bodyForUpstream = signAnthropicMessagesBody(bodyForUpstream)
 	}
+	reporter.SetTranslatedReasoningEffort(bodyForUpstream, to.String())
 
 	url := fmt.Sprintf("%s/v1/messages?beta=true", baseURL)
 	httpReq, err := http.NewRequestWithContext(ctx, http.MethodPost, url, bytes.NewReader(bodyForUpstream))
@@ -374,6 +375,7 @@ func (e *ClaudeExecutor) ExecuteStream(ctx context.Context, auth *cliproxyauth.A
 	if oauthToken || experimentalCCHSigningEnabled(e.cfg, auth) {
 		bodyForUpstream = signAnthropicMessagesBody(bodyForUpstream)
 	}
+	reporter.SetTranslatedReasoningEffort(bodyForUpstream, to.String())
 
 	url := fmt.Sprintf("%s/v1/messages?beta=true", baseURL)
 	httpReq, err := http.NewRequestWithContext(ctx, http.MethodPost, url, bytes.NewReader(bodyForUpstream))
diff --git a/internal/runtime/executor/codex_executor.go b/internal/runtime/executor/codex_executor.go
@@ -285,6 +285,7 @@ func (e *CodexExecutor) Execute(ctx context.Context, auth *cliproxyauth.Auth, re
 	if e.cfg == nil || e.cfg.DisableImageGeneration == config.DisableImageGenerationOff {
 		body = ensureImageGenerationTool(body, baseModel, auth)
 	}
+	reporter.SetTranslatedReasoningEffort(body, to.String())
 
 	url := strings.TrimSuffix(baseURL, "/") + "/responses"
 	httpReq, err := e.cacheHelper(ctx, from, url, req, body)
@@ -441,6 +442,7 @@ func (e *CodexExecutor) executeCompact(ctx context.Context, auth *cliproxyauth.A
 	if e.cfg == nil || e.cfg.DisableImageGeneration == config.DisableImageGenerationOff {
 		body = ensureImageGenerationTool(body, baseModel, auth)
 	}
+	reporter.SetTranslatedReasoningEffort(body, to.String())
 
 	url := strings.TrimSuffix(baseURL, "/") + "/responses/compact"
 	httpReq, err := e.cacheHelper(ctx, from, url, req, body)
@@ -542,6 +544,7 @@ func (e *CodexExecutor) ExecuteStream(ctx context.Context, auth *cliproxyauth.Au
 	if e.cfg == nil || e.cfg.DisableImageGeneration == config.DisableImageGenerationOff {
 		body = ensureImageGenerationTool(body, baseModel, auth)
 	}
+	reporter.SetTranslatedReasoningEffort(body, to.String())
 
 	url := strings.TrimSuffix(baseURL, "/") + "/responses"
 	httpReq, err := e.cacheHelper(ctx, from, url, req, body)
diff --git a/internal/runtime/executor/codex_openai_images.go b/internal/runtime/executor/codex_openai_images.go
@@ -96,6 +96,7 @@ func (e *CodexExecutor) executeOpenAIImage(ctx context.Context, auth *cliproxyau
 	if errBuild != nil {
 		return resp, errBuild
 	}
+	reporter.SetTranslatedReasoningEffort(body, "codex")
 
 	url := strings.TrimSuffix(baseURL, "/") + "/responses"
 	httpReq, errCache := e.cacheHelper(ctx, sdktranslator.FromString(codexOpenAIImageSourceFormat), url, req, body)
@@ -184,6 +185,7 @@ func (e *CodexExecutor) executeOpenAIImageStream(ctx context.Context, auth *clip
 	if errBuild != nil {
 		return nil, errBuild
 	}
+	reporter.SetTranslatedReasoningEffort(body, "codex")
 
 	url := strings.TrimSuffix(baseURL, "/") + "/responses"
 	httpReq, errCache := e.cacheHelper(ctx, sdktranslator.FromString(codexOpenAIImageSourceFormat), url, req, body)
diff --git a/internal/runtime/executor/codex_websockets_executor.go b/internal/runtime/executor/codex_websockets_executor.go
@@ -221,6 +221,7 @@ func (e *CodexWebsocketsExecutor) Execute(ctx context.Context, auth *cliproxyaut
 	}
 
 	body, wsHeaders := applyCodexPromptCacheHeaders(from, req, body)
+	reporter.SetTranslatedReasoningEffort(body, to.String())
 	wsHeaders = applyCodexWebsocketHeaders(ctx, wsHeaders, auth, apiKey, e.cfg)
 
 	var authID, authLabel, authType, authValue string
@@ -421,6 +422,7 @@ func (e *CodexWebsocketsExecutor) ExecuteStream(ctx context.Context, auth *clipr
 	}
 
 	body, wsHeaders := applyCodexPromptCacheHeaders(from, req, body)
+	reporter.SetTranslatedReasoningEffort(body, to.String())
 	wsHeaders = applyCodexWebsocketHeaders(ctx, wsHeaders, auth, apiKey, e.cfg)
 
 	var authID, authLabel, authType, authValue string
diff --git a/internal/runtime/executor/gemini_cli_executor.go b/internal/runtime/executor/gemini_cli_executor.go
@@ -142,6 +142,7 @@ func (e *GeminiCLIExecutor) Execute(ctx context.Context, auth *cliproxyauth.Auth
 	requestPath := helps.PayloadRequestPath(opts)
 	basePayload = helps.ApplyPayloadConfigWithRequest(e.cfg, baseModel, "gemini", from.String(), "request", basePayload, originalTranslated, requestedModel, requestPath, opts.Headers)
 	basePayload = cleanGeminiCLIRequestSchemas(basePayload)
+	reporter.SetTranslatedReasoningEffort(basePayload, to.String())
 
 	action := "generateContent"
 	if req.Metadata != nil {
@@ -299,6 +300,7 @@ func (e *GeminiCLIExecutor) ExecuteStream(ctx context.Context, auth *cliproxyaut
 	requestPath := helps.PayloadRequestPath(opts)
 	basePayload = helps.ApplyPayloadConfigWithRequest(e.cfg, baseModel, "gemini", from.String(), "request", basePayload, originalTranslated, requestedModel, requestPath, opts.Headers)
 	basePayload = cleanGeminiCLIRequestSchemas(basePayload)
+	reporter.SetTranslatedReasoningEffort(basePayload, to.String())
 
 	projectID := resolveGeminiProjectID(auth)
 
diff --git a/internal/runtime/executor/gemini_executor.go b/internal/runtime/executor/gemini_executor.go
@@ -151,6 +151,7 @@ func (e *GeminiExecutor) Execute(ctx context.Context, auth *cliproxyauth.Auth, r
 	}
 
 	body, _ = sjson.DeleteBytes(body, "session_id")
+	reporter.SetTranslatedReasoningEffort(body, to.String())
 
 	httpReq, err := http.NewRequestWithContext(ctx, http.MethodPost, url, bytes.NewReader(body))
 	if err != nil {
@@ -256,6 +257,7 @@ func (e *GeminiExecutor) ExecuteStream(ctx context.Context, auth *cliproxyauth.A
 	}
 
 	body, _ = sjson.DeleteBytes(body, "session_id")
+	reporter.SetTranslatedReasoningEffort(body, to.String())
 
 	httpReq, err := http.NewRequestWithContext(ctx, http.MethodPost, url, bytes.NewReader(body))
 	if err != nil {
diff --git a/internal/runtime/executor/gemini_vertex_executor.go b/internal/runtime/executor/gemini_vertex_executor.go
@@ -356,6 +356,7 @@ func (e *GeminiVertexExecutor) executeWithServiceAccount(ctx context.Context, au
 		url = url + fmt.Sprintf("?$alt=%s", opts.Alt)
 	}
 	body, _ = sjson.DeleteBytes(body, "session_id")
+	reporter.SetTranslatedReasoningEffort(body, "gemini")
 
 	httpReq, errNewReq := http.NewRequestWithContext(ctx, http.MethodPost, url, bytes.NewReader(body))
 	if errNewReq != nil {
@@ -481,6 +482,7 @@ func (e *GeminiVertexExecutor) executeWithAPIKey(ctx context.Context, auth *clip
 		url = url + fmt.Sprintf("?$alt=%s", opts.Alt)
 	}
 	body, _ = sjson.DeleteBytes(body, "session_id")
+	reporter.SetTranslatedReasoningEffort(body, to.String())
 
 	httpReq, errNewReq := http.NewRequestWithContext(ctx, http.MethodPost, url, bytes.NewReader(body))
 	if errNewReq != nil {
@@ -589,6 +591,7 @@ func (e *GeminiVertexExecutor) executeStreamWithServiceAccount(ctx context.Conte
 		}
 	}
 	body, _ = sjson.DeleteBytes(body, "session_id")
+	reporter.SetTranslatedReasoningEffort(body, to.String())
 
 	httpReq, errNewReq := http.NewRequestWithContext(ctx, http.MethodPost, url, bytes.NewReader(body))
 	if errNewReq != nil {
@@ -734,6 +737,7 @@ func (e *GeminiVertexExecutor) executeStreamWithAPIKey(ctx context.Context, auth
 		}
 	}
 	body, _ = sjson.DeleteBytes(body, "session_id")
+	reporter.SetTranslatedReasoningEffort(body, to.String())
 
 	httpReq, errNewReq := http.NewRequestWithContext(ctx, http.MethodPost, url, bytes.NewReader(body))
 	if errNewReq != nil {
diff --git a/internal/runtime/executor/helps/usage_helpers.go b/internal/runtime/executor/helps/usage_helpers.go
@@ -11,6 +11,7 @@ import (
 
 	"github.com/gin-gonic/gin"
 	internallogging "github.com/router-for-me/CLIProxyAPI/v7/internal/logging"
+	"github.com/router-for-me/CLIProxyAPI/v7/internal/thinking"
 	cliproxyauth "github.com/router-for-me/CLIProxyAPI/v7/sdk/cliproxy/auth"
 	"github.com/router-for-me/CLIProxyAPI/v7/sdk/cliproxy/usage"
 	"github.com/tidwall/gjson"
@@ -66,6 +67,13 @@ func (r *UsageReporter) PublishAdditionalModel(ctx context.Context, model string
 	r.publishRecord(ctx, record)
 }
 
+func (r *UsageReporter) SetTranslatedReasoningEffort(payload []byte, format string) {
+	if r == nil {
+		return
+	}
+	r.reasoning = thinking.ExtractTranslatedReasoningEffort(payload, format)
+}
+
 func (r *UsageReporter) buildAdditionalModelRecord(model string, detail usage.Detail) (usage.Record, bool) {
 	if r == nil {
 		return usage.Record{}, false
diff --git a/internal/runtime/executor/kimi_executor.go b/internal/runtime/executor/kimi_executor.go
@@ -114,6 +114,7 @@ func (e *KimiExecutor) Execute(ctx context.Context, auth *cliproxyauth.Auth, req
 	if err != nil {
 		return resp, err
 	}
+	reporter.SetTranslatedReasoningEffort(body, e.Identifier())
 
 	url := kimiauth.KimiAPIBaseURL + "/v1/chat/completions"
 	httpReq, err := http.NewRequestWithContext(ctx, http.MethodPost, url, bytes.NewReader(body))
@@ -224,6 +225,7 @@ func (e *KimiExecutor) ExecuteStream(ctx context.Context, auth *cliproxyauth.Aut
 	if err != nil {
 		return nil, err
 	}
+	reporter.SetTranslatedReasoningEffort(body, e.Identifier())
 
 	url := kimiauth.KimiAPIBaseURL + "/v1/chat/completions"
 	httpReq, err := http.NewRequestWithContext(ctx, http.MethodPost, url, bytes.NewReader(body))
diff --git a/internal/runtime/executor/openai_compat_executor.go b/internal/runtime/executor/openai_compat_executor.go
@@ -126,6 +126,7 @@ func (e *OpenAICompatExecutor) Execute(ctx context.Context, auth *cliproxyauth.A
 			translated = updated
 		}
 	}
+	reporter.SetTranslatedReasoningEffort(translated, to.String())
 
 	url := strings.TrimSuffix(baseURL, "/") + endpoint
 	httpReq, err := http.NewRequestWithContext(ctx, http.MethodPost, url, bytes.NewReader(translated))
@@ -215,6 +216,7 @@ func (e *OpenAICompatExecutor) executeImages(ctx context.Context, auth *cliproxy
 	if contentType == "" {
 		contentType = "application/json"
 	}
+	reporter.SetTranslatedReasoningEffort(payload, "openai")
 
 	url := strings.TrimSuffix(baseURL, "/") + endpointPath
 	httpReq, err := http.NewRequestWithContext(ctx, http.MethodPost, url, bytes.NewReader(payload))
@@ -320,6 +322,7 @@ func (e *OpenAICompatExecutor) ExecuteStream(ctx context.Context, auth *cliproxy
 	// Request usage data in the final streaming chunk so that token statistics
 	// are captured even when the upstream is an OpenAI-compatible provider.
 	translated, _ = sjson.SetBytes(translated, "stream_options.include_usage", true)
+	reporter.SetTranslatedReasoningEffort(translated, to.String())
 
 	url := strings.TrimSuffix(baseURL, "/") + "/chat/completions"
 	httpReq, err := http.NewRequestWithContext(ctx, http.MethodPost, url, bytes.NewReader(translated))
@@ -469,6 +472,7 @@ func (e *OpenAICompatExecutor) executeImagesStream(ctx context.Context, auth *cl
 	if contentType == "" {
 		contentType = "application/json"
 	}
+	reporter.SetTranslatedReasoningEffort(payload, "openai")
 
 	url := strings.TrimSuffix(baseURL, "/") + endpointPath
 	httpReq, err := http.NewRequestWithContext(ctx, http.MethodPost, url, bytes.NewReader(payload))
diff --git a/internal/runtime/executor/xai_executor.go b/internal/runtime/executor/xai_executor.go
@@ -116,6 +116,7 @@ func (e *XAIExecutor) Execute(ctx context.Context, auth *cliproxyauth.Auth, req
 
 	reporter := helps.NewUsageReporter(ctx, e.Identifier(), prepared.baseModel, auth)
 	defer reporter.TrackFailure(ctx, &err)
+	reporter.SetTranslatedReasoningEffort(prepared.body, e.Identifier())
 
 	url := strings.TrimSuffix(baseURL, "/") + "/responses"
 	httpReq, err := http.NewRequestWithContext(ctx, http.MethodPost, url, bytes.NewReader(prepared.body))
@@ -302,6 +303,7 @@ func (e *XAIExecutor) ExecuteStream(ctx context.Context, auth *cliproxyauth.Auth
 
 	reporter := helps.NewUsageReporter(ctx, e.Identifier(), prepared.baseModel, auth)
 	defer reporter.TrackFailure(ctx, &err)
+	reporter.SetTranslatedReasoningEffort(prepared.body, e.Identifier())
 
 	url := strings.TrimSuffix(baseURL, "/") + "/responses"
 	httpReq, err := http.NewRequestWithContext(ctx, http.MethodPost, url, bytes.NewReader(prepared.body))
diff --git a/internal/thinking/apply.go b/internal/thinking/apply.go
@@ -360,6 +360,23 @@ func ExtractReasoningEffort(body []byte, provider, model string) string {
 	return reasoningEffortFromConfig(config)
 }
 
+// ExtractTranslatedReasoningEffort returns the final provider payload's thinking
+// setting as a canonical reasoning_effort label for usage logging.
+func ExtractTranslatedReasoningEffort(body []byte, provider string) string {
+	provider = strings.ToLower(strings.TrimSpace(provider))
+	config := extractThinkingConfig(body, provider)
+	if !hasThinkingConfig(config) {
+		switch provider {
+		case "openai", "openai-response":
+			config = extractCodexConfig(body)
+			if !hasThinkingConfig(config) {
+				config = extractOpenAIConfig(body)
+			}
+		}
+	}
+	return reasoningEffortFromConfig(config)
+}
+
 func reasoningEffortFromSuffix(suffix SuffixResult) string {
 	if !suffix.HasSuffix {
 		return ""
diff --git a/sdk/cliproxy/usage/manager.go b/sdk/cliproxy/usage/manager.go
@@ -20,7 +20,7 @@ type Record struct {
 	AuthIndex string
 	AuthType  string
 	Source    string
-	// ReasoningEffort stores the client-requested thinking level for request event logs.
+	// ReasoningEffort stores the translated upstream thinking level for request event logs.
 	ReasoningEffort string
 	RequestedAt     time.Time
 	Latency         time.Duration

Original file line number	Diff line number	Diff line change
`@@ -135,6 +135,7 @@ func (e AIStudioExecutor) Execute(ctx context.Context, auth cliproxyauth.Auth,`
`135`	`135`	`if err != nil {`
`136`	`136`	`return resp, err`
`137`	`137`	`}`
	`138`	`+ reporter.SetTranslatedReasoningEffort(body.payload, body.toFormat.String())`
`138`	`139`
`139`	`140`	`endpoint := e.buildEndpoint(baseModel, body.action, opts.Alt)`
`140`	`141`	`wsReq := &wsrelay.HTTPRequest{`
`@@ -199,6 +200,7 @@ func (e AIStudioExecutor) ExecuteStream(ctx context.Context, auth cliproxyauth`
`199`	`200`	`if err != nil {`
`200`	`201`	`return nil, err`
`201`	`202`	`}`
	`203`	`+ reporter.SetTranslatedReasoningEffort(body.payload, body.toFormat.String())`
`202`	`204`
`203`	`205`	`endpoint := e.buildEndpoint(baseModel, body.action, opts.Alt)`
`204`	`206`	`wsReq := &wsrelay.HTTPRequest{`
Original file line number	Diff line number	Diff line change
`@@ -200,6 +200,7 @@ func (e ClaudeExecutor) Execute(ctx context.Context, auth cliproxyauth.Auth, r`
`200`	`200`	`if oauthToken \|\| experimentalCCHSigningEnabled(e.cfg, auth) {`
`201`	`201`	`bodyForUpstream = signAnthropicMessagesBody(bodyForUpstream)`
`202`	`202`	`}`
	`203`	`+ reporter.SetTranslatedReasoningEffort(bodyForUpstream, to.String())`
`203`	`204`
`204`	`205`	`url := fmt.Sprintf("%s/v1/messages?beta=true", baseURL)`
`205`	`206`	`httpReq, err := http.NewRequestWithContext(ctx, http.MethodPost, url, bytes.NewReader(bodyForUpstream))`
`@@ -374,6 +375,7 @@ func (e ClaudeExecutor) ExecuteStream(ctx context.Context, auth cliproxyauth.A`
`374`	`375`	`if oauthToken \|\| experimentalCCHSigningEnabled(e.cfg, auth) {`
`375`	`376`	`bodyForUpstream = signAnthropicMessagesBody(bodyForUpstream)`
`376`	`377`	`}`
	`378`	`+ reporter.SetTranslatedReasoningEffort(bodyForUpstream, to.String())`
`377`	`379`
`378`	`380`	`url := fmt.Sprintf("%s/v1/messages?beta=true", baseURL)`
`379`	`381`	`httpReq, err := http.NewRequestWithContext(ctx, http.MethodPost, url, bytes.NewReader(bodyForUpstream))`
Original file line number	Diff line number	Diff line change
`@@ -285,6 +285,7 @@ func (e CodexExecutor) Execute(ctx context.Context, auth cliproxyauth.Auth, re`
`285`	`285`	`if e.cfg == nil \|\| e.cfg.DisableImageGeneration == config.DisableImageGenerationOff {`
`286`	`286`	`body = ensureImageGenerationTool(body, baseModel, auth)`
`287`	`287`	`}`
	`288`	`+ reporter.SetTranslatedReasoningEffort(body, to.String())`
`288`	`289`
`289`	`290`	`url := strings.TrimSuffix(baseURL, "/") + "/responses"`
`290`	`291`	`httpReq, err := e.cacheHelper(ctx, from, url, req, body)`
`@@ -441,6 +442,7 @@ func (e CodexExecutor) executeCompact(ctx context.Context, auth cliproxyauth.A`
`441`	`442`	`if e.cfg == nil \|\| e.cfg.DisableImageGeneration == config.DisableImageGenerationOff {`
`442`	`443`	`body = ensureImageGenerationTool(body, baseModel, auth)`
`443`	`444`	`}`
	`445`	`+ reporter.SetTranslatedReasoningEffort(body, to.String())`
`444`	`446`
`445`	`447`	`url := strings.TrimSuffix(baseURL, "/") + "/responses/compact"`
`446`	`448`	`httpReq, err := e.cacheHelper(ctx, from, url, req, body)`
`@@ -542,6 +544,7 @@ func (e CodexExecutor) ExecuteStream(ctx context.Context, auth cliproxyauth.Au`
`542`	`544`	`if e.cfg == nil \|\| e.cfg.DisableImageGeneration == config.DisableImageGenerationOff {`
`543`	`545`	`body = ensureImageGenerationTool(body, baseModel, auth)`
`544`	`546`	`}`
	`547`	`+ reporter.SetTranslatedReasoningEffort(body, to.String())`
`545`	`548`
`546`	`549`	`url := strings.TrimSuffix(baseURL, "/") + "/responses"`
`547`	`550`	`httpReq, err := e.cacheHelper(ctx, from, url, req, body)`
Original file line number	Diff line number	Diff line change
`@@ -96,6 +96,7 @@ func (e CodexExecutor) executeOpenAIImage(ctx context.Context, auth cliproxyau`
`96`	`96`	`if errBuild != nil {`
`97`	`97`	`return resp, errBuild`
`98`	`98`	`}`
	`99`	`+ reporter.SetTranslatedReasoningEffort(body, "codex")`
`99`	`100`
`100`	`101`	`url := strings.TrimSuffix(baseURL, "/") + "/responses"`
`101`	`102`	`httpReq, errCache := e.cacheHelper(ctx, sdktranslator.FromString(codexOpenAIImageSourceFormat), url, req, body)`
`@@ -184,6 +185,7 @@ func (e CodexExecutor) executeOpenAIImageStream(ctx context.Context, auth clip`
`184`	`185`	`if errBuild != nil {`
`185`	`186`	`return nil, errBuild`
`186`	`187`	`}`
	`188`	`+ reporter.SetTranslatedReasoningEffort(body, "codex")`
`187`	`189`
`188`	`190`	`url := strings.TrimSuffix(baseURL, "/") + "/responses"`
`189`	`191`	`httpReq, errCache := e.cacheHelper(ctx, sdktranslator.FromString(codexOpenAIImageSourceFormat), url, req, body)`
Original file line number	Diff line number	Diff line change
`@@ -221,6 +221,7 @@ func (e CodexWebsocketsExecutor) Execute(ctx context.Context, auth cliproxyaut`
`221`	`221`	`}`
`222`	`222`
`223`	`223`	`body, wsHeaders := applyCodexPromptCacheHeaders(from, req, body)`
	`224`	`+ reporter.SetTranslatedReasoningEffort(body, to.String())`
`224`	`225`	`wsHeaders = applyCodexWebsocketHeaders(ctx, wsHeaders, auth, apiKey, e.cfg)`
`225`	`226`
`226`	`227`	`var authID, authLabel, authType, authValue string`
`@@ -421,6 +422,7 @@ func (e CodexWebsocketsExecutor) ExecuteStream(ctx context.Context, auth clipr`
`421`	`422`	`}`
`422`	`423`
`423`	`424`	`body, wsHeaders := applyCodexPromptCacheHeaders(from, req, body)`
	`425`	`+ reporter.SetTranslatedReasoningEffort(body, to.String())`
`424`	`426`	`wsHeaders = applyCodexWebsocketHeaders(ctx, wsHeaders, auth, apiKey, e.cfg)`
`425`	`427`
`426`	`428`	`var authID, authLabel, authType, authValue string`
Original file line number	Diff line number	Diff line change
`@@ -151,6 +151,7 @@ func (e GeminiExecutor) Execute(ctx context.Context, auth cliproxyauth.Auth, r`
`151`	`151`	`}`
`152`	`152`
`153`	`153`	`body, _ = sjson.DeleteBytes(body, "session_id")`
	`154`	`+ reporter.SetTranslatedReasoningEffort(body, to.String())`
`154`	`155`
`155`	`156`	`httpReq, err := http.NewRequestWithContext(ctx, http.MethodPost, url, bytes.NewReader(body))`
`156`	`157`	`if err != nil {`
`@@ -256,6 +257,7 @@ func (e GeminiExecutor) ExecuteStream(ctx context.Context, auth cliproxyauth.A`
`256`	`257`	`}`
`257`	`258`
`258`	`259`	`body, _ = sjson.DeleteBytes(body, "session_id")`
	`260`	`+ reporter.SetTranslatedReasoningEffort(body, to.String())`
`259`	`261`
`260`	`262`	`httpReq, err := http.NewRequestWithContext(ctx, http.MethodPost, url, bytes.NewReader(body))`
`261`	`263`	`if err != nil {`
Original file line number	Diff line number	Diff line change
`@@ -356,6 +356,7 @@ func (e *GeminiVertexExecutor) executeWithServiceAccount(ctx context.Context, au`
`356`	`356`	`url = url + fmt.Sprintf("?$alt=%s", opts.Alt)`
`357`	`357`	`}`
`358`	`358`	`body, _ = sjson.DeleteBytes(body, "session_id")`
	`359`	`+ reporter.SetTranslatedReasoningEffort(body, "gemini")`
`359`	`360`
`360`	`361`	`httpReq, errNewReq := http.NewRequestWithContext(ctx, http.MethodPost, url, bytes.NewReader(body))`
`361`	`362`	`if errNewReq != nil {`
`@@ -481,6 +482,7 @@ func (e GeminiVertexExecutor) executeWithAPIKey(ctx context.Context, auth clip`
`481`	`482`	`url = url + fmt.Sprintf("?$alt=%s", opts.Alt)`
`482`	`483`	`}`
`483`	`484`	`body, _ = sjson.DeleteBytes(body, "session_id")`
	`485`	`+ reporter.SetTranslatedReasoningEffort(body, to.String())`
`484`	`486`
`485`	`487`	`httpReq, errNewReq := http.NewRequestWithContext(ctx, http.MethodPost, url, bytes.NewReader(body))`
`486`	`488`	`if errNewReq != nil {`
`@@ -589,6 +591,7 @@ func (e *GeminiVertexExecutor) executeStreamWithServiceAccount(ctx context.Conte`
`589`	`591`	`}`
`590`	`592`	`}`
`591`	`593`	`body, _ = sjson.DeleteBytes(body, "session_id")`
	`594`	`+ reporter.SetTranslatedReasoningEffort(body, to.String())`
`592`	`595`
`593`	`596`	`httpReq, errNewReq := http.NewRequestWithContext(ctx, http.MethodPost, url, bytes.NewReader(body))`
`594`	`597`	`if errNewReq != nil {`
`@@ -734,6 +737,7 @@ func (e *GeminiVertexExecutor) executeStreamWithAPIKey(ctx context.Context, auth`
`734`	`737`	`}`
`735`	`738`	`}`
`736`	`739`	`body, _ = sjson.DeleteBytes(body, "session_id")`
	`740`	`+ reporter.SetTranslatedReasoningEffort(body, to.String())`
`737`	`741`
`738`	`742`	`httpReq, errNewReq := http.NewRequestWithContext(ctx, http.MethodPost, url, bytes.NewReader(body))`
`739`	`743`	`if errNewReq != nil {`