LedgerPort

upsert

upsert(self, tenant_id: str, txns: Sequence[LedgerTransaction]) -> list[SyncEvent]

Insert or update transactions inside one tenant's ledger.

Tenant-scoped (rule #6). Returns the resulting events ordered by ascending last-modified seq (SPEC §6.4). A re-delivered transaction whose payload is unchanged (payload_equal) emits no event, UNLESS the stored row is removed, in which case the transaction is re-added: stored with removed=False, a bumped seq, and an ADDED event (SPEC §6.4 re-add semantics; alternative backends must copy this).

Parameters

sync

sync(self, tenant_id: str, cursor: str | None = None, limit: int = 100) -> SyncPage

Page of changes for one tenant since cursor (SPEC §6.4).

Tenant-scoped (rule #6). Events are ordered by ascending last-modified seq: last-modified order, NOT transaction date, so an old row that changes reappears. cursor=None starts from the beginning; a malformed cursor raises auradefi.errors.CursorError. Clients page until has_more is False before persisting next_cursor.

Parameters

Raises

CursorError

get

get(self, tenant_id: str, txn_id: str) -> LedgerTransaction

Fetch one transaction within the caller's tenant scope.

Tenant-scoped (rule #6). Raises auradefi.errors.NotFoundError when the id does not exist inside this tenant. Another tenant's transaction is indistinguishable from a missing one.

Parameters

Raises

NotFoundError

mark_removed

mark_removed(self, tenant_id: str, txn_ids: Sequence[str]) -> list[SyncEvent]

Mark transactions removed (reorg semantics) inside one tenant.

Tenant-scoped (rule #6). Returns REMOVED events ordered by ascending last-modified seq (SPEC §6.4); a reorg is removed plus a later re-added, never an in-place mutation.

Parameters

__init__

__init__(self, *args, **kwargs)

Parameters