Struct miden_node_store::db::Db

pub struct Db { /* private fields */ }

Implementations

impl Db

pub async fn setup( config: StoreConfig, block_store: Arc<BlockStore>, ) -> Result<Self, DatabaseSetupError>

Open a connection to the DB, apply any pending migrations, and ensure that the genesis block is as expected and present in the database.

pub async fn select_nullifiers(&self) -> Result<Vec<(Nullifier, BlockNumber)>>

Loads all the nullifiers from the DB.

pub async fn select_nullifiers_by_prefix( &self, prefix_len: u32, nullifier_prefixes: Vec<u32>, ) -> Result<Vec<NullifierInfo>>

Loads the nullifiers that match the prefixes from the DB.

pub async fn select_notes(&self) -> Result<Vec<NoteRecord>>

Loads all the notes from the DB.

pub async fn select_accounts(&self) -> Result<Vec<AccountInfo>>

Loads all the accounts from the DB.

pub async fn select_block_header_by_block_num( &self, block_number: Option<BlockNumber>, ) -> Result<Option<BlockHeader>>

Search for a BlockHeader from the database by its block_num.

When block_number is None, the latest block header is returned.

pub async fn select_block_headers( &self, blocks: Vec<BlockNumber>, ) -> Result<Vec<BlockHeader>>

Loads multiple block headers from the DB.

pub async fn select_all_block_headers(&self) -> Result<Vec<BlockHeader>>

Loads all the block headers from the DB.

pub async fn select_account_hashes(&self) -> Result<Vec<(AccountId, RpoDigest)>>

Loads all the account hashes from the DB.

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

Loads public account details from the DB.

pub async fn get_state_sync( &self, block_num: BlockNumber, account_ids: Vec<AccountId>, note_tags: Vec<u32>, nullifier_prefixes: Vec<u32>, ) -> Result<StateSyncUpdate, StateSyncError>

pub async fn get_note_sync( &self, block_num: BlockNumber, note_tags: Vec<u32>, ) -> Result<NoteSyncUpdate, NoteSyncError>

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

Loads all the Note’s matching a certain NoteId from the database.

pub async fn select_note_inclusion_proofs( &self, note_ids: BTreeSet<NoteId>, ) -> Result<BTreeMap<NoteId, NoteInclusionProof>>

Loads inclusion proofs for notes matching the given IDs.

pub async fn select_note_ids( &self, note_ids: Vec<NoteId>, ) -> Result<BTreeSet<NoteId>>

Loads all note IDs matching a certain NoteId from the database.

pub async fn apply_block( &self, allow_acquire: Sender<()>, acquire_done: Receiver<()>, block: Block, notes: Vec<NoteRecord>, ) -> Result<()>

Inserts the data of a new block into the DB.

allow_acquire and acquire_done are used to synchronize writes to the DB with writes to the in-memory trees. Further details available on super::state::State::apply_block.