feat: 🎸 update the remote.update() method

Author: streamich

src/__demos__/json-crdt-server/routes/block/methods/upd.ts

@@ -1,6 +1,6 @@
 import {ResolveType} from 'json-joy/lib/json-type';
 import type {RouteDeps, Router, RouterBase} from '../../types';
-import {BlockCurRef, BlockIdRef, BlockPatchPartialRef, BlockPatchPartialReturnRef} from '../schema';
+import {BlockIdRef, BlockPatchPartialRef, BlockPatchPartialReturnRef} from '../schema';
 
 export const upd =
   ({t, services}: RouteDeps) =>

src/json-crdt-repo/remote/DemoServerRemoteHistory.ts

@@ -79,22 +79,17 @@ export class DemoServerRemoteHistory
 
   public async update(
     id: string,
-    cursor: Cursor,
     patches: Pick<DemoServerPatch, 'blob'>[],
   ): Promise<{patches: Omit<DemoServerPatch, 'blob'>[]}> {
-    throw new Error('Method not implemented.');
-    // const res = await this.client.call('block.upd', {
-    //   id,
-    //   patches: patches.map((patch, seq) => ({
-    //     seq,
-    //     created: Date.now(),
-    //     blob: patch.blob,
-    //   })),
-    // });
-    // return {
-    //   cursor: res.patches.length ? res.patches[res.patches.length - 1].seq : cursor,
-    //   patches: res.patches,
-    // };
+    const res = await this.client.call('block.upd', {
+      id,
+      patches: patches.map((patch) => ({
+        blob: patch.blob,
+      })),
+    });
+    return {
+      patches: res.patches,
+    };
   }
 
   public async delete(id: string): Promise<void> {

src/json-crdt-repo/remote/__tests__/DemoServerRemoteHistory.spec.ts

@@ -93,6 +93,30 @@ describe('.read()', () => {
   });
 });
 
+describe('.update()', () => {
+  test('can apply changes to an empty document', async () => {
+    const {remote, caller} = await setup();
+    const id = genId();
+    await remote.create(id, []);
+    const read1 = await remote.read(id);
+    const model1 = Model.fromBinary(read1.block.snapshot.blob);
+    expect(model1.view()).toBe(undefined);
+    const model = Model.withLogicalClock();
+    model.api.root({score: 42});
+    const patch = model.api.flush();
+    const blob = patch.toBinary();
+    const update = await remote.update(id, [{blob}]);
+    expect(update).toMatchObject({
+      patches: [{
+        ts: expect.any(Number),
+      }]
+    });
+    const read2 = await remote.read(id);
+    const model2 = Model.fromBinary(read2.block.snapshot.blob);
+    expect(model2.view()).toEqual({score: 42});
+  });
+});
+
 describe('.delete()', () => {
   test('can delete an existing block', async () => {
     const {remote, caller} = await setup();

src/json-crdt-repo/remote/types.ts

@@ -83,7 +83,7 @@ export interface RemoteHistory<
    * @param cursor The cursor of the last known model state of the block.
    * @param patches A list of patches to apply to the block.
    */
-  update(id: string, cursor: Cursor, patches: Pick<P, 'blob'>[]): Promise<{patches: Omit<P, 'blob'>[]}>;
+  update(id: string, patches: Pick<P, 'blob'>[]): Promise<{patches: Omit<P, 'blob'>[]}>;
 
   /**
    * Delete the block. If not implemented, means that the protocol does not