Struct DexExtended

pub struct DexExtended {
    pub dex: SharedDex,
    pub parse_pool_created_event_fn: Option<fn(Log) -> Result<PoolCreatedEvent>>,
    pub parse_swap_event_fn: Option<fn(Log) -> Result<SwapEvent>>,
    pub parse_mint_event_fn: Option<fn(Log) -> Result<MintEvent>>,
    pub parse_burn_event_fn: Option<fn(Log) -> Result<BurnEvent>>,
    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_swap_event_fn: Option<fn(Log) -> Result<SwapEvent>>

Function to parse swap events

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

Function to parse mint events

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

Function to parse burn 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_swap_event_parsing( &mut self, parse_swap_event: fn(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(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(Log) -> Result<BurnEvent>, )

Sets the function used to parse burn 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.

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

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

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.

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

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

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

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

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.

const 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.