Struct ComponentTracker

pub struct ComponentTracker<R: RPCClient> {
    pub components: HashMap<String, ProtocolComponent>,
    pub contracts: HashSet<Bytes>,
    /* private fields */
}

Helper struct to store which components are being tracked atm.

Fields

components: HashMap<String, ProtocolComponent>

contracts: HashSet<Bytes>

derived from tracked components, we need this if subscribed to a vm extractor cause updates are emitted on a contract level instead of on a component level.

Implementations

impl<R> ComponentTracker<R>

where R: RPCClient,

pub fn new( chain: Chain, protocol_system: &str, filter: ComponentFilter, rpc: R, ) -> Self

pub async fn initialise_components(&mut self) -> Result<(), RPCError>

Retrieve all components that belong to the system we are extracing and have sufficient tvl.

pub async fn start_tracking( &mut self, new_components: &[&String], ) -> Result<(), RPCError>

Add a new component to be tracked

pub fn stop_tracking<'a, I: IntoIterator<Item = &'a String> + Debug>( &mut self, to_remove: I, ) -> HashMap<String, ProtocolComponent>

Stop tracking components

pub fn get_contracts_by_component<'a, I: IntoIterator<Item = &'a String>>( &self, ids: I, ) -> HashSet<Bytes>

pub fn get_tracked_component_ids(&self) -> Vec<String>

pub fn filter_updated_components( &self, deltas: &BlockChanges, ) -> (Vec<String>, Vec<String>)

Given BlockChanges, filter out components that are no longer relevant and return the components that need to be added or removed.