Struct brontes_inspect::mev_inspectors::shared_utils::SharedInspectorUtils

pub struct SharedInspectorUtils<'db, DB: LibmdbxReader> {
    pub metrics: Option<OutlierMetrics>,
    /* private fields */
}

Fields

metrics: Option<OutlierMetrics>

Implementations

impl<'db, DB: LibmdbxReader> SharedInspectorUtils<'db, DB>

pub fn new( quote_address: Address, db: &'db DB, metrics: Option<OutlierMetrics>, ) -> Self

impl<DB: LibmdbxReader> SharedInspectorUtils<'_, DB>

pub fn get_metrics(&self) -> Option<&OutlierMetrics>

pub fn usd_delta_by_address( &self, tx_position: u64, at: PriceAt, deltas: &FastHashMap<Address, FastHashMap<Address, Rational>>, metadata: Arc<Metadata>, cex: bool, at_or_before: bool, filter_fn: impl Fn(&Address, Option<Rational>) -> Option<Rational>, ) -> Option<FastHashMap<Address, Rational>>

Calculates the USD value of the token balance deltas by address

pub fn flatten_nested_actions_default<'a>( &self, iter: impl Iterator<Item = Action> + 'a, ) -> impl Iterator<Item = Action> + 'a

pub fn flatten_nested_actions<'a, F>( &self, iter: impl Iterator<Item = Action> + 'a, filter_actions: &'a F, ) -> impl Iterator<Item = Action> + 'a

where F: for<'b> Fn(&'b Action) -> bool + 'a,

pub fn try_create_swaps( &self, transfers: &[NormalizedTransfer], invalid_addresses: FastHashSet<Address>, ) -> Vec<NormalizedSwap>

tries to convert transfer over to swaps

pub fn get_token_value_dex( &self, tx_index: usize, at: PriceAt, token_address: Address, amount: &Rational, metadata: &Arc<Metadata>, ) -> Option<Rational>

pub fn get_token_value_dex_block( &self, block_price: BlockPrice, token_address: Address, amount: &Rational, metadata: &Arc<Metadata>, ) -> Option<Rational>

pub fn get_token_price_on_dex( &self, tx_index: usize, at: PriceAt, token_address: Address, metadata: &Arc<Metadata>, ) -> Option<Rational>

pub fn get_token_price_on_dex_block( &self, block: BlockPrice, token_address: Address, metadata: &Arc<Metadata>, ) -> Option<Rational>

pub fn build_bundle_header_searcher_activity( &self, bundle_deltas: Vec<FastHashMap<Address, FastHashMap<Address, Rational>>>, bundle_txes: Vec<TxHash>, info: &TxInfo, profit_usd: f64, price_type: BlockPrice, gas_details: &[GasDetails], metadata: Arc<Metadata>, mev_type: MevType, no_pricing_calculated: bool, ) -> BundleHeader

pub fn build_bundle_header( &self, bundle_deltas: Vec<FastHashMap<Address, FastHashMap<Address, Rational>>>, bundle_txes: Vec<TxHash>, info: &TxInfo, profit_usd: f64, gas_details: &[GasDetails], metadata: Arc<Metadata>, mev_type: MevType, no_pricing_calculated: bool, price_f: impl Fn(&Self, Address, Rational) -> Option<Rational>, ) -> BundleHeader

pub fn get_full_block_price( &self, price_type: BlockPrice, mev_addresses: FastHashSet<Address>, deltas: &FastHashMap<Address, FastHashMap<Address, Rational>>, metadata: Arc<Metadata>, ) -> Option<Rational>

pub fn get_deltas_usd( &self, tx_index: u64, at: PriceAt, mev_addresses: &FastHashSet<Address>, deltas: &FastHashMap<Address, FastHashMap<Address, Rational>>, metadata: Arc<Metadata>, at_or_before: bool, ) -> Option<Rational>

pub fn get_bundle_accounting( &self, bundle_txes: Vec<FixedBytes<32>>, bundle_deltas: Vec<FastHashMap<Address, FastHashMap<Address, Rational>>>, price_f: impl Fn(&Self, Address, Rational) -> Option<Rational>, ) -> Vec<TransactionAccounting>

pub fn fetch_address_name(&self, address: Address) -> Option<String>

pub fn valid_pricing<'a>( &self, metadata: Arc<Metadata>, swaps: &[NormalizedSwap], tokens: impl Iterator<Item = &'a Address>, idx: usize, max_price_diff: Rational, mev_type: MevType, ) -> bool

Evaluates the validity of swap prices against DEX quoted prices within a given metadata context.

This function iterates over each token involved in the provided swaps and compares the effective swap rates against the DEX quoted prices for corresponding token pairs. It computes the difference between the effective price and the DEX pricing rate. If any swap exhibits a price difference exceeding MAX_PRICE_DIFF, it logs a warning and captures relevant metrics. The function returns true if all evaluated swaps have price differences within the acceptable range.

pub fn dedup_bundles(bundles: Vec<Bundle>) -> Vec<Bundle>

Because of the recursive split nature of the search, we can sometimes get overlap which leads to double counting and false positives that are unwanted. to combat this we check all hashes and will check for duplicates. when a duplicate arises, we will always take the bundle with more transactions as it is the most correct

pub fn cex_try_convert_transfer_to_swap( &self, transfers: Vec<NormalizedTransfer>, info: &TxInfo, mev_type: MevType, ) -> Option<NormalizedSwap>

pub fn cex_merge_possible_swaps( swaps: Vec<NormalizedSwap>, ) -> Vec<NormalizedSwap>

Trait Implementations

impl<'db, DB: Debug + LibmdbxReader> Debug for SharedInspectorUtils<'db, DB>

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

Formats the value using the given formatter.

Layout

Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...) attributes. Please see the Rust Reference's “Type Layout” chapter for details on type layout guarantees.

Size: 80 bytes