Function readJsonRpcEnvelope

apps/cloud/src/mcp/telemetry.ts:130–138

(request: Request)

const decodeElicitationReplyResult = Schema.decodeUnknownOption(ElicitationReplyResult);

const readJsonRpcEnvelope = (request: Request): Effect.Effect<Option.Option<JsonRpcEnvelope>> =>
  Effect.tryPromise({
    try: () => request.clone().text(),
    catch: () => undefined,
  }).pipe(
    Effect.map((text) => (text ? decodeJsonRpcEnvelopeString(text) : Option.none())),
    Effect.catchCause(() => Effect.succeed(Option.none())),
    Effect.withSpan("mcp.request.read_json_rpc"),
  );

// Managed-cloud capture of the executed script, on the `mcp.request` span
// beside the client fingerprint. This module is cloud-only by construction —