Creates a per-IP rate limit layer using the configured governor settings.

Test helper: reconstructs account storage at a given block from DB. Reads `accounts.storage_header` and `account_storage_map_values` to reconstruct t

Returns storage map details by reconstructing the storage map from the database.

Streams blocks from the validator into the local store until the chain tip is reached.

Registers a dummy actor handle (no real actor task) in the coordinator's registry.

If [`IncrementService`] regenerated accounts and published a new pair, adopt it and reset tracking state.

Removes a single SMT Subtree from storage, identified by its root `NodeIndex`. # Errors - `StorageError::Backend`: If the subtrees column family is m

After an htmx swap we still have cached probe results — paint them immediately.

Builds the [`ExponentialBuilder`] used to back off retries on transient request failures.

Reverts all batches and transactions that have expired. Expired batch descendants are also reverted since these are now invalid. Transactions from b

Runs the network transaction builder event loop until a fatal error occurs.

Bootstraps the network transaction services and runs them. Deployment is retried forever with exponential backoff, publishing an unhealthy status on

Collect Rust source files from explicit files, directories, or the repository root. Directory traversal skips common generated or dependency director

Saves the proving inputs for the given block to the block store.

Opens a fresh connection to the store's SQLite database and inserts a private network-account row for `account_id`, marking it as a network account in

Seeds the store with a given number of accounts.

Selects account commitments with pagination. Returns up to `page_size` account commitments, starting after `after_account_id` if provided. Results ar

Select all block headers from the DB using the given [`SqliteConnection`]. # Returns A vector of [`BlockHeader`] or an error. # Raw SQL ```sql SEL

Select a [`BlockHeader`] and its [`Signature`] from the DB by its `block_num` using the given [`SqliteConnection`]. # Returns The block header with

Select the subset of note commitments that already exist in the notes table # Raw SQL ```sql SELECT notes.note_commitment FROM notes WHERE note_comm

Fetch account storage header and all storage maps

TODO this is expensive and should only be called from tests

Selects the latest vault assets for an account. # Raw SQL ```sql SELECT vault_key, asset FROM account_vault_assets WHERE account_id = ?1 AND is_late

Selects the minimal account state needed for applying a delta update. Optimized query that only fetches: - `nonce` (to add `nonce_delta`) - `code_com

Maps each given nullifier to its note ID. Only public notes have a nullifier stored (`notes.nullifier` is NULL for private notes), so private notes n

Select note inclusion proofs matching the note commitments. # Parameters `note_ids`: Set of note IDs to query - Limit: 0 <= count <= 1000 # Returns

Returns the script for a note by its root.

Select note sync records matching the given note commitments. # Parameters `note_commitments`: Slice of note commitments to query - Limit: 0 <= count

Selects nullifiers with pagination. Returns up to `page_size` nullifiers, starting after `after_nullifier` if provided. Results are ordered by nullif

Selects public account IDs with pagination. Returns up to `page_size` public account IDs, starting after `after_account_id` if provided. Results are

Selects public account vault roots and storage headers with pagination. Returns up to `page_size` public account states, starting after `after_accoun

Returns the complete transaction records for the specified accounts within the specified block range, including state commitments and note IDs. Note:

Selects vault balances for specific vault keys. Optimized query that only fetches balances for the vault keys that are being updated by a delta, rath

Sends a stream item to the client while also observing server shutdown.

Runs the frontend server.

Serves the RPC API. In full-node mode, also runs the block/proof sync loop concurrently. Either component failing causes both to stop. Note: Execute

Serves the validator RPC API. Executes in place (i.e. not spawned) and will run indefinitely until a fatal error is encountered.

Constructs the underlying tonic server for this service behind an opaque tower service type.

Returns the gRPC service name used by tonic routing and health reporting.

Sets the genesis commitment, returning an error if it is already set. Required since the store client is used to fetch the `genesis_commitment` after