fix: [AI-7743] keep Bus mirror off the question Deferred critical path

Address review feedback (flagged by all reviewers): the `Bus.publish` mirrors
added for /event (webview) clients sat on the Deferred critical path. Since
`Effect.promise` converts a promise rejection into an unrecoverable fiber
defect, a `Bus.publish` rejection could abort the fiber before
`Deferred.succeed`/`Deferred.fail` ran — leaving the awaiting `Question.ask()`
hung on "Thinking…", the exact failure this PR fixes.

- Add a best-effort `mirror()` helper: `Effect.promise(() => Bus.publish(...))`
  recovered with `Effect.catchCause` to a logged warning, so a publish failure
  can never abort core question settlement.
- Settle the Deferred FIRST, then mirror, in `reply()` and `reject()`.
- `ask()` uses `mirror()` too, so a publish failure can't abort it before the
  cleanup finalizer is registered.
- Replace `z.any()` with `z.unknown()` in the `question.asked` Bus schema.
- Log (not silently swallow) failures in the instance-dispose cleanup.

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>

Author: saravmajestic

packages/opencode/src/question/index.ts

@@ -112,7 +112,7 @@ const BusAsked = BusEvent.define(
   z.object({
     id: QuestionID.zod,
     sessionID: SessionID.zod,
-    questions: z.array(z.any()),
+    questions: z.array(z.unknown()),
     tool: z.object({ messageID: MessageID.zod, callID: z.string() }).optional(),
   }),
 )
@@ -128,6 +128,17 @@ const BusRejected = BusEvent.define(
   "question.rejected",
   z.object({ sessionID: SessionID.zod, requestID: QuestionID.zod }),
 )
+
+// Best-effort Bus mirror. A fire-and-forget /event notification must NEVER be
+// able to abort core question settlement: `Effect.promise` turns a promise
+// rejection into an unrecoverable fiber defect, and on the Deferred critical
+// path that would skip `Deferred.succeed`/`Deferred.fail` and re-hang the tool
+// on "Thinking…" — the exact failure this PR fixes. Recover any cause to a
+// logged warning so publication can never block settlement.
+const mirror = <D extends BusEvent.Definition>(def: D, properties: z.output<D["properties"]>) =>
+  Effect.promise(() => Bus.publish(def, properties)).pipe(
+    Effect.catchCause((cause) => Effect.logWarning("question bus mirror failed", { type: def.type, cause })),
+  )
 // altimate_change end
 
 export class RejectedError extends Schema.TaggedErrorClass<RejectedError>()("QuestionRejectedError", {}) {
@@ -202,7 +213,11 @@ export const layer = Layer.effect(
       if (!map) return
       pendingByDir.delete(directory)
       for (const { deferred } of map.values()) {
-        await Effect.runPromise(Deferred.fail(deferred, new RejectedError())).catch(() => {})
+        await Effect.runPromise(
+          Deferred.fail(deferred, new RejectedError()).pipe(
+            Effect.catchCause((cause) => Effect.logWarning("question cleanup failed on dispose", { cause })),
+          ),
+        )
       }
     })
     yield* Effect.addFinalizer(() => Effect.sync(off))
@@ -229,11 +244,16 @@ export const layer = Layer.effect(
       }
       pending.set(id, { info, deferred })
       yield* events.publish(Event.Asked, info)
-      // altimate_change start — also publish on the Bus wildcard so the IDE webview
+      // altimate_change start — also mirror on the Bus wildcard so the IDE webview
       // (subscribed to /event) receives question.asked and can answer the card.
-      yield* Effect.promise(() =>
-        Bus.publish(BusAsked, { id, sessionID: input.sessionID, questions: [...input.questions], tool: input.tool }),
-      )
+      // Best-effort: a publish failure must not abort ask() before it registers
+      // the cleanup finalizer below (see `mirror`).
+      yield* mirror(BusAsked, {
+        id,
+        sessionID: input.sessionID,
+        questions: [...input.questions],
+        tool: input.tool,
+      })
       // altimate_change end
 
       return yield* Effect.ensuring(
@@ -263,16 +283,15 @@ export const layer = Layer.effect(
         requestID: existing.info.id,
         answers: input.answers.map((a) => [...a]),
       })
-      // altimate_change start — mirror on the Bus wildcard for /event (webview) clients.
-      yield* Effect.promise(() =>
-        Bus.publish(BusReplied, {
-          sessionID: existing.info.sessionID,
-          requestID: existing.info.id,
-          answers: input.answers.map((a) => [...a]),
-        }),
-      )
-      // altimate_change end
       yield* Deferred.succeed(existing.deferred, input.answers)
+      // altimate_change start — mirror on the Bus wildcard for /event (webview) clients,
+      // AFTER settling the Deferred and best-effort so a publish failure can't re-hang ask().
+      yield* mirror(BusReplied, {
+        sessionID: existing.info.sessionID,
+        requestID: existing.info.id,
+        answers: input.answers.map((a) => [...a]),
+      })
+      // altimate_change end
     })
 
     const reject = Effect.fn("Question.reject")(function* (requestID: QuestionID) {
@@ -290,12 +309,11 @@ export const layer = Layer.effect(
         sessionID: existing.info.sessionID,
         requestID: existing.info.id,
       })
-      // altimate_change start — mirror on the Bus wildcard for /event (webview) clients.
-      yield* Effect.promise(() =>
-        Bus.publish(BusRejected, { sessionID: existing.info.sessionID, requestID: existing.info.id }),
-      )
-      // altimate_change end
       yield* Deferred.fail(existing.deferred, new RejectedError())
+      // altimate_change start — mirror on the Bus wildcard for /event (webview) clients,
+      // AFTER settling the Deferred and best-effort so a publish failure can't strand it.
+      yield* mirror(BusRejected, { sessionID: existing.info.sessionID, requestID: existing.info.id })
+      // altimate_change end
     })
 
     const list = Effect.fn("Question.list")(function* () {