opencode/picoclaw
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix(codex): accumulate output items from stream events

Browse source 
The Codex/OpenAI Responses streaming API sends output items via
response.output_item.done events during the stream, but the final
response.completed event arrives with an empty Output array. This
caused all Codex provider responses to return empty content despite
the model successfully generating a reply.

Fix by accumulating output items as they arrive and merging them
into the response when response.completed has none.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
This commit is contained in:
grearsl 2026-04-09 07:34:46 +01:00
parent 06023c79fa
commit be005307b2
1 changed files with 9 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
pkg/providers/codex_provider.go
View file

@ -104,12 +104,21 @@ func (p *CodexProvider) Chat(
defer stream.Close() defer stream.Close()
var resp *responses.Response var resp *responses.Response
var accumulatedOutput []responses.ResponseOutputItemUnion
for stream.Next() { for stream.Next() {
evt := stream.Current() evt := stream.Current()
// Accumulate output items as they arrive — the response.completed
// event may not include them in its Response.Output field.
if evt.Type == "response.output_item.done" {
accumulatedOutput = append(accumulatedOutput, evt.Item)
}
if evt.Type == "response.completed" || evt.Type == "response.failed" || evt.Type == "response.incomplete" { if evt.Type == "response.completed" || evt.Type == "response.failed" || evt.Type == "response.incomplete" {
evtResp := evt.Response evtResp := evt.Response
if evtResp.ID != "" { if evtResp.ID != "" {
evtRespCopy := evtResp evtRespCopy := evtResp
if len(evtRespCopy.Output) == 0 && len(accumulatedOutput) > 0 {
evtRespCopy.Output = accumulatedOutput
}
resp = &evtRespCopy resp = &evtRespCopy
} }
} }