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 68724x 13x 13557x 13x 8782x 8782x 8782x 8782x 8782x 8782x 8782x 8782x 49172x 49172x 3837x 3837x 3837x 1369x 1369x 5970x 5970x 4x 4x 4840x 4840x 1365x 1365x 3967x 3967x 2917x 2917x 6478x 6478x 6478x 6478x 6478x 17555x 17555x 6478x 6478x 2x 2x 2x 2x 2x 2x 2x 2x 2x 7526x 7526x 2696x 2696x 2840x 2840x 2840x 2840x 2840x 8429x 2840x 2840x 4297x 4297x 4297x 4297x 13557x 4297x 4297x 1064x 1064x 8782x 8782x 8782x | 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;
};
|