test: 💍 persist tests

Author: streamich

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

@@ -28,7 +28,7 @@ describe('.pull()', () => {
         }
       });
       await kit.local.pull(kit.blockId);
-      const get = await kit.local.get(kit.blockId);
+      const get = await kit.local.get({id: kit.blockId});
       expect(get.model.view()).toEqual({foo: 'bar'});
       await kit.stop();
     });
@@ -90,19 +90,19 @@ describe('.pull()', () => {
           }],
         },
       });
-      const get1 = await local.get(kit.blockId);
+      const get1 = await local.get({id: kit.blockId});
       expect(get1.model.view()).toEqual({foo: 'bar'});
       let cnt = 0;
       kit.local.change$(kit.blockId).subscribe((event) => {
         if (!(event as LocalRepoMergeEvent).merge) return;
         cnt++;
       });
       await kit.local.pull(kit.blockId);
-      const get2 = await local.get(kit.blockId);
+      const get2 = await local.get({id: kit.blockId});
       expect(get2.model.view()).toEqual({foo: 'baz', x: 1});
       await kit.local.pull(kit.blockId);
       await kit.local.pull(kit.blockId);
-      const get3 = await local.get(kit.blockId);
+      const get3 = await local.get({id: kit.blockId});
       expect(get3.model.view()).toEqual({foo: 'baz', x: 1});
       await kit.stop();
     });
@@ -244,7 +244,7 @@ describe('.pull()', () => {
       expect(model.view()).toEqual({foo: 'bar'});
       for (const patch of event.merge) model.applyPatch(patch);
       expect(model.view()).toEqual({foo: 'baz', x: 1});
-      const read = await kit.local.get(kit.blockId);
+      const read = await kit.local.get({id: kit.blockId});
       expect(read.model.view()).toEqual({foo: 'baz', x: 1});
       await kit.stop();
     });
@@ -295,7 +295,7 @@ describe('.pull()', () => {
       expect(model.view()).toEqual({foo: 'bar'});
       model.reset(<Model<any>>event.reset);
       expect(model.view()).toEqual({foo: 'baz', x: 123});
-      const read = await kit.local.get(kit.blockId);
+      const read = await kit.local.get({id: kit.blockId});
       expect(read.model.view()).toEqual({foo: 'baz', x: 123});
       await kit.stop();
     });

src/json-crdt-repo/session/__tests__/EditSession.events.spec.ts

@@ -0,0 +1,30 @@
+import {s} from 'json-joy/lib/json-crdt';
+import {setup} from './setup';
+import {BehaviorSubject} from 'rxjs';
+import {until} from 'thingies';
+import {LocalRepoRebaseEvent} from '../../local/types';
+
+describe('events', () => {
+  test('emits "rebase" event on change', async () => {
+    const kit = await setup({local: {connected$: new BehaviorSubject(false)}});
+    const schema = s.obj({foo: s.con(1)});
+    const session1 = kit.sessions.make({id: kit.blockId, schema});
+    await session1.sync();
+    const events: LocalRepoRebaseEvent[] = [];
+    const sub = kit.local.change$(kit.blockId).subscribe((event) => {
+      if ((event as LocalRepoRebaseEvent).rebase) events.push(event as LocalRepoRebaseEvent);
+    });
+    const model2 = session1.model.clone();
+    session1.model.api.obj([]).set({foo: 2});
+    await until(() => events.length === 1);
+    const get1 = await kit.local.get({id: kit.blockId});
+    expect(get1.model.view()).toEqual({foo: 2});
+    const event = events[0];
+    expect(model2.view()).toEqual({foo: 1});
+    for (const patch of event.rebase) {
+      model2.applyPatch(patch);
+    }
+    expect(model2.view()).toEqual({foo: 2});
+    await kit.stop();
+  });
+});