Function readRequestBody

packages/plugins/mcp/src/testing/server.ts:63–75

(
  request: http.IncomingMessage,
)

};

const readRequestBody = (
  request: http.IncomingMessage,
): Effect.Effect<string, McpTestServerError> =>
  Effect.tryPromise({
    try: () =>
      new Promise<string>((resolve, reject) => {
        const chunks: Buffer[] = [];
        request.on("data", (chunk: Buffer) => chunks.push(chunk));
        request.on("end", () => resolve(Buffer.concat(chunks).toString("utf8")));
        request.on("error", reject);
      }),
    catch: (cause) => new McpTestServerError({ cause }),
  });

const decodeJsonBody = Schema.decodeUnknownOption(Schema.fromJsonString(Schema.Unknown));