test: 💍 add background sync with remote test

Author: streamich

src/json-crdt-repo/__tests__/testbed.ts

@@ -6,6 +6,7 @@ import {MemoryLevel} from 'memory-level';
 import {pubsub as createPubsub} from '../pubsub';
 import {BinStrLevel, LevelLocalRepoPubSub} from '../local/level/types';
 import {EditSessionFactory} from '../session/EditSessionFactory';
+import {Model, Patch} from 'json-joy/lib/json-crdt';
 
 /* tslint:disable:no-console */
 
@@ -26,6 +27,15 @@ export class Testbed {
   public createBrowser(): BrowserTestbed {
     return new BrowserTestbed(this);
   }
+
+  public readonly getModelFromRemote = async (id: string | string[]): Promise<Model> => {
+    if (Array.isArray(id)) id = id.join('/');
+    const res = await this.remote.client.call('block.get', {id});
+    const model = Model.fromBinary(res.block.snapshot.blob);
+    for (const batch of res.block.tip)
+      for (const patch of batch.patches) model.applyPatch(Patch.fromBinary(patch.blob));
+    return model;
+  };
 }
 
 export class BrowserTestbed {
@@ -94,6 +104,10 @@ export class LocalRepoTestbed {
     });
   }
 
+  public readonly getModelFromRemote = async (id: string | string[]): Promise<Model> => {
+    return await this.tab.browser.global.getModelFromRemote(id);
+  };
+
   public readonly stop = async () => {
     await this.repo.stop();
   };

src/json-crdt-repo/local/level/__tests__/LevelLocalRepo.remote-sync.spec.ts

@@ -0,0 +1,43 @@
+import {s} from 'json-joy/lib/json-crdt';
+import {BehaviorSubject} from 'rxjs';
+import {Testbed} from '../../../__tests__/testbed';
+import {tick, until} from 'thingies';
+
+describe('remote sync', () => {
+  test('can synchronize after connection resumes', async () => {
+    const connected$ = new BehaviorSubject<boolean>(true);
+    const repo = Testbed.createRepo({connected$});
+    const schema = s.obj({foo: s.str('bar')});
+    const {session: session1} = repo.sessions.make({id: repo.blockId, schema});
+    await until(async () => {
+      try {
+        await repo.getModelFromRemote(repo.blockId);
+        return true;
+      } catch {
+        return false;
+      }
+    });
+    const model1 = await repo.getModelFromRemote(repo.blockId);
+    expect(model1.view()).toEqual({foo: 'bar'});
+    connected$.next(false);
+    session1.model.api.obj([]).set({
+      foo: 'baz',
+      x: 'y',
+    });
+    const {session: session2} = await repo.sessions.make({id: repo.blockId, schema});
+    await until(() => session2.model.view()?.foo === 'baz');
+    await tick(123);
+    const model2 = await repo.getModelFromRemote(repo.blockId);
+    expect(model2.view()).toEqual({foo: 'bar'});
+    connected$.next(true);
+    await until(async () => {
+      const model = await repo.getModelFromRemote(repo.blockId);
+      return model.view()?.foo === 'baz';
+    });
+    const model3 = await repo.getModelFromRemote(repo.blockId);
+    expect(model3.view()).toEqual({foo: 'baz', x: 'y'});
+    await session1.dispose();
+    await session2.dispose();
+    await repo.stopTab();
+  }, 10_000);
+});