Skip to main content

SqliteRunStateStore

@totemsdk/agent-policy

@totemsdk/agent-policy / SqliteRunStateStore

Class: SqliteRunStateStore

Implements​

Constructors​

Constructor​

new SqliteRunStateStore(dbPath, options?): SqliteRunStateStore

Parameters​

dbPath​

string

options?​

SqliteRunStateStoreOptions

Returns​

SqliteRunStateStore

Methods​

abort()​

abort(reservationId, reason): Promise<void>

Abort a reservation after execution fails or is cancelled.

Parameters​

reservationId​

string

reason​

string

Returns​

Promise<void>

Implementation of​

GrantUsageStore.abort

abortStep()​

abortStep(reservationId, reason): Promise<void>

Parameters​

reservationId​

string

reason​

string

Returns​

Promise<void>

Implementation of​

RunStateStore.abortStep

authorizeAndReserve()​

authorizeAndReserve(input): Promise<StepAuthorization>

Atomically reserve mandate usage + local quotas for a step.

Parameters​

input​
actionDigest​

string

mandateId​

string

now​

number

runId​

string

stepId​

string

ttlMs?​

number

usageDelta​

{ amount?: string; count: number; }

usageDelta.amount?​

string

usageDelta.count​

number

Returns​

Promise<StepAuthorization>

Implementation of​

GrantUsageStore.authorizeAndReserve

checkNonce()​

checkNonce(runId, nonce): Promise<boolean>

Parameters​

runId​

string

nonce​

string

Returns​

Promise<boolean>

Implementation of​

RunStateStore.checkNonce

close()​

close(): void

Returns​

void

commit()​

commit(reservationId, receipt): Promise<void>

Commit a reservation after execution succeeds.

Parameters​

reservationId​

string

receipt​

StepReceipt

Returns​

Promise<void>

Implementation of​

GrantUsageStore.commit

commitStep()​

commitStep(reservationId, receipt): Promise<void>

Parameters​

reservationId​

string

receipt​

RunStepReceipt

Returns​

Promise<void>

Implementation of​

RunStateStore.commitStep

countAborted()​

countAborted(runId): Promise<number>

Parameters​

runId​

string

Returns​

Promise<number>

Implementation of​

GrantUsageStore.countAborted

countCommitted()​

countCommitted(runId): Promise<number>

Run-level accounting for local bounds.

Parameters​

runId​

string

Returns​

Promise<number>

Implementation of​

GrantUsageStore.countCommitted

countReserved()​

countReserved(runId): Promise<number>

Parameters​

runId​

string

Returns​

Promise<number>

Implementation of​

GrantUsageStore.countReserved

countUnknown()​

countUnknown(runId): Promise<number>

Reservations whose outcome is unknown after crash/timeout — budget HELD.

Parameters​

runId​

string

Returns​

Promise<number>

Implementation of​

GrantUsageStore.countUnknown

createRun()​

createRun(snapshot): Promise<void>

Parameters​

snapshot​

RunStateSnapshot

Returns​

Promise<void>

Implementation of​

RunStateStore.createRun

getReceipt()​

getReceipt(reservationId): Promise<RunStepReceipt | undefined>

Parameters​

reservationId​

string

Returns​

Promise<RunStepReceipt | undefined>

Implementation of​

RunStateStore.getReceipt

getReservation()​

Call Signature​

getReservation(reservationId): Promise<RunReservation | undefined>

Read a reservation (for commit/abort bookkeeping).

Parameters​
reservationId​

string

Returns​

Promise<RunReservation | undefined>

Implementation of​

GrantUsageStore.getReservation

Call Signature​

getReservation(reservationId): Promise<StepAuthorization | undefined>

Parameters​
reservationId​

string

Returns​

Promise<StepAuthorization | undefined>

Implementation of​

RunStateStore.getReservation

getRun()​

getRun(runId): Promise<RunStateSnapshot | undefined>

Parameters​

runId​

string

Returns​

Promise<RunStateSnapshot | undefined>

Implementation of​

RunStateStore.getRun

listCommittedReceipts()​

listCommittedReceipts(mandateId): Promise<StepReceipt[]>

Committed receipts for a mandate — used to build the usage snapshot.

Parameters​

mandateId​

string

Returns​

Promise<StepReceipt[]>

Implementation of​

GrantUsageStore.listCommittedReceipts

listStepReceipts()​

listStepReceipts(runId): Promise<RunStepReceipt[]>

Parameters​

runId​

string

Returns​

Promise<RunStepReceipt[]>

Implementation of​

RunStateStore.listStepReceipts

reconcileReservation()​

reconcileReservation(reservationId, outcome, opts?): Promise<void>

Settle a recovered (unknown) reservation. The ONLY way an unsettled reservation releases its budget is an explicit 'definitely-not-executed' reconciliation; 'completed' commits it and folds the receipt into the run totals.

Parameters​

reservationId​

string

outcome​

ReservationSettlementOutcome

opts?​
reason?​

string

receipt?​

StepReceipt | RunStepReceipt

Returns​

Promise<void>

Implementation of​

GrantUsageStore.reconcileReservation

recoverReservations()​

recoverReservations(runId?): Promise<OutOfBandReservation[]>

Conservative reservation recovery (RFC-007 §3.5): a reservation that was never settled before its deadline is classified unknown — its budget is HELD, never restored by expiry. Returns every unsettled reservation.

Parameters​

runId?​

string

Returns​

Promise<OutOfBandReservation[]>

Implementation of​

GrantUsageStore.recoverReservations

reserveStep()​

reserveStep(reservation): Promise<void>

Parameters​

reservation​

RunReservation

Returns​

Promise<void>

Implementation of​

RunStateStore.reserveStep