Class StubBroadcast

packages/server/test/snapshotService.unit.test.ts:63–83

}

class StubBroadcast implements IWSBroadcastServiceT {
  readonly _serviceBrand: undefined;
  snapshotCalls = 0;
  inFlight: SessionSnapshotState['inFlightTurn'] = null;
  seq = 0;
  epoch = 'ep_test';

  async getBufferedSince(): Promise<never> {
    throw new Error('not used');
  }
  async getCursor(): Promise<{ seq: number; epoch: string }> {
    return { seq: this.seq, epoch: this.epoch };
  }
  async getSnapshotState(): Promise<SessionSnapshotState> {
    this.snapshotCalls++;
    return { seq: this.seq, epoch: this.epoch, inFlightTurn: this.inFlight };
  }
  currentSeq(): number {
    return this.seq;
  }
}

class StubApprovals {
  readonly _serviceBrand: undefined;