All files / json-crdt-patch/codec/clock ClockTable.ts

97.5% Statements 39/40
0% Branches 0/1
100% Functions 9/9
100% Lines 35/35

Press n or j to go to the next uncovered block, b, p or k for the previous block.

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 6412x       12x   56858x 56858x       12x   1616x 1616x   26808x 1616x       1620x 1620x 1620x 26812x 1620x     3236x 3236x     77257x 77257x 77257x 77257x 77257x       56858x 56858x 56858x 56858x       313370x 313370x 313370x       1618x 1618x 1618x 1618x 28429x 28429x 28429x        
import {type ITimestampStruct, type IClockVector, Timestamp} from '../../clock';
import type {CrdtReader} from '../../util/binary/CrdtReader';
import type {CrdtWriter} from '../../util/binary/CrdtWriter';
 
export class ClockTableEntry {
  constructor(
    public index: number,
    public id: ITimestampStruct,
  ) {}
}
 
export class ClockTable {
  public static from(clock: IClockVector): ClockTable {
    const table = new ClockTable();
    table.push(new Timestamp(clock.sid, clock.time - 1));
    // biome-ignore lint: using .forEach() on Map is the fastest way to iterate
    clock.peers.forEach((id) => table.push(id));
    return table;
  }
 
  public static decode(reader: CrdtReader): ClockTable {
    const clockTable = new ClockTable();
    const length = reader.vu57();
    clockTable.push(new Timestamp(reader.vu57(), reader.vu57()));
    for (let i = 1; i < length; i++) clockTable.push(new Timestamp(reader.vu57(), reader.vu57()));
    return clockTable;
  }
 
  public readonly bySid: Map<number, ClockTableEntry> = new Map<number, ClockTableEntry>();
  public readonly byIdx: ITimestampStruct[] = [];
 
  public parseField(field: `${string}_${string}`): ITimestampStruct {
    const underscoreIndex = field.indexOf('_');
    const relativeSid = Number.parseInt(field.slice(0, underscoreIndex), 36);
    const time = Number.parseInt(field.slice(underscoreIndex + 1), 36);
    const clock = this.byIdx[relativeSid];
    return new Timestamp(clock.sid, time);
  }
 
  public push(id: ITimestampStruct): void {
    const byIdx = this.byIdx;
    const index = byIdx.length;
    byIdx.push(id);
    this.bySid.set(id.sid, new ClockTableEntry(index, id));
  }
 
  public getBySid(sid: number): ClockTableEntry {
    const entry = this.bySid.get(sid);
    Iif (!entry) throw new Error('CLOCK_NOT_FOUND');
    return entry;
  }
 
  public write(writer: CrdtWriter): void {
    const table = this.byIdx;
    const length = table.length;
    writer.vu57(length);
    for (let i = 0; i < length; i++) {
      const clock = table[i];
      writer.vu57(clock.sid);
      writer.vu57(clock.time);
    }
  }
}