Helper function to create an `AccountTree` from entries using the new API

Signals the actor that DB state may have changed. Notifications coalesce when one is already pending.

Returns the current proven chain tip.

Select account storage map values from the DB using the given [`SqliteConnection`]. # Returns A vector of tuples containing `(slot, key, value, is_l

Spawn a blocking task in the current tracing span.

Returns the high 16 bits of the provided nullifier.

Spawns a probe task and returns its handle.

Explicitly enable TLS.

Builds, submits, and applies an empty block, advancing the chain tip. Panics if the block is rejected.

Puts a value into the cache.

Reconstruct full Account from database tables for the latest account state This function queries the database tables to reconstruct a complete Accoun

Binds a socket on an available port, runs the RPC server on it, and returns a client to talk to the server, along with the socket address.

Ensures that `node` can be appended on top of the current state without conflicts.

Disables OpenTelemetry context propagation. This should be disabled when interfacing with external third party gRPC servers.

Inserts network notes from a committed block. Uses `INSERT OR IGNORE` so re-applying the same block (e.g. on a redelivery from the subscription stream

Convenience function to cast the state type and carry internal configuration forward.

Appends the given transaction to the current batch. # Panics Panics if the new transaction's account update is inconsistent with the current account

Adds a SQL migration that remains supported for existing databases.

Queries the account header for a specific account at a specific block number. This reconstructs the `AccountHeader` by reading from the `accounts` ta

Test helper: query vault assets at a specific block by finding the most recent update for each `vault_key`. Uses a single raw SQL query with a subque

Enables OpenTelemetry context propagation via gRPC. This is used to by OpenTelemetry to connect traces across network boundaries. The server on the o

Overrides the timeout of the server.

Explicitly disable TLS.

Waits for either an unexpected task completion or a shutdown request. Before shutdown, any task completion is treated as fatal because this type supe

Collect all the keys from the `MetadataMap`.

Creates a distinct [`TransactionId`] from a seed, for landing-detection tests.

Select a [`BlockHeader`] from the DB by its `block_num` using the given [`SqliteConnection`]. # Returns When `block_num` is [None], the latest block

Select latest account storage by querying `accounts.storage_header` where `is_latest=true` and reconstructing full storage from the header plus map va

Returns nullifiers filtered by prefix within a block number range. # Parameters `prefix_len`: Length of nullifier prefix in bits - Must be exactly 16

Spawns the prover server, returning its handle and the port it is listening on.

Check, but don't repeat ourselves mapping the error

Computes mutations relative to the latest state.

Gets the current Unix timestamp in seconds. This function is infallible - if the system time is somehow before Unix epoch (extremely unlikely), it re

Returns the default SQLite connection pool size. Defaults to twice the available CPU parallelism. If the OS cannot report the available parallelism,

Builds an empty [`ProposedBlock`] that extends the given parent block header using the provided partial blockchain state.

Increments each transaction's failure counter, and reverts transactions which exceed the failure limit. This weeds out transactions which participate

Adds a pure SQL retired migration. Retired migrations initialize fresh databases from SQL that replaces old active migrations. They must be pushed be

Select account vault assets within a block range (inclusive). # Parameters `account_id`: Account ID to query `block_from`: Starting block number `blo

Select notes matching the given tags within a block range. # Parameters `note_tags`: List of note tags to filter by - Limit: 0 <= count <= 1000 `bloc

Explicitly disable request timeout.

Applies `node` to the state, returning the set of parent node identifiers inferred from state dependencies.