tycho_simulation/evm/protocol/ekubo_v3/

decoder.rs

use std::{borrow::Cow, collections::HashMap};

use alloy::primitives::aliases::B32;
use ekubo_sdk::{
    chain::evm::{
        EvmConcentratedPoolConfig, EvmConcentratedPoolKey, EvmConcentratedPoolState,
        EvmFullRangePoolState, EvmOraclePoolKey, EvmPoolTypeConfig, EvmTwammPoolKey,
    },
    quoting::{
        pools::{
            full_range::{FullRangePoolKey, FullRangePoolState, FullRangePoolTypeConfig},
            stableswap::{StableswapPoolKey, StableswapPoolState},
            twamm::TwammPoolState,
        },
        types::{PoolConfig, Tick, TimeRateDelta},
        util::find_nearest_initialized_tick_index,
    },
    U256,
};
use itertools::Itertools;
use revm::primitives::Address;
use tycho_client::feed::{synchronizer::ComponentWithState, BlockHeader};
use tycho_common::{
    models::{token::Token, Chain},
    Bytes,
};

use super::{
    addresses::{
        BOOSTED_FEES_CONCENTRATED_ADDRESS, MEV_CAPTURE_ADDRESS, ORACLE_ADDRESS,
        SIGNED_EXCLUSIVE_SWAP_DEPLOYMENTS, TWAMM_ADDRESS_V1, TWAMM_ADDRESS_V2,
        VE33_ROBINHOOD_ADDRESS,
    },
    attributes::{rate_deltas_from_attributes, ticks_from_attributes},
    pool::{
        boosted_fees::BoostedFeesPool,
        concentrated::ConcentratedPool,
        full_range::FullRangePool,
        mev_capture::MevCapturePool,
        oracle::OraclePool,
        stableswap::StableswapPool,
        twamm::TwammPool,
        ve33::{Ve33Pool, Ve33UnderlyingPool},
    },
    state::EkuboV3State,
};
use crate::protocol::{
    errors::InvalidSnapshotError,
    models::{DecoderContext, TryFromWithBlock},
};

pub enum ExtensionType {
    NoSwapCallPoints,
    Oracle,
    Twamm,
    MevCapture,
    BoostedFees,
    SignedExclusiveSwap,
    Ve33,
}

fn has_no_swap_call_points(extension: Address) -> bool {
    // Call points are encoded in the first byte of the extension address.
    // Bit 6 == beforeSwap, bit 5 == afterSwap.
    extension[0] & 0b0110_0000 == 0
}

pub fn extension_type(extension: Address, chain: Chain) -> Option<ExtensionType> {
    Some(if has_no_swap_call_points(extension) {
        ExtensionType::NoSwapCallPoints
    } else if extension == ORACLE_ADDRESS {
        ExtensionType::Oracle
    } else if [TWAMM_ADDRESS_V2, TWAMM_ADDRESS_V1].contains(&extension) {
        ExtensionType::Twamm
    } else if extension == MEV_CAPTURE_ADDRESS {
        ExtensionType::MevCapture
    } else if extension == BOOSTED_FEES_CONCENTRATED_ADDRESS {
        ExtensionType::BoostedFees
    } else if SIGNED_EXCLUSIVE_SWAP_DEPLOYMENTS.contains(&(chain, extension)) {
        ExtensionType::SignedExclusiveSwap
    } else if chain == Chain::Robinhood && extension == VE33_ROBINHOOD_ADDRESS {
        ExtensionType::Ve33
    } else {
        return None;
    })
}

struct TimedStateDetails {
    rate_token0: u128,
    rate_token1: u128,
    last_time: u64,
    rate_deltas: Vec<TimeRateDelta>,
}

impl TryFromWithBlock<ComponentWithState, BlockHeader> for EkuboV3State {
    type Error = InvalidSnapshotError;

    async fn try_from_with_header(
        snapshot: ComponentWithState,
        _block: BlockHeader,
        _account_balances: &HashMap<Bytes, HashMap<Bytes, Bytes>>,
        _all_tokens: &HashMap<Bytes, Token>,
        _decoder_context: &DecoderContext,
    ) -> Result<Self, Self::Error> {
        let chain = snapshot.component.chain;
        let static_attrs = snapshot.component.static_attributes;
        let state_attrs = snapshot.state.attributes;

        let (token0, token1) = (
            parse_address(attribute(&static_attrs, "token0")?, "token0")?,
            parse_address(attribute(&static_attrs, "token1")?, "token1")?,
        );

        let fee = u64::from_be_bytes(
            attribute(&static_attrs, "fee")?
                .as_ref()
                .try_into()
                .map_err(|err| {
                    InvalidSnapshotError::ValueError(format!("fee length mismatch: {err:?}"))
                })?,
        );

        let pool_type_config = EvmPoolTypeConfig::try_from(
            B32::try_from(attribute(&static_attrs, "pool_type_config")?.as_ref()).map_err(
                |err| {
                    InvalidSnapshotError::ValueError(format!(
                        "pool_type_config length mismatch: {err:?}"
                    ))
                },
            )?,
        )
        .map_err(|err| {
            InvalidSnapshotError::ValueError(format!("parsing pool_type_config: {err}"))
        })?;

        let extension = parse_address(attribute(&static_attrs, "extension")?, "extension")?;

        let liquidity = attribute(&state_attrs, "liquidity")?
            .clone()
            .into();

        let sqrt_ratio = U256::try_from_be_slice(&attribute(&state_attrs, "sqrt_ratio")?[..])
            .ok_or_else(|| InvalidSnapshotError::ValueError("invalid pool price".to_string()))?;

        let concentrated_pool = |state_attrs,
                                 pool_type_config|
         -> Result<
            (EvmConcentratedPoolKey, EvmConcentratedPoolState, i32, Vec<Tick>),
            InvalidSnapshotError,
        > {
            let tick = attribute(state_attrs, "tick")?
                .clone()
                .into();

            let mut ticks = ticks_from_attributes(
                state_attrs
                    .iter()
                    .map(|(key, value)| (key.as_str(), Cow::Borrowed(value))),
            )
            .map_err(InvalidSnapshotError::ValueError)?;

            ticks.sort_unstable_by_key(|tick| tick.index);

            Ok((
                EvmConcentratedPoolKey {
                    token0,
                    token1,
                    config: EvmConcentratedPoolConfig { extension, fee, pool_type_config },
                },
                EvmConcentratedPoolState {
                    sqrt_ratio,
                    liquidity,
                    active_tick_index: find_nearest_initialized_tick_index(&ticks, tick),
                },
                tick,
                ticks,
            ))
        };

        let ext_type = extension_type_from_attributes_or_address(&static_attrs, extension, chain)?;

        Ok(match ext_type {
            ExtensionType::NoSwapCallPoints => match pool_type_config {
                EvmPoolTypeConfig::FullRange(pool_type_config) => {
                    Self::FullRange(FullRangePool::new(
                        FullRangePoolKey {
                            token0,
                            token1,
                            config: PoolConfig { extension, fee, pool_type_config },
                        },
                        FullRangePoolState { sqrt_ratio, liquidity },
                    )?)
                }
                EvmPoolTypeConfig::Stableswap(pool_type_config) => {
                    Self::Stableswap(StableswapPool::new(
                        StableswapPoolKey {
                            token0,
                            token1,
                            config: PoolConfig { extension, fee, pool_type_config },
                        },
                        StableswapPoolState { sqrt_ratio, liquidity },
                    )?)
                }
                EvmPoolTypeConfig::Concentrated(pool_type_config) => {
                    let (key, state, tick, ticks) =
                        concentrated_pool(&state_attrs, pool_type_config)?;

                    Self::Concentrated(ConcentratedPool::new(key, state, tick, ticks)?)
                }
            },
            ExtensionType::Oracle => Self::Oracle(OraclePool::new(
                EvmOraclePoolKey {
                    token0,
                    token1,
                    config: PoolConfig {
                        extension,
                        fee,
                        pool_type_config: FullRangePoolTypeConfig,
                    },
                },
                EvmFullRangePoolState { sqrt_ratio, liquidity },
            )?),
            ExtensionType::Twamm => {
                let TimedStateDetails {
                    rate_token0: token0_sale_rate,
                    rate_token1: token1_sale_rate,
                    last_time: last_execution_time,
                    rate_deltas: virtual_order_deltas,
                } = timed_state_details(state_attrs)?;

                Self::Twamm(TwammPool::new(
                    EvmTwammPoolKey {
                        token0,
                        token1,
                        config: PoolConfig {
                            extension,
                            fee,
                            pool_type_config: FullRangePoolTypeConfig,
                        },
                    },
                    TwammPoolState {
                        full_range_pool_state: FullRangePoolState { sqrt_ratio, liquidity },
                        token0_sale_rate,
                        token1_sale_rate,
                        last_execution_time,
                    },
                    virtual_order_deltas,
                )?)
            }
            ExtensionType::MevCapture => {
                let EvmPoolTypeConfig::Concentrated(pool_type_config) = pool_type_config else {
                    return Err(InvalidSnapshotError::ValueError(
                        "expected concentrated pool type config for MEVCapture pool".to_string(),
                    ));
                };

                let (key, concentrated_state, tick, ticks) =
                    concentrated_pool(&state_attrs, pool_type_config)?;

                Self::MevCapture(MevCapturePool::new(key, tick, concentrated_state, ticks)?)
            }
            ExtensionType::SignedExclusiveSwap => {
                let EvmPoolTypeConfig::Concentrated(pool_type_config) = pool_type_config else {
                    return Err(InvalidSnapshotError::ValueError(
                        "expected concentrated pool type config for SignedExclusiveSwap pool"
                            .to_string(),
                    ));
                };

                let (key, state, tick, ticks) = concentrated_pool(&state_attrs, pool_type_config)?;

                Self::Concentrated(ConcentratedPool::new(key, state, tick, ticks)?)
            }
            ExtensionType::BoostedFees => {
                let EvmPoolTypeConfig::Concentrated(pool_type_config) = pool_type_config else {
                    return Err(InvalidSnapshotError::ValueError(
                        "expected concentrated pool type config for BoostedFees pool".to_string(),
                    ));
                };

                let (key, concentrated_pool_state, tick, ticks) =
                    concentrated_pool(&state_attrs, pool_type_config)?;

                let TimedStateDetails {
                    rate_token0: donate_rate0,
                    rate_token1: donate_rate1,
                    last_time: last_donate_time,
                    rate_deltas: donate_rate_deltas,
                } = timed_state_details(state_attrs)?;

                Self::BoostedFees(BoostedFeesPool::new(
                    key,
                    concentrated_pool_state,
                    donate_rate0,
                    donate_rate1,
                    last_donate_time,
                    donate_rate_deltas,
                    ticks,
                    tick,
                )?)
            }
            ExtensionType::Ve33 => {
                let underlying_pool = match pool_type_config {
                    EvmPoolTypeConfig::FullRange(pool_type_config) => {
                        Ve33UnderlyingPool::FullRange(FullRangePool::new(
                            FullRangePoolKey {
                                token0,
                                token1,
                                config: PoolConfig { extension, fee, pool_type_config },
                            },
                            FullRangePoolState { sqrt_ratio, liquidity },
                        )?)
                    }
                    EvmPoolTypeConfig::Stableswap(pool_type_config) => {
                        Ve33UnderlyingPool::Stableswap(StableswapPool::new(
                            StableswapPoolKey {
                                token0,
                                token1,
                                config: PoolConfig { extension, fee, pool_type_config },
                            },
                            StableswapPoolState { sqrt_ratio, liquidity },
                        )?)
                    }
                    EvmPoolTypeConfig::Concentrated(pool_type_config) => {
                        let (key, state, tick, ticks) =
                            concentrated_pool(&state_attrs, pool_type_config)?;
                        Ve33UnderlyingPool::Concentrated(ConcentratedPool::new(
                            key, state, tick, ticks,
                        )?)
                    }
                };
                let swap_fee = u64::from_be_bytes(
                    attribute(&state_attrs, "swap_fee")?
                        .as_ref()
                        .try_into()
                        .map_err(|err| {
                            InvalidSnapshotError::ValueError(format!(
                                "swap_fee length mismatch: {err:?}"
                            ))
                        })?,
                );

                Self::Ve33(Ve33Pool::new(underlying_pool, swap_fee)?)
            }
        })
    }
}

/// Determines the extension type, checking the legacy `extension_id` static
/// attribute first if present, then falling back to address-based detection.
fn extension_type_from_attributes_or_address(
    static_attrs: &HashMap<String, Bytes>,
    extension: Address,
    chain: Chain,
) -> Result<ExtensionType, InvalidSnapshotError> {
    // Backward compat: use extension_id attribute if present (legacy format).
    // A value of 0 means unset — fall through to address-based detection.
    if let Some(extension_id) = static_attrs.get("extension_id") {
        match i32::from(extension_id.clone()) {
            0 => {}
            1 => return Ok(ExtensionType::NoSwapCallPoints),
            2 => return Ok(ExtensionType::Oracle),
            3 => return Ok(ExtensionType::Twamm),
            4 => return Ok(ExtensionType::MevCapture),
            _ => {}
        }
    }

    // New way: detect from extension address
    extension_type(extension, chain).ok_or_else(|| {
        InvalidSnapshotError::ValueError(format!("unsupported extension {extension:x}"))
    })
}

fn attribute<'a>(
    map: &'a HashMap<String, Bytes>,
    key: &str,
) -> Result<&'a Bytes, InvalidSnapshotError> {
    map.get(key)
        .ok_or_else(|| InvalidSnapshotError::MissingAttribute(key.to_string()))
}

fn parse_address(bytes: &Bytes, attr_name: &str) -> Result<Address, InvalidSnapshotError> {
    Address::try_from(&bytes[..])
        .map_err(|err| InvalidSnapshotError::ValueError(format!("parsing {attr_name}: {err}")))
}

/// Gets an attribute by key, with an optional legacy fallback key.
fn attribute_with_fallback<'a>(
    map: &'a HashMap<String, Bytes>,
    key: &str,
    legacy_key: &str,
) -> Result<&'a Bytes, InvalidSnapshotError> {
    map.get(key)
        .or_else(|| map.get(legacy_key))
        .ok_or_else(|| InvalidSnapshotError::MissingAttribute(key.to_string()))
}

fn timed_state_details(
    attrs: HashMap<String, Bytes>,
) -> Result<TimedStateDetails, InvalidSnapshotError> {
    let last_time = attribute_with_fallback(&attrs, "last_time", "last_execution_time")?
        .clone()
        .into();

    Ok(TimedStateDetails {
        rate_token0: attribute_with_fallback(&attrs, "rate_token0", "token0_sale_rate")?
            .clone()
            .into(),
        rate_token1: attribute_with_fallback(&attrs, "rate_token1", "token1_sale_rate")?
            .clone()
            .into(),
        last_time,
        rate_deltas: rate_deltas_from_attributes(
            attrs
                .into_iter()
                .map(|(key, value)| (key, Cow::Owned(value))),
            last_time,
        )
        .map_err(InvalidSnapshotError::ValueError)?
        .sorted_unstable_by_key(|delta| delta.time)
        .collect(),
    })
}

#[cfg(test)]
mod tests {
    use rstest::*;
    use rstest_reuse::apply;
    use tycho_common::models::protocol::ProtocolComponentState;

    use super::*;
    use crate::evm::protocol::{
        ekubo_v3::test_cases::*, test_utils::try_decode_snapshot_with_defaults,
    };

    #[apply(all_cases)]
    #[tokio::test]
    async fn test_try_from_with_header(case: TestCase) {
        let snapshot = ComponentWithState {
            state: ProtocolComponentState {
                component_id: String::new(),
                attributes: case.state_attributes,
                balances: HashMap::new(),
            },
            component: case.component,
            component_tvl: None,
            entrypoints: Vec::new(),
        };

        let result = try_decode_snapshot_with_defaults::<EkuboV3State>(snapshot)
            .await
            .expect("reconstructing state");

        assert_eq!(result, case.state_before_transition);
    }

    /// Tests backward compatibility with the legacy attribute format:
    /// - `extension_id` discriminant instead of address-based detection
    /// - `ticks/` prefix instead of `tick/`
    /// - `orders/` prefix instead of `rate_delta/`
    /// - `token0_sale_rate`/`token1_sale_rate` instead of `rate_token0`/`rate_token1`
    /// - `last_execution_time` instead of `last_time`
    #[apply(all_cases)]
    #[tokio::test]
    async fn test_try_from_legacy_format(case: TestCase) {
        let extension_id: i32 = match &case.state_before_transition {
            EkuboV3State::Concentrated(_) |
            EkuboV3State::FullRange(_) |
            EkuboV3State::Stableswap(_) => 1,
            EkuboV3State::Oracle(_) => 2,
            EkuboV3State::Twamm(_) => 3,
            EkuboV3State::MevCapture(_) => 4,
            // BoostedFees is new, no legacy format
            EkuboV3State::BoostedFees(_) | EkuboV3State::Ve33(_) => return,
        };

        let mut component = case.component;
        // Add legacy extension_id attribute (keeps real extension address since
        // the SDK validates it)
        component
            .static_attributes
            .insert("extension_id".to_string(), extension_id.to_be_bytes().into());

        // Rename state attributes to legacy format
        let state_attributes = case
            .state_attributes
            .into_iter()
            .map(|(key, value)| {
                let key = key
                    .replace("tick/", "ticks/")
                    .replace("rate_delta/", "orders/");
                let key = match key.as_str() {
                    "rate_token0" => "token0_sale_rate".to_string(),
                    "rate_token1" => "token1_sale_rate".to_string(),
                    "last_time" => "last_execution_time".to_string(),
                    _ => key,
                };
                (key, value)
            })
            .collect();

        let snapshot = ComponentWithState {
            state: ProtocolComponentState {
                component_id: String::new(),
                attributes: state_attributes,
                balances: HashMap::new(),
            },
            component,
            component_tvl: None,
            entrypoints: Vec::new(),
        };

        let result = try_decode_snapshot_with_defaults::<EkuboV3State>(snapshot)
            .await
            .expect("reconstructing state from legacy format");

        assert_eq!(result, case.state_before_transition);
    }

    #[apply(all_cases)]
    #[tokio::test]
    async fn test_try_from_invalid(case: TestCase) {
        for missing_attribute in case.required_attributes {
            let mut component = case.component.clone();
            let mut attributes = case.state_attributes.clone();

            component
                .static_attributes
                .remove(&missing_attribute);
            attributes.remove(&missing_attribute);

            let snapshot = ComponentWithState {
                state: ProtocolComponentState {
                    attributes,
                    component_id: String::new(),
                    balances: HashMap::new(),
                },
                component,
                component_tvl: None,
                entrypoints: Vec::new(),
            };

            EkuboV3State::try_from_with_header(
                snapshot,
                BlockHeader::default(),
                &HashMap::default(),
                &HashMap::default(),
                &DecoderContext::new(),
            )
            .await
            .unwrap_err();
        }
    }

    #[rstest]
    #[case::concentrated(concentrated())]
    #[case::full_range(full_range())]
    #[case::stableswap(stableswap())]
    #[tokio::test]
    async fn test_decode_ve33_underlying_pool_types(#[case] mut case: TestCase) {
        case.component.chain = Chain::Robinhood;
        case.component.static_attributes.insert(
            "extension".to_string(),
            VE33_ROBINHOOD_ADDRESS
                .into_array()
                .into(),
        );
        case.state_attributes
            .insert("swap_fee".to_string(), 1_u64.to_be_bytes().into());

        let snapshot = ComponentWithState {
            state: ProtocolComponentState {
                component_id: String::new(),
                attributes: case.state_attributes,
                balances: HashMap::new(),
            },
            component: case.component,
            component_tvl: None,
            entrypoints: Vec::new(),
        };

        let result = try_decode_snapshot_with_defaults::<EkuboV3State>(snapshot)
            .await
            .expect("reconstructing Ve33 state");

        assert!(matches!(result, EkuboV3State::Ve33(_)));
    }
}