( failure: DurableObjectFailure, operation: string, )
| 102 | * unrecognized failure never reaches here and keeps escaping as before. |
| 103 | */ |
| 104 | const recordDurableObjectFailure = ( |
| 105 | failure: DurableObjectFailure, |
| 106 | operation: string, |
| 107 | ): Effect.Effect<void> => |
| 108 | Effect.sync(() => { |
| 109 | console.warn( |
| 110 | JSON.stringify({ |
| 111 | event: "mcp_durable_object_platform_failure", |
| 112 | operation, |
| 113 | resetKind: failure.kind, |
| 114 | disposition: failure.disposition, |
| 115 | }), |
| 116 | ); |
| 117 | }).pipe( |
| 118 | Effect.withSpan("mcp.do.platform_failure", { |
| 119 | attributes: { |
| 120 | "mcp.do.reset_kind": failure.kind, |
| 121 | "mcp.do.reset_disposition": failure.disposition, |
| 122 | "mcp.do.reset_operation": operation, |
| 123 | }, |
| 124 | }), |
| 125 | ); |
| 126 | |
| 127 | const authenticate = (request: Request) => |
| 128 | Effect.gen(function* () { |
no test coverage detected