ext/new-api
2
0
Fork 0
mirror of https://github.com/QuantumNous/new-api.git synced 2026-08-31 02:41:34 +00:00
Code

Merge 57dbe13050cc680991bdad406971d59c854c9048 into 2b6f1dfefbe217fed31fc0726717cc7de6958e8e

Browse Source
This commit is contained in:
Seefs 2026-08-30 17:03:44 +02:00 committed by GitHub
commit a7f0cc0047
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 14 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
relay/channel/openai/relay_responses.go
View File

@ -95,6 +95,19 @@ func OaiResponsesStreamHandler(c *gin.Context, info *relaycommon.RelayInfo, resp
return
}
sendResponsesStreamData(c, streamResponse, data)
switch streamResponse.Type {
case "error", "response.error", "response.failed":
streamError := streamResponse.Error
if (len(streamError) == 0 || string(streamError) == "null") && streamResponse.Response != nil && streamResponse.Response.Error != nil {
if errorBytes, err := common.Marshal(streamResponse.Response.Error); err == nil {
streamError = errorBytes
}
}
if len(streamError) > 0 && string(streamError) != "null" {
sr.Error(fmt.Errorf("%s: %s", streamResponse.Type, streamError))
}
}
switch streamResponse.Type {
case "response.completed", "response.done":
if streamResponse.Response != nil {

1
relaykit/dto/openai_response.go
View File

@ -386,6 +386,7 @@ const (
type ResponsesStreamResponse struct {
Type string `json:"type"`
Response *OpenAIResponsesResponse `json:"response,omitempty"`
Error json.RawMessage `json:"error,omitempty"`
Delta string `json:"delta,omitempty"`
Item *ResponsesOutput `json:"item,omitempty"`
// - response.function_call_arguments.delta