oadmin/sub2api
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

refactor(openai): 移除不必要的 seedOpenAISessionHeaders 函数

Browse Source
This commit is contained in:
ianshaw
2026-01-12 20:38:46 -08:00
parent 3d6e01a58f
commit d7fa47d732
1 changed files with 0 additions and 33 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
backend/internal/handler/openai_gateway_handler.go
View File

@@ -96,8 +96,6 @@ func (h *OpenAIGatewayHandler) Responses(c *gin.Context) {
return return
} }
seedOpenAISessionHeaders(c, reqBody)
userAgent := c.GetHeader("User-Agent") userAgent := c.GetHeader("User-Agent")
if !openai.IsCodexCLIRequest(userAgent) { if !openai.IsCodexCLIRequest(userAgent) {
existingInstructions, _ := reqBody["instructions"].(string) existingInstructions, _ := reqBody["instructions"].(string)
@@ -301,37 +299,6 @@ func (h *OpenAIGatewayHandler) handleFailoverExhausted(c *gin.Context, statusCod
h.handleStreamingAwareError(c, status, errType, errMsg, streamStarted) 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) { func (h *OpenAIGatewayHandler) mapUpstreamError(statusCode int) (int, string, string) {
switch statusCode { switch statusCode {
case 401: case 401: