blueprint_client_eigenlayer/

client.rs

use crate::error::Result;
use alloy_primitives::{Address, Bytes, U256};
use alloy_provider::{Provider, RootProvider};
use blueprint_evm_extra::util::{get_provider_http, get_wallet_provider_http};
use blueprint_runner::config::BlueprintEnvironment;
use blueprint_std::collections::HashMap;
use eigensdk::client_avsregistry::reader::AvsRegistryReader;
use eigensdk::common::get_ws_provider;
use eigensdk::utils::rewardsv2::middleware::registry_coordinator::RegistryCoordinator;
use eigensdk::utils::rewardsv2::middleware::stake_registry::{IStakeRegistry, StakeRegistry};
use eigensdk::utils::slashing::core::allocation_manager::{
    AllocationManager, IAllocationManagerTypes,
};
use eigensdk::utils::slashing::core::delegation_manager::DelegationManager;
use eigensdk::utils::slashing::middleware::operator_state_retriever::OperatorStateRetriever;
use num_bigint::BigInt;

/// Client that provides access to EigenLayer utility functions through the use of the [`BlueprintEnvironment`].
#[derive(Clone)]
pub struct EigenlayerClient {
    pub config: BlueprintEnvironment,
}

impl EigenlayerClient {
    /// Creates a new [`EigenlayerClient`].
    #[must_use]
    pub fn new(config: BlueprintEnvironment) -> Self {
        Self { config }
    }

    /// Get the [`BlueprintEnvironment`] for this client
    #[must_use]
    pub fn config(&self) -> &BlueprintEnvironment {
        &self.config
    }

    /// Get the provider for this client's http endpoint
    ///
    /// # Returns
    /// - [`The HTTP provider`](RootProvider)
    #[must_use]
    pub fn get_provider_http(&self) -> RootProvider {
        get_provider_http(self.config.http_rpc_endpoint.clone())
    }

    /// Get the provider for this client's http endpoint with the specified [`EthereumWallet`]
    ///
    /// # Returns
    /// - [`The HTTP wallet provider`](RootProvider)
    ///
    /// [`EthereumWallet`]: alloy_network::EthereumWallet
    #[must_use]
    pub fn get_wallet_provider_http(&self, wallet: alloy_network::EthereumWallet) -> RootProvider {
        get_wallet_provider_http(self.config.http_rpc_endpoint.clone(), wallet)
    }

    /// Get the provider for this client's websocket endpoint
    ///
    /// # Errors
    ///
    /// * Bad WS URL
    ///
    /// # Returns
    /// - [`The WS provider`](RootProvider<BoxTransport>)
    pub async fn get_provider_ws(&self) -> Result<RootProvider> {
        get_ws_provider(self.config.ws_rpc_endpoint.as_str())
            .await
            .map_err(Into::into)
    }

    // TODO: Slashing contracts equivalent
    // /// Get the slasher address from the `DelegationManager` contract
    // ///
    // /// # Returns
    // /// - [`Address`] - The slasher address
    // ///
    // /// # Errors
    // /// - [`Error::AlloyContract`] - If the call to the contract fails (i.e. the contract doesn't exist at the given address)
    // pub async fn get_slasher_address(&self, eigen_pod_manager_address: Address) -> Result<Address> {
    //     let provider = self.get_provider_http();
    //     let eigen_pod_manager =
    //         EigenPodManager::EigenPodManagerInstance::new(eigen_pod_manager_address, provider);
    //     eigen_pod_manager
    //         .slasher()
    //         .call()
    //         .await
    //         .map(|a| a._0)
    //         .map_err(Into::into)
    // }

    /// Provides a reader for the AVS registry.
    ///
    /// # Errors
    ///
    /// * The [`BlueprintEnvironment`] is not configured for Eigenlayer
    /// * See [`AvsRegistryChainReader::new()`]
    ///
    /// [`AvsRegistryChainReader::new()`]: eigensdk::client_avsregistry::reader::AvsRegistryChainReader::new
    pub async fn avs_registry_reader(
        &self,
    ) -> Result<eigensdk::client_avsregistry::reader::AvsRegistryChainReader> {
        let http_rpc_endpoint = self.config.http_rpc_endpoint.clone();
        let contract_addresses = self.config.protocol_settings.eigenlayer()?;
        let registry_coordinator_address = contract_addresses.registry_coordinator_address;
        let operator_state_retriever_address = contract_addresses.operator_state_retriever_address;
        eigensdk::client_avsregistry::reader::AvsRegistryChainReader::new(
            registry_coordinator_address,
            operator_state_retriever_address,
            http_rpc_endpoint.to_string(),
        )
        .await
        .map_err(Into::into)
    }

    /// Provides a writer for the AVS registry.
    ///
    /// # Errors
    ///
    /// * The [`BlueprintEnvironment`] is not configured for Eigenlayer
    /// * See [`AvsRegistryChainWriter::build_avs_registry_chain_writer()`]
    ///
    /// [`AvsRegistryChainWriter::build_avs_registry_chain_writer()`]: eigensdk::client_avsregistry::writer::AvsRegistryChainWriter::build_avs_registry_chain_writer
    pub async fn avs_registry_writer(
        &self,
        private_key: String,
    ) -> Result<eigensdk::client_avsregistry::writer::AvsRegistryChainWriter> {
        let contract_addresses = self.config.protocol_settings.eigenlayer()?;
        let registry_coordinator_address = contract_addresses.registry_coordinator_address;
        let service_manager_address = contract_addresses.service_manager_address;

        eigensdk::client_avsregistry::writer::AvsRegistryChainWriter::build_avs_registry_chain_writer(
            self.config.http_rpc_endpoint.to_string(),
            private_key,
            registry_coordinator_address,
            service_manager_address,
        ).await
        .map_err(Into::into)
    }

    /// Provides an operator info service.
    ///
    /// # Errors
    ///
    /// * The [`BlueprintEnvironment`] is not configured for Eigenlayer
    /// * See [`OperatorInfoServiceInMemory::new()`]
    ///
    /// [`OperatorInfoServiceInMemory::new()`]: eigensdk::services_operatorsinfo::operatorsinfo_inmemory::OperatorInfoServiceInMemory::new
    pub async fn operator_info_service_in_memory(
        &self,
    ) -> Result<(
        eigensdk::services_operatorsinfo::operatorsinfo_inmemory::OperatorInfoServiceInMemory,
        tokio::sync::mpsc::UnboundedReceiver<
            eigensdk::services_operatorsinfo::operatorsinfo_inmemory::OperatorInfoServiceError,
        >,
    )> {
        let avs_registry_reader = self.avs_registry_reader().await?;

        eigensdk::services_operatorsinfo::operatorsinfo_inmemory::OperatorInfoServiceInMemory::new(
            avs_registry_reader,
            self.config.ws_rpc_endpoint.to_string(),
        )
        .await
        .map_err(Into::into)
    }

    /// Provides an AVS registry service chain caller.
    ///
    /// # Errors
    ///
    /// * See [`Self::avs_registry_reader()`]
    /// * See [`Self::operator_info_service_in_memory()`]
    pub async fn avs_registry_service_chain_caller_in_memory(
        &self,
    ) -> Result<
        eigensdk::services_avsregistry::chaincaller::AvsRegistryServiceChainCaller<
            eigensdk::client_avsregistry::reader::AvsRegistryChainReader,
            eigensdk::services_operatorsinfo::operatorsinfo_inmemory::OperatorInfoServiceInMemory,
        >,
    > {
        let avs_registry_reader = self.avs_registry_reader().await?;
        let (operator_info_service, _) = self.operator_info_service_in_memory().await?;

        let cancellation_token = tokio_util::sync::CancellationToken::new();
        let token_clone = cancellation_token.clone();
        let provider = self.get_provider_http();
        let current_block = provider.get_block_number().await?;
        let operator_info_clone = operator_info_service.clone();

        tokio::task::spawn(async move {
            operator_info_clone
                .start_service(&token_clone, 0, current_block)
                .await
        });

        Ok(
            eigensdk::services_avsregistry::chaincaller::AvsRegistryServiceChainCaller::new(
                avs_registry_reader,
                operator_info_service,
            ),
        )
    }

    /// Provides a BLS aggregation service.
    ///
    /// # Errors
    ///
    /// * See [`Self::avs_registry_service_chain_caller_in_memory()`]
    pub async fn bls_aggregation_service_in_memory(&self) -> Result<eigensdk::services_blsaggregation::bls_agg::BlsAggregatorService<
        eigensdk::services_avsregistry::chaincaller::AvsRegistryServiceChainCaller<
            eigensdk::client_avsregistry::reader::AvsRegistryChainReader,
            eigensdk::services_operatorsinfo::operatorsinfo_inmemory::OperatorInfoServiceInMemory
        >
    >>{
        let avs_registry_service = self.avs_registry_service_chain_caller_in_memory().await?;
        Ok(
            eigensdk::services_blsaggregation::bls_agg::BlsAggregatorService::new(
                avs_registry_service,
            ),
        )
    }

    /// Get Operator stake in Quorums at a given block.
    ///
    /// # Errors
    ///
    /// * See [`Self::avs_registry_reader()`]
    /// * See [`AvsRegistryChainReader::get_operators_stake_in_quorums_at_block()`]
    ///
    /// [`AvsRegistryChainReader::get_operators_stake_in_quorums_at_block()`]: eigensdk::client_avsregistry::reader::AvsRegistryChainReader::get_operators_stake_in_quorums_at_block
    pub async fn get_operator_stake_in_quorums_at_block(
        &self,
        block_number: u32,
        quorum_numbers: Bytes,
    ) -> Result<Vec<Vec<OperatorStateRetriever::Operator>>> {
        self.avs_registry_reader()
            .await?
            .get_operators_stake_in_quorums_at_block(block_number.into(), quorum_numbers)
            .await
            .map_err(Into::into)
    }

    /// Get an Operator's stake in Quorums at current block.
    ///
    /// # Errors
    ///
    /// * See [`Self::avs_registry_reader()`]
    /// * See [`AvsRegistryChainReader::get_operator_stake_in_quorums_of_operator_at_current_block()`]
    ///
    /// [`AvsRegistryChainReader::get_operator_stake_in_quorums_of_operator_at_current_block()`]: eigensdk::client_avsregistry::reader::AvsRegistryChainReader::get_operator_stake_in_quorums_of_operator_at_current_block
    pub async fn get_operator_stake_in_quorums_at_current_block(
        &self,
        operator_id: alloy_primitives::FixedBytes<32>,
    ) -> Result<HashMap<u8, BigInt>> {
        self.avs_registry_reader()
            .await?
            .get_operator_stake_in_quorums_of_operator_at_current_block(operator_id)
            .await
            .map_err(Into::into)
    }

    /// Get an Operator by ID.
    ///
    /// # Errors
    ///
    /// * See [`Self::avs_registry_reader()`]
    /// * See [`AvsRegistryReader::get_operator_from_id()`]
    pub async fn get_operator_by_id(&self, operator_id: [u8; 32]) -> Result<Address> {
        self.avs_registry_reader()
            .await?
            .get_operator_from_id(operator_id)
            .await
            .map_err(Into::into)
    }

    /// Get an Operator stake history.
    ///
    /// # Errors
    ///
    /// * The [`BlueprintEnvironment`] is not configured for Eigenlayer
    pub async fn get_operator_stake_history(
        &self,
        operator_id: alloy_primitives::FixedBytes<32>,
        quorum_number: u8,
    ) -> Result<Vec<IStakeRegistry::StakeUpdate>> {
        let contract_addresses = self.config.protocol_settings.eigenlayer()?;
        let provider = self.get_provider_http();
        let registry_coordinator = RegistryCoordinator::new(
            contract_addresses.registry_coordinator_address,
            provider.clone(),
        );
        let stake_registry_address = registry_coordinator.stakeRegistry().call().await?;
        let instance =
            StakeRegistry::StakeRegistryInstance::new(stake_registry_address, provider.clone());
        let call_builder = instance.getStakeHistory(operator_id, quorum_number);
        let response = call_builder.call().await?;
        Ok(response)
    }

    /// Get an Operator stake update at a given index.
    ///
    /// # Errors
    ///
    /// * The [`BlueprintEnvironment`] is not configured for Eigenlayer
    pub async fn get_operator_stake_update_at_index(
        &self,
        quorum_number: u8,
        operator_id: alloy_primitives::FixedBytes<32>,
        index: alloy_primitives::U256,
    ) -> Result<IStakeRegistry::StakeUpdate> {
        let contract_addresses = self.config.protocol_settings.eigenlayer()?;
        let provider = self.get_provider_http();
        let registry_coordinator = RegistryCoordinator::new(
            contract_addresses.registry_coordinator_address,
            provider.clone(),
        );
        let stake_registry_address = registry_coordinator.stakeRegistry().call().await?;
        let instance =
            StakeRegistry::StakeRegistryInstance::new(stake_registry_address, provider.clone());
        let call_builder = instance.getStakeUpdateAtIndex(quorum_number, operator_id, index);
        let response = call_builder.call().await?;
        Ok(response)
    }

    /// Get an Operator's stake at a given block number.
    ///
    /// # Errors
    ///
    /// * The [`BlueprintEnvironment`] is not configured for Eigenlayer
    pub async fn get_operator_stake_at_block_number(
        &self,
        operator_id: alloy_primitives::FixedBytes<32>,
        quorum_number: u8,
        block_number: u32,
    ) -> Result<alloy_primitives::Uint<96, 2>> {
        let contract_addresses = self.config.protocol_settings.eigenlayer()?;
        let provider = self.get_provider_http();
        let registry_coordinator = RegistryCoordinator::new(
            contract_addresses.registry_coordinator_address,
            provider.clone(),
        );
        let stake_registry_address = registry_coordinator.stakeRegistry().call().await?;
        let instance =
            StakeRegistry::StakeRegistryInstance::new(stake_registry_address, provider.clone());
        let call_builder = instance.getStakeAtBlockNumber(operator_id, quorum_number, block_number);
        let response = call_builder.call().await?;
        Ok(response)
    }

    // TODO: Slashing contract equivalent
    // /// Get an Operator's [`details`](OperatorDetails).
    // pub async fn get_operator_details(
    //     &self,
    //     operator_addr: Address,
    // ) -> Result<eigensdk::types::operator::Operator> {
    //     let http_rpc_endpoint = self.config.http_rpc_endpoint.clone();
    //     let contract_addresses = self.config.protocol_settings.eigenlayer()?;
    //     let chain_reader = eigensdk::client_elcontracts::reader::ELChainReader::new(
    //         Some(contract_addresses.allocation_manager_address),
    //         contract_addresses.delegation_manager_address,
    //         contract_addresses.rewards_coordinator_address,
    //         contract_addresses.avs_directory_address,
    //         Some(contract_addresses.permission_controller_address),
    //         http_rpc_endpoint.clone(),
    //     );
    //     Ok(chain_reader.get_operator_details(operator_addr).await?)
    // }

    /// Get an Operator's latest stake update.
    ///
    /// # Errors
    ///
    /// * The [`BlueprintEnvironment`] is not configured for Eigenlayer
    pub async fn get_latest_stake_update(
        &self,
        operator_id: alloy_primitives::FixedBytes<32>,
        quorum_number: u8,
    ) -> Result<IStakeRegistry::StakeUpdate> {
        let contract_addresses = self.config.protocol_settings.eigenlayer()?;
        let provider = self.get_provider_http();
        let registry_coordinator = RegistryCoordinator::new(
            contract_addresses.registry_coordinator_address,
            provider.clone(),
        );
        let stake_registry_address = registry_coordinator.stakeRegistry().call().await?;
        let instance =
            StakeRegistry::StakeRegistryInstance::new(stake_registry_address, provider.clone());
        let call_builder = instance.getLatestStakeUpdate(operator_id, quorum_number);
        let response = call_builder.call().await?;
        Ok(response)
    }

    /// Get an Operator's ID as [`FixedBytes`] from its [`Address`].
    ///
    /// # Errors
    ///
    /// * See [`Self::avs_registry_reader()`]
    /// * See [`AvsRegistryChainReader::get_operator_id()`]
    ///
    /// [`FixedBytes`]: alloy_primitives::FixedBytes
    /// [`AvsRegistryChainReader::get_operator_id()`]: eigensdk::client_avsregistry::reader::AvsRegistryChainReader::get_operator_id
    pub async fn get_operator_id(
        &self,
        operator_addr: Address,
    ) -> Result<alloy_primitives::FixedBytes<32>> {
        self.avs_registry_reader()
            .await?
            .get_operator_id(operator_addr)
            .await
            .map_err(Into::into)
    }

    /// Get the total stake at a given block number from a given index.
    ///
    /// # Errors
    ///
    /// * The [`BlueprintEnvironment`] is not configured for Eigenlayer
    pub async fn get_total_stake_at_block_number_from_index(
        &self,
        quorum_number: u8,
        block_number: u32,
        index: alloy_primitives::U256,
    ) -> Result<alloy_primitives::Uint<96, 2>> {
        let contract_addresses = self.config.protocol_settings.eigenlayer()?;
        let provider = self.get_provider_http();
        let registry_coordinator = RegistryCoordinator::new(
            contract_addresses.registry_coordinator_address,
            provider.clone(),
        );
        let stake_registry_address = registry_coordinator.stakeRegistry().call().await?;
        let instance =
            StakeRegistry::StakeRegistryInstance::new(stake_registry_address, provider.clone());
        let call_builder =
            instance.getTotalStakeAtBlockNumberFromIndex(quorum_number, block_number, index);
        let response = call_builder.call().await?;
        Ok(response)
    }

    /// Get the total stake history length of a given quorum.
    ///
    /// # Errors
    ///
    /// * The [`BlueprintEnvironment`] is not configured for Eigenlayer
    pub async fn get_total_stake_history_length(
        &self,
        quorum_number: u8,
    ) -> Result<alloy_primitives::U256> {
        let contract_addresses = self.config.protocol_settings.eigenlayer()?;
        let provider = self.get_provider_http();
        let registry_coordinator = RegistryCoordinator::new(
            contract_addresses.registry_coordinator_address,
            provider.clone(),
        );
        let stake_registry_address = registry_coordinator.stakeRegistry().call().await?;
        let instance =
            StakeRegistry::StakeRegistryInstance::new(stake_registry_address, provider.clone());
        let call_builder = instance.getTotalStakeHistoryLength(quorum_number);
        let response = call_builder.call().await?;
        Ok(response)
    }

    /// Provides the public keys of existing registered operators within the provided block range.
    ///
    /// # Errors
    ///
    /// * See [`Self::avs_registry_reader()`]
    /// * See [`AvsRegistryChainReader::query_existing_registered_operator_pub_keys()`]
    ///
    /// [`AvsRegistryChainReader::query_existing_registered_operator_pub_keys()`]: eigensdk::client_avsregistry::reader::AvsRegistryChainReader::query_existing_registered_operator_pub_keys
    pub async fn query_existing_registered_operator_pub_keys(
        &self,
        start_block: u64,
        to_block: u64,
    ) -> Result<(
        Vec<Address>,
        Vec<eigensdk::types::operator::OperatorPubKeys>,
    )> {
        self.avs_registry_reader()
            .await?
            .query_existing_registered_operator_pub_keys(
                start_block,
                to_block,
                self.config.ws_rpc_endpoint.to_string(),
            )
            .await
            .map_err(Into::into)
    }

    /// Get strategies in an operator set (quorum) for a given AVS.
    ///
    /// # Arguments
    ///
    /// * `avs_address` - The address of the AVS service manager
    /// * `operator_set_id` - The ID of the operator set (quorum number)
    ///
    /// # Returns
    ///
    /// A vector of strategy addresses used in the specified operator set
    ///
    /// # Errors
    ///
    /// * [`Error::AlloyContractError`] - If the call to the contract fails
    pub async fn get_strategies_in_operator_set(
        &self,
        avs_address: Address,
        operator_set_id: u8,
    ) -> Result<Vec<Address>> {
        let contract_addresses = self.config.protocol_settings.eigenlayer()?;
        let provider = self.get_provider_http();

        let allocation_manager = AllocationManager::AllocationManagerInstance::new(
            contract_addresses.allocation_manager_address,
            provider,
        );

        let operator_set = AllocationManager::OperatorSet {
            avs: avs_address,
            id: u32::from(operator_set_id), // Convert u8 to u32
        };

        let result = allocation_manager
            .getStrategiesInOperatorSet(operator_set)
            .call()
            .await?;

        Ok(result)
    }

    /// Get strategy allocations for a specific operator and strategy.
    ///
    /// # Arguments
    ///
    /// * `operator_address` - The address of the operator
    /// * `strategy_address` - The address of the strategy
    ///
    /// # Returns
    ///
    /// A tuple containing:
    /// - A vector of operator sets the operator is part of
    /// - A vector of allocations for each operator set
    ///
    /// # Errors
    ///
    /// * [`Error::AlloyContractError`] - If the call to the contract fails
    pub async fn get_strategy_allocations(
        &self,
        operator_address: Address,
        strategy_address: Address,
    ) -> Result<(
        Vec<AllocationManager::OperatorSet>,
        Vec<IAllocationManagerTypes::Allocation>,
    )> {
        let contract_addresses = self.config.protocol_settings.eigenlayer()?;
        let provider = self.get_provider_http();

        let allocation_manager = AllocationManager::AllocationManagerInstance::new(
            contract_addresses.allocation_manager_address,
            provider,
        );

        let result = allocation_manager
            .getStrategyAllocations(operator_address, strategy_address)
            .call()
            .await?;

        Ok((result._0, result._1))
    }

    /// Get the maximum magnitude for a specific operator and strategy.
    ///
    /// # Arguments
    ///
    /// * `operator_address` - The address of the operator
    /// * `strategy_address` - The address of the strategy
    ///
    /// # Returns
    ///
    /// The maximum magnitude
    ///
    /// # Errors
    ///
    /// * [`Error::AlloyContractError`] - If the call to the contract fails
    pub async fn get_max_magnitude(
        &self,
        operator_address: Address,
        strategy_address: Address,
    ) -> Result<u64> {
        let contract_addresses = self.config.protocol_settings.eigenlayer()?;
        let provider = self.get_provider_http();

        let allocation_manager = AllocationManager::AllocationManagerInstance::new(
            contract_addresses.allocation_manager_address,
            provider,
        );

        let result = allocation_manager
            .getMaxMagnitude(operator_address, strategy_address)
            .call()
            .await?;

        Ok(result)
    }

    /// Get slashable shares in queue for a specific operator and strategy.
    ///
    /// # Arguments
    ///
    /// * `operator_address` - The address of the operator
    /// * `strategy_address` - The address of the strategy
    ///
    /// # Returns
    ///
    /// The amount of slashable shares in the queue
    ///
    /// # Errors
    ///
    /// * [`Error::AlloyContractError`] - If the call to the contract fails
    pub async fn get_slashable_shares_in_queue(
        &self,
        operator_address: Address,
        strategy_address: Address,
    ) -> Result<U256> {
        let contract_addresses = self.config.protocol_settings.eigenlayer()?;
        let provider = self.get_provider_http();

        let delegation_manager = DelegationManager::DelegationManagerInstance::new(
            contract_addresses.delegation_manager_address,
            provider,
        );

        let result = delegation_manager
            .getSlashableSharesInQueue(operator_address, strategy_address)
            .call()
            .await?;

        Ok(result)
    }

    /// Get all operators for a service at a specific block.
    ///
    /// # Arguments
    ///
    /// * `avs_address` - The address of the AVS service manager
    /// * `block_number` - The block number to retrieve the operators at
    /// * `quorum_numbers` - The quorum numbers to retrieve operators for
    ///
    /// # Returns
    ///
    /// A vector of vectors containing operators in each quorum
    ///
    /// # Errors
    ///
    /// * [`Error::AlloyContractError`] - If the call to the contract fails
    pub async fn get_operators_for_service(
        &self,
        _avs_address: Address,
        block_number: u32,
        quorum_numbers: Vec<u8>,
    ) -> Result<Vec<Vec<OperatorStateRetriever::Operator>>> {
        let quorum_bytes = Bytes::from(quorum_numbers);
        self.get_operator_stake_in_quorums_at_block(block_number, quorum_bytes)
            .await
    }

    /// Get all slashable assets for an AVS.
    ///
    /// # Arguments
    ///
    /// * `avs_address` - The address of the AVS service manager
    /// * `block_number` - The block number to retrieve the data at
    /// * `quorum_numbers` - The quorum numbers (operator set IDs) to retrieve data for
    ///
    /// # Returns
    ///
    /// A hashmap where:
    /// - Key: Operator address
    /// - Value: A hashmap where:
    ///   - Key: Strategy address
    ///   - Value: Amount of slashable shares
    ///
    /// # Errors
    ///
    /// * [`Error::AlloyContractError`] - If any contract call fails
    pub async fn get_slashable_assets_for_avs(
        &self,
        avs_address: Address,
        block_number: u32,
        quorum_numbers: Vec<u8>,
    ) -> Result<HashMap<Address, HashMap<Address, U256>>> {
        let mut result = HashMap::new();

        let all_operator_info = self
            .get_operators_for_service(avs_address, block_number, quorum_numbers.clone())
            .await?;

        for (operators, quorum_number) in all_operator_info.iter().zip(quorum_numbers) {
            let strategies = self
                .get_strategies_in_operator_set(avs_address, quorum_number)
                .await?;

            for operator in operators {
                let operator_id = operator.operatorId;

                let operator_address = self.get_operator_by_id(operator_id.into()).await?;

                let operator_entry = result.entry(operator_address).or_insert_with(HashMap::new);

                for strategy_address in &strategies {
                    match self
                        .get_slashable_shares_in_queue(operator_address, *strategy_address)
                        .await
                    {
                        Ok(slashable_shares) => {
                            operator_entry.insert(*strategy_address, slashable_shares);
                        }
                        Err(e) => {
                            // Log the error but continue with other strategies
                            blueprint_core::error!(
                                "Error getting slashable shares for operator {operator_address}, strategy {strategy_address}: {e}",
                            );
                        }
                    }
                }
            }
        }

        Ok(result)
    }
}