test: 💍 add local patch test

Author: streamich

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

@@ -3,6 +3,7 @@ import {setup} from './setup';
 import {BehaviorSubject} from 'rxjs';
 import {until} from 'thingies';
 import {LocalRepoRebaseEvent} from '../../local/types';
+import {Testbed} from '../../__tests__/testbed';
 
 describe('events', () => {
   test('emits "rebase" event on change', async () => {
@@ -27,4 +28,27 @@ describe('events', () => {
     expect(model2.view()).toEqual({foo: 2});
     await kit.stop();
   });
+
+  test('can synchronize sessions using local .applyPatch()', async () => {
+    const repo = Testbed.createRepo();
+    const schema = s.obj({str: s.str('abc')});
+    const {session: session1} = repo.sessions.make({id: repo.blockId, schema});
+    const {session: session2} = repo.sessions.make({id: repo.blockId, schema});
+    const clone = session1.model.clone();
+    session1.model.api.str(['str']).ins(3, 'd');
+    expect(session1.model.view()).toEqual({str: 'abcd'});
+    clone.api.str(['str']).ins(3, ' - 2');
+    expect(clone.view()).toEqual({str: 'abc - 2'});
+    await session1.sync();
+    const patch = clone.api.flush();
+    session1.model.applyLocalPatch(patch);
+    expect(session1.model.view()).toEqual({str: 'abc - 2d'});
+    await session1.sync();
+    await until(() => session2.model.view().str === 'abc - 2d');
+    expect(session2.model.view()).toEqual({str: 'abc - 2d'});
+    expect(session1.model.view()).toEqual({str: 'abc - 2d'});
+    await session1.dispose();
+    await session2.dispose();
+    await repo.stopTab();
+  });
 });