feat(json-crdt): 🎸 unserialize frontier

Author: streamich

src/json-crdt-patch/clock/clock.ts

@@ -196,10 +196,10 @@ export class ClockVector extends LogicalClock implements IClockVector {
   }
 
   /**
-   * Returns a human-readable string representation of the vector clock.
+   * Returns a human-readable string representation of the clock vector.
    *
    * @param tab String to use for indentation.
-   * @returns Human-readable string representation of the vector clock.
+   * @returns Human-readable string representation of the clock vector.
    */
   public toString(tab: string = ''): string {
     const last = this.peers.size;
@@ -236,4 +236,13 @@ export class ServerClockVector extends LogicalClock implements IClockVector {
   public fork(): ServerClockVector {
     return new ServerClockVector(SESSION.SERVER, this.time);
   }
+
+  /**
+   * Returns a human-readable string representation of the clock vector.
+   *
+   * @returns Human-readable string representation of the clock vector.
+   */
+  public toString(): string {
+    return `clock ${this.sid}.${this.time}`;
+  }
 }

src/json-crdt/file/File.ts

@@ -41,6 +41,13 @@ export class File implements Printable {
     }
     if (!log) throw new Error('NO_HISTORY');
     if (!decodedModel) decodedModel = log.replayToEnd();
+    if (frontier.length) {
+      for (const patch of frontier) {
+        const patchDecoded = decodePatch(patch);
+        decodedModel.applyPatch(patchDecoded);
+        log.push(patchDecoded);
+      }
+    }
     const file = new File(decodedModel, log);
     return file;
   }

src/json-crdt/file/__tests__/File.spec.ts

@@ -102,3 +102,20 @@ describe('.toBinary()', () => {
     }
   });
 });
+
+describe('.unserialize()', () => {
+  test('applies frontier', () => {
+    const {file, model} = setup({foo: 'bar'});
+    const clone = model.clone();
+    clone.api.obj([]).set({
+      xyz: 123,
+    });
+    const serialized = file.serialize({
+      history: 'binary',
+    });
+    serialized.push(clone.api.flush().toBinary());
+    expect(file.model.view()).toEqual({foo: 'bar'});
+    const file2 = File.unserialize(serialized);
+    expect(file2.model.view()).toEqual({foo: 'bar', xyz: 123});
+  });
+});