export interface HttpErrorInit { status?: number; expose?: unknown; detail?: Record<string, unknown>;}
export class HttpError extends Error { status: number; expose: unknown; detail: Record<string, unknown>;
constructor(message: string, init?: HttpErrorInit) { super(message); this.status = init?.status || 500; this.expose = init?.expose || null; this.detail = init?.detail || {}; }}
export interface Serializer<I = unknown, O = unknown> { check(value: unknown): boolean; serialize(value: I): O; deserialize( raw: unknown, whenDone: (fn: (ready: O) => void) => void, ): I;}
export function serializer<I = unknown, O = unknown>( init: Serializer<I, O>,): Serializer<I, O> { return init;}
export type AnySerializer = Serializer<any, any>;
export type Serializers = Record<string, AnySerializer | null>;
export function isPojo(obj: unknown): obj is Record<string | symbol, unknown> { return ( !!obj && typeof obj === "object" && ( Object.getPrototypeOf(obj) === Object.prototype || Object.getPrototypeOf(obj) === null ) );}
function defaults(): Map<string, AnySerializer> { const sym = Symbol.for("defaults.serial.cav.bar"); const s = self as unknown as typeof self & { [sym]?: Map<string, AnySerializer>; };
const cached = s[sym]; if (cached) { return cached; }
Object.assign(self, { [sym]: new Map<string, AnySerializer>(Object.entries({ symbol: serializer({ check: (v) => typeof v === "symbol", serialize: (v: symbol) => { const key = Symbol.keyFor(v); if (typeof key === "string") { return { for: key }; } return { desc: v.description }; }, deserialize: (raw: { for: string } | { desc: string }) => { if ("for" in raw && typeof raw.for === "string") { return Symbol.for(raw.for); } return Symbol((raw as { desc: string }).desc); }, }), error: serializer({ check: (v) => v instanceof Error, serialize: (v: Error) => { if (v instanceof HttpError) { return { type: "HttpError", message: v.message, status: v.status, expose: v.expose, }; } switch (v.name) { case "EvalError": case "RangeError": case "ReferenceError": case "SyntaxError": case "TypeError": case "URIError": case "AggregateError": return { type: v.name, message: v.message }; default: return v.message; } }, deserialize: (raw: any, whenDone) => { if (typeof raw === "string") { return new Error(raw); } switch (raw.type) { case "HttpError": { const err = new HttpError(raw.message, { status: parseInt(raw.status, 10), }); whenDone((ready: any) => { err.expose = ready.expose; }); return err; } case "EvalError": return new EvalError(raw.message); case "RangeError": return new RangeError(raw.message); case "ReferenceError": return new ReferenceError(raw.message); case "SyntaxError": return new SyntaxError(raw.message); case "TypeError": return new TypeError(raw.message); case "URIError": return new URIError(raw.message); case "AggregateError": return new AggregateError(raw.message); default: return new Error(raw.message); } }, }), date: serializer({ check: (v) => v instanceof Date, serialize: (v: Date) => v.toJSON(), deserialize: (raw) => new Date(raw as string), }), undefined: serializer({ check: (v) => typeof v === "undefined", serialize: () => true, deserialize: () => undefined, }), map: serializer({ check: (v) => v instanceof Map, serialize: (v: Map<unknown, unknown>) => Array.from(v.entries()), deserialize: (_, whenDone) => { const map = new Map(); whenDone((entries) => { entries.forEach((v) => map.set(v[0], v[1])); }); return map; }, }), set: serializer({ check: (val) => val instanceof Set, serialize: (v: Set<unknown>) => Array.from(v.values()), deserialize: (_, whenDone) => { const set = new Set(); whenDone((values) => { values.forEach((v) => set.add(v)); }); return set; }, }), bigint: serializer({ check: (v) => typeof v === "bigint", serialize: (v: bigint) => v.toString(), deserialize: (raw) => BigInt(raw as string), }), regexp: serializer({ check: (v) => v instanceof RegExp, serialize: (v: RegExp) => v.toString(), deserialize: (raw) => { const r = (raw as string).slice(1).split("/"); return new RegExp(r[0], r[1]); }, }), number: serializer({ check: (v) => typeof v === "number" && ( isNaN(v) || v === Number.POSITIVE_INFINITY || v === Number.NEGATIVE_INFINITY || Object.is(v, -0) ), serialize: (v: number) => ( Object.is(v, -0) ? "-zero" : v === Number.POSITIVE_INFINITY ? "+infinity" : v === Number.NEGATIVE_INFINITY ? "-infinity" : "nan" ), deserialize: (raw: string) => ( raw === "-zero" ? -0 : raw === "+infinity" ? Number.POSITIVE_INFINITY : raw === "-infinity" ? Number.NEGATIVE_INFINITY : NaN ), }), conflict: serializer({ check: (v) => { if (!isPojo(v)) { return false; } const keys = Object.keys(v); return keys.length === 1 && keys[0].startsWith("$"); }, serialize: (v: Record<string, string>) => Object.entries(v)[0], deserialize: (_, whenDone) => { const result: Record<string, unknown> = {}; whenDone((entry) => { result[entry[0]] = entry[1]; }); return result; }, }), buffer: serializer({ check: (v) => v instanceof ArrayBuffer || ArrayBuffer.isView(v), serialize: (v: ArrayBufferView | ArrayBuffer) => { let base64 = ""; const data = new Uint8Array( v instanceof ArrayBuffer ? v : v.buffer, ); for (let i = 0; i < data.length; i++) { base64 += String.fromCharCode(data[i]); } return { type: v.constructor.name, data: self.btoa(base64), }; }, deserialize: (raw: { type: string; data: string }) => { const data = self.atob(raw.data); const buf = new Uint8Array(data.length); for (let i = 0; i < data.length; i++) { buf[i] = data.charCodeAt(i); } switch (raw.type) { case "ArrayBuffer": return buf.buffer; case "Int8Array": return new Int8Array(buf.buffer); case "Uint8Array": return new Uint8Array(buf.buffer); case "Uint8ClampedArray": return new Uint8ClampedArray(buf.buffer); case "Int16Array": return new Int16Array(buf.buffer); case "Uint16Array": return new Uint16Array(buf.buffer); case "Int32Array": return new Int32Array(buf.buffer); case "Uint32Array": return new Uint32Array(buf.buffer); case "Float32Array": return new Float32Array(buf.buffer); case "Float64Array": return new Float64Array(buf.buffer); case "BigInt64Array": return new BigInt64Array(buf.buffer); case "BigUint64Array": return new BigUint64Array(buf.buffer); case "DataView": return new DataView(buf.buffer); default: return buf; } }, }), })), });
return s[sym]!;}
function serializerMap(serializers?: Serializers): Map<string, AnySerializer> { if (!serializers) { return defaults(); }
const defs = defaults(); const smap = new Map<string, AnySerializer>(); for (const [k, v] of Object.entries(serializers)) { if (v === null) { continue; } if (k === "ref" || defs.has(k)) { throw new Error( `Conflict: The serializer key "${k}" is reserved`, ); } smap.set(k, v); } if (!smap.size) { return defs; } for (const [k, v] of defs.entries()) { smap.set(k, v); } return smap;}
export function serialize( value: unknown, serializers?: Serializers | null,): unknown { const smap = serializerMap(serializers || undefined); const paths = new Map<unknown, string[]>();
const pathString = (p: string[]) => ( p.map((v) => v.replace(/\./g, "\\.")).join(".") );
const recur = ( val: unknown, path: string[], ): unknown => { if (val && (typeof val === "object" || typeof val === "symbol")) { if (paths.has(val)) { return { $ref: pathString(paths.get(val)!) }; } paths.set(val, path); }
if ( val === null || typeof val === "string" || typeof val === "boolean" || (typeof val === "number" && !Object.is(val, -0) && Number.isFinite(val)) ) { return val; }
for (const [name, serializer] of smap.entries()) { if (serializer.check(val)) { const key = `$${name}`; return { [key]: recur(serializer.serialize(val), [...path, key]) }; } }
if (isPojo(val)) { const copy: Record<string, unknown> = {}; for (const [k, v] of Object.entries(val)) { copy[k] = recur(v, [...path, k]); } return copy; }
if (Array.isArray(val)) { const copy: unknown[] = []; for (let k = 0; k < val.length; k++) { copy[k] = recur(val[k], [...path, k.toString()]); } return copy; }
if ( typeof val === "object" && "toJSON" in val && typeof (val as { toJSON: unknown })["toJSON"] === "function" ) { return (val as { toJSON: (key: string) => unknown }).toJSON( path[path.length - 1], ); }
throw new TypeError( `No matching serializers for instance of "${(val as any).constructor.name}"`, ); };
return recur(value, [""]);}
export function deserialize<T = unknown>( value: unknown, serializers?: Serializers | null,): T { const smap = serializerMap(serializers || undefined); const objects = new Map<string, unknown>(); const whenDones: (() => void)[] = [];
const recur = (val: unknown, path: string) => { if (!val || typeof val !== "object") { return val; }
if (Array.isArray(val)) { const copy: unknown[] = []; objects.set(path, copy); for (let i = 0; i < val.length; i++) { copy.push(recur(val[i], path + "." + i.toString())); } return copy; }
if (!isPojo(val)) { throw new TypeError( `Non-plain objects can't be deserialized - Path: "${path}"`, ); }
const keys = Object.keys(val); if (keys.length === 1 && keys[0] === "$ref") { const refPath = (val as Record<string, string>).$ref; const ref = objects.get(refPath); if (!ref) { throw new Error( `Invalid reference "${refPath}" - Path: "${path}"`, ); } return ref; } if (keys.length === 1 && keys[0].startsWith("$")) { const tag = keys[0]; const name = keys[0].slice(1); const serializer = smap.get(name); if (!serializer) { throw new Error( `No matching serializer with name "${name}" - Path: "${path}"`, ); }
const raw = val[tag]; let serialized: unknown = undefined; const result = serializer.deserialize(raw, (fn) => { whenDones.push(() => fn(serialized)); }); if ( result && ( typeof result === "object" || typeof result === "symbol" ) ) { objects.set(path, result); } serialized = recur(raw, `${path}.${tag}`); return result; }
const copy: Record<string, unknown> = {}; objects.set(path, copy); for (const [k, v] of Object.entries(val)) { copy[k] = recur(v, path + "." + k.replace(/\./g, "\\.")); } return copy; };
const result = recur(value, ""); let fn = whenDones.pop(); while (fn) { fn(); fn = whenDones.pop(); } return result as T;}
interface PackedBody { body?: BodyInit | null; headers?: HeadersInit;}
function packBody(body: unknown): PackedBody { if ( body instanceof ReadableStream || body instanceof ArrayBuffer || ArrayBuffer.isView(body) || typeof body === "string" ) { return { body }; }
if (typeof body === "undefined" || body === null) { return { body, headers: { "content-type": "" }, }; }
if (body instanceof URLSearchParams) { return { body, headers: { "content-type": "application/x-www-form-urlencoded; charset=UTF-8", }, }; }
if (body instanceof FormData) { return { body, headers: { "content-type": "multipart/form-data; charset=UTF-8", }, }; }
if (body instanceof File) { return { body, headers: { "content-disposition": `attachment; filename="${body.name}"`, "content-type": body.type, }, }; }
if (body instanceof Blob) { return { body, headers: { "content-disposition": "attachment", "content-type": body.type, }, }; }
const form = new FormData(); const fileKeys = new Map<Blob, string>(); const json = JSON.stringify(serialize(body, { __blob: serializer({ check: (v) => v instanceof Blob, serialize: (v: Blob) => { let key = fileKeys.get(v); if (key) { return key; }
key = crypto.randomUUID(); form.set(key, v); fileKeys.set(v, key); return key; }, deserialize: () => null, }), })); if (!fileKeys.size) { return { body: json, headers: { "content-type": "application/json; charset=UTF-8" }, }; } form.set( "__shape", new File([json], "__shape.json", { type: "application/json; charset=UTF-8", }), ); return { body: form, headers: { "content-type": "multipart/form-data; charset=UTF-8" }, };}
function mergeHeaders(a?: HeadersInit, b?: HeadersInit) { const ah = new Headers(a); const bh = new Headers(b); for (const [k, v] of bh.entries()) { if (k === "content-type" || k === "content-disposition") { ah.set(k, v); } else { ah.append(k, v); } } return ah;}
export interface PackRequestInit extends Omit<RequestInit, "body" | "method"> { body?: unknown;}
declare const _packedRequest: unique symbol;
export interface PackedRequest< B = unknown, CT = unknown, CD = unknown,> extends Request { [_packedRequest]?: [B, CT, CD];}
export function packRequest<B = undefined, CT = undefined, CD = undefined>( url: string, init?: PackRequestInit & { body?: B; headers?: HeadersInit & { "content-type"?: CT; "content-disposition"?: CD; }; },): PackedRequest<B, CT, CD> { const packed = packBody(init?.body); return new Request(url, { ...init, method: typeof packed.body === "undefined" ? "GET" : "POST", headers: mergeHeaders(init?.headers, packed.headers), body: packed.body, });}
export type PackResponseInit = ResponseInit & { body?: unknown;};
declare const _packedResponse: unique symbol;
export interface PackedResponse< B = unknown, CT = unknown, CD = unknown,> extends Response { [_packedResponse]?: [B, CT, CD];}
export function packResponse<B = undefined, CT = undefined, CD = undefined>( init?: PackResponseInit & { body?: B; headers?: HeadersInit & { "content-type"?: CT; "content-disposition"?: CD; }; },): PackedResponse<B, CT, CD> { const body = init?.body; if (body instanceof Response) { const mergeHeaders = new Headers(init?.headers); for (const [k, v] of mergeHeaders.entries()) { body.headers.append(k, v); } return body as PackedResponse<B, CT, CD>; }
const packed = packBody(body); return new Response(packed.body, { status: typeof packed.body === "undefined" ? 204 : 200, ...init, headers: mergeHeaders(init?.headers, packed.headers), }) as PackedResponse<B, CT, CD>;}
export type Unpack<R> = ( R extends ( | PackedResponse<infer B, infer CT, infer CD> | PackedRequest<infer B, infer CT, infer CD> ) ? ( B extends ( | Response | ReadableStream | ArrayBuffer | ArrayBufferView | string ) ? ( CD extends `attachment; filename=${string}` ? File : CD extends `attachment${string}` ? Blob : CT extends `text/plain${string}` ? string : CT extends `application/x-www-form-urlencoded${string}` ? ( Record<string, string | string[]> ) : CT extends `multipart/form-data${string}` ? ( Record<string, string | File | (string | File)[]> ) : CT extends `application/json${string}` ? unknown : string extends CT ? unknown : CT extends string ? Blob : B extends string ? string : unknown ) : B extends URLSearchParams ? ( Record<string, string | string[]> ) : B extends FormData ? ( Record<string, string | File | (string | File)[]> ) : B ) : unknown);
const mimeString = /^text\/plain;?/;const mimeParams = /^application\/x-www-form-urlencoded;?/;const mimeJson = /^application\/json;?/;const mimeForm = /^multipart\/form-data;?/;
export interface UnpackOptions { maxBodySize?: number;}
export async function unpack<R extends Request | Response>( packed: R, opt?: UnpackOptions,): Promise<Unpack<R>> { if ( (packed instanceof Request && packed.method === "GET") || (packed instanceof Response && packed.status === 204) ) { return undefined as any; } if (!packed.body) { return null as any; }
const maxBodySize = ( typeof opt?.maxBodySize === "number" ? opt.maxBodySize : 1024 * 1024 ); const contentLength = parseInt(packed.headers.get("content-length")!, 10); if (isNaN(contentLength) && maxBodySize !== 0) { const reader = packed.body.getReader(); const op = packed; let size = 0; packed = new Response(new ReadableStream({ start: controller => { const pump = async (): Promise<void> => { const chunk = await reader.read(); if (chunk.done) { controller.close(); return; } if (chunk.value) { size += chunk.value.length; if (size > maxBodySize) { throw new HttpError("413 payload too large", { status: 413 }); } } controller.enqueue(chunk.value); return pump(); }; return pump(); }, }), { headers: op.headers }) as R; }
const type = packed.headers.get("content-type") || ""; const disposition = packed.headers.get("content-disposition"); if (disposition) { const match = disposition.match(/^attachment; filename="(.+)"/); if (match) { const filename = match[1]; return new File([await packed.blob()], filename, { type }) as any; } if (disposition.match(/^attachment;?/)) { return await packed.blob() as any; } }
const parseForm = (form: FormData) => { const result: Record<string, string | File | (string | File)[]> = {}; for (const [k, v] of form.entries()) { const old = result[k]; if (Array.isArray(old)) { old.push(v); } else if (typeof old === "undefined") { result[k] = v; } else { result[k] = [old, v]; } } return result; };
if (type.match(mimeString)) { return await packed.text() as any; } if (type.match(mimeParams)) { return parseForm(await packed.formData()) as any; } if (type.match(mimeJson)) { return deserialize(await packed.json()); } if (type.match(mimeForm)) { const form = await packed.formData(); const shape = form.get("__shape"); if ( !shape || !(shape instanceof Blob) || shape.type !== "application/json" ) { return parseForm(form) as any; } return deserialize(JSON.parse(await shape.text()), { __blob: serializer({ check: () => false, serialize: () => null, deserialize: (raw: string) => form.get(raw), }), }); }
return await packed.blob() as any;}