fix(core): make responses websockets opt-in (#48231)

Co-authored-by: rekram1-node <rekram1-node@users.noreply.github.com>

Author: opencode-agent[bot]

packages/core/src/model-resolver.ts

@@ -323,7 +323,7 @@ export const layer = Layer.effect(
         cost: selected.cost,
         limit: selected.limit,
         compaction: selected.compaction,
-        websocket: selected.websocket ?? true,
+        websocket: selected.websocket ?? false,
       }
     })
     return Service.of({

packages/core/src/plugin/provider/azure.ts

@@ -162,7 +162,10 @@ export const AzurePlugin = define({
                 draft.settings.baseURL,
                 resolveResourceName(draft.settings, resourceName) ?? resourceName,
               )
-            if (responsesWebSocketCapable(item.provider, draft)) draft.capabilities.responsesWebsockets = true
+            if (responsesWebSocketCapable(item.provider, draft)) {
+              draft.capabilities.responsesWebsockets = true
+              draft.websocket = true
+            }
           })
         }
       }

packages/core/src/plugin/provider/openai.ts

@@ -257,6 +257,7 @@ export const OpenAIPlugin = define({
       for (const model of item.models.values()) {
         evt.model.update(item.provider.id, model.id, (draft) => {
           draft.capabilities.responsesWebsockets = true
+          draft.websocket = true
         })
       }
       if (!chatgpt) return

packages/core/src/session/runner/model.ts

@@ -73,7 +73,7 @@ export const resolved = (
   cost: options.cost,
   limit: options.limit,
   compaction: options.compaction,
-  websocket: options.websocket ?? true,
+  websocket: options.websocket ?? false,
 })
 
 const layer = Layer.effect(

packages/core/test/generate.test.ts

@@ -94,7 +94,7 @@ resolverIt.effect("resolves dynamic models with their catalog metadata", () =>
       capabilities: selected.capabilities,
       cost: selected.cost,
       limit: selected.limit,
-      websocket: true,
+      websocket: false,
     })
   }),
 )

packages/core/test/plugin/provider-azure.test.ts

@@ -488,13 +488,14 @@ describe("AzurePlugin", () => {
 
         yield* addPlugin()
 
-        expect(
-          required(yield* catalog.model.get(Provider.ID.azure, models.responses)).capabilities.responsesWebsockets,
-        ).toBe(true)
-        for (const modelID of [models.chat, models.preview, models.deploymentURL, models.gateway, models.nonAzure])
-          expect(
-            required(yield* catalog.model.get(Provider.ID.azure, modelID)).capabilities.responsesWebsockets,
-          ).toBeUndefined()
+        const responses = required(yield* catalog.model.get(Provider.ID.azure, models.responses))
+        expect(responses.capabilities.responsesWebsockets).toBe(true)
+        expect(responses.websocket).toBe(true)
+        for (const modelID of [models.chat, models.preview, models.deploymentURL, models.gateway, models.nonAzure]) {
+          const model = required(yield* catalog.model.get(Provider.ID.azure, modelID))
+          expect(model.capabilities.responsesWebsockets).toBeUndefined()
+          expect(model.websocket).toBeUndefined()
+        }
       }),
     ),
   )

packages/core/test/plugin/provider-openai.test.ts

@@ -207,6 +207,7 @@ describe("OpenAIPlugin", () => {
       expect(model.enabled).toBe(true)
       expect(model.limit).toEqual({ context: 1_050_000, input: 922_000, output: 128_000 })
       expect(model.capabilities.responsesWebsockets).toBe(true)
+      expect(model.websocket).toBe(true)
       expect(direct.headers).not.toHaveProperty("originator")
       expect(direct.baseURL).toBe("https://api.openai.com/v1")
       expect(provider.headers).not.toHaveProperty("x-codex-beta-features")
@@ -216,7 +217,7 @@ describe("OpenAIPlugin", () => {
     }),
   )
 
-  it.effect("selects Azure WebSocket from capability unless the policy disables it", () =>
+  it.effect("selects WebSocket only from explicit policy", () =>
     Effect.gen(function* () {
       const credentials = yield* Credential.Service
       yield* credentials.create({
@@ -267,11 +268,13 @@ describe("OpenAIPlugin", () => {
           Effect.provideService(SessionModelTransport.Service, transport),
         )
 
-      const prepared = yield* prepare()
+      const prepared = yield* prepare(true)
+      const defaulted = yield* prepare()
       const disabled = yield* prepare(false)
 
       expect(prepared.options.webSocket).toBe(executor)
       expect(prepared.options.http).toBeUndefined()
+      expect(defaulted.options.webSocket).toBeUndefined()
       expect(disabled.options.webSocket).toBeUndefined()
     }),
   )

packages/core/test/plugin/provider-xai.test.ts

@@ -69,7 +69,7 @@ describe("XAIPlugin", () => {
     }),
   )
 
-  it.effect("marks xAI deployments as Responses WebSocket capable", () =>
+  it.effect("keeps xAI Responses WebSockets opt-in", () =>
     Effect.gen(function* () {
       const catalog = yield* Catalog.Service
       const providerID = Provider.ID.make("xai")
@@ -82,9 +82,9 @@ describe("XAIPlugin", () => {
 
       yield* addPlugin()
 
-      expect((yield* catalog.model.get(providerID, Model.ID.make("grok-4.6")))?.capabilities.responsesWebsockets).toBe(
-        true,
-      )
+      const model = yield* catalog.model.get(providerID, Model.ID.make("grok-4.6"))
+      expect(model?.capabilities.responsesWebsockets).toBe(true)
+      expect(model?.websocket).toBeUndefined()
     }),
   )
 })

packages/schema/src/config/provider.ts

@@ -64,7 +64,7 @@ class Model extends Schema.Class<Model>("Config.Model")({
 export class Info extends Schema.Class<Info>("Config.Provider")({
   compaction: Provider.Compaction.pipe(optional),
   websocket: Schema.Boolean.pipe(optional).annotate({
-    description: "Use the provider's WebSocket transport when the route supports it. Defaults to true.",
+    description: "Use the provider's WebSocket transport when the route supports it. Defaults to the built-in policy.",
   }),
   canonical: Provider.ID.pipe(optional),
   name: Schema.String.pipe(optional),

packages/schema/src/model.ts

@@ -107,7 +107,7 @@ export const Info = Schema.Struct({
   compatibility: Compatibility.pipe(optional),
   package: Provider.Package.pipe(optional),
   compaction: Provider.Compaction.pipe(optional),
-  /** Session WebSocket policy; omitted inherits the provider policy, which defaults to enabled. */
+  /** Session WebSocket policy; omitted inherits the provider policy, then defaults to disabled. */
   websocket: Schema.Boolean.pipe(optional),
   ...Provider.Overlays,
   capabilities: Capabilities,