Skip to content

fix(openai): preserve websocket idle state #30586

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
rekram1-node merged 7 commits into from
Jun 3, 2026
Merged

fix(openai): preserve websocket idle state #30586

Changes from 1 commit
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
ed2dd96
fix(openai): preserve websocket idle state
rekram1-node Jun 3, 2026
a78f674
fix(openai): retain active HTTP fallback lanes
rekram1-node Jun 3, 2026
7333930
fix(openai): track busy HTTP fallback streams
rekram1-node Jun 3, 2026
0198b39
refactor(openai): keep websocket fallback session sticky
rekram1-node Jun 3, 2026
38a7fd2
test(openai): widen websocket retry timing margin
rekram1-node Jun 3, 2026
1c4f41c
fix(openai): release deleted websocket sessions
rekram1-node Jun 3, 2026
920c6bf
test(openai): cover deleted active websocket sessions
rekram1-node Jun 3, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
test(openai): widen websocket retry timing margin
  • Loading branch information
@rekram1-node
rekram1-node committed Jun 3, 2026
commit 38a7fd24e2881a8df0b001d4d746e32dbbd65d2f
6 changes: 3 additions & 3 deletions packages/opencode/test/plugin/openai-ws.test.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -493,14 +493,14 @@ describe("plugin.openai.ws-pool", () => {
})
const fetch = OpenAIWebSocketPool.createWebSocketFetch({
url: server.url,
idleTimeout: 200,
idleTimeout: 500,
streamRetries: 1,
})

await new Promise((resolve) => setTimeout(resolve, 100))
await new Promise((resolve) => setTimeout(resolve, 250))
const first = await fetch(server.url, streamRequest())
expect((await readTextError(first.text())).message).toContain("idle timeout waiting for websocket")
await new Promise((resolve) => setTimeout(resolve, 130))
await new Promise((resolve) => setTimeout(resolve, 300))

const second = await fetch(server.url, streamRequest())

Expand Down
Loading