Press n or j to go to the next uncovered block, b, p or k for the previous block.
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 | 13x 13x 13x 13x 13x 13x 68965x 13x 14191x 13x 8872x 8872x 8872x 8872x 8872x 8872x 8872x 8872x 48885x 48885x 3723x 3723x 3723x 1385x 1385x 5942x 5942x 4x 4x 4848x 4848x 1332x 1332x 3852x 3852x 2772x 2772x 6331x 6331x 6331x 6331x 6331x 17533x 17533x 6331x 6331x 2x 2x 2x 2x 2x 2x 2x 2x 2x 7393x 7393x 2837x 2837x 2946x 2946x 2946x 2946x 2946x 8828x 2946x 2946x 4370x 4370x 4370x 4370x 14191x 4370x 4370x 1148x 1148x 8872x 8872x 8872x | import {JsonCrdtPatchOpcode} from '../../constants';
import {fromBase64} from '@jsonjoy.com/base64/lib/fromBase64';
import {
type ITimespanStruct,
type ITimestampStruct,
ClockVector,
ServerClockVector,
Timespan,
Timestamp,
} from '../../clock';
import type {Patch} from '../../Patch';
import {PatchBuilder} from '../../PatchBuilder';
import {SESSION} from '../../constants';
import type * as types from './types';
const timestamp = (sid: number, x: types.CompactCodecTimestamp): ITimestampStruct => {
return Array.isArray(x) ? new Timestamp(x[0], x[1]) : new Timestamp(sid, x);
};
const timespan = (sid: number, span: types.CompactCodecTimespan): ITimespanStruct => {
return span.length === 3 ? new Timespan(span[0], span[1], span[2]) : new Timespan(sid, span[0], span[1]);
};
/**
* Decodes a JSON CRDT Patch from a "compact" POJO into a {@link Patch} instance.
*
* @param data A JavaScript POJO array in the compact codec format.
* @returns A decoded patch.
*/
export const decode = (data: types.CompactCodecPatch): Patch => {
const header = data[0];
const x = header[0];
const clock = Array.isArray(x) ? new ClockVector(x[0], x[1]) : new ServerClockVector(SESSION.SERVER, x as number);
const sid = clock.sid;
const time = clock.time;
const builder = new PatchBuilder(clock);
const length = data.length;
for (let i = 1; i < length; i++) {
const op = data[i] as types.CompactCodecOperation;
switch (op[0]) {
case JsonCrdtPatchOpcode.new_con: {
const [, value, isTimestamp] = op;
builder.const(isTimestamp ? timestamp(sid, value as types.CompactCodecTimestamp) : value);
break;
}
case JsonCrdtPatchOpcode.new_val: {
builder.val();
break;
}
case JsonCrdtPatchOpcode.new_obj: {
builder.obj();
break;
}
case JsonCrdtPatchOpcode.new_vec: {
builder.vec();
break;
}
case JsonCrdtPatchOpcode.new_str: {
builder.str();
break;
}
case JsonCrdtPatchOpcode.new_bin: {
builder.bin();
break;
}
case JsonCrdtPatchOpcode.new_arr: {
builder.arr();
break;
}
case JsonCrdtPatchOpcode.ins_val: {
builder.setVal(timestamp(sid, op[1]), timestamp(sid, op[2]));
break;
}
case JsonCrdtPatchOpcode.ins_obj: {
const obj = timestamp(sid, op[1]);
const tuples: [key: string, value: ITimestampStruct][] = [];
const value = op[2];
const length = value.length;
for (let j = 0; j < length; j++) {
const [key, x] = value[j];
tuples.push([key, timestamp(sid, x)]);
}
builder.insObj(obj, tuples);
break;
}
case JsonCrdtPatchOpcode.ins_vec: {
const obj = timestamp(sid, op[1]);
const tuples: [key: number, value: ITimestampStruct][] = [];
const value = op[2];
const length = value.length;
for (let j = 0; j < length; j++) {
const [key, x] = value[j];
tuples.push([key, timestamp(sid, x)]);
}
builder.insVec(obj, tuples);
break;
}
case JsonCrdtPatchOpcode.ins_str: {
builder.insStr(timestamp(sid, op[1]), timestamp(sid, op[2]), op[3]);
break;
}
case JsonCrdtPatchOpcode.ins_bin: {
builder.insBin(timestamp(sid, op[1]), timestamp(sid, op[2]), fromBase64(op[3]));
break;
}
case JsonCrdtPatchOpcode.ins_arr: {
const obj = timestamp(sid, op[1]);
const ref = timestamp(sid, op[2]);
const value = op[3];
const elements: ITimestampStruct[] = [];
const length = value.length;
for (let j = 0; j < length; j++) elements.push(timestamp(sid, value[j]));
builder.insArr(obj, ref, elements);
break;
}
case JsonCrdtPatchOpcode.del: {
const obj = timestamp(sid, op[1]);
const spans = op[2];
const what: ITimespanStruct[] = [];
const length = spans.length;
for (let i = 0; i < length; i++) what.push(timespan(sid, spans[i]));
builder.del(obj, what);
break;
}
case JsonCrdtPatchOpcode.nop: {
builder.nop(op[1] || 1);
break;
}
}
}
const patch = builder.patch;
patch.meta = header[1];
return patch;
};
|