feat: 🎸 update remote.scanFwd() method

Author: streamich

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

@@ -28,23 +28,13 @@ export class DemoServerRemoteHistory
   }
 
   public async scanFwd(id: string, cursor: Cursor): Promise<{patches: DemoServerPatch[]}> {
-    throw new Error('Method not implemented.');
-    // const limit = 100;
-    // const res = await this.client.call('block.scan', {
-    //   id,
-    //   seq: cursor,
-    //   limit: cursor + limit,
-    // });
-    // if (res.patches.length === 0) {
-    //   return {
-    //     cursor,
-    //     patches: [],
-    //   };
-    // }
-    // return {
-    //   cursor: res.patches[res.patches.length - 1].seq,
-    //   patches: res.patches,
-    // };
+    const limit = 100;
+    const res = await this.client.call('block.scan', {
+      id,
+      cur: cursor,
+      limit,
+    });
+    return res;
   }
 
   public async scanBwd(

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

@@ -95,7 +95,7 @@ describe('.read()', () => {
 
 describe('.update()', () => {
   test('can apply changes to an empty document', async () => {
-    const {remote, caller} = await setup();
+    const {remote} = await setup();
     const id = genId();
     await remote.create(id, []);
     const read1 = await remote.read(id);
@@ -117,6 +117,32 @@ describe('.update()', () => {
   });
 });
 
+describe('.scanFwd()', () => {
+  test('can scan patches forward', async () => {
+    const {remote} = await setup();
+    const id = genId();
+    const model1 = Model.withLogicalClock();
+    model1.api.root({score: 42});
+    const patch1 = model1.api.flush();
+    const blob = patch1.toBinary();
+    await remote.create(id, [{blob}]);
+    const read1 = await remote.read(id);
+    model1.api.obj([]).set({
+      foo: 'bar',
+    });
+    const patch2 = model1.api.flush();
+    const blob2 = patch2.toBinary();
+    await remote.update(id, [{blob: blob2}]);
+    const scan1 = await remote.scanFwd(id, read1.block.snapshot.cur + 1);
+    expect(scan1).toMatchObject({
+      patches: [{
+        blob: expect.any(Uint8Array),
+        ts: expect.any(Number),
+      }]
+    });
+  });
+});
+
 describe('.delete()', () => {
   test('can delete an existing block', async () => {
     const {remote, caller} = await setup();