diff options
Diffstat (limited to 'packages')
| -rw-r--r-- | packages/opencode/src/server/routes/instance/httpapi/handlers/session.ts | 22 |
1 files changed, 10 insertions, 12 deletions
diff --git a/packages/opencode/src/server/routes/instance/httpapi/handlers/session.ts b/packages/opencode/src/server/routes/instance/httpapi/handlers/session.ts index 91afd0045..39643e35f 100644 --- a/packages/opencode/src/server/routes/instance/httpapi/handlers/session.ts +++ b/packages/opencode/src/server/routes/instance/httpapi/handlers/session.ts @@ -287,19 +287,17 @@ export const sessionHandlers = HttpApiBuilder.group(InstanceHttpApi, "session", const bridge = yield* EffectBridge.make() yield* Effect.sync(() => { bridge.fork( - promptSvc - .prompt({ ...ctx.payload, sessionID: ctx.params.sessionID }) - .pipe( - Effect.catchCause((error) => - Effect.sync(() => { - log.error("prompt_async failed", { sessionID: ctx.params.sessionID, error }) - void Bus.publish(Session.Event.Error, { - sessionID: ctx.params.sessionID, - error: new NamedError.Unknown({ message: String(error) }).toObject(), - }) - }), - ), + promptSvc.prompt({ ...ctx.payload, sessionID: ctx.params.sessionID }).pipe( + Effect.catchCause((error) => + Effect.sync(() => { + log.error("prompt_async failed", { sessionID: ctx.params.sessionID, error }) + void Bus.publish(Session.Event.Error, { + sessionID: ctx.params.sessionID, + error: new NamedError.Unknown({ message: String(error) }).toObject(), + }) + }), ), + ), ) }) return HttpApiSchema.NoContent.make() |