Struct BlockStateSynchronizer 

pub struct BlockStateSynchronizer { /* private fields */ }

Block state synchronizer that manages block header tracking and reorg handling.

Matches the TS BlockSynchronizer:

• Syncs the anchor block header from the node
• Detects chain reorganizations (when the node’s block number < our anchor)
• Rolls back NoteStore and PrivateEventStore on reorg
• Signals ContractSyncService cache invalidation

The synchronizer ensures that all PXE state is consistent with the node’s view of the chain.

Implementations

impl BlockStateSynchronizer

pub fn new( anchor_block_store: Arc<AnchorBlockStore>, note_store: Arc<NoteStore>, private_event_store: Arc<PrivateEventStore>, config: BlockSyncConfig, ) -> BlockStateSynchronizer

pub async fn sync<N>(&self, node: &N) -> Result<(), Error>

where N: AztecNode,

Sync the PXE with the node’s current state.

This is the main entry point called before transaction simulation or event retrieval. It:

1. Fetches the latest block header from the node
2. Detects if a reorg has occurred
3. Handles rollback if needed
4. Updates the anchor block header

pub async fn take_anchor_changed(&self) -> bool

Check and consume the anchor-changed flag.

Returns true if the anchor block has changed since the last call. The flag is reset to false after reading. This is used by EmbeddedPxe to know when to wipe the ContractSyncService cache.

pub fn anchor_block_store(&self) -> &AnchorBlockStore

Get a reference to the anchor block store.

pub async fn get_anchor_block_header( &self, ) -> Result<Option<AnchorBlockHeader>, Error>

Get the current anchor block header.

pub async fn get_anchor_block_number(&self) -> Result<u64, Error>

Get the current anchor block number.