{"version":3,"file":"codec.d.ts","sourceRoot":"","sources":["../src/codec.ts"],"names":[],"mappings":"AAGA,OAAO,EAAuD,KAAK,mBAAmB,EAAE,MAAM,cAAc,CAAC;AAC7G,OAAO,EACN,KAAK,aAAa,EAElB,gBAAgB,EAChB,KAAK,aAAa,EAElB,MAAM,eAAe,CAAC;AAEvB,qBAAa,uBAAwB,SAAQ,KAAK;IACjD,YAAY,OAAO,EAAE,MAAM,EAG1B;CACD;AAED,wBAAgB,kBAAkB,CAAC,KAAK,EAAE,OAAO,GAAG,aAAa,CAKhE;AAED,wBAAgB,kBAAkB,CAAC,KAAK,EAAE,OAAO,GAAG,aAAa,CAKhE;AAuBD,yEAAyE;AACzE,wBAAgB,mBAAmB,CAAC,OAAO,EAAE,aAAa,EAAE,OAAO,CAAC,EAAE,mBAAmB,GAAG,UAAU,CAErG;AAED,yEAAyE;AACzE,wBAAgB,mBAAmB,CAAC,OAAO,EAAE,aAAa,EAAE,OAAO,CAAC,EAAE,mBAAmB,GAAG,UAAU,CAErG;AA0CD,kEAAkE;AAClE,qBAAa,oBAAoB;IAChC,OAAO,CAAC,QAAQ,CAAC,OAAO,CAAyC;IAEjE,YAAY,OAAO,CAAC,EAAE,mBAAmB,EAExC;IAED,IAAI,CAAC,KAAK,EAAE,UAAU,GAAG,aAAa,EAAE,CAEvC;IAED,GAAG,IAAI,IAAI,CAEV;CACD;AAED,kEAAkE;AAClE,qBAAa,oBAAoB;IAChC,OAAO,CAAC,QAAQ,CAAC,OAAO,CAAyC;IAEjE,YAAY,OAAO,CAAC,EAAE,mBAAmB,EAExC;IAED,IAAI,CAAC,KAAK,EAAE,UAAU,GAAG,aAAa,EAAE,CAEvC;IAED,GAAG,IAAI,IAAI,CAEV;CACD;AAED,wBAAgB,0BAA0B,CAAC,OAAO,EAAE,MAAM,GAAG,OAAO,IAAI,OAAO,gBAAgB,CAE9F","sourcesContent":["import { isJsonValue } from \"@earendil-works/chord\";\nimport { Check } from \"typebox/value\";\nimport { decodeCbor, encodeCbor } from \"./cbor/index.ts\";\nimport { DEFAULT_MAX_FRAME_LENGTH, encodeFrame, FrameDecoder, type FrameDecoderOptions } from \"./framing.ts\";\nimport {\n\ttype ClientMessage,\n\tClientMessageSchema,\n\tPROTOCOL_VERSION,\n\ttype ServerMessage,\n\tServerMessageSchema,\n} from \"./protocol.ts\";\n\nexport class ProtocolValidationError extends Error {\n\tconstructor(message: string) {\n\t\tsuper(message);\n\t\tthis.name = \"ProtocolValidationError\";\n\t}\n}\n\nexport function parseClientMessage(value: unknown): ClientMessage {\n\tif (!Check(ClientMessageSchema, value) || !isJsonValue(value)) {\n\t\tthrow new ProtocolValidationError(\"Invalid client protocol message\");\n\t}\n\treturn value;\n}\n\nexport function parseServerMessage(value: unknown): ServerMessage {\n\tif (!Check(ServerMessageSchema, value) || !isJsonValue(value)) {\n\t\tthrow new ProtocolValidationError(\"Invalid server protocol message\");\n\t}\n\treturn value;\n}\n\nfunction boundedErrorMessage(error: unknown): string {\n\tif (!(error instanceof Error)) return \"Unknown codec error\";\n\treturn error.message.length <= 500 ? error.message : `${error.message.slice(0, 497)}...`;\n}\n\nfunction encodeProtocolMessage<T>(\n\tvalue: T,\n\tparse: (candidate: unknown) => T,\n\tkind: string,\n\toptions?: FrameDecoderOptions,\n): Uint8Array {\n\tconst validated = parse(value);\n\ttry {\n\t\tconst maxFrameLength = options?.maxFrameLength ?? DEFAULT_MAX_FRAME_LENGTH;\n\t\treturn encodeFrame(encodeCbor(validated, { maxByteLength: maxFrameLength }));\n\t} catch (error) {\n\t\tif (error instanceof ProtocolValidationError) throw error;\n\t\tthrow new ProtocolValidationError(`Unable to encode ${kind} protocol message: ${boundedErrorMessage(error)}`);\n\t}\n}\n\n/** Validates and encodes one complete length-prefixed client message. */\nexport function encodeClientMessage(message: ClientMessage, options?: FrameDecoderOptions): Uint8Array {\n\treturn encodeProtocolMessage(message, parseClientMessage, \"client\", options);\n}\n\n/** Validates and encodes one complete length-prefixed server message. */\nexport function encodeServerMessage(message: ServerMessage, options?: FrameDecoderOptions): Uint8Array {\n\treturn encodeProtocolMessage(message, parseServerMessage, \"server\", options);\n}\n\nclass ValidatedMessageDecoder<T> {\n\tprivate failed = false;\n\tprivate readonly frames: FrameDecoder;\n\tprivate readonly kind: string;\n\tprivate readonly maxFrameLength: number;\n\tprivate readonly parse: (candidate: unknown) => T;\n\n\tconstructor(kind: string, parse: (candidate: unknown) => T, options?: FrameDecoderOptions) {\n\t\tthis.frames = new FrameDecoder(options);\n\t\tthis.kind = kind;\n\t\tthis.maxFrameLength = options?.maxFrameLength ?? DEFAULT_MAX_FRAME_LENGTH;\n\t\tthis.parse = parse;\n\t}\n\n\tpush(chunk: Uint8Array): T[] {\n\t\tif (this.failed) throw new ProtocolValidationError(`${this.kind} message decoder has failed`);\n\t\ttry {\n\t\t\tconst messages: T[] = [];\n\t\t\tfor (const frame of this.frames.push(chunk)) {\n\t\t\t\tmessages.push(this.parse(decodeCbor(frame, { maxByteLength: this.maxFrameLength })));\n\t\t\t}\n\t\t\treturn messages;\n\t\t} catch (error) {\n\t\t\tthis.failed = true;\n\t\t\tif (error instanceof ProtocolValidationError) throw error;\n\t\t\tthrow new ProtocolValidationError(`Invalid ${this.kind} protocol frame: ${boundedErrorMessage(error)}`);\n\t\t}\n\t}\n\n\tend(): void {\n\t\tif (this.failed) throw new ProtocolValidationError(`${this.kind} message decoder has failed`);\n\t\ttry {\n\t\t\tthis.frames.end();\n\t\t} catch (error) {\n\t\t\tthis.failed = true;\n\t\t\tthrow new ProtocolValidationError(`Invalid ${this.kind} protocol framing: ${boundedErrorMessage(error)}`);\n\t\t}\n\t}\n}\n\n/** Incrementally decodes and validates framed client messages. */\nexport class ClientMessageDecoder {\n\tprivate readonly decoder: ValidatedMessageDecoder<ClientMessage>;\n\n\tconstructor(options?: FrameDecoderOptions) {\n\t\tthis.decoder = new ValidatedMessageDecoder(\"client\", parseClientMessage, options);\n\t}\n\n\tpush(chunk: Uint8Array): ClientMessage[] {\n\t\treturn this.decoder.push(chunk);\n\t}\n\n\tend(): void {\n\t\tthis.decoder.end();\n\t}\n}\n\n/** Incrementally decodes and validates framed server messages. */\nexport class ServerMessageDecoder {\n\tprivate readonly decoder: ValidatedMessageDecoder<ServerMessage>;\n\n\tconstructor(options?: FrameDecoderOptions) {\n\t\tthis.decoder = new ValidatedMessageDecoder(\"server\", parseServerMessage, options);\n\t}\n\n\tpush(chunk: Uint8Array): ServerMessage[] {\n\t\treturn this.decoder.push(chunk);\n\t}\n\n\tend(): void {\n\t\tthis.decoder.end();\n\t}\n}\n\nexport function isSupportedProtocolVersion(version: number): version is typeof PROTOCOL_VERSION {\n\treturn Number.isInteger(version) && version === PROTOCOL_VERSION;\n}\n"]}