feat(json-crdt): 🎸 use SESSION.GLOBAL for default value and schema setup

Author: streamich

src/json-crdt-patch/clock/types.ts

@@ -8,7 +8,7 @@ export interface ITimestampStruct {
    * Session ID (or actor ID, site ID, process ID, etc.), a random identifier
    * randomly assigned to each editing session.
    */
-  readonly sid: number;
+  sid: number;
 
   /**
    * Logical time (or sequence number, tick, etc.), a monotonically increasing

src/json-crdt/model/Model.ts

@@ -396,10 +396,21 @@ export class Model<N extends JsonNode = JsonNode<any>> implements Printable {
    * the document is empty.
    *
    * @param schema The schema to set for this model.
+   * @param sid Session ID to use for setting the default value of the document.
+   *            Defaults to `SESSION.GLOBAL` (2), which is the default session ID
+   *            for all operations operations that are not attributed to a specific
+   *            session.
    * @returns Strictly typed model.
    */
-  public setSchema<S extends NodeBuilder>(schema: S): Model<SchemaToJsonNode<S>> {
-    if (this.clock.time < 2) this.api.root(schema);
+  public setSchema<S extends NodeBuilder>(schema: S, useGlobalSession: boolean = true): Model<SchemaToJsonNode<S>> {
+    const clock = this.clock;
+    const sid = useGlobalSession ? SESSION.GLOBAL : clock.sid;
+    if (clock.time < 2) {
+      const oldSid = clock.sid;
+      clock.sid = sid;
+      this.api.root(schema);
+      clock.sid = oldSid;
+    }
     return <any>this;
   }
 

src/json-crdt/model/__tests__/Model.schema.spec.ts

@@ -0,0 +1,63 @@
+import {nodes, s} from '../../../json-crdt-patch';
+import {SESSION} from '../../../json-crdt-patch/constants';
+import {Model} from '../Model';
+
+test('can set object schema', () => {
+  const model = Model.withLogicalClock().setSchema(
+    s.obj({
+      str: s.str('asdf'),
+      con: s.con(123),
+    }),
+  );
+  expect(model.s.str.toApi().view()).toBe('asdf');
+  expect(model.s.con.toApi().view()).toBe(123);
+});
+
+test('can set map schema', () => {
+  const model = Model.withLogicalClock().setSchema(
+    s.map<nodes.str | nodes.con<number>>({
+      str: s.str('asdf'),
+      con1: s.con(123),
+    }),
+  );
+  expect(model.s.str.toApi().view()).toBe('asdf');
+  expect(model.s.con1.toApi().view()).toBe(123);
+  expect(model.view().str).toBe('asdf');
+  expect(model.view().con1).toBe(123);
+  expect(model.view().anyKeyAllowed).toBe(undefined);
+});
+
+test('uses global session ID by default', () => {
+  const model = Model.withLogicalClock().setSchema(s.obj({
+    id: s.str<string>('asdf'),
+    num: s.con(123),
+  }));
+  expect(model.api.r.get().node.id.sid).toBe(SESSION.GLOBAL);
+  expect(model.api.r.get().get('id').node.id.sid).toBe(SESSION.GLOBAL);
+  expect(model.api.r.get().get('num').node.id.sid).toBe(SESSION.GLOBAL);
+});
+
+test('allows to specify custom session ID', () => {
+  const schema = s.obj({
+    id: s.str<string>('asdf'),
+    num: s.con(123),
+  });
+  const model = Model.withLogicalClock().setSchema(schema, false);
+  expect(model.api.r.get().node.id.sid).toBe(model.clock.sid);
+  expect(model.api.r.get().get('id').node.id.sid).toBe(model.clock.sid);
+  expect(model.api.r.get().get('num').node.id.sid).toBe(model.clock.sid);
+});
+
+test('resets session ID to user specified', () => {
+  const model = Model.withLogicalClock().setSchema(s.obj({
+    id: s.str<string>('asdf'),
+    num: s.con(123),
+  }));
+  expect(model.view().num).toBe(123);
+  expect(model.api.r.get().get('num').node.id.sid).toBe(SESSION.GLOBAL);
+  model.api.r.get().set({
+    num: 456,
+  });
+  expect(model.view().num).toBe(456);
+  expect(model.api.r.get().get('num').node.id.sid).not.toBe(SESSION.GLOBAL);
+});