MCPX MCP Gateway

import { randomUUID } from "crypto"; import z from "zod/v4"; const metadataSchema = z.object({ id: z.string(), correlationId: z.string().optional(), }); export type Metadata = z.infer<typeof metadataSchema>; // Wraps a generic payload schema with an envelope containing metadata export function Envelope<T extends z.ZodTypeAny>( payload: T, ): z.ZodObject<{ metadata: typeof metadataSchema; payload: T }, z.core.$strip> { return z.object({ metadata: metadataSchema, payload, }); } // Type helper to extract the payload type from an enveloped schema export type EnvelopedMessage<T> = { metadata: Metadata; payload: T; }; // Utility function to wrap a payload with metadata export function wrapInEnvelope<T>( payload: T, id?: string, correlationId?: string, ): EnvelopedMessage<T> { return { metadata: { id: id || randomUUID(), correlationId, }, payload, }; } export function safeParseEnvelopedMessage<T>( payloadSchema: z.ZodType<T>, ): (enveloped: unknown) => z.ZodSafeParseResult<EnvelopedMessage<T>> { const envelopedSchema = Envelope(payloadSchema); return (enveloped: unknown) => { return envelopedSchema.safeParse(enveloped); }; }