|
|
@@ -263,10 +263,12 @@ export const sessionHandlers = HttpApiBuilder.group(InstanceHttpApi, "session",
|
|
|
const workspace = yield* InstanceState.workspaceID
|
|
|
return HttpServerResponse.stream(
|
|
|
Stream.fromEffect(
|
|
|
- promptSvc.prompt({
|
|
|
- ...ctx.payload,
|
|
|
- sessionID: ctx.params.sessionID,
|
|
|
- }).pipe(Effect.provideService(InstanceRef, instance), Effect.provideService(WorkspaceRef, workspace)),
|
|
|
+ promptSvc
|
|
|
+ .prompt({
|
|
|
+ ...ctx.payload,
|
|
|
+ sessionID: ctx.params.sessionID,
|
|
|
+ })
|
|
|
+ .pipe(Effect.provideService(InstanceRef, instance), Effect.provideService(WorkspaceRef, workspace)),
|
|
|
).pipe(
|
|
|
Stream.map((message) => JSON.stringify(message)),
|
|
|
Stream.encodeText,
|