feat: add more codecs

Add 6 new codecs: dag-json, dag-cbor, bencode, resp, bson, ejson

Author: streamich

src/CliCodecs.ts

@@ -1,6 +1,6 @@
 import type {CliCodec} from './types';
 
-const CODEC_REGEX = /(\w{0,32})(?:\:(\w{0,32}))?/;
+const CODEC_REGEX = /([\w-]{0,32})(?:\:([\w-]{0,32}))?/;
 
 export class CliCodecs {
   public defaultCodec: string = 'json4';

src/codecs/bencode.ts

@@ -0,0 +1,24 @@
+import {BencodeDecoder} from '@jsonjoy.com/json-pack/lib/bencode/BencodeDecoder';
+import {BencodeEncoder} from '@jsonjoy.com/json-pack/lib/bencode/BencodeEncoder';
+import type {Writer} from '@jsonjoy.com/util/lib/buffers/Writer';
+import type {CliCodec} from '../types';
+
+export class CliCodecBencode implements CliCodec<'bencode'> {
+  public readonly id = 'bencode';
+  public readonly description = 'Bencode: Bittorrent serialization format';
+  protected readonly encoder: BencodeEncoder;
+  protected readonly decoder: BencodeDecoder;
+
+  constructor(protected readonly writer: Writer) {
+    this.encoder = new BencodeEncoder(writer);
+    this.decoder = new BencodeDecoder();
+  }
+
+  encode(value: unknown): Uint8Array {
+    return this.encoder.encode(value);
+  }
+
+  decode(bytes: Uint8Array): unknown {
+    return this.decoder.read(bytes);
+  }
+}

src/codecs/bson.ts

@@ -0,0 +1,24 @@
+import {BsonDecoder} from '@jsonjoy.com/json-pack/lib/bson/BsonDecoder';
+import {BsonEncoder} from '@jsonjoy.com/json-pack/lib/bson/BsonEncoder';
+import type {Writer} from '@jsonjoy.com/util/lib/buffers/Writer';
+import type {CliCodec} from '../types';
+
+export class CliCodecBson implements CliCodec<'bson'> {
+  public readonly id = 'bson';
+  public readonly description = 'BSON: MongoDB binary format';
+  protected readonly encoder: BsonEncoder;
+  protected readonly decoder: BsonDecoder;
+
+  constructor(protected readonly writer: Writer) {
+    this.encoder = new BsonEncoder(writer);
+    this.decoder = new BsonDecoder();
+  }
+
+  encode(value: unknown): Uint8Array {
+    return this.encoder.encode(value);
+  }
+
+  decode(bytes: Uint8Array): unknown {
+    return this.decoder.read(bytes);
+  }
+}

src/codecs/dag-cbor.ts

@@ -0,0 +1,24 @@
+import {CborDecoderDag} from '@jsonjoy.com/json-pack/lib/cbor/CborDecoderDag';
+import {CborEncoderDag} from '@jsonjoy.com/json-pack/lib/cbor/CborEncoderDag';
+import type {Writer} from '@jsonjoy.com/util/lib/buffers/Writer';
+import type {CliCodec} from '../types';
+
+export class CliCodecDagCbor implements CliCodec<'dag-cbor'> {
+  public readonly id = 'dag-cbor';
+  public readonly description = 'DAG-CBOR: deterministic CBOR codec';
+  protected readonly encoder: CborEncoderDag;
+  protected readonly decoder: CborDecoderDag;
+
+  constructor(protected readonly writer: Writer) {
+    this.encoder = new CborEncoderDag(writer);
+    this.decoder = new CborDecoderDag();
+  }
+
+  encode(value: unknown): Uint8Array {
+    return this.encoder.encode(value);
+  }
+
+  decode(bytes: Uint8Array): unknown {
+    return this.decoder.read(bytes);
+  }
+}

src/codecs/dag-json.ts

@@ -0,0 +1,24 @@
+import {JsonDecoderDag} from '@jsonjoy.com/json-pack/lib/json/JsonDecoderDag';
+import {JsonEncoderDag} from '@jsonjoy.com/json-pack/lib/json/JsonEncoderDag';
+import type {Writer} from '@jsonjoy.com/util/lib/buffers/Writer';
+import type {CliCodec} from '../types';
+
+export class CliCodecDagJson implements CliCodec<'dag-json'> {
+  public readonly id = 'dag-json';
+  public readonly description = 'DAG-JSON: deterministic JSON codec';
+  protected readonly encoder: JsonEncoderDag;
+  protected readonly decoder: JsonDecoderDag;
+
+  constructor(protected readonly writer: Writer) {
+    this.encoder = new JsonEncoderDag(writer);
+    this.decoder = new JsonDecoderDag();
+  }
+
+  encode(value: unknown): Uint8Array {
+    return this.encoder.encode(value);
+  }
+
+  decode(bytes: Uint8Array): unknown {
+    return this.decoder.read(bytes);
+  }
+}

src/codecs/ejson.ts

@@ -0,0 +1,24 @@
+import {EjsonDecoder} from '@jsonjoy.com/json-pack/lib/ejson/EjsonDecoder';
+import {EjsonEncoder} from '@jsonjoy.com/json-pack/lib/ejson/EjsonEncoder';
+import type {Writer} from '@jsonjoy.com/util/lib/buffers/Writer';
+import type {CliCodec} from '../types';
+
+export class CliCodecEjson implements CliCodec<'ejson'> {
+  public readonly id = 'ejson';
+  public readonly description = 'EJSON v2: MongoDB text variant of BSON';
+  protected readonly encoder: EjsonEncoder;
+  protected readonly decoder: EjsonDecoder;
+
+  constructor(protected readonly writer: Writer) {
+    this.encoder = new EjsonEncoder(writer);
+    this.decoder = new EjsonDecoder();
+  }
+
+  encode(value: unknown): Uint8Array {
+    return this.encoder.encode(value);
+  }
+
+  decode(bytes: Uint8Array): unknown {
+    return this.decoder.read(bytes);
+  }
+}

src/codecs/resp.ts

@@ -0,0 +1,24 @@
+import {RespDecoder} from '@jsonjoy.com/json-pack/lib/resp/RespDecoder';
+import {RespEncoder} from '@jsonjoy.com/json-pack/lib/resp/RespEncoder';
+import type {Writer} from '@jsonjoy.com/util/lib/buffers/Writer';
+import type {CliCodec} from '../types';
+
+export class CliCodecResp implements CliCodec<'resp'> {
+  public readonly id = 'resp';
+  public readonly description = 'RESP3: Redis serialization format';
+  protected readonly encoder: RespEncoder;
+  protected readonly decoder: RespDecoder;
+
+  constructor(protected readonly writer: Writer) {
+    this.encoder = new RespEncoder(writer);
+    this.decoder = new RespDecoder();
+  }
+
+  encode(value: unknown): Uint8Array {
+    return this.encoder.encode(value);
+  }
+
+  decode(bytes: Uint8Array): unknown {
+    return this.decoder.read(bytes);
+  }
+}

src/defaultCodecs.ts

@@ -10,6 +10,12 @@ import {CliCodecText} from './codecs/text';
 import {CliCodecTree} from './codecs/tree';
 import {CliCodecUbjson} from './codecs/ubjson';
 import {CliCodecHex} from './codecs/hex';
+import {CliCodecDagJson} from './codecs/dag-json';
+import {CliCodecDagCbor} from './codecs/dag-cbor';
+import {CliCodecBencode} from './codecs/bencode';
+import {CliCodecResp} from './codecs/resp';
+import {CliCodecBson} from './codecs/bson';
+import {CliCodecEjson} from './codecs/ejson';
 
 export const defaultCodecs = new CliCodecs();
 
@@ -24,3 +30,9 @@ defaultCodecs.register(new CliCodecText());
 defaultCodecs.register(new CliCodecTree());
 defaultCodecs.register(new CliCodecRaw());
 defaultCodecs.register(new CliCodecHex());
+defaultCodecs.register(new CliCodecDagJson(writer));
+defaultCodecs.register(new CliCodecDagCbor(writer));
+defaultCodecs.register(new CliCodecBencode(writer));
+defaultCodecs.register(new CliCodecResp(writer));
+defaultCodecs.register(new CliCodecBson(writer));
+defaultCodecs.register(new CliCodecEjson(writer));