From 2f1547ebafe5852027949ace288752aad937e25d Mon Sep 17 00:00:00 2001 From: "opencode-agent[bot]" Date: Wed, 27 May 2026 20:05:11 +0000 Subject: [PATCH] chore: generate --- packages/opencode/src/plugin/openai/ws-pool.ts | 12 ++++++++++-- packages/opencode/src/plugin/openai/ws.ts | 9 ++++++++- packages/opencode/test/plugin/openai-ws.test.ts | 5 ++++- 3 files changed, 22 insertions(+), 4 deletions(-) diff --git a/packages/opencode/src/plugin/openai/ws-pool.ts b/packages/opencode/src/plugin/openai/ws-pool.ts index ae18eb5407..0af4c57c91 100644 --- a/packages/opencode/src/plugin/openai/ws-pool.ts +++ b/packages/opencode/src/plugin/openai/ws-pool.ts @@ -162,7 +162,11 @@ export function createWebSocketFetch(options?: CreateWebSocketFetchOptions) { } entry.fallback = true - log.warn("websocket setup failed", { key, error: error instanceof Error ? error.message : String(error), fallback: "http" }) + log.warn("websocket setup failed", { + key, + error: error instanceof Error ? error.message : String(error), + fallback: "http", + }) invalidate(entry) return httpFetch(input, httpInit) } @@ -202,7 +206,11 @@ async function socket( maxConnectionAge: number, signal?: AbortSignal | null, ) { - if (entry.socket?.readyState === WebSocket.OPEN && entry.connectedAt && Date.now() - entry.connectedAt < maxConnectionAge) { + if ( + entry.socket?.readyState === WebSocket.OPEN && + entry.connectedAt && + Date.now() - entry.connectedAt < maxConnectionAge + ) { return entry.socket } diff --git a/packages/opencode/src/plugin/openai/ws.ts b/packages/opencode/src/plugin/openai/ws.ts index 9d434d89f4..7176ab2104 100644 --- a/packages/opencode/src/plugin/openai/ws.ts +++ b/packages/opencode/src/plugin/openai/ws.ts @@ -201,7 +201,14 @@ export function streamResponsesWebSocket(options: StreamResponsesWebSocketOption } if (!emitted) options.onFirstEvent?.() - controller?.enqueue(encoder.encode(`${text.split(/\r?\n/).map((line) => `data: ${line}`).join("\n")}\n\n`)) + controller?.enqueue( + encoder.encode( + `${text + .split(/\r?\n/) + .map((line) => `data: ${line}`) + .join("\n")}\n\n`, + ), + ) emitted = true resetIdleTimeout("idle timeout waiting for websocket") diff --git a/packages/opencode/test/plugin/openai-ws.test.ts b/packages/opencode/test/plugin/openai-ws.test.ts index 65eaca655d..1fe26cfcb4 100644 --- a/packages/opencode/test/plugin/openai-ws.test.ts +++ b/packages/opencode/test/plugin/openai-ws.test.ts @@ -551,7 +551,10 @@ function streamRequest(headers?: Record, signal?: AbortSignal): } function mockFetch( - fn: (input: Parameters[0], init: Parameters[1]) => ReturnType, + fn: ( + input: Parameters[0], + init: Parameters[1], + ) => ReturnType, ): typeof globalThis.fetch { return Object.assign(fn, { preconnect: globalThis.fetch.preconnect }) }