|
@@ -882,9 +882,9 @@ export const SessionRoutes = lazy(() =>
|
|
|
const msg = await runRequest(
|
|
const msg = await runRequest(
|
|
|
"SessionRoutes.prompt",
|
|
"SessionRoutes.prompt",
|
|
|
c,
|
|
c,
|
|
|
- SessionPrompt.Service.use((svc) =>
|
|
|
|
|
- svc.prompt({ ...body, sessionID } as unknown as SessionPrompt.PromptInput),
|
|
|
|
|
- ),
|
|
|
|
|
|
|
+ SessionPrompt.Service.use((svc) =>
|
|
|
|
|
+ svc.prompt({ ...body, sessionID } as unknown as SessionPrompt.PromptInput),
|
|
|
|
|
+ ),
|
|
|
)
|
|
)
|
|
|
void stream.write(JSON.stringify(msg))
|
|
void stream.write(JSON.stringify(msg))
|
|
|
})
|
|
})
|
|
@@ -917,7 +917,9 @@ export const SessionRoutes = lazy(() =>
|
|
|
void runRequest(
|
|
void runRequest(
|
|
|
"SessionRoutes.prompt_async",
|
|
"SessionRoutes.prompt_async",
|
|
|
c,
|
|
c,
|
|
|
- SessionPrompt.Service.use((svc) => svc.prompt({ ...body, sessionID } as unknown as SessionPrompt.PromptInput)),
|
|
|
|
|
|
|
+ SessionPrompt.Service.use((svc) =>
|
|
|
|
|
+ svc.prompt({ ...body, sessionID } as unknown as SessionPrompt.PromptInput),
|
|
|
|
|
+ ),
|
|
|
).catch((err) => {
|
|
).catch((err) => {
|
|
|
log.error("prompt_async failed", { sessionID, error: err })
|
|
log.error("prompt_async failed", { sessionID, error: err })
|
|
|
void Bus.publish(Session.Event.Error, {
|
|
void Bus.publish(Session.Event.Error, {
|