Struct ClientDataStore 

pub struct ClientDataStore { /* private fields */ }

Available on crate feature testing only.

Wrapper structure that implements DataStore over any Store.

Implementations

impl ClientDataStore

pub fn new(store: Arc<dyn Store>, rpc_api: Arc<dyn NodeRpcClient>) -> Self

pub fn with_chain_anchor(self, anchor: ChainAnchor) -> Self

Serves chain data from the provided ChainAnchor instead of rebuilding it at the store’s sync height, pinning execution to the anchor’s reference block.

The store’s account data is still used as-is: only the reference block header and the partial blockchain come from the anchor. Any authenticated input note must have been created in a block tracked by the anchor’s partial blockchain, otherwise get_transaction_inputs fails.

pub fn with_execution_input_cache(self) -> Self

Enables memoization of get_transaction_inputs and get_vault_asset_witnesses for the lifetime of this data store.

This is only correct when the account state served to the executor does not change between executions, as is the case while the crate::note::NoteScreener runs trial executions against the same accounts and reference block. It must stay disabled for real transaction execution, where account state evolves between executions.

pub fn mast_store(&self) -> Arc<TransactionMastStore>

pub fn register_foreign_account_inputs( &self, foreign_accounts: impl IntoIterator<Item = AccountInputs>, )

Stores the provided foreign account inputs so they can be served to the executor upon request.

pub fn register_note_scripts( &self, note_scripts: impl IntoIterator<Item = NoteScript>, )

Registers note scripts so they can be served to the executor upon request.

Scripts accumulate across calls (they are not cleared) so that a data store reused for several executions — e.g. by crate::transaction::BatchBuilder — keeps serving the scripts registered for earlier transactions.

Trait Implementations

impl DataStore for ClientDataStore

async fn get_vault_asset_witnesses( &self, account_id: AccountId, vault_root: Word, asset_ids: BTreeSet<AssetId>, ) -> Result<Vec<AssetWitness>, DataStoreError>

Retrieves witnesses for the requested assets from the local store, falling back to a single RPC vault fetch when the store cannot serve the requested root.

Assets absent from the vault are served too: the store returns an emptiness proof for them, which the executor needs when an asset is being added to the vault.

async fn get_storage_map_witness( &self, account_id: AccountId, map_root: Word, map_key: StorageMapKey, ) -> Result<StorageMapWitness, DataStoreError>

Retrieves the StorageMapWitness requested from the store. Alternatively fetching it from the RPC if not available locally. Witnesses fetched via RPC are cached in memory so that repeated accesses to the same map entry within a transaction avoid additional RPC calls.

async fn get_foreign_account_inputs( &self, foreign_account_id: AccountId, ref_block: BlockNumber, ) -> Result<AccountInputs, DataStoreError>

Returns the AccountInputs for the given foreign account from the cache or alternatively fetching them from the RPC if not available locally.

fn get_note_script( &self, script_root: NoteScriptRoot, ) -> impl FutureMaybeSend<Result<Option<NoteScript>, DataStoreError>>

Returns the NoteScript for the given script root from the registered session scripts, the store, or alternatively fetching it from the RPC if not available locally.

async fn get_transaction_inputs( &self, account_id: AccountId, block_refs: BTreeSet<BlockNumber>, ) -> Result<(PartialAccount, BlockHeader, PartialBlockchain), DataStoreError>

Returns all the data required to execute a transaction against the account with the specified ID and consuming input notes created in blocks in the input ref_blocks set.

impl MastForestStore for ClientDataStore

fn get(&self, procedure_hash: &Word) -> Option<LoadedMastForest>

Returns a MastForest which is guaranteed to contain a procedure with the provided procedure hash as one of its procedure, if any.