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 67431x 13x 12733x 13x 8401x 8401x 8401x 8401x 8401x 8401x 8401x 8401x 48235x 48235x 3676x 3676x 3676x 1396x 1396x 5874x 5874x 4x 4x 4939x 4939x 1257x 1257x 3948x 3948x 2910x 2910x 6258x 6258x 6258x 6258x 6258x 17025x 17025x 6258x 6258x 2x 2x 2x 2x 2x 2x 2x 2x 2x 7243x 7243x 2798x 2798x 2827x 2827x 2827x 2827x 2827x 8578x 2827x 2827x 4007x 4007x 4007x 4007x 12733x 4007x 4007x 1096x 1096x 8401x 8401x 8401x | 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; }; |