Struct 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_by_prefix( &self, prefix_len: u32, nullifier_prefixes: Vec<u32>, ) -> Result<Vec<NullifierInfo>, DatabaseError>

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 get_note_authentication_info( &self, note_ids: BTreeSet<NoteId>, ) -> Result<NoteAuthenticationInfo, GetNoteInclusionProofError>

Queries all the note inclusion proofs matching a certain Note IDs from the database.

pub async fn sync_state( &self, block_num: BlockNumber, account_ids: Vec<AccountId>, note_tags: Vec<u32>, nullifier_prefixes: Vec<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 known 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_tags: The tags the client is interested in, result is restricted to the first block with any matches tags.
• 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 sync_notes( &self, block_num: BlockNumber, note_tags: Vec<u32>, ) -> Result<(NoteSyncUpdate, MmrProof), NoteSyncError>

Loads data to synchronize a client’s notes.

The client’s request contains a list of tags, 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 known by the client, updates start from the next block.
• note_tags: The tags the client is interested in, resulting notes are restricted to the first block containing a matching note.

pub async fn get_block_inputs( &self, account_ids: &[AccountId], nullifiers: &[Nullifier], unauthenticated_notes: BTreeSet<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 get_account_details( &self, id: AccountId, ) -> Result<AccountInfo, DatabaseError>

Returns details for public (on-chain) account.

pub async fn get_account_proofs( &self, account_requests: Vec<AccountProofRequest>, known_code_commitments: BTreeSet<RpoDigest>, include_headers: bool, ) -> Result<(BlockNumber, Vec<AccountProofsResponse>), DatabaseError>

Returns account proofs with optional account and storage headers.

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.