Class CompressedJSON

src/CompressedJSON.ts:54–328

};

export class CompressedJSON {
    private _rootValue: Value | undefined;

    private _ctx: Context | undefined;
    private _contextStack: Context[] = [];

    private _strings: string[] = [];
    private _stringValues: { [str: string]: Value } = {};
    private _objects: Value[][] = [];
    private _arrays: Value[][] = [];

    constructor(
        private readonly _makeDate: boolean,
        private readonly _makeTime: boolean,
        private readonly _makeDateTime: boolean
    ) {}

    async readFromStream(readStream: stream.Readable): Promise<Value> {
        const jsonSource = makeSource();
        jsonSource.on("startObject", this.handleStartObject);
        jsonSource.on("endObject", this.handleEndObject);
        jsonSource.on("startArray", this.handleStartArray);
        jsonSource.on("endArray", this.handleEndArray);
        jsonSource.on("startKey", this.handleStartKey);
        jsonSource.on("endKey", this.handleEndKey);
        jsonSource.on("startString", this.handleStartString);
        jsonSource.on("stringChunk", this.handleStringChunk);
        jsonSource.on("endString", this.handleEndString);
        jsonSource.on("startNumber", this.handleStartNumber);
        jsonSource.on("numberChunk", this.handleNumberChunk);
        jsonSource.on("endNumber", this.handleEndNumber);
        jsonSource.on("nullValue", this.handleNullValue);
        jsonSource.on("trueValue", this.handleTrueValue);
        jsonSource.on("falseValue", this.handleFalseValue);
        const promise = new Promise<Value>(resolve => {
            jsonSource.on("end", () => {
                resolve(this.finish());
            });
        });
        readStream.setEncoding("utf8");
        readStream.pipe(jsonSource.input);
        readStream.resume();
        return promise;
    }

    getStringForValue = (v: Value): string => {
        return this._strings[getIndex(v, Tag.InternedString)];
    };

    getObjectForValue = (v: Value): Value[] => {
        return this._objects[getIndex(v, Tag.Object)];
    };

    getArrayForValue = (v: Value): Value[] => {
        return this._arrays[getIndex(v, Tag.Array)];
    };

    private internString = (s: string): Value => {