Replica

tested

Generic op-based CRDT replica: owns a Lamport clock + op log, integrates local and remote ops (with causal buffering and dedup), and exposes deltas for transport-agnostic sync. The domain state lives behind {@link ReplicaHandlers}.

Source Tests

Signature

class Replica<Op extends HasOpId>

Type Parameters

Opextends HasOpId

Properties

Property	Type	Default	Description
`site`readonly	`string`	—	—
`version`readonly	`VersionVector`	—	—

Methods

nextId

Next op id for a locally-generated operation.

nextId(): OpId

ReturnsOpId

commitLocal

Integrate + log a local op, then notify listeners (origin `'local'`).

commitLocal(op: Op): void

Parameter	Type	Default	Description
`op`	`Op`	—	—

receive

Receive remote ops: dedup, buffer until causally ready, integrate, log, and notify with the ops actually applied. Returns the applied ops (in apply order).

receive(ops: readonly Op[], origin: unknown = 'remote'): Op[]

Parameter	Type	Default	Description
`ops`	`readonly Op[]`	—	—
`origin`?	`unknown`	`'remote'`	—

ReturnsOp[]

delta

Ops a remote replica (described by its version vector) is missing.

delta(remote: VersionVector): Op[]

Parameter	Type	Default	Description
`remote`	`VersionVector`	—	—

ReturnsOp[]

onUpdate

Subscribe to applied ops (local + remote). Returns an unsubscribe fn.

onUpdate(listener: UpdateListener<Op>): () => void

Parameter	Type	Default	Description
`listener`	`UpdateListener<Op>`	—	—

Returns() => void