Fetches the committed chain tip and ensures the requested range does not extend beyond it. Returns the chain tip so callers can reuse it (e.g. in the

Select account code by its commitment hash from the `account_codes` table. # Returns The account code bytes if found, or `None` if no code exists wi

Returns the set of nodes which can be selected. Candidates are nodes that are not currently selected, have all parents selected, and can be handed di

Spawns a named task into the set.

Loads the store state from the given data directory.

Include a specific genesis commitment string in request metadata.

Helper to write TOML content to a file and return the path

Returns a description of changes between the initial and final account states.

Applies a committed block's effects to the database in a single transaction: - Upserts each touched network account: new full-state deltas insert, pa

Returns the latest block number.

Builds a public account using a fixed account ID seed but a different component code. All accounts produced here share the same [`AccountId`] because

Create an RPC client configured with the correct genesis metadata in the `Accept` header so that write RPCs such as `SubmitProvenTx` are accepted by t

Returns the default base path for `RocksDB` benchmark storage.

Returns the total byte length of all files in `path` iteratively, or `0` on any error.

Creates a full-state `AccountDelta` (with code) for testing DB reconstruction.

Expand [`AccountStorageRequest`] to a vector of slot requests.

Fetch the u64 value held in the named value slot of the given account from RPC. Returns `None` if the account is not yet available on-chain. The valu

Generates a deterministic `AccountId` from a seed.

Generates a deterministic word from a seed.

Returns a reference to the account or a standardized "unknown account" error.

Loads the data necessary for a note sync across all matching blocks in the given range. Returns one [`NoteSyncUpdate`] per block that contains at lea

Translates a gRPC protobuf path to the corresponding generated Rust path. This is used to translate the protobuf type definitions to their tonic gener

Inserts a note script (idempotent via INSERT OR IGNORE).

Returns `true` if it contains no transactions.

Returns the latest block number.

Creates a mock network [`Account`] with the provided auth component.

Creates a mock genesis [`SignedBlock`] with an empty body. The signature is produced by a throwaway key over the header commitment; it is not expecte

Builds a full-state [`AccountUpdateDetails`] for a network account. The returned account passes `NetworkAccount::new`, so the ntx-builder treats the u

Reconstructs storage map root from DB entries at a specific block.

Reflow all safe comment blocks in a Rust source string. The source is parsed with tree-sitter so that only syntactic line comments are considered. Th

Removes all state associated with `node`, undoing the effects of [`Self::apply_append`].

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

Runs a service future until it completes or a shutdown signal is received. On `SIGTERM` or Ctrl-C, the provided root cancellation token is cancelled

Marks a node as selected. # Panics Panics if the given node is not a selection candidate.

Select all notes matching the given set of identifiers # Raw SQL ```sql SELECT notes.committed_at, notes.batch_index, notes.note_index, notes.note_i

Sends an arbitrary / irrelevant request to the RPC.

Utility to convert an iterable container to a vector of byte blobs

Starts the gRPC server on the given listener.

The trait describing the service's interface. This is a super trait consisting of all the gRPC method traits for this service. ```rust trait <Self::

Creates a `RocksDB` storage instance for benchmarking. # Arguments `base_path` - Base directory for `RocksDB` storage. Each call creates a unique sub

Creates a [`NoteError`] from a string message, for use in tests.

Returns the number of transactions currently waiting to be batched.