test(json-crdt): 💍 run latest editing traces and run fuzzer traces

Author: streamich

package.json

@@ -117,7 +117,7 @@
     "js-base64": "^3.7.2",
     "js-sdsl": "^4.4.0",
     "jsbi": "^4.3.0",
-    "json-crdt-traces": "https://github.com/streamich/json-crdt-traces#5f68a13baf798897d39b87d7028b0b3cd5a50a6c",
+    "json-crdt-traces": "https://github.com/streamich/json-crdt-traces#02718a7a5d09e0dc6c31ea7d45a9ce3cbb0bf085",
     "json-logic-js": "^2.0.1",
     "json-pack-napi": "^0.0.2",
     "load-script": "^2.0.0",

src/json-crdt/__bench__/util/fuzzer-traces.ts

@@ -0,0 +1,20 @@
+import * as path from 'path';
+import * as fs from 'fs';
+import {Patch} from '../../../json-crdt-patch';
+import {CborDecoder} from '../../../json-pack/cbor/CborDecoder';
+import {Model} from '../../model';
+import {bufferToUint8Array} from '../../../util/buffers/bufferToUint8Array';
+
+export const loadFuzzerTrace = (traceName: string): [batch: Patch[], model: Model] => {
+  const root = path.resolve(__dirname, '..', '..', '..', '..');
+  const dir = path.join(root, 'node_modules', 'json-crdt-traces', 'traces', 'fuzzer', 'processed', traceName);
+  const patchFile = path.join(dir, 'patches.bin');
+  const modelFile = path.join(dir, 'model.bin');
+  const buf = fs.readFileSync(patchFile);
+  const modelBuf = bufferToUint8Array(fs.readFileSync(modelFile));
+  const model = Model.fromBinary(modelBuf);
+  const cborDecoder = new CborDecoder();
+  const data = cborDecoder.read(buf) as Uint8Array[];
+  const batch = data.map((blob) => Patch.fromBinary(blob));
+  return [batch, model];
+};

src/json-crdt/__tests__/editing-traces.spec.ts

@@ -3,6 +3,7 @@ import {sequentialTraceNames, traces} from '../__bench__/util/traces';
 import {editors} from '../__bench__/util/editors';
 import {Model} from '../model';
 import {loadConcurrentTrace} from '../__bench__/util/concurrent-trace';
+import {loadFuzzerTrace} from '../__bench__/util/fuzzer-traces';
 
 describe('sequential traces', () => {
   const editor = editors['json-joy'];
@@ -15,7 +16,7 @@ describe('sequential traces', () => {
   }
 });
 
-describe.skip('concurrent traces', () => {
+describe('concurrent traces', () => {
   const traces: string[] = ['friendsforever'];
   for (const traceName of traces) {
     test(`"${traceName}" trace`, async () => {
@@ -26,3 +27,27 @@ describe.skip('concurrent traces', () => {
     });
   }
 });
+
+describe('fuzzer traces', () => {
+  const traces = [
+    <const>'trace-1',
+    <const>'trace-2',
+    <const>'trace-3',
+    <const>'long',
+    <const>'short',
+    <const>'low-concurrency',
+    <const>'high-concurrency',
+    <const>'str-only',
+    <const>'bin-only',
+  ];
+
+  for (const traceName of traces) {
+    test(`"${traceName}" trace`, async () => {
+      const [batch, doc] = loadFuzzerTrace(traceName);
+      const model = Model.withLogicalClock(1000000);
+      model.applyBatch(batch);
+      expect(Model.fromBinary(model.toBinary()).toString()).toBe(doc.toString());
+      expect(model.view()).toStrictEqual(doc.view());
+    });
+  }
+});

yarn.lock

@@ -3664,9 +3664,9 @@ jsesc@^2.5.1:
   resolved "https://registry.yarnpkg.com/jsesc/-/jsesc-2.5.2.tgz#80564d2e483dacf6e8ef209650a67df3f0c283a4"
   integrity sha512-OYu7XEzjkCQ3C5Ps3QIZsQfNpqoJyZZA99wd9aWd05NCtC5pWOkShK2mkL6HXQR6/Cy2lbNdPlZBpuQHXE63gA==
 
-"json-crdt-traces@https://github.com/streamich/json-crdt-traces#5f68a13baf798897d39b87d7028b0b3cd5a50a6c":
+"json-crdt-traces@https://github.com/streamich/json-crdt-traces#02718a7a5d09e0dc6c31ea7d45a9ce3cbb0bf085":
   version "0.0.1"
-  resolved "https://github.com/streamich/json-crdt-traces#5f68a13baf798897d39b87d7028b0b3cd5a50a6c"
+  resolved "https://github.com/streamich/json-crdt-traces#02718a7a5d09e0dc6c31ea7d45a9ce3cbb0bf085"
 
 json-logic-js@^2.0.1:
   version "2.0.2"