Skip to main content

NegotiationStore

@totemsdk/edge

@totemsdk/edge / NegotiationStore

Interface: NegotiationStore

A durable negotiation store with atomic CAS semantics.

Methods​

compareAndSet()​

compareAndSet(negotiationId, expectedRevision, next): Promise<boolean>

Atomically replace the record only if its current revision equals expectedRevision. Returns false when the record was advanced by another writer (stale transition).

Parameters​

negotiationId​

string

expectedRevision​

number

next​

NegotiationRecord

Returns​

Promise<boolean>

create()​

create(record): Promise<void>

Parameters​

record​

NegotiationRecord

Returns​

Promise<void>

get()​

get(negotiationId): Promise<NegotiationRecord | undefined>

Parameters​

negotiationId​

string

Returns​

Promise<NegotiationRecord | undefined>

listRecoverable()?​

optional listRecoverable(): Promise<NegotiationRecord[]>

List recoverable (non-terminal) negotiations.

Returns​

Promise<NegotiationRecord[]>

transitionAndEnqueue()​

transitionAndEnqueue(negotiationId, expectedRevision, next, outboxMessages): Promise<boolean>

Atomically perform a negotiation CAS AND enqueue outbox messages in ONE durable transaction. Returns false when the CAS failed (stale revision).

For SQLite/Postgres this MUST be a single DB transaction so that the economic transition and the protocol response commit or fail together.

The default falls back to a two-step (non-transactional) sequence. A durable store MUST override this to keep the crash window closed.

Parameters​

negotiationId​

string

expectedRevision​

number

next​

NegotiationRecord

outboxMessages​

OutboxMessage[]

Returns​

Promise<boolean>