Struct DefiDataSubscriptionManager 

pub struct DefiDataSubscriptionManager { /* private fields */ }

Manages subscriptions to DeFi protocol events (swaps, mints, burns) across different DEXs.

This manager tracks which pool addresses are subscribed for each event type and maintains the event signature encodings for efficient filtering.

Implementations

impl DefiDataSubscriptionManager

pub fn new() -> Self

Creates a new DefiDataSubscriptionManager instance.

pub fn get_subscribed_dex_contract_addresses( &self, dex: &DexType, ) -> Vec<Address>

Gets all unique contract addresses subscribed for any event type for a given DEX.

pub fn get_subscribed_dex_event_signatures(&self, dex: &DexType) -> Vec<String>

Gets all event signatures (keccak256 hashes) registered for a given DEX.

pub fn get_dex_pool_swap_event_signature(&self, dex: &DexType) -> Option<String>

Gets the swap event signature for a specific DEX.

pub fn get_dex_pool_mint_event_signature(&self, dex: &DexType) -> Option<String>

Gets the mint event signature for a specific DEX.

pub fn get_dex_pool_burn_event_signature(&self, dex: &DexType) -> Option<String>

Gets the burn event signature for a specific DEX.

pub fn register_dex_for_subscriptions( &mut self, dex: DexType, swap_event_signature: &str, mint_event_signature: &str, burn_event_signature: &str, )

Registers a DEX with its event signatures for subscription management.

This must be called before subscribing to any events for a DEX. Event signatures can be either raw signatures or pre-encoded keccak256 hashes.

pub fn subscribe_swaps(&mut self, dex: DexType, address: Address)

Subscribes to swap events for a specific pool address on a DEX.

pub fn subscribe_mints(&mut self, dex: DexType, address: Address)

Subscribes to mint events for a specific pool address on a DEX.

pub fn subscribe_burns(&mut self, dex: DexType, address: Address)

Subscribes to burn events for a specific pool address on a DEX.

pub fn unsubscribe_swaps(&mut self, dex: DexType, address: Address)

Unsubscribes from swap events for a specific pool address on a DEX.

pub fn unsubscribe_mints(&mut self, dex: DexType, address: Address)

Unsubscribes from mint events for a specific pool address on a DEX.

pub fn unsubscribe_burns(&mut self, dex: DexType, address: Address)

Unsubscribes from burn events for a specific pool address on a DEX.

Trait Implementations

impl Debug for DefiDataSubscriptionManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for DefiDataSubscriptionManager

fn default() -> Self

Returns the “default value” for a type.