Added LSEQ CRDT

src/lseq/README.md

@@ -0,0 +1,9 @@
+# lseq
+
+The LSEQ CRDT provides a clever allocation strategy for a distributed sequence of basic elements
+that can be lines, words or characters.
+
+## References
+
+* [Logoot-Undo: Distributed Collaborative Editing System on P2P Networks](https://hal.archives-ouvertes.fr/hal-00450416/)
+* [LSEQ: an Adaptive Structure for Sequences in Distributed Collaborative Editing](https://hal.archives-ouvertes.fr/hal-00921633/)

src/lseq/createLseqAction.js

@@ -0,0 +1,15 @@
+export const createLseqInsertAction = name => (id, value) => ({
+  type: `LSEQ_INSERT_${name}`,
+  payload: {
+    id,
+    value,
+  },
+});
+
+export const createLseqRemoveAction = name => (id, value) => ({
+  type: `LSEQ_REMOVE_${name}`,
+  payload: {
+    id,
+    value,
+  },
+});

src/lseq/createLseqAction.spec.js

@@ -0,0 +1,41 @@
+import { createLseqInsertAction, createLseqRemoveAction } from './createLseqAction';
+
+describe('createLseqAction', () => {
+  describe('createLseqInsertAction', () => {
+    it('should be a function', () => {
+      expect(typeof createLseqInsertAction).toBe('function');
+    });
+
+    it('should return an action object', () => {
+      const expected = {
+        type: 'LSEQ_INSERT_AA',
+        payload: {
+          id: 'A',
+          value: 1,
+        },
+      };
+      const countA = createLseqInsertAction('AA');
+      const result = countA('A', 1);
+      expect(result).toEqual(expected);
+    });
+  });
+
+  describe('createLseqRemoveAction', () => {
+    it('should be a function', () => {
+      expect(typeof createLseqRemoveAction).toBe('function');
+    });
+
+    it('should return an action object', () => {
+      const expected = {
+        type: 'LSEQ_REMOVE_AA',
+        payload: {
+          id: 'A',
+          value: 1,
+        },
+      };
+      const countA = createLseqRemoveAction('AA');
+      const result = countA('A', 1);
+      expect(result).toEqual(expected);
+    });
+  });
+});

src/lseq/createLseqReducer.js

@@ -0,0 +1,31 @@
+export const lseqInitalState = {
+  type: 'pn-counter',
+  p: {},
+  n: {},
+};
+
+export const createLseqReducer = name => (state = lseqInitalState, action) => {
+  if (!state || !action) {
+    return lseqInitalState;
+  }
+  switch (action.type) {
+    case `LSEQ_INSERT_${name}`:
+      if (action.payload) {
+        return state;
+      }
+      break;
+    case `LSEQ_REMOVE_${name}`:
+      if (action.payload) {
+        return state;
+      }
+      break;
+    case `LSEQ_MERGE_${name}`:
+      if (action.payload) {
+        return state;
+      }
+      break;
+    default:
+      return state;
+  }
+  return state;
+};

src/lseq/createLseqReducer.spec.js

@@ -0,0 +1,7 @@
+import { createLseqReducer } from './createLseqReducer';
+
+describe('createLseqReducer', () => {
+  it('should be a function', () => {
+    expect(typeof createLseqReducer).toBe('function');
+  });
+});

src/lseq/lseqSelector.js

@@ -0,0 +1 @@
+export default state => state;

src/lseq/lseqSelector.spec.js

@@ -0,0 +1,7 @@
+import lseqSelector from './lseqSelector';
+
+describe('lseqSelector', () => {
+  it('should be a function', () => {
+    expect(typeof lseqSelector).toBe('function');
+  });
+});