From d7fa47d732c239b5868ac0a09434882963645f4e Mon Sep 17 00:00:00 2001 From: ianshaw Date: Mon, 12 Jan 2026 20:38:46 -0800 Subject: [PATCH] =?UTF-8?q?refactor(openai):=20=E7=A7=BB=E9=99=A4=E4=B8=8D?= =?UTF-8?q?=E5=BF=85=E8=A6=81=E7=9A=84=20seedOpenAISessionHeaders=20?= =?UTF-8?q?=E5=87=BD=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../handler/openai_gateway_handler.go | 33 ------------------- 1 file changed, 33 deletions(-) diff --git a/backend/internal/handler/openai_gateway_handler.go b/backend/internal/handler/openai_gateway_handler.go index afb1ddc9..3011b97d 100644 --- a/backend/internal/handler/openai_gateway_handler.go +++ b/backend/internal/handler/openai_gateway_handler.go @@ -96,8 +96,6 @@ func (h *OpenAIGatewayHandler) Responses(c *gin.Context) { return } - seedOpenAISessionHeaders(c, reqBody) - userAgent := c.GetHeader("User-Agent") if !openai.IsCodexCLIRequest(userAgent) { existingInstructions, _ := reqBody["instructions"].(string) @@ -301,37 +299,6 @@ func (h *OpenAIGatewayHandler) handleFailoverExhausted(c *gin.Context, statusCod h.handleStreamingAwareError(c, status, errType, errMsg, streamStarted) } -func seedOpenAISessionHeaders(c *gin.Context, reqBody map[string]any) { - if c.GetHeader("session_id") == "" { - if v := firstNonEmptyString( - reqBody["prompt_cache_key"], - reqBody["session_id"], - reqBody["conversation_id"], - reqBody["previous_response_id"], - ); v != "" { - c.Request.Header.Set("session_id", v) - } - } - if c.GetHeader("conversation_id") == "" { - if v := firstNonEmptyString(reqBody["prompt_cache_key"], reqBody["conversation_id"]); v != "" { - c.Request.Header.Set("conversation_id", v) - } - } -} - -func firstNonEmptyString(values ...any) string { - for _, value := range values { - s, ok := value.(string) - if ok { - s = strings.TrimSpace(s) - if s != "" { - return s - } - } - } - return "" -} - func (h *OpenAIGatewayHandler) mapUpstreamError(statusCode int) (int, string, string) { switch statusCode { case 401: