test(json-crdt): 💍 add tests for new eventing methods

Author: streamich

src/json-crdt/model/api/__tests__/ModelApi.events.spec.ts

@@ -196,3 +196,42 @@ describe('DOM Level 2 events, .et.addEventListener()', () => {
     expect(set!.has(ModelChangeType.RESET)).toBe(true);
   });
 });
+
+describe('fanout', () => {
+  describe('changes', () => {
+    test('emits events on document change', async () => {
+      const doc = Model.withLogicalClock();
+      const api = doc.api;
+      let cnt = 0;
+      api.root({a: {}});
+      expect(cnt).toBe(0);
+      api.changes.listen(() => {
+        cnt++;
+      });
+      api.obj([]).set({gg: true});
+      await Promise.resolve();
+      expect(cnt).toBe(1);
+      api.obj(['a']).set({1: 1, 2: 2});
+      await Promise.resolve();
+      expect(cnt).toBe(2);
+    });
+
+    test('can have multiple subscribers', async () => {
+      const doc = Model.withLogicalClock();
+      const api = doc.api;
+      let cnt = 0;
+      api.root({a: {}});
+      expect(cnt).toBe(0);
+      api.changes.listen(() => {
+        cnt++;
+      });
+      api.changes.listen(() => {
+        cnt++;
+      });
+      expect(cnt).toBe(0);
+      api.obj([]).set({gg: true});
+      await Promise.resolve();
+      expect(cnt).toBe(2);
+    });
+  });
+});

src/json-crdt/model/api/__tests__/StringApi.spec.ts

@@ -63,4 +63,55 @@ describe('events', () => {
     await Promise.resolve();
     expect(cnt).toEqual(1);
   });
+
+  describe('.changes', () => {
+    test('can listen to events', async () => {
+      const doc = Model.withLogicalClock();
+      const api = doc.api;
+      api.root('');
+      const str = api.str([]);
+      let cnt = 0;
+      const onView = () => cnt++;
+      str.ins(0, 'aaa');
+      expect(cnt).toEqual(0);
+      const unsubscribe = str.events.changes.listen(onView);
+      str.ins(0, 'bbb');
+      await Promise.resolve();
+      expect(cnt).toEqual(1);
+      str.ins(0, 'ccc');
+      await Promise.resolve();
+      expect(cnt).toEqual(2);
+      unsubscribe();
+      str.del(1, 7);
+      expect(cnt).toEqual(2);
+    });
+  });
+
+  describe('SyncStore', () => {
+    test('can listen to events', async () => {
+      const doc = Model.withLogicalClock();
+      const api = doc.api;
+      api.root('');
+      const str = api.str([]);
+      let cnt = 0;
+      const onView = () => cnt++;
+      str.ins(0, 'aaa');
+      expect(cnt).toEqual(0);
+      expect(str.events.getSnapshot()).toEqual('aaa');
+      const unsubscribe = str.events.subscribe(onView);
+      str.ins(0, 'bbb');
+      await Promise.resolve();
+      expect(str.events.getSnapshot()).toEqual('bbbaaa');
+      expect(cnt).toEqual(1);
+      str.ins(0, 'ccc');
+      await Promise.resolve();
+      expect(str.events.getSnapshot()).toEqual('cccbbbaaa');
+      expect(cnt).toEqual(2);
+      unsubscribe();
+      str.del(1, 7);
+      expect(cnt).toEqual(2);
+    });
+  });
 });
+
+