Applies pending migrations to the ntx-builder database at `database_filepath`.

Returns the migration name for a one-based migration version.

Builds a valid nonce-only [`AccountDelta`] for `account_id`.

Seed status published on the NTX channels until the accounts are deployed.

Decodes the `(sender, note_type, tag)` triple from a proto `NoteMetadata` into a [`PartialNoteMetadata`]. The attachment-related fields on the proto a

Returns the byte length of the file at `path`, or `0` if it does not exist.

Returns `None` if there are no samples.

Extracts the label portion of a semver pre-release identifier, stripping any trailing numeric segment. For example, `"alpha.3"` returns `Some("alpha")

Print a compact per-block series so the operator can eyeball the time-series shape (ramp, plateau, dip). Empty blocks in the scan range are intentiona

Prints a per-phase summary of how long proof generation took, broken down into the executor (VM execution) and prover (STARK proving) costs, plus the

Window after which a probe outcome with no fresh updates is considered stale. Two full probe intervals plus the request timeout: a healthy probe task

Returns the number of batches currently being proven.

The list of `*.proto` files in the given directory. Does _not_ recurse into folders; only top level files are returned.

Returns the number of proven batches waiting for block inclusion.

Removes the node _IFF_ it has no ancestor nodes and returns the pruned node. # Panics Panics if this node has any ancestor nodes, or if this node wa

Adds an active migration and the schema hash expected after it runs. This is used by [`MigratorBuilder`] after it has already applied the migration t

Reads a trusted, signed genesis block from disk.

Records the latest subscriber gap and returns whether it is still within the allowed limit.

Tracks the size of the store file.

Decides the actor's next mode after a coordinator notification, advancing the in-memory account when the actor's own transaction lands. - In `NoViabl

Registers storage map slot names for the given account ID and storage header. These slot names are subsequently used to query for storage map witness

Errors if any of `candidate_ids` is classified as a network account by the store. Callers should pre-filter to post-deployment, public-account ids; `O

Renders the Rust source written by [`Migrator::generate`]. For one retired migration named `001_legacy`, one SQL migration named `002_initial`, and o

Returns the [`ExponentialBuilder`] used for per-request retry backoff.

Reverts the given transaction and _all_ its descendants _IFF_ it is present in the graph. This includes batches that have been marked as proven. Ret

Returns the root hash at a specific historical block. Returns `None` if the block is in the future or too old (pruned).

Returns the root hash of the latest state.

Main loop of the proof scheduler. Maintains a pool of concurrent proving jobs via [`JoinSet`], fills them up to `max_concurrent_proofs`, and drains c

Starts the [`BatchBuilder`], creating and proving batches dynamically. Full batches are spawned on each check and job completion. A batch of any size

Runs the producer until it reaches a terminal stream error, then reports that status.

Runs the account actor, processing notifications and managing state until shutdown. The return value signals the shutdown category to the coordinator

Atomically writes `tip` to the proven tip file (write to temp, then rename).

Seeds a committed row for `account_id` so the coordinator's spawn check sees the account.

Select account by ID from the DB using the given [`SqliteConnection`]. # Returns The latest account info, or an error. # Raw SQL ```sql SELECT acc

Selects a set of batches for inclusion in the next block. A batch is available for selection if: - all the batches it depends on have been selected f

Select block headers for the given block numbers. # Parameters `blocks`: Iterator of block numbers to retrieve - Limit: 0 <= count <= 1000 # Note O

Reads the singleton chain state row, returning the persisted block number, header, and chain MMR if any block has been applied locally. # Raw SQL ``

Marks the node as a selection candidate if all its parents are already selected.

Stores a single subtree in RocksDB and optionally updates the depth-24 root cache. The subtree is serialized and written to its corresponding column

Creates a validator database seeded with a genesis block whose `validator_key` is the public key of `key`. Returns the database handle and the genesis

Fetch the genesis block header and build the data store + increment script needed to produce network notes from a freshly-created wallet/counter pair.

Waits for all currently running actors to exit after cancellation.

Spawns a new task to prove a block.

Spawns an actor for the given account if its committed state exists in the DB; otherwise defers the spawn until the block carrying the account's creat

Spawn a blocking task in a span.

Spawns a background task that periodically records the on-disk size of every store data path as `OTel` span attributes.

Card grid + last-updated line. Returned from `/fragments/status` for htmx to swap into `#status-container`.

Submit one executed tx for proving. The remote path spawns a concurrent task and returns immediately; the local path proves inline now, blocking until

Submits each transaction in the batch to the validator for re-execution. # Errors - If `transaction_inputs` does not match the batch's transactions

Returns a new receiver that wakes on every proven-tip advance.