File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -31,14 +31,11 @@ export namespace Observability {
3131
3232 export const layer = ! base
3333 ? EffectLogger . layer
34- : Layer . mergeAll (
35- EffectLogger . layer ,
36- Otlp . layerJson ( {
37- baseUrl : base ,
38- loggerExportInterval : Duration . seconds ( 1 ) ,
39- loggerMergeWithExisting : true ,
40- resource,
41- headers,
42- } ) ,
43- ) . pipe ( Layer . provide ( FetchHttpClient . layer ) )
34+ : Otlp . layerJson ( {
35+ baseUrl : base ,
36+ loggerExportInterval : Duration . seconds ( 1 ) ,
37+ loggerMergeWithExisting : true ,
38+ resource,
39+ headers,
40+ } ) . pipe ( Layer . provide ( EffectLogger . layer ) , Layer . provide ( FetchHttpClient . layer ) )
4441}
Original file line number Diff line number Diff line change @@ -13,6 +13,7 @@ import { SessionShare } from "@/share/session"
1313import { SessionStatus } from "@/session/status"
1414import { SessionSummary } from "@/session/summary"
1515import { Todo } from "../../session/todo"
16+ import { AppRuntime } from "../../effect/app-runtime"
1617import { Agent } from "../../agent/agent"
1718import { Snapshot } from "@/snapshot"
1819import { Command } from "../../command"
@@ -185,7 +186,7 @@ export const SessionRoutes = lazy(() =>
185186 ) ,
186187 async ( c ) => {
187188 const sessionID = c . req . valid ( "param" ) . sessionID
188- const todos = await Todo . get ( sessionID )
189+ const todos = await AppRuntime . runPromise ( Todo . Service . use ( ( svc ) => svc . get ( sessionID ) ) )
189190 return c . json ( todos )
190191 } ,
191192 )
Original file line number Diff line number Diff line change 11import { BusEvent } from "@/bus/bus-event"
22import { Bus } from "@/bus"
3- import { makeRuntime } from "@/effect/run-service"
43import { SessionID } from "./schema"
54import { Effect , Layer , ServiceMap } from "effect"
65import z from "zod"
@@ -83,9 +82,4 @@ export namespace Todo {
8382 )
8483
8584 export const defaultLayer = layer . pipe ( Layer . provide ( Bus . layer ) )
86- const { runPromise } = makeRuntime ( Service , defaultLayer )
87-
88- export async function get ( sessionID : SessionID ) {
89- return runPromise ( ( svc ) => svc . get ( sessionID ) )
90- }
9185}
You can’t perform that action at this time.
0 commit comments