eigen_client_elcontracts/

reader.rs

use crate::error::ElContractsError;
use alloy::{
    primitives::{Address, FixedBytes, U256},
    providers::Provider,
};
use eigen_common::{get_provider, SdkProvider};
use eigen_utils::slashing::core::allocation_manager::AllocationManager::{self, OperatorSet};
use eigen_utils::slashing::{
    core::{
        avs_directory::AVSDirectory,
        delegation_manager::DelegationManager,
        i_rewards_coordinator::{
            IRewardsCoordinator::{self},
            IRewardsCoordinatorTypes::{DistributionRoot, RewardsMerkleClaim},
        },
        i_strategy::IStrategy::{self, IStrategyInstance},
        permission_controller::PermissionController,
    },
    middleware::ierc20::IERC20::{self, IERC20Instance},
};
#[derive(Debug, Clone)]
pub struct ELChainReader {
    allocation_manager: Option<Address>,
    pub(crate) delegation_manager: Address,
    avs_directory: Address,
    permission_controller: Option<Address>,
    rewards_coordinator: Address,
    // TODO: we should make this private
    pub provider: String,
}

impl ELChainReader {
    /// Creates a new `ELChainReader` instance with the given parameters.
    ///
    /// # Arguments
    ///
    /// * `allocation_manager` - The address of the allocation manager contract.
    /// * `delegation_manager` - The address of the delegation manager contract.
    /// * `rewards_coordinator` - The address of the rewards coordinator contract.
    /// * `avs_directory` - The address of the avs directory contract.
    /// * `permission_controller` - The address of the permission controller contract.
    /// * `provider` - The provider to use for the RPC client.
    ///
    /// # Returns
    ///
    /// A new `ELChainReader` instance.
    pub fn new(
        allocation_manager: Option<Address>,
        delegation_manager: Address,
        rewards_coordinator: Address,
        avs_directory: Address,
        permission_controller: Option<Address>,
        provider: String,
    ) -> Self {
        ELChainReader {
            allocation_manager,
            delegation_manager,
            rewards_coordinator,
            avs_directory,
            permission_controller,
            provider,
        }
    }

    /// Builds a new `ELChainReader` instance, getting the AllocationManager and PermissionController addresses
    /// from the delegation manager.
    ///
    /// # Arguments
    ///
    /// * `delegation_manager` - The address of the delegation manager contract.
    /// * `avs_directory` - The address of the avs directory contract.
    /// * `rewards_coordinator` - The address of the rewards coordinator contract.
    /// * `client` - The provider to use for the RPC client to call the contracts.
    ///
    /// # Returns
    ///
    /// A new `ELChainReader` instance.
    ///
    /// # Errors
    pub async fn build(
        delegation_manager: Address,
        avs_directory: Address,
        rewards_coordinator: Address,
        client: &String,
    ) -> Result<Self, ElContractsError> {
        let provider = get_provider(client);

        let contract_delegation_manager = DelegationManager::new(delegation_manager, provider);
        let is_operator_set = contract_delegation_manager.allocationManager().call().await;
        if is_operator_set.is_err() {
            Ok(Self {
                allocation_manager: None,
                delegation_manager,
                avs_directory,
                permission_controller: None,
                rewards_coordinator,
                provider: client.to_string(),
            })
        } else {
            let allocation_manager = contract_delegation_manager
                .allocationManager()
                .call()
                .await
                .map_err(ElContractsError::AlloyContractError)?;
            let permission_controller = contract_delegation_manager
                .permissionController()
                .call()
                .await
                .map_err(ElContractsError::AlloyContractError)?;

            Ok(Self {
                avs_directory,
                allocation_manager: Some(allocation_manager),
                delegation_manager,
                rewards_coordinator,
                permission_controller: Some(permission_controller),
                provider: client.to_string(),
            })
        }
    }

    /// Calculate the delegation approval digest hash
    ///
    /// # Arguments
    ///
    /// * `staker` - The staker's address
    /// * `operator` - The operator's address
    /// * `delegation_approver` - The delegation approver's address
    /// * `approve_salt` - The approve salt
    /// * `expiry` - The expiry
    ///
    /// # Returns
    ///
    /// * `FixedBytes<32>` - The delegation approval digest hash
    ///
    /// # Errors
    ///
    /// * `ElContractsError` - if the call to the contract fails
    pub async fn calculate_delegation_approval_digest_hash(
        &self,
        staker: Address,
        operator: Address,
        delegation_approver: Address,
        approve_salt: FixedBytes<32>,
        expiry: U256,
    ) -> Result<FixedBytes<32>, ElContractsError> {
        let provider = get_provider(&self.provider);
        let contract_delegation_manager = DelegationManager::new(self.delegation_manager, provider);
        contract_delegation_manager
            .calculateDelegationApprovalDigestHash(
                staker,
                operator,
                delegation_approver,
                approve_salt,
                expiry,
            )
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)
    }

    /// Calculate the operator avs registration digest hash
    ///
    /// # Arguments
    ///
    /// * `operator` - The operator's address
    /// * `avs` - The avs's address
    /// * `salt` - The salt
    /// * `expiry` - The expiry
    ///
    /// # Returns
    ///
    /// * `FixedBytes<32>` - The operator avs registration digest hash
    ///
    /// # Errors
    ///
    /// * `ElContractsError` - if the call to the contract fails
    pub async fn calculate_operator_avs_registration_digest_hash(
        &self,
        operator: Address,
        avs: Address,
        salt: FixedBytes<32>,
        expiry: U256,
    ) -> Result<FixedBytes<32>, ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_avs_directory = AVSDirectory::new(self.avs_directory, provider);

        contract_avs_directory
            .calculateOperatorAVSRegistrationDigestHash(operator, avs, salt, expiry)
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)
    }

    /// Get the length of the distribution roots.
    ///
    /// # Returns
    ///
    /// * `Result<U256, ElContractsError>` - The length of the distribution roots if the call is successful,
    ///   otherwise an error.
    ///
    /// # Errors
    ///
    /// * `ElContractsError` - if the call to the contract fails.
    pub async fn get_distribution_roots_length(&self) -> Result<U256, ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_rewards_coordinator =
            IRewardsCoordinator::new(self.rewards_coordinator, &provider);

        contract_rewards_coordinator
            .getDistributionRootsLength()
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)
    }

    /// Get the current rewards calculation end timestamp (the timestamp until which rewards have been calculated).
    ///
    /// # Returns
    ///
    /// * `Result<u32, ElContractsError>` - The current rewards calculation
    ///   end timestamp if the call is successful.
    ///
    /// # Errors
    ///
    /// * `ElContractsError` - if the call to the contract fails.
    pub async fn curr_rewards_calculation_end_timestamp(&self) -> Result<u32, ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_rewards_coordinator =
            IRewardsCoordinator::new(self.rewards_coordinator, &provider);

        contract_rewards_coordinator
            .currRewardsCalculationEndTimestamp()
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)
    }

    /// Get the latest claimable distribution root.
    ///
    /// # Returns
    /// * `Result<DistributionRoot, ElContractsError>` - The latest claimable distribution root if the call is successful.
    ///
    /// # Errors
    /// * `ElContractsError` - if the call to the contract fails.
    pub async fn get_current_claimable_distribution_root(
        &self,
    ) -> Result<DistributionRoot, ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_rewards_coordinator =
            IRewardsCoordinator::new(self.rewards_coordinator, &provider);

        contract_rewards_coordinator
            .getCurrentClaimableDistributionRoot()
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)
    }

    /// Get the root index from a given hash.
    ///
    /// # Arguments
    ///
    /// * `hash` - The hash to get the root index from.
    ///
    /// # Returns
    ///
    /// * `Result<u32, ElContractsError>` - The root index if the
    ///   call is successful.
    ///
    /// # Errors
    ///
    /// * `ElContractsError` - if the call to the contract fails.
    pub async fn get_root_index_from_hash(
        &self,
        hash: FixedBytes<32>,
    ) -> Result<u32, ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_rewards_coordinator =
            IRewardsCoordinator::new(self.rewards_coordinator, &provider);

        contract_rewards_coordinator
            .getRootIndexFromHash(hash)
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)
    }

    /// Get the cumulative claimed amount for a given earner address and token.
    ///
    /// # Arguments
    ///
    /// * `earner_address` - The address of the earner.
    /// * `token` - The address of the token.
    ///
    /// # Returns
    ///
    /// * `Result<U256, ElContractsError>` - The cumulative claimed amount if the call is successful.
    ///
    /// # Errors
    ///
    /// * `ElContractsError` - if the call to the contract fails.
    pub async fn get_cumulative_claimed(
        &self,
        earner_address: Address,
        token: Address,
    ) -> Result<U256, ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_rewards_coordinator =
            IRewardsCoordinator::new(self.rewards_coordinator, &provider);

        contract_rewards_coordinator
            .cumulativeClaimed(earner_address, token)
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)
    }

    /// Check if a claim would currently pass the validations in `process_claim`
    ///
    /// # Arguments
    ///
    /// * `claim` - The claim to check
    ///
    /// # Returns
    ///
    /// * `Result<bool, ElContractsError>` - True if the claim would pass the validations, false otherwise
    ///
    /// # Errors
    ///
    /// * `ElContractsError` - if the call to the contract fails. Also fails if no root has been submitted yet.
    pub async fn check_claim(&self, claim: RewardsMerkleClaim) -> Result<bool, ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_rewards_coordinator =
            IRewardsCoordinator::new(self.rewards_coordinator, &provider);

        contract_rewards_coordinator
            .checkClaim(claim)
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)
    }

    /// Gets the split of a specific `operator` for a specific `avs`
    ///
    /// # Arguments
    ///
    /// * `operator` - The operator address
    /// * `avs` - The AVS address
    ///
    /// # Returns
    ///
    /// * u16 - The split of the operator for the AVS, if the call is successful
    ///
    /// # Errors
    ///
    /// * `ElContractsError` - if the call to the contract fails.
    pub async fn get_operator_avs_split(
        &self,
        operator: Address,
        avs: Address,
    ) -> Result<u16, ElContractsError> {
        let provider = get_provider(&self.provider);

        let rewards_coordinator = IRewardsCoordinator::new(self.rewards_coordinator, provider);

        rewards_coordinator
            .getOperatorAVSSplit(operator, avs)
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)
    }

    /// Gets the split of a specific `operator` for Programmatic Incentives
    ///
    /// # Arguments
    ///
    /// * `operator` - The operator address
    ///
    /// # Returns
    ///
    /// * u16 - The split of the operator for PI, if the call is successful
    ///
    /// # Errors
    ///
    /// * `ElContractsError` - if the call to the contract fails.
    pub async fn get_operator_pi_split(&self, operator: Address) -> Result<u16, ElContractsError> {
        let provider = get_provider(&self.provider);

        let rewards_coordinator = IRewardsCoordinator::new(self.rewards_coordinator, provider);

        rewards_coordinator
            .getOperatorPISplit(operator)
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)
    }

    /// Gets the split for a specific `operator` for a given `OperatorSet`
    ///
    /// # Arguments
    ///
    /// * `operator` - The operator address
    /// * `OperatorSet` - The operator set which consists of avs address and id.
    ///
    /// # Returns
    ///
    /// * u16 - The split for a specific `operator` for a given `OperatorSet`, if the call is successful
    ///
    /// # Errors
    ///
    /// * `ElContractsError` - if the call to the contract fails.
    pub async fn get_operator_set_split(
        &self,
        operator: Address,
        operator_set: eigen_utils::slashing::core::i_rewards_coordinator::IRewardsCoordinator::OperatorSet,
    ) -> Result<u16, ElContractsError> {
        let provider = get_provider(&self.provider);

        let rewards_coordinator = IRewardsCoordinator::new(self.rewards_coordinator, provider);

        rewards_coordinator
            .getOperatorSetSplit(operator, operator_set)
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)
    }

    /// Get the operator's shares in a strategy
    ///
    /// # Arguments
    ///
    /// * `operator_addr` - The operator's address
    /// * `strategy_addr` - The strategy's address
    ///
    /// # Returns
    ///
    /// * `U256` - The operator's shares in the strategy
    ///
    /// # Errors
    ///
    /// * `ElContractsError` - if the call to the contract fails
    pub async fn get_operator_shares_in_strategy(
        &self,
        operator_addr: Address,
        strategy_addr: Address,
    ) -> Result<U256, ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_delegation_manager = DelegationManager::new(self.delegation_manager, provider);

        contract_delegation_manager
            .operatorShares(operator_addr, strategy_addr)
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)
    }

    /// Get strategy and underlying ERC-20 token
    ///
    /// # Arguments
    ///
    /// * `strategy_addr` - The strategy's address
    ///
    /// # Returns
    ///
    /// - the strategy contract,
    /// - the erc20 bindings for the underlying token
    /// - and the underlying token address
    ///
    /// # Errors
    ///
    /// * `ElContractsError` - if the call to the contract fails
    pub async fn get_strategy_and_underlying_erc20_token(
        &self,
        strategy_addr: Address,
    ) -> Result<
        (
            IStrategyInstance<SdkProvider>,
            IERC20Instance<SdkProvider>,
            Address,
        ),
        ElContractsError,
    > {
        let (contract_strategy, underlying_token) = self
            .get_strategy_and_underlying_token(strategy_addr)
            .await?;

        let token_contract = IERC20::new(underlying_token, contract_strategy.provider().to_owned());

        Ok((contract_strategy, token_contract, underlying_token))
    }

    /// Check if the operator is registered
    ///
    /// # Arguments
    ///
    /// * `operator` - The operator's address
    ///
    /// # Returns
    ///
    /// * `bool` - true if the operator is registered, false otherwise
    ///
    /// # Errors
    ///
    /// * `ElContractsError` - if the call to the contract fails
    pub async fn is_operator_registered(
        &self,
        operator: Address,
    ) -> Result<bool, ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_delegation_manager = DelegationManager::new(self.delegation_manager, provider);

        contract_delegation_manager
            .isOperator(operator)
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)
    }

    /// Get the staker's shares in all of the strategies in which they have nonzero shares
    /// # Arguments
    /// * `staker_address` - The staker's address
    /// * `block_number` - The block number
    ///
    /// # Returns
    /// * `Vec<Address>` - An array of strategy addresses
    /// * `Vec<U256>` - An array with the amount of shares the staker has in each strategy
    ///
    /// # Errors
    /// * `ElContractsError` - if the call to the contract fails
    pub async fn get_staker_shares(
        &self,
        staker_address: Address,
    ) -> Result<(Vec<Address>, Vec<U256>), ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_delegation_manager = DelegationManager::new(self.delegation_manager, provider);

        let deposited_shares = contract_delegation_manager
            .getDepositedShares(staker_address)
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)?;

        let DelegationManager::getDepositedSharesReturn {
            _0: addresses,
            _1: shares,
        } = deposited_shares;

        Ok((addresses, shares))
    }

    /// Get the delegated operator
    /// # Arguments
    /// * `staker_address` - The staker's address
    /// * `block_number` - The block number
    ///
    /// # Returns
    /// * `Address` - The address of the operator to whom the staker has delegated their shares
    ///
    /// # Errors
    /// * `ElContractsError` - if the call to the contract fails
    pub async fn get_delegated_operator(
        &self,
        staker_address: Address,
    ) -> Result<Address, ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_delegation_manager = DelegationManager::new(self.delegation_manager, provider);

        contract_delegation_manager
            .delegatedTo(staker_address)
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)
    }

    /// # Returns the strategy contract and the underlying token address.
    ///
    /// # Arguments
    ///
    /// * `strategy_addr` - The strategy's address
    ///
    /// # Returns
    ///
    /// - the strategy contract address,
    /// - and the underlying token address
    ///
    /// # Errors
    ///
    /// * `ElContractsError` - if the call to the contract fails
    pub async fn get_strategy_and_underlying_token(
        &self,
        strategy_addr: Address,
    ) -> Result<(IStrategyInstance<SdkProvider>, Address), ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_strategy = IStrategy::new(strategy_addr, provider);

        let underlying_token = contract_strategy
            .underlyingToken()
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)?;

        Ok((contract_strategy, underlying_token))
    }

    /// For a strategy, get the amount of magnitude not currently allocated to any operator set
    /// # Arguments
    /// * `operator_address` - The operator's address to query
    /// * `strategy_address` - The strategy's address to get allocatable magnitude for
    /// # Returns
    /// * `u64` - The magnitude available to be allocated to an operator set
    /// # Errors
    /// * `ElContractsError` - if the call to the contract fails
    pub async fn get_allocatable_magnitude(
        &self,
        operator_address: Address,
        strategy_address: Address,
    ) -> Result<u64, ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_allocation_manager = AllocationManager::new(
            self.allocation_manager
                .ok_or(ElContractsError::MissingParameter)?,
            provider,
        );

        contract_allocation_manager
            .getAllocatableMagnitude(operator_address, strategy_address)
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)
    }

    /// Get the maximum magnitude an operator can allocate for the given strategies
    /// # Arguments
    /// * `operator_address` - The operator's address to query
    /// * `strategy_addresses` - The strategy's addresses to get max magnitudes for
    /// # Returns
    /// * `Vec<u64>` - The maximum magnitudes for the strategies
    /// # Errors
    /// * `ElContractsError` - if the call to the contract fails
    pub async fn get_max_magnitudes(
        &self,
        operator_address: Address,
        strategy_addresses: Vec<Address>,
    ) -> Result<Vec<u64>, ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_allocation_manager = AllocationManager::new(
            self.allocation_manager
                .ok_or(ElContractsError::MissingParameter)?,
            provider,
        );

        contract_allocation_manager
            .getMaxMagnitudes_1(operator_address, strategy_addresses)
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)
    }

    /// Get the allocation info given a strategy and an operator. Returns the info for each operator set where an operator has allocation.
    /// # Arguments
    /// * `operator_address` - The operator's address to query
    /// * `strategy_address` - The strategy's address to get allocation info for
    /// # Returns
    /// * `Vec<AllocationInfo>` - The allocation info for each operator set
    /// # Errors
    /// * `ElContractsError` - if the call to the contract fails
    pub async fn get_allocation_info(
        &self,
        operator_address: Address,
        strategy_address: Address,
    ) -> Result<Vec<AllocationInfo>, ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_allocation_manager = AllocationManager::new(
            self.allocation_manager
                .ok_or(ElContractsError::MissingParameter)?,
            provider,
        );

        let allocations = contract_allocation_manager
            .getStrategyAllocations(operator_address, strategy_address)
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)?;

        let AllocationManager::getStrategyAllocationsReturn {
            _0: operator_sets,
            _1: allocation_info,
        } = allocations;

        let mut allocations_info = vec![];
        for (i, operator_set) in operator_sets.iter().enumerate() {
            allocations_info.push(AllocationInfo {
                operator_set: operator_set.clone(),
                current_magnitude: U256::from(allocation_info[i].currentMagnitude),
                pending_diff: U256::from(allocation_info[i].pendingDiff),
                effect_block: allocation_info[i].effectBlock,
            });
        }

        Ok(allocations_info)
    }

    /// Get the shares that an operator owns in a set of strategies
    /// # Arguments
    /// * `operator_address` - The operator's address to get shares for
    /// * `strategy_addresses` - The strategy's addresses to get shares for
    /// # Returns
    /// * `Vec<U256>` - The list of shares for each strategy
    /// # Errors
    /// * `ElContractsError` - if the call to the contract fails
    pub async fn get_operator_shares(
        &self,
        operator_address: Address,
        strategy_addresses: Vec<Address>,
    ) -> Result<Vec<U256>, ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_delegation_manager = DelegationManager::new(self.delegation_manager, provider);

        contract_delegation_manager
            .getOperatorShares(operator_address, strategy_addresses)
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)
    }

    /// Get the shares that a list of operators own in a set of strategies
    /// # Arguments
    /// * `operator_addresses` - The list of operators' addresses to get shares for
    /// * `strategy_addresses` - The strategy's addresses to get shares for
    /// # Returns
    /// * `Vec<Vec<U256>>` - The list of shares for each operator
    /// # Errors
    /// * `ElContractsError` - if the call to the contract fails
    pub async fn get_operators_shares(
        &self,
        operator_addresses: Vec<Address>,
        strategy_addresses: Vec<Address>,
    ) -> Result<Vec<Vec<U256>>, ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_delegation_manager = DelegationManager::new(self.delegation_manager, provider);

        contract_delegation_manager
            .getOperatorsShares(operator_addresses, strategy_addresses)
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)
    }

    /// Get the number of operator sets that an operator is part of. Doesn't include M2 AVSs
    /// # Arguments
    /// * `operator_addr` - The operator's address to query
    /// # Returns
    /// * `U256` - The number of operator sets the operator is part of
    /// # Errors
    /// * `ElContractsError` - if the call to the contract fails
    pub async fn get_num_operator_sets_for_operator(
        &self,
        operator_addr: Address,
    ) -> Result<U256, ElContractsError> {
        self.get_operator_sets_for_operator(operator_addr)
            .await
            .map(|operator_sets| U256::from(operator_sets.len() as u64))
    }

    /// Get the operator sets that an operator is part of. Doesn't include M2 AVSs
    /// # Arguments
    /// * `operator_addr` - The operator's address to query
    /// # Returns
    /// * `Vec<OperatorSet>` - The operator sets the operator is part of
    /// # Errors
    /// * `ElContractsError` - if the call to the contract fails
    pub async fn get_operator_sets_for_operator(
        &self,
        operator_addr: Address,
    ) -> Result<Vec<OperatorSet>, ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_allocation_manager = AllocationManager::new(
            self.allocation_manager
                .ok_or(ElContractsError::MissingParameter)?,
            provider,
        );

        contract_allocation_manager
            .getAllocatedSets(operator_addr)
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)
    }

    /// Check if an operator is registered with a specific operator set
    /// # Arguments
    /// * `operator_address` - The operator's address to query
    /// * `operator_set` - The operator set to check if the operator is registered with
    /// # Returns
    /// * `bool` - true if the operator is registered with the operator set, false otherwise
    /// # Errors
    /// * `ElContractsError` - if the call to the contract fails
    pub async fn is_operator_registered_with_operator_set(
        &self,
        operator_address: Address,
        operator_set: OperatorSet,
    ) -> Result<bool, ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_allocation_manager = AllocationManager::new(
            self.allocation_manager
                .ok_or(ElContractsError::MissingParameter)?,
            provider,
        );
        let registered_operator_sets = contract_allocation_manager
            .getRegisteredSets(operator_address)
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)?;

        let is_registered = registered_operator_sets
            .iter()
            .any(|registered_operator_set| {
                registered_operator_set.id == operator_set.id
                    && registered_operator_set.avs == operator_set.avs
            });
        Ok(is_registered)
    }

    /// Get the operators in a specific operator set. Not supported for M2 AVSs
    /// # Arguments
    /// * `operator_set` - The operator set to query
    /// # Returns
    /// * `Vec<Address>` - The list of operator's addresses in the operator set
    /// # Errors
    /// * `ElContractsError` - if the call to the contract fails
    pub async fn get_operators_for_operator_set(
        &self,
        operator_set: OperatorSet,
    ) -> Result<Vec<Address>, ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_allocation_manager = AllocationManager::new(
            self.allocation_manager
                .ok_or(ElContractsError::MissingParameter)?,
            provider,
        );

        contract_allocation_manager
            .getMembers(operator_set)
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)
    }

    /// Get the number of operators in a specific operator set. Not supported for M2 AVSs
    /// # Arguments
    /// * `operator_set` - The operator set to query
    /// # Returns
    /// * `U256` - The number of operators in the operator set
    /// # Errors
    /// * `ElContractsError` - if the call to the contract fails
    pub async fn get_num_operators_for_operator_set(
        &self,
        operator_set: OperatorSet,
    ) -> Result<U256, ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_allocation_manager = AllocationManager::new(
            self.allocation_manager
                .ok_or(ElContractsError::MissingParameter)?,
            provider,
        );

        contract_allocation_manager
            .getMemberCount(operator_set)
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)
    }

    /// Get the strategies in a specific operator set. Not supported for M2 AVSs
    /// # Arguments
    /// * `operator_set` - The operator set to query
    /// # Returns
    /// * `Vec<Address>` - The list of strategy's addresses in the operator set
    /// # Errors
    pub async fn get_strategies_for_operator_set(
        &self,
        operator_set: OperatorSet,
    ) -> Result<Vec<Address>, ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_allocation_manager = AllocationManager::new(
            self.allocation_manager
                .ok_or(ElContractsError::MissingParameter)?,
            provider,
        );

        contract_allocation_manager
            .getStrategiesInOperatorSet(operator_set)
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)
    }

    /// Get the slashable shares for an operator.
    /// # Arguments
    /// * `operator_address` - The operator's address to query
    /// * `operator_set` - The operator set to query
    /// * `strategies` - The strategies to query
    /// # Returns
    /// * `Vec<U256>` - The amount of slashable shares for each strategy
    /// # Errors
    /// * `ElContractsError` - if the call to the contract fails
    pub async fn get_slashable_shares(
        &self,
        operator_address: Address,
        operator_set: OperatorSet,
        strategies: Vec<Address>,
    ) -> Result<Vec<U256>, ElContractsError> {
        let provider = get_provider(&self.provider);
        let current_block_number = provider.get_block_number().await.map_err(|e| {
            ElContractsError::AlloyContractError(alloy::contract::Error::TransportError(e))
        })?;

        let contract_allocation_manager = AllocationManager::new(
            self.allocation_manager
                .ok_or(ElContractsError::MissingParameter)?,
            provider,
        );
        let slashable_stake = contract_allocation_manager
            .getMinimumSlashableStake(
                operator_set,
                vec![operator_address],
                strategies.clone(),
                current_block_number as u32,
            )
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)?;

        let Some(slashable_operator_stake) = slashable_stake.first() else {
            return Err(ElContractsError::NoSlashableSharesFound);
        };

        Ok(slashable_operator_stake.clone())
    }

    /// Get the minimum amount of shares that are slashable by the operator sets. Not supported for M2 AVSs.
    /// # Arguments
    /// * `operator_sets` - The operator sets to query
    /// # Returns
    /// * `Vec<OperatorSetStakes>` - The operator sets, their strategies, operators, and slashable stakes
    /// # Errors
    /// * `ElContractsError` - if the call to the contract fails
    pub async fn get_slashable_shares_for_operator_sets(
        &self,
        operator_sets: Vec<OperatorSet>,
    ) -> Result<Vec<OperatorSetStakes>, ElContractsError> {
        let provider = get_provider(&self.provider);
        let current_block_number = provider.get_block_number().await.map_err(|e| {
            ElContractsError::AlloyContractError(alloy::contract::Error::TransportError(e))
        })?;
        self.get_slashable_shares_for_operator_sets_before(
            operator_sets,
            current_block_number as u32,
        )
        .await
    }

    /// Given a list of operator sets, for each one get:
    /// - the operators,
    /// - the strategies,
    /// - the minimum amount of shares that are slashable before a given block.
    ///   Not supported for M2 AVSs.
    /// # Arguments
    /// * `operator_sets` - The operator sets to query
    /// * `future_block` - The block at which to get allocation information. It must be greater that the current block number.
    /// # Returns
    /// * `Vec<OperatorSetStakes>` - The operator sets, their strategies, operators, and slashable stakes
    /// # Errors
    /// * `ElContractsError` - if the call to the contract fails
    pub async fn get_slashable_shares_for_operator_sets_before(
        &self,
        operator_sets: Vec<OperatorSet>,
        future_block: u32,
    ) -> Result<Vec<OperatorSetStakes>, ElContractsError> {
        let provider = get_provider(&self.provider);
        let mut operator_set_stakes = vec![];
        let contract_allocation_manager = AllocationManager::new(
            self.allocation_manager
                .ok_or(ElContractsError::MissingParameter)?,
            provider,
        );

        for operator_set in operator_sets {
            let operators = self
                .get_operators_for_operator_set(operator_set.clone())
                .await?;
            let strategies = self
                .get_strategies_for_operator_set(operator_set.clone())
                .await?;

            let slashable_stakes = contract_allocation_manager
                .getMinimumSlashableStake(
                    operator_set.clone(),
                    operators.clone(),
                    strategies.clone(),
                    future_block,
                )
                .call()
                .await?;
            operator_set_stakes.push(OperatorSetStakes {
                operator_set,
                strategies,
                operators,
                slashable_stakes,
            });
        }
        Ok(operator_set_stakes)
    }

    /// Get the allocation delay for an operator. Is the number of blocks between an operator allocating slashable magnitude and the magnitude becoming slashable.
    /// # Arguments
    /// * `operator_address` - The operator's address to query
    /// # Returns
    /// * `u32` - The allocation delay
    /// # Errors
    /// * `ElContractsError` - if the call to the contract fails
    /// * `AllocationDelayNotSet` - if the allocation delay is not set
    pub async fn get_allocation_delay(
        &self,
        operator_address: Address,
    ) -> Result<u32, ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_allocation_manager = AllocationManager::new(
            self.allocation_manager
                .ok_or(ElContractsError::MissingParameter)?,
            provider,
        );

        let allocation_delay = contract_allocation_manager
            .getAllocationDelay(operator_address)
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)?;

        let AllocationManager::getAllocationDelayReturn {
            _0: is_set,
            _1: delay,
        } = allocation_delay;

        if !is_set {
            return Err(ElContractsError::AllocationDelayNotSet);
        }

        Ok(delay)
    }

    /// Get the operator sets that the operator is registered for
    /// # Arguments
    /// * `operator_address` - The operator's address to query
    /// # Returns
    /// * `Vec<OperatorSet>` - The operator sets the operator is registered for
    /// # Errors
    /// * `ElContractsError` - if the call to the contract fails
    pub async fn get_registered_sets(
        &self,
        operator_address: Address,
    ) -> Result<Vec<OperatorSet>, ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_allocation_manager = AllocationManager::new(
            self.allocation_manager
                .ok_or(ElContractsError::MissingParameter)?,
            provider,
        );

        contract_allocation_manager
            .getRegisteredSets(operator_address)
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)
    }

    /// Check if the given caller has permissions to call the function
    ///
    /// # Arguments
    ///
    /// * `account_address` - The account address to check
    /// * `appointee_address` - The caller address to check permissions for
    /// * `target` - The target address to check permissions for
    /// * `selector` - The selector of the function to check permissions for
    ///
    /// # Returns
    ///
    /// * `bool` - true if the account has permissions to call the function, false otherwise
    ///
    /// # Errors
    ///
    /// * `ElContractsError` - if the call to the contract fails
    pub async fn can_call(
        &self,
        account_address: Address,
        appointee_address: Address,
        target: Address,
        selector: FixedBytes<4>,
    ) -> Result<bool, ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_permission_controller =
            PermissionController::new(self.permission_controller.unwrap(), provider);

        contract_permission_controller
            .canCall(account_address, appointee_address, target, selector)
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)
    }

    /// Get the list of appointees for a given account and function
    /// # Arguments
    /// * `account_address` - The account address to get appointees for
    /// * `target` - The target address to get appointees for
    /// * `selector` - The selector of the function to get appointees for
    /// # Returns
    /// * `Vec<Address>` - The list of appointees
    /// # Errors
    /// * `ElContractsError` - if the call to the contract fails
    pub async fn list_appointees(
        &self,
        account_address: Address,
        target: Address,
        selector: FixedBytes<4>,
    ) -> Result<Vec<Address>, ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_permission_controller =
            PermissionController::new(self.permission_controller.unwrap(), provider);

        contract_permission_controller
            .getAppointees(account_address, target, selector)
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)
    }

    /// Get the list of permissions of an appointee for a given account
    /// # Arguments
    /// * `account_address` - The account address to get appointee permissions for
    /// * `appointee_address` - The appointee address to get permissions
    /// # Returns
    /// * `Vec<Address>` - The list of targets
    /// * `Vec<FixedBytes<4>>` - The list of selectors
    /// # Errors
    /// * `ElContractsError` - if the call to the contract fails
    pub async fn list_appointee_permissions(
        &self,
        account_address: Address,
        appointee_address: Address,
    ) -> Result<(Vec<Address>, Vec<FixedBytes<4>>), ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_permission_controller =
            PermissionController::new(self.permission_controller.unwrap(), provider);

        let appointee_permissions = contract_permission_controller
            .getAppointeePermissions(account_address, appointee_address)
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)?;

        let PermissionController::getAppointeePermissionsReturn {
            _0: targets,
            _1: selectors,
        } = appointee_permissions;

        Ok((targets, selectors))
    }

    /// Get the list of pending admins of a given account
    /// # Arguments
    /// * `account_address` - The account address to get pending admins of
    /// # Returns
    /// * `Vec<Address>` - The list of pending admins
    /// # Errors
    /// * `ElContractsError` - if the call to the contract fails
    pub async fn list_pending_admins(
        &self,
        account_address: Address,
    ) -> Result<Vec<Address>, ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_permission_controller =
            PermissionController::new(self.permission_controller.unwrap(), provider);

        contract_permission_controller
            .getPendingAdmins(account_address)
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)
    }

    /// Get the list of admins of a given account
    /// # Arguments
    /// * `account_address` - The account address
    /// # Returns
    /// * `Vec<Address>` - The list of admins
    /// # Errors
    /// * `ElContractsError` - if the call to the contract fails
    pub async fn list_admins(
        &self,
        account_address: Address,
    ) -> Result<Vec<Address>, ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_permission_controller =
            PermissionController::new(self.permission_controller.unwrap(), provider);

        contract_permission_controller
            .getAdmins(account_address)
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)
    }

    /// Check if an address is a pending admin of another account
    /// # Arguments
    /// * `account_address` - The account address
    /// * `pending_admin_address` - The pending admin address to check
    /// # Returns
    /// * `bool` - true if the pending_admin_address is a pending admin, false otherwise
    /// # Errors
    /// * `ElContractsError` - if the call to the contract fails
    pub async fn is_pending_admin(
        &self,
        account_address: Address,
        pending_admin_address: Address,
    ) -> Result<bool, ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_permission_controller =
            PermissionController::new(self.permission_controller.unwrap(), provider);

        contract_permission_controller
            .isPendingAdmin(account_address, pending_admin_address)
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)
    }

    /// Check if an address is an admin of another account
    /// # Arguments
    /// * `account_address` - The account address
    /// * `admin_address` - The admin address to check
    /// # Returns
    /// * `bool` - true if the admin_address is an admin, false otherwise
    /// # Errors
    /// * `ElContractsError` - if the call to the contract fails
    pub async fn is_admin(
        &self,
        account_address: Address,
        admin_address: Address,
    ) -> Result<bool, ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_permission_controller =
            PermissionController::new(self.permission_controller.unwrap(), provider);

        contract_permission_controller
            .isAdmin(account_address, admin_address)
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)
    }

    /// Checks if an operator is slashable by an operator set.
    /// # Arguments
    /// * `operator_address` - The operator to check slashability for
    /// * `operator_set` - The operator set to check slashability for
    /// # Returns
    /// * [`bool`] - true if the operator is registered or their slashableUntil block has not passed.
    ///   This is because even when operators are deregistered, they still remain slashable for a period of time.
    /// # Errors
    /// * [`ElContractsError`] - if the call to the contract fails
    pub async fn is_operator_slashable(
        &self,
        operator_address: Address,
        operator_set: OperatorSet,
    ) -> Result<bool, ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_allocation_manager =
            AllocationManager::new(self.allocation_manager.unwrap(), provider);

        contract_allocation_manager
            .isOperatorSlashable(operator_address, operator_set)
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)
    }

    /// Returns the current allocated stake, irrespective of the operator's slashable status for the [`OperatorSet`].
    /// # Arguments
    /// * `operators` - The operators to query
    /// * `operator_set` - The operator set to query
    /// * `strategies` - The strategies to query
    /// # Returns
    /// * [`Vec<Vec<U256>>`] - Current Allocated Stake
    /// # Errors
    /// * [`ElContractsError`] - if the call to the contract fails
    pub async fn get_allocated_stake(
        &self,
        operator_set: OperatorSet,
        operators: Vec<Address>,
        strategies: Vec<Address>,
    ) -> Result<Vec<Vec<U256>>, ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_allocation_manager =
            AllocationManager::new(self.allocation_manager.unwrap(), provider);

        contract_allocation_manager
            .getAllocatedStake(operator_set, operators, strategies)
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)
    }

    /// For a strategy, get the amount of magnitude that is allocated across one or more operator sets
    /// # Arguments
    /// * `operator` - The operator to query
    /// * `strategy_address` - The strategy to get allocatable magnitude for
    /// # Returns
    /// [`u64`] - currently allocated magnitude
    pub async fn get_encumbered_magnitude(
        &self,
        operator: Address,
        strategy_address: Address,
    ) -> Result<u64, ElContractsError> {
        let provider = get_provider(&self.provider);

        let contract_allocation_manager =
            AllocationManager::new(self.allocation_manager.unwrap(), provider);

        contract_allocation_manager
            .getEncumberedMagnitude(operator, strategy_address)
            .call()
            .await
            .map_err(ElContractsError::AlloyContractError)
    }
}

// TODO: move to types.rs?

#[derive(Clone)]
pub struct OperatorSetStakes {
    pub operator_set: OperatorSet,
    pub strategies: Vec<Address>,
    pub operators: Vec<Address>,
    pub slashable_stakes: Vec<Vec<U256>>,
}

#[derive(Clone)]
pub struct AllocationInfo {
    pub current_magnitude: U256,
    pub pending_diff: U256,
    pub effect_block: u32,
    pub operator_set: OperatorSet,
}

#[cfg(test)]
mod tests {
    use super::*;
    use alloy::eips::eip1898::BlockNumberOrTag::Number;
    use alloy::primitives::{address, keccak256, Address, FixedBytes, U256};
    use alloy::providers::Provider;
    use eigen_testing_utils::anvil_constants::get_erc20_mock_strategy;
    use eigen_testing_utils::{
        anvil::start_anvil_container,
        anvil_constants::{get_avs_directory_address, get_delegation_manager_address},
        chain_clients::{build_el_chain_reader, new_test_claim, OPERATOR_ADDRESS},
    };
    use eigen_utils::slashing::core::{
        avs_directory::AVSDirectory, delegation_manager::DelegationManager,
    };

    #[tokio::test]
    async fn test_calculate_delegation_approval_digest_hash() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let provider = get_provider(&http_endpoint);
        let el_chain_reader = build_el_chain_reader(http_endpoint.clone()).await;
        let operator: Address = address!("5eb15C0992734B5e77c888D713b4FC67b3D679A2");

        let staker = operator;

        let delegation_approver = Address::ZERO;

        let approve_salt: FixedBytes<32> = FixedBytes::from([0x02; 32]);
        let current_block_number = provider.get_block_number().await.unwrap();
        let block_info = provider
            .get_block_by_number(Number(current_block_number))
            .await
            .unwrap();

        let block = block_info.unwrap();
        let timestamp = block.header.timestamp;
        let expiry = U256::from::<u64>(timestamp + 100);
        let calculate_digest_hash = el_chain_reader
            .calculate_delegation_approval_digest_hash(
                staker,
                operator,
                delegation_approver,
                approve_salt,
                expiry,
            )
            .await
            .unwrap();

        // Directly calling the function through bindings to compare with the sdk .
        let delegation_manager_address = get_delegation_manager_address(http_endpoint).await;
        let delegation_manager_contract =
            DelegationManager::new(delegation_manager_address, provider);

        let hash = delegation_manager_contract
            .calculateDelegationApprovalDigestHash(
                staker,
                operator,
                delegation_approver,
                approve_salt,
                expiry,
            )
            .call()
            .await
            .unwrap();
        assert_eq!(hash, calculate_digest_hash);
    }

    #[tokio::test]
    async fn test_calculate_operator_avs_registration_digest_hash() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let provider = get_provider(&http_endpoint);
        let el_chain_reader = build_el_chain_reader(http_endpoint.clone()).await;
        let operator: Address = address!("5eb15C0992734B5e77c888D713b4FC67b3D679A2");
        let avs = Address::from_slice(&keccak256("avs ")[0..20]);
        let salt: FixedBytes<32> = FixedBytes::from([0x02; 32]);
        let current_block_number = provider.get_block_number().await.unwrap();
        let block_info = provider
            .get_block_by_number(Number(current_block_number))
            .await
            .unwrap();
        let block = block_info.unwrap();

        let timestamp = block.header.timestamp;
        let expiry = U256::from::<u64>(timestamp + 100);
        let operator_hash = el_chain_reader
            .calculate_operator_avs_registration_digest_hash(operator, avs, salt, expiry)
            .await
            .unwrap();

        // Using bindings directly to compare with sdk's output
        let avs_directory_address = get_avs_directory_address(http_endpoint.clone()).await;
        let avs_registry_contract = AVSDirectory::new(avs_directory_address, provider.clone());
        let operator_hash_from_bindings = avs_registry_contract
            .calculateOperatorAVSRegistrationDigestHash(operator, avs, salt, expiry)
            .call()
            .await
            .unwrap();

        assert_eq!(operator_hash_from_bindings, operator_hash);
    }

    #[tokio::test]
    async fn test_get_distribution_roots_length() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let el_chain_reader = build_el_chain_reader(http_endpoint.clone()).await;

        let distribution_roots_length_ret = el_chain_reader
            .get_distribution_roots_length()
            .await
            .unwrap();

        assert_eq!(distribution_roots_length_ret, U256::from(0));

        _ = new_test_claim(&http_endpoint).await;

        let distribution_roots_length_ret = el_chain_reader
            .get_distribution_roots_length()
            .await
            .unwrap();

        assert_eq!(distribution_roots_length_ret, U256::from(1));
    }

    #[tokio::test]
    async fn test_curr_rewards_calculation_end_timestamp() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let el_chain_reader = build_el_chain_reader(http_endpoint.clone()).await;

        let end_timestamp = el_chain_reader
            .curr_rewards_calculation_end_timestamp()
            .await
            .unwrap();

        assert_eq!(end_timestamp, 0);

        _ = new_test_claim(&http_endpoint).await;

        let end_timestamp = el_chain_reader
            .curr_rewards_calculation_end_timestamp()
            .await
            .unwrap();

        assert_eq!(end_timestamp, 1);
    }

    #[tokio::test]
    async fn test_get_current_claimable_distribution_root() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let el_chain_reader = build_el_chain_reader(http_endpoint.to_string()).await;

        let distribution_root = el_chain_reader
            .get_current_claimable_distribution_root()
            .await
            .unwrap();
        // The root starts being zero
        assert_eq!(distribution_root.root, FixedBytes::ZERO);

        let (root, _) = new_test_claim(&http_endpoint).await;

        let distribution_root = el_chain_reader
            .get_current_claimable_distribution_root()
            .await
            .unwrap();

        assert_eq!(distribution_root.root, root);
    }

    #[tokio::test]
    async fn test_get_root_index_from_hash() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let el_chain_reader = build_el_chain_reader(http_endpoint.to_string()).await;
        let (root, _) = new_test_claim(&http_endpoint).await;

        let index = el_chain_reader
            .get_root_index_from_hash(root)
            .await
            .unwrap();

        assert_eq!(index, 0);
    }

    #[tokio::test]
    async fn test_get_cumulative_claimed() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let el_chain_reader = build_el_chain_reader(http_endpoint.to_string()).await;

        let earner_address = address!("F2288D736d27C1584Ebf7be5f52f9E4d47251AeE");
        let (_, _, token_address) = el_chain_reader
            .get_strategy_and_underlying_erc20_token(
                get_erc20_mock_strategy(http_endpoint.clone()).await,
            )
            .await
            .unwrap();

        let cumulative_claimed_ret = el_chain_reader
            .get_cumulative_claimed(earner_address, token_address)
            .await
            .unwrap();

        // No claims so cumulative claimed should be zero
        assert_eq!(cumulative_claimed_ret, U256::from(0));
    }

    #[tokio::test]
    async fn test_check_claim() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let el_chain_reader = build_el_chain_reader(http_endpoint.to_string()).await;
        let (_, claim) = new_test_claim(&http_endpoint).await;

        let valid_claim = el_chain_reader.check_claim(claim.clone()).await.unwrap();
        assert!(valid_claim);
    }

    #[tokio::test]
    async fn test_is_operator_registered() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let chain_reader = build_el_chain_reader(http_endpoint).await;

        let is_registered = chain_reader
            .is_operator_registered(OPERATOR_ADDRESS)
            .await
            .unwrap();

        assert!(is_registered);
    }

    #[tokio::test]
    async fn test_get_staker_shares() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let chain_reader = build_el_chain_reader(http_endpoint.clone()).await;

        let (strategies, shares) = chain_reader
            .get_staker_shares(OPERATOR_ADDRESS)
            .await
            .unwrap();

        let expected_strategies: Vec<Address> = vec![get_erc20_mock_strategy(http_endpoint).await];

        assert!(strategies.len() == shares.len());
        assert_eq!(strategies, expected_strategies);
    }

    #[tokio::test]
    async fn test_get_delegated_operator() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let chain_reader = build_el_chain_reader(http_endpoint.clone()).await;

        let operator_addr = chain_reader
            .get_delegated_operator(OPERATOR_ADDRESS)
            .await
            .unwrap();

        assert_eq!(operator_addr, OPERATOR_ADDRESS); // operator is delegated to himself
    }

    #[tokio::test]
    async fn test_get_strategy_and_underlying_token() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let strategy_addr = get_erc20_mock_strategy(http_endpoint.clone()).await;
        let chain_reader = build_el_chain_reader(http_endpoint).await;

        let (strategy_contract_addr, underlying_token_addr) = chain_reader
            .get_strategy_and_underlying_token(strategy_addr)
            .await
            .unwrap();

        let underlying_token_addr_str = underlying_token_addr.to_string();
        assert_eq!(
            underlying_token_addr_str,
            "0x36C02dA8a0983159322a80FFE9F24b1acfF8B570"
        );

        let strategy_contract_addr_str = strategy_contract_addr.address().to_string();
        assert_eq!(
            strategy_contract_addr_str,
            "0xeC4cFde48EAdca2bC63E94BB437BbeAcE1371bF3"
        );
    }

    #[tokio::test]
    async fn test_get_allocatable_magnitude_and_max_magnitude() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let strategy_addr = get_erc20_mock_strategy(http_endpoint.clone()).await;
        let chain_reader = build_el_chain_reader(http_endpoint).await;

        let allocatable_magnitude = chain_reader
            .get_allocatable_magnitude(OPERATOR_ADDRESS, strategy_addr)
            .await
            .unwrap();

        assert!(allocatable_magnitude > 0);

        // Since the operator has no encumbered magnitude, the max magnitude should be the same as the allocatable magnitude
        let max_magnitude = chain_reader
            .get_max_magnitudes(OPERATOR_ADDRESS, vec![strategy_addr])
            .await
            .unwrap()[0];

        assert_eq!(allocatable_magnitude, max_magnitude);
    }

    #[tokio::test]
    async fn test_get_allocation_info() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let strategy_addr = get_erc20_mock_strategy(http_endpoint.clone()).await;
        let chain_reader = build_el_chain_reader(http_endpoint).await;

        let allocations_info = chain_reader
            .get_allocation_info(OPERATOR_ADDRESS, strategy_addr)
            .await
            .unwrap();

        assert!(allocations_info.is_empty());
    }

    #[tokio::test]
    async fn test_get_operator_shares() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let strategy_addr = get_erc20_mock_strategy(http_endpoint.clone()).await;
        let chain_reader = build_el_chain_reader(http_endpoint).await;

        let operator_shares = chain_reader
            .get_operator_shares(OPERATOR_ADDRESS, vec![strategy_addr])
            .await
            .unwrap();

        assert_eq!(operator_shares.len(), 1);
        assert_eq!(operator_shares[0], U256::from(10e18));
    }

    #[tokio::test]
    async fn test_get_operators_shares() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let strategy_addr = get_erc20_mock_strategy(http_endpoint.clone()).await;
        let chain_reader = build_el_chain_reader(http_endpoint).await;

        let operator_shares = chain_reader
            .get_operators_shares(vec![OPERATOR_ADDRESS], vec![strategy_addr])
            .await
            .unwrap();

        assert_eq!(operator_shares.len(), 1);
        assert_eq!(operator_shares[0].len(), 1);
        assert_eq!(operator_shares[0][0], U256::from(10e18));
    }

    #[tokio::test]
    async fn test_get_num_operator_sets_for_operator() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let chain_reader = build_el_chain_reader(http_endpoint).await;

        let num_operator_sets = chain_reader
            .get_num_operator_sets_for_operator(OPERATOR_ADDRESS)
            .await
            .unwrap();

        assert_eq!(num_operator_sets, U256::from(0));
    }

    #[tokio::test]
    async fn test_get_operator_sets_for_operator() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let chain_reader = build_el_chain_reader(http_endpoint).await;

        let operator_sets = chain_reader
            .get_operator_sets_for_operator(OPERATOR_ADDRESS)
            .await
            .unwrap();

        assert_eq!(operator_sets.len(), 0);
    }

    #[tokio::test]
    async fn test_is_operator_registered_with_operator_set() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let chain_reader = build_el_chain_reader(http_endpoint).await;

        let operator_set = OperatorSet {
            id: 1,
            avs: Address::ZERO,
        };

        let is_registered = chain_reader
            .is_operator_registered_with_operator_set(OPERATOR_ADDRESS, operator_set)
            .await
            .unwrap();

        assert!(!is_registered);
    }

    #[tokio::test]
    async fn test_get_operators_for_operator_set() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let chain_reader = build_el_chain_reader(http_endpoint).await;

        let operator_set = OperatorSet {
            id: 1,
            avs: Address::ZERO,
        };

        let operators = chain_reader
            .get_operators_for_operator_set(operator_set)
            .await
            .unwrap();

        assert_eq!(operators.len(), 0);
    }

    #[tokio::test]
    async fn test_get_num_operators_for_operator_set() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let chain_reader = build_el_chain_reader(http_endpoint).await;

        let operator_set = OperatorSet {
            id: 1,
            avs: Address::ZERO,
        };

        let num_operators = chain_reader
            .get_num_operators_for_operator_set(operator_set)
            .await
            .unwrap();

        assert_eq!(num_operators, U256::from(0));
    }

    #[tokio::test]
    async fn test_get_strategies_for_operator_set() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let chain_reader = build_el_chain_reader(http_endpoint.clone()).await;

        let operator_set = OperatorSet {
            id: 1,
            avs: Address::ZERO,
        };

        let strategies = chain_reader
            .get_strategies_for_operator_set(operator_set)
            .await
            .unwrap();

        assert_eq!(strategies.len(), 0);
    }

    #[tokio::test]
    async fn test_get_slashable_shares() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let chain_reader = build_el_chain_reader(http_endpoint.clone()).await;

        let operator_set = OperatorSet {
            id: 1,
            avs: Address::ZERO,
        };

        let strategies = vec![get_erc20_mock_strategy(http_endpoint).await];
        let slashable_shares = chain_reader
            .get_slashable_shares(OPERATOR_ADDRESS, operator_set, strategies)
            .await
            .unwrap();

        assert_eq!(slashable_shares.len(), 1);
        assert_eq!(slashable_shares[0], U256::ZERO);
    }

    #[tokio::test]
    async fn test_is_operator_slashable() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let chain_reader = build_el_chain_reader(http_endpoint.clone()).await;

        let operator_set = OperatorSet {
            id: 1,
            avs: Address::ZERO,
        };

        let is_slashable = chain_reader
            .is_operator_slashable(OPERATOR_ADDRESS, operator_set)
            .await
            .unwrap();
        assert!(!is_slashable);
    }

    #[tokio::test]
    async fn test_get_slashable_shares_for_operator_sets() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let chain_reader = build_el_chain_reader(http_endpoint).await;

        let operator_set = OperatorSet {
            id: 1,
            avs: Address::ZERO,
        };

        let slashable_shares = chain_reader
            .get_slashable_shares_for_operator_sets(vec![operator_set])
            .await
            .unwrap();

        assert_eq!(slashable_shares.len(), 1);
        assert_eq!(slashable_shares[0].operator_set.id, 1);
        assert_eq!(slashable_shares[0].operators.len(), 0);
        assert_eq!(slashable_shares[0].slashable_stakes.len(), 0);
    }

    #[tokio::test]
    async fn test_get_delegated_and_slashable_shares_for_operator_sets_before() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let chain_reader = build_el_chain_reader(http_endpoint.clone()).await;

        let operator_set = OperatorSet {
            id: 1,
            avs: Address::ZERO,
        };

        let current_block_number = get_provider(&http_endpoint)
            .get_block_number()
            .await
            .unwrap() as u32;
        let slashable_shares = chain_reader
            .get_slashable_shares_for_operator_sets_before(
                vec![operator_set],
                current_block_number + 1,
            )
            .await
            .unwrap();

        assert_eq!(slashable_shares.len(), 1);
        assert_eq!(slashable_shares[0].operator_set.id, 1);
        assert_eq!(slashable_shares[0].operators.len(), 0);
        assert_eq!(slashable_shares[0].slashable_stakes.len(), 0);
    }

    #[tokio::test]
    async fn test_get_allocation_delay() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let chain_reader = build_el_chain_reader(http_endpoint).await;

        let allocation_delay = chain_reader
            .get_allocation_delay(OPERATOR_ADDRESS)
            .await
            .unwrap();

        assert_eq!(allocation_delay, 1);
    }

    #[tokio::test]
    async fn test_get_registered_sets() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let chain_reader = build_el_chain_reader(http_endpoint.clone()).await;

        let ret = chain_reader
            .get_registered_sets(OPERATOR_ADDRESS)
            .await
            .unwrap();

        assert_eq!(ret.len(), 0);
    }

    #[tokio::test]
    async fn test_list_appointee() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let chain_reader = build_el_chain_reader(http_endpoint.clone()).await;

        let target = Address::ZERO;
        let selector = FixedBytes::from([0x00; 4]);
        let appointees = chain_reader
            .list_appointees(OPERATOR_ADDRESS, target, selector)
            .await
            .unwrap();

        assert!(appointees.is_empty());
    }

    #[tokio::test]
    async fn test_list_appointee_permissions() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let chain_reader = build_el_chain_reader(http_endpoint.clone()).await;

        let account_address = OPERATOR_ADDRESS;
        let appointee_address = OPERATOR_ADDRESS;
        let (targets, selectors) = chain_reader
            .list_appointee_permissions(account_address, appointee_address)
            .await
            .unwrap();

        assert!(targets.is_empty());
        assert!(selectors.is_empty());
    }

    #[tokio::test]
    async fn test_list_pending_admins() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let chain_reader = build_el_chain_reader(http_endpoint.clone()).await;

        let pending_admins = chain_reader
            .list_pending_admins(OPERATOR_ADDRESS)
            .await
            .unwrap();

        assert!(pending_admins.is_empty());
    }

    #[tokio::test]
    async fn test_list_admins() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let chain_reader = build_el_chain_reader(http_endpoint.clone()).await;

        let admins = chain_reader.list_admins(OPERATOR_ADDRESS).await.unwrap();

        assert_eq!(admins, vec![OPERATOR_ADDRESS]);
    }

    #[tokio::test]
    async fn test_is_pending_admin() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let chain_reader = build_el_chain_reader(http_endpoint.clone()).await;

        let is_pending_admin = chain_reader
            .is_pending_admin(OPERATOR_ADDRESS, OPERATOR_ADDRESS)
            .await
            .unwrap();

        assert!(!is_pending_admin);
    }

    #[tokio::test]
    async fn test_is_admin() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let chain_reader = build_el_chain_reader(http_endpoint.clone()).await;

        let is_admin = chain_reader
            .is_admin(OPERATOR_ADDRESS, OPERATOR_ADDRESS)
            .await
            .unwrap();

        assert!(is_admin);
    }

    #[tokio::test]
    async fn test_get_allocated_stake() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let chain_reader = build_el_chain_reader(http_endpoint.clone()).await;

        let operator_set = OperatorSet {
            id: 1,
            avs: Address::ZERO,
        };
        let operators = vec![OPERATOR_ADDRESS];
        let strategies = vec![get_erc20_mock_strategy(http_endpoint.to_string()).await];
        let slashable_stake = chain_reader
            .get_allocated_stake(operator_set, operators, strategies)
            .await
            .unwrap();
        assert_eq!(slashable_stake[0][0], "0".parse().unwrap());
    }

    #[tokio::test]
    async fn test_get_encumbered_magnitude() {
        let (_container, http_endpoint, _ws_endpoint) = start_anvil_container().await;
        let chain_reader = build_el_chain_reader(http_endpoint.clone()).await;

        let magnitude = chain_reader
            .get_encumbered_magnitude(
                OPERATOR_ADDRESS,
                get_erc20_mock_strategy(http_endpoint.to_string()).await,
            )
            .await
            .unwrap();
        assert_eq!(magnitude, 0);
    }
}