update

Author: lrbmike

backend/go.mod

@@ -23,6 +23,7 @@ require (
 	github.com/go-playground/validator/v10 v10.14.0 // indirect
 	github.com/go-sql-driver/mysql v1.7.0 // indirect
 	github.com/goccy/go-json v0.10.2 // indirect
+	github.com/google/uuid v1.6.0 // indirect
 	github.com/jinzhu/inflection v1.0.0 // indirect
 	github.com/jinzhu/now v1.1.5 // indirect
 	github.com/json-iterator/go v1.1.12 // indirect

backend/go.sum

@@ -37,6 +37,8 @@ github.com/golang/protobuf v1.5.0/go.mod h1:FsONVRAS9T7sI+LIUmWTfcYkHO4aIWwzhcaS
 github.com/google/go-cmp v0.5.5 h1:Khx7svrCpmxxtHBq5j2mp/xVjsi8hQMfNLvJFAlrGgU=
 github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
 github.com/google/gofuzz v1.0.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg=
+github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
+github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
 github.com/jinzhu/inflection v1.0.0 h1:K317FqzuhWc8YvSVlFMCCUb36O/S9MCKRDI7QkRKD/E=
 github.com/jinzhu/inflection v1.0.0/go.mod h1:h+uFLlag+Qp1Va5pdKtLDYj+kHp5pxUVkryuEj+Srlc=
 github.com/jinzhu/now v1.1.5 h1:/o9tlHleP7gOFmsnYNz3RGnqzefHA47wQpKrrdTIwXQ=

backend/internal/adapters/anthropic_adapter.go

@@ -62,7 +62,7 @@ func (a *AnthropicAdapter) ProcessRequest() (*services.TargetRequest, error) {
 	}
 
 	// 3. Build the target request.
-	headers := utils.FilterRequestHeaders(a.c.Request.Header, []string{"x-api-key", "Authorization", "x-anthropic-api-key"})
+	headers := utils.FilterRequestHeaders(a.c.Request.Header, []string{"x-api-key", "Authorization", "x-anthropic-api-key", "accept-encoding"})
 
 	// 优先使用数据库中为该proxyConfig保存的APIKeyName, 否则回退到默认值
 	keyName := "x-api-key"

backend/internal/adapters/gemini_adapter.go

@@ -5,8 +5,8 @@ import (
 	"io"
 	"strings"
 
-	"api-key-rotator/backend/internal/infrastructure/cache"
 	"api-key-rotator/backend/internal/config"
+	"api-key-rotator/backend/internal/infrastructure/cache"
 	"api-key-rotator/backend/internal/logger"
 	"api-key-rotator/backend/internal/models"
 	"api-key-rotator/backend/internal/services"
@@ -33,7 +33,7 @@ func NewGeminiAdapter(cfg *config.Config, db *gorm.DB, cacheClient cache.CacheIn
 func (a *GeminiAdapter) ProcessRequest() (*services.TargetRequest, error) {
 	// 1. 代理访问认证 (劫持 'x-goog-api-key' Header)
 	proxyKey := a.c.GetHeader("x-goog-api-key")
-	
+
 	validKeys := a.cfg.GetGlobalProxyKeys()
 	isValidKey := false
 	for _, key := range validKeys {
@@ -45,15 +45,15 @@ func (a *GeminiAdapter) ProcessRequest() (*services.TargetRequest, error) {
 	if !isValidKey {
 		return nil, fmt.Errorf("invalid Proxy Key. Provide it via the 'key' URL query parameter")
 	}
-	
+
 	// 2. 轮询上游密钥
 	upstreamKey, err := a.RotateUpstreamKey()
 	if err != nil {
 		return nil, err
 	}
 
 	// 3. 构建目标请求 (偷梁换柱)
-	headers := utils.FilterRequestHeaders(a.c.Request.Header, []string{"x-goog-api-key"})
+	headers := utils.FilterRequestHeaders(a.c.Request.Header, []string{"x-goog-api-key", "accept-encoding"})
 
 	// 优先使用数据库中为该proxyConfig保存的APIKeyName, 否则回退到默认值
 	keyName := "x-goog-api-key"
@@ -110,4 +110,4 @@ func (a *GeminiAdapter) ProcessRequest() (*services.TargetRequest, error) {
 		Params:  params,
 		Body:    body,
 	}, nil
-}
+}

backend/internal/adapters/openai_adapter.go

@@ -6,8 +6,8 @@ import (
 	"io"
 	"strings"
 
-	"api-key-rotator/backend/internal/infrastructure/cache"
 	"api-key-rotator/backend/internal/config"
+	"api-key-rotator/backend/internal/infrastructure/cache"
 	"api-key-rotator/backend/internal/logger"
 	"api-key-rotator/backend/internal/models"
 	"api-key-rotator/backend/internal/services"
@@ -87,7 +87,7 @@ func (a *OpenAIAdapter) ProcessRequest() (*services.TargetRequest, error) {
 	}
 
 	// 3. 构建目标请求 (偷梁换柱)
-	headers := utils.FilterRequestHeaders(a.c.Request.Header, []string{"authorization"})
+	headers := utils.FilterRequestHeaders(a.c.Request.Header, []string{"authorization", "accept-encoding"})
 
 	// 优先使用数据库中为该proxyConfig保存的APIKeyName, 否则回退到默认值
 	keyName := "Authorization"
@@ -147,4 +147,4 @@ func (a *OpenAIAdapter) ProcessRequest() (*services.TargetRequest, error) {
 		Params:  params,
 		Body:    bodyBytes,
 	}, nil
-}
+}

backend/internal/converters/converter.go

@@ -8,6 +8,7 @@ import (
 	_ "api-key-rotator/backend/internal/converters/formats/anthropic"
 	_ "api-key-rotator/backend/internal/converters/formats/gemini"
 	_ "api-key-rotator/backend/internal/converters/formats/openai"
+	_ "api-key-rotator/backend/internal/converters/formats/openai_responses"
 )
 
 // Converter handles format conversion between different LLM API formats

backend/internal/converters/formats/openai/handler.go

@@ -198,12 +198,25 @@ func (h *Handler) BuildResponse(resp *formats.UniversalResponse) ([]byte, error)
 	return json.Marshal(openaiResp)
 }
 
-// GetAPIPath implements FormatHandler
+// GetAPIPath implements FormatHandler - converts client action to OpenAI API path
 func (h *Handler) GetAPIPath(action string) string {
-	return action
+	switch action {
+	case "v1/messages", "messages":
+		// Anthropic endpoint -> OpenAI endpoint
+		return "chat/completions"
+	case "v1/chat/completions":
+		return "chat/completions"
+	default:
+		return action
+	}
 }
 
-// GetClientAction implements FormatHandler
+// GetClientAction implements FormatHandler - converts API path to client action
 func (h *Handler) GetClientAction(apiPath string) string {
-	return apiPath
+	switch apiPath {
+	case "chat/completions", "v1/chat/completions":
+		return "v1/chat/completions"
+	default:
+		return apiPath
+	}
 }