(request: Request, program: Effect.Effect<A>)
| 160 | // (via Effect.currentParentSpan) ferry that same trace into the session DO |
| 161 | // instead of letting the DO start a fresh root per request. |
| 162 | const runTraced = <A>(request: Request, program: Effect.Effect<A>): Promise<A> => { |
| 163 | const parsed = parseTraceparent( |
| 164 | request.headers.get("traceparent"), |
| 165 | request.headers.get("tracestate"), |
| 166 | ); |
| 167 | return Effect.runPromise( |
| 168 | (parsed ? OtelTracer.withSpanContext(program, parsed) : program).pipe( |
| 169 | Effect.provide(WorkerTelemetryLive), |
| 170 | ), |
| 171 | ); |
| 172 | }; |
| 173 | |
| 174 | type TraceCloudMcpRequest = ( |
| 175 | request: Request, |
no test coverage detected