Merge pull request #372 from streamich/crdt-binary-encoding

CRDT binary encoding

Author: streamich

src/json-crdt-patch/codec/binary/Decoder.ts

@@ -1,4 +1,4 @@
-import {CrdtReader} from '../../util/binary/CrdtDecoder';
+import {CrdtReader} from '../../util/binary/CrdtReader';
 import {interval, ITimespanStruct, ITimestampStruct, VectorClock, ServerVectorClock, Timestamp} from '../../clock';
 import {Patch} from '../../Patch';
 import {PatchBuilder} from '../../PatchBuilder';

src/json-crdt-patch/codec/binary/Encoder.ts

@@ -1,6 +1,6 @@
 import * as operations from '../../operations';
 import {JsonCrdtPatchOpcode} from '../../constants';
-import {CrdtWriter} from '../../util/binary/CrdtEncoder';
+import {CrdtWriter} from '../../util/binary/CrdtWriter';
 import {ITimespanStruct, ITimestampStruct, Timestamp} from '../../clock';
 import {CborEncoder} from '../../../json-pack/cbor/CborEncoder';
 import type {JsonCrdtPatchOperation, Patch} from '../../Patch';

src/json-crdt-patch/codec/binary/shared.ts

@@ -1,7 +1,7 @@
 import {Encoder} from './Encoder';
 import {Decoder} from './Decoder';
 import {Patch} from '../../Patch';
-import {CrdtWriter} from '../../util/binary/CrdtEncoder';
+import {CrdtWriter} from '../../util/binary/CrdtWriter';
 
 /** A shared instance of the {@link CrdtWriter} class. */
 const writer = new CrdtWriter(1024 * 4);

src/json-crdt-patch/codec/clock/ClockDecoder.ts

@@ -1,5 +1,4 @@
 import {ITimestampStruct, VectorClock, ts} from '../../clock';
-import type {CrdtReader} from '../../util/binary/CrdtDecoder';
 
 export class ClockDecoder {
   /** Clock session index to logical clock. */

src/json-crdt-patch/codec/clock/ClockEncoder.ts

@@ -1,6 +1,5 @@
 import {ITimestampStruct, IVectorClock, tick} from '../../clock';
 import {RelativeTimestamp} from './RelativeTimestamp';
-import type {CrdtWriter} from '../../util/binary/CrdtEncoder';
 
 class ClockTableEntry {
   constructor(public index: number, public clock: ITimestampStruct) {}

src/json-crdt-patch/codec/clock/ClockTable.ts

@@ -1,6 +1,6 @@
 import {ITimestampStruct, IVectorClock, Timestamp} from '../../clock';
-import {CrdtReader} from '../../util/binary/CrdtDecoder';
-import {CrdtWriter} from '../../util/binary/CrdtEncoder';
+import {CrdtReader} from '../../util/binary/CrdtReader';
+import {CrdtWriter} from '../../util/binary/CrdtWriter';
 
 export class ClockTableEntry {
   constructor(public index: number, public id: ITimestampStruct) {}

src/json-crdt-patch/util/binary/CrdtDecoder.ts renamed to src/json-crdt-patch/util/binary/CrdtReader.ts

@@ -1,5 +1,6 @@
 import {Reader} from '../../../util/buffers/Reader';
 
+/** @todo Rename file name. */
 export class CrdtReader extends Reader {
   public id(): [x: number, y: number] {
     const byte = this.u8();

src/json-crdt-patch/util/binary/CrdtEncoder.ts renamed to src/json-crdt-patch/util/binary/CrdtWriter.ts

@@ -1,5 +1,5 @@
-import {CrdtWriter} from '../CrdtEncoder';
-import {CrdtReader} from '../CrdtDecoder';
+import {CrdtWriter} from '../CrdtWriter';
+import {CrdtReader} from '../CrdtReader';
 
 const encoder = new CrdtWriter();
 const decoder = new CrdtReader();

src/json-crdt-patch/util/binary/__tests__/CrdtDecoder.b1vuint28.spec.ts renamed to src/json-crdt-patch/util/binary/__tests__/CrdtReader.b1vuint28.spec.ts

@@ -1,5 +1,5 @@
-import {CrdtWriter} from '../CrdtEncoder';
-import {CrdtReader} from '../CrdtDecoder';
+import {CrdtWriter} from '../CrdtWriter';
+import {CrdtReader} from '../CrdtReader';
 
 const encoder = new CrdtWriter();
 const decoder = new CrdtReader();