Struct miden_node_store::state::State

pub struct State { /* private fields */ }

The rollup state

Implementations

impl State

pub async fn load( db: Db, block_store: Arc<BlockStore>, ) -> Result<Self, StateInitializationError>

Loads the state from the db.

pub async fn apply_block(&self, block: Block) -> Result<(), ApplyBlockError>

Apply changes of a new block to the DB and in-memory data structures.

Note on state consistency

The server contains in-memory representations of the existing trees, the in-memory representation must be kept consistent with the committed data, this is necessary so to provide consistent results for all endpoints. In order to achieve consistency, the following steps are used:

• the request data is validated, prior to starting any modifications.
• block is being saved into the store in parallel with updating the DB, but before committing. This block is considered as candidate and not yet available for reading because the latest block pointer is not updated yet.
• a transaction is open in the DB and the writes are started.
• while the transaction is not committed, concurrent reads are allowed, both the DB and the in-memory representations, which are consistent at this stage.
• prior to committing the changes to the DB, an exclusive lock to the in-memory data is acquired, preventing concurrent reads to the in-memory data, since that will be out-of-sync w.r.t. the DB.
• the DB transaction is committed, and requests that read only from the DB can proceed to use the fresh data.
• the in-memory structures are updated, including the latest block pointer and the lock is released.

pub async fn get_block_header( &self, block_num: Option<BlockNumber>, include_mmr_proof: bool, ) -> Result<(Option<BlockHeader>, Option<MmrProof>), GetBlockHeaderError>

Queries a BlockHeader from the database, and returns it alongside its inclusion proof.

If None is given as the value of block_num, the data for the latest BlockHeader is returned.

pub async fn check_nullifiers(&self, nullifiers: &[Nullifier]) -> Vec<SmtProof>

Generates membership proofs for each one of the nullifiers against the latest nullifier tree.

Note: these proofs are invalidated once the nullifier tree is modified, i.e. on a new block.

pub async fn get_notes_by_id( &self, note_ids: Vec<NoteId>, ) -> Result<Vec<NoteRecord>, DatabaseError>

Queries a list of NoteRecord from the database.

If the provided list of NoteId given is empty or no NoteRecord matches the provided NoteId an empty list is returned.

pub async fn sync_state( &self, block_num: BlockNumber, account_ids: &[AccountId], note_tag_prefixes: &[u32], nullifier_prefixes: &[u32], ) -> Result<(StateSyncUpdate, MmrDelta), StateSyncError>

Loads data to synchronize a client.

The client’s request contains a list of tag prefixes, this method will return the first block with a matching tag, or the chain tip. All the other values are filter based on this block range.

Arguments

• block_num: The last block know by the client, updates start from the next block.
• account_ids: Include the account’s hash if their last change was in the result’s block range.
• note_tag_prefixes: Only the 16 high bits of the tags the client is interested in, result will include notes with matching prefixes, the first block with a matching note determines the block range.
• nullifier_prefixes: Only the 16 high bits of the nullifiers the client is interested in, results will include nullifiers matching prefixes produced in the given block range.

pub async fn get_block_inputs( &self, account_ids: &[AccountId], nullifiers: &[Nullifier], unauthenticated_notes: Vec<NoteId>, ) -> Result<BlockInputs, GetBlockInputsError>

Returns data needed by the block producer to construct and prove the next block.

pub async fn get_transaction_inputs( &self, account_id: AccountId, nullifiers: &[Nullifier], unauthenticated_notes: Vec<NoteId>, ) -> Result<TransactionInputs, DatabaseError>

Returns data needed by the block producer to verify transactions validity.

pub async fn list_nullifiers( &self, ) -> Result<Vec<(Nullifier, u32)>, DatabaseError>

Lists all known nullifiers with their inclusion blocks, intended for testing.

pub async fn list_accounts(&self) -> Result<Vec<AccountInfo>, DatabaseError>

Lists all known accounts, with their ids, latest state hash, and block at which the account was last modified, intended for testing.

pub async fn list_notes(&self) -> Result<Vec<NoteRecord>, DatabaseError>

Lists all known notes, intended for testing.

pub async fn get_account_details( &self, id: AccountId, ) -> Result<AccountInfo, DatabaseError>

Returns details for public (on-chain) account.

pub async fn load_block( &self, block_num: BlockNumber, ) -> Result<Option<Vec<u8>>, DatabaseError>

Loads a block from the block store. Return Ok(None) if the block is not found.

pub async fn latest_block_num(&self) -> BlockNumber

Returns the latest block number.