seewe/sub2api
1
0
Fork 0
mirror of https://github.com/Wei-Shaw/sub2api.git synced 2026-10-14 03:52:26 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(openai): normalize Lite requests in WS HTTP bridge

Browse Source
This commit is contained in:
Jiao Ziang
2026-08-25 03:46:46 +08:00
parent d6012b0b35
commit d5e43ef7d1
2 changed files with 12 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/internal/service/openai_ws_http_bridge.go
+9
View File
@@ -349,6 +349,15 @@ func (s *OpenAIGatewayService) proxyOpenAIWSHTTPBridgeTurn(
LoweredTools: loweredTools,
})
}
if account.Platform != PlatformGrok && isOpenAIResponsesLiteWebSocketPayload(payload) {
liteBody, liteChanged, liteErr := normalizeOpenAIResponsesLitePayloadForAccount(body, account)
if liteErr != nil {
return nil, fmt.Errorf("normalize responses Lite payload: %w", liteErr)
}
if liteChanged {
body = liteBody
}
}
buildUpstreamRequest := func(requestBody []byte) (*http.Request, error) {
upstreamCtx, releaseUpstreamCtx := detachUpstreamContext(ctx)
backend/internal/service/openai_ws_http_bridge_test.go
+3 -1
View File
@@ -1239,7 +1239,7 @@ func TestOpenAIWSHTTPBridgeRelaysSSEFramesAsWebSocketMessages(t *testing.T) {
Concurrency: 1,
Status: StatusActive,
}
payload := []byte(`{"type":"response.create","generate":true,"model":"gpt-5","stream":true,"client_metadata":{"ws_request_header_x_openai_internal_codex_responses_lite":"true"},"input":"hi"}`)
payload := []byte(`{"type":"response.create","generate":true,"model":"gpt-5","stream":true,"client_metadata":{"ws_request_header_x_openai_internal_codex_responses_lite":"true"},"input":"hi","tools":[{"type":"function","name":"lookup","parameters":{"type":"object"}}],"parallel_tool_calls":true}`)
type bridgeResult struct {
result *OpenAIForwardResult
@@ -1325,6 +1325,8 @@ func TestOpenAIWSHTTPBridgeRelaysSSEFramesAsWebSocketMessages(t *testing.T) {
require.False(t, gjson.GetBytes(upstream.lastBody, "type").Exists())
require.False(t, gjson.GetBytes(upstream.lastBody, "generate").Exists())
require.True(t, gjson.GetBytes(upstream.lastBody, "stream").Bool())
require.True(t, gjson.GetBytes(upstream.lastBody, "parallel_tool_calls").Exists())
require.False(t, gjson.GetBytes(upstream.lastBody, "parallel_tool_calls").Bool())
}
func TestProxyOpenAIWSHTTPBridgeTurnForGrokDefaultsEmptyModelTo45(t *testing.T) {