Struct DexExtended 

pub struct DexExtended {
    pub dex: SharedDex,
    pub parse_pool_created_event_fn: Option<fn(Log) -> Result<PoolCreatedEvent>>,
    pub parse_initialize_event_fn: Option<fn(SharedDex, Log) -> Result<InitializeEvent>>,
    pub parse_swap_event_fn: Option<fn(SharedDex, Log) -> Result<SwapEvent>>,
    pub parse_mint_event_fn: Option<fn(SharedDex, Log) -> Result<MintEvent>>,
    pub parse_burn_event_fn: Option<fn(SharedDex, Log) -> Result<BurnEvent>>,
    pub parse_collect_event_fn: Option<fn(SharedDex, Log) -> Result<CollectEvent>>,
    pub convert_to_trade_data_fn: Option<fn(&Token, &Token, &SwapEvent) -> Result<(OrderSide, Quantity, Price)>>,
}

Extended DEX wrapper that adds provider-specific event parsing capabilities to the domain Dex model.

Fields

dex: SharedDex

The core domain Dex object being extended.

parse_pool_created_event_fn: Option<fn(Log) -> Result<PoolCreatedEvent>>

Function to parse pool creation events.

parse_initialize_event_fn: Option<fn(SharedDex, Log) -> Result<InitializeEvent>>

Function to parse initialize events.

parse_swap_event_fn: Option<fn(SharedDex, Log) -> Result<SwapEvent>>

Function to parse swap events.

parse_mint_event_fn: Option<fn(SharedDex, Log) -> Result<MintEvent>>

Function to parse mint events.

parse_burn_event_fn: Option<fn(SharedDex, Log) -> Result<BurnEvent>>

Function to parse burn events.

parse_collect_event_fn: Option<fn(SharedDex, Log) -> Result<CollectEvent>>

Function to parse collect events.

convert_to_trade_data_fn: Option<fn(&Token, &Token, &SwapEvent) -> Result<(OrderSide, Quantity, Price)>>

Function to convert to trade data.

Implementations

impl DexExtended

pub fn new(dex: Dex) -> Self

Creates a new DexExtended wrapper around a domain Dex object.

pub fn set_pool_created_event_parsing( &mut self, parse_pool_created_event: fn(Log) -> Result<PoolCreatedEvent>, )

Sets the function used to parse pool creation events for this Dex.

pub fn set_initialize_event_parsing( &mut self, parse_initialize_event: fn(SharedDex, Log) -> Result<InitializeEvent>, )

Sets the function used to parse initialize events for this Dex.

pub fn set_swap_event_parsing( &mut self, parse_swap_event: fn(SharedDex, Log) -> Result<SwapEvent>, )

Sets the function used to parse swap events for this Dex.

pub fn set_mint_event_parsing( &mut self, parse_mint_event: fn(SharedDex, Log) -> Result<MintEvent>, )

Sets the function used to parse mint events for this Dex.

pub fn set_burn_event_parsing( &mut self, parse_burn_event: fn(SharedDex, Log) -> Result<BurnEvent>, )

Sets the function used to parse burn events for this Dex.

pub fn set_collect_event_parsing( &mut self, parse_collect_event: fn(SharedDex, Log) -> Result<CollectEvent>, )

Sets the function used to parse collect events for this Dex.

pub fn set_convert_trade_data( &mut self, convert_trade_data: fn(&Token, &Token, &SwapEvent) -> Result<(OrderSide, Quantity, Price)>, )

Sets the function used to convert trade data for this Dex.

pub fn parse_pool_created_event(&self, log: Log) -> Result<PoolCreatedEvent>

Parses a pool creation event log using this DEX’s specific parsing function.

Errors

Returns an error if the DEX does not have a pool creation event parser defined or if parsing fails.

pub fn parse_swap_event(&self, log: Log) -> Result<SwapEvent>

Parses a swap event log using this DEX’s specific parsing function.

Errors

Returns an error if the DEX does not have a swap event parser defined or if parsing fails.

pub fn convert_to_trade_data( &self, token0: &Token, token1: &Token, swap_event: &SwapEvent, ) -> Result<(OrderSide, Quantity, Price)>

Convert to trade data from a log using this DEX’s specific parsing function.

Errors

Returns an error if the DEX does not have a trade data converter defined or if conversion fails.

pub fn parse_mint_event(&self, log: Log) -> Result<MintEvent>

Parses a mint event log using this DEX’s specific parsing function.

Errors

Returns an error if the DEX does not have a mint event parser defined or if parsing fails.

pub fn parse_burn_event(&self, log: Log) -> Result<BurnEvent>

Parses a burn event log using this DEX’s specific parsing function.

Errors

Returns an error if the DEX does not have a burn event parser defined or if parsing fails.

pub fn needs_initialization(&self) -> bool

Checks if this DEX requires pool initialization events.

pub fn parse_initialize_event(&self, log: Log) -> Result<InitializeEvent>

Parses an event log into an InitializeEvent struct.

pub fn parse_collect_event(&self, log: Log) -> Result<CollectEvent>

Parses a collect event log using this DEX’s specific parsing function.

Errors

Returns an error if the DEX does not have a collect event parser defined or if parsing fails.

Methods from Deref<Target = Dex>

pub fn id(&self) -> String

Returns a unique identifier for this DEX, combining chain and protocol name.

Trait Implementations

impl Clone for DexExtended

fn clone(&self) -> DexExtended

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for DexExtended

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

Formats the value using the given formatter.

impl Deref for DexExtended

type Target = Dex

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.