Merge pull request #46 from Layr-Labs/update-middleware-to-latest

Update eigenlayer-middleware to dev head

aggregator/aggregator.go

@@ -12,7 +12,7 @@ import (
 	sdkclients "github.com/Layr-Labs/eigensdk-go/chainio/clients"
 	"github.com/Layr-Labs/eigensdk-go/services/avsregistry"
 	blsagg "github.com/Layr-Labs/eigensdk-go/services/bls_aggregation"
-	oppubkeysserv "github.com/Layr-Labs/eigensdk-go/services/operatorpubkeys"
+	oprsinfoserv "github.com/Layr-Labs/eigensdk-go/services/operatorsinfo"
 	sdktypes "github.com/Layr-Labs/eigensdk-go/types"
 	"github.com/Layr-Labs/incredible-squaring-avs/aggregator/types"
 	"github.com/Layr-Labs/incredible-squaring-avs/core"
@@ -99,13 +99,13 @@ func NewAggregator(c *config.Config) (*Aggregator, error) {
 		AvsName:                    avsName,
 		PromMetricsIpPortAddress:   ":9090",
 	}
-	clients, err := clients.BuildAll(chainioConfig, c.AggregatorAddress, c.SignerFn, c.Logger)
+	clients, err := clients.BuildAll(chainioConfig, c.EcdsaPrivateKey, c.Logger)
 	if err != nil {
 		c.Logger.Errorf("Cannot create sdk clients", "err", err)
 		return nil, err
 	}
 
-	operatorPubkeysService := oppubkeysserv.NewOperatorPubkeysServiceInMemory(context.Background(), clients.AvsRegistryChainSubscriber, clients.AvsRegistryChainReader, c.Logger)
+	operatorPubkeysService := oprsinfoserv.NewOperatorsInfoServiceInMemory(context.Background(), clients.AvsRegistryChainSubscriber, clients.AvsRegistryChainReader, c.Logger)
 	avsRegistryService := avsregistry.NewAvsRegistryServiceChainCaller(avsReader, operatorPubkeysService, c.Logger)
 	blsAggregationService := blsagg.NewBlsAggregatorService(avsRegistryService, c.Logger)
 
@@ -208,13 +208,17 @@ func (agg *Aggregator) sendNewTask(numToSquare *big.Int) error {
 	agg.tasks[taskIndex] = newTask
 	agg.tasksMu.Unlock()
 
-	quorumThresholdPercentages := make([]uint32, len(newTask.QuorumNumbers))
+	quorumThresholdPercentages := make(sdktypes.QuorumThresholdPercentages, len(newTask.QuorumNumbers))
 	for i := range newTask.QuorumNumbers {
-		quorumThresholdPercentages[i] = newTask.QuorumThresholdPercentage
+		quorumThresholdPercentages[i] = sdktypes.QuorumThresholdPercentage(newTask.QuorumThresholdPercentage)
 	}
 	// TODO(samlaf): we use seconds for now, but we should ideally pass a blocknumber to the blsAggregationService
 	// and it should monitor the chain and only expire the task aggregation once the chain has reached that block number.
 	taskTimeToExpiry := taskChallengeWindowBlock * blockTimeSeconds
-	agg.blsAggregationService.InitializeNewTask(taskIndex, newTask.TaskCreatedBlock, newTask.QuorumNumbers, quorumThresholdPercentages, taskTimeToExpiry)
+	var quorumNums sdktypes.QuorumNums
+	for _, quorumNum := range newTask.QuorumNumbers {
+		quorumNums = append(quorumNums, sdktypes.QuorumNum(quorumNum))
+	}
+	agg.blsAggregationService.InitializeNewTask(taskIndex, newTask.TaskCreatedBlock, quorumNums, quorumThresholdPercentages, taskTimeToExpiry)
 	return nil
 }

aggregator/aggregator_test.go

@@ -43,7 +43,7 @@ func TestSendNewTask(t *testing.T) {
 	MOCK_OPERATOR_G1PUBKEY := MOCK_OPERATOR_KEYPAIR.GetPubKeyG1()
 	MOCK_OPERATOR_G2PUBKEY := MOCK_OPERATOR_KEYPAIR.GetPubKeyG2()
 
-	operatorPubkeyDict := map[bls.OperatorId]types.OperatorInfo{
+	operatorPubkeyDict := map[sdktypes.OperatorId]types.OperatorInfo{
 		MOCK_OPERATOR_ID: {
 			OperatorPubkeys: sdktypes.OperatorPubkeys{
 				G1Pubkey: MOCK_OPERATOR_G1PUBKEY,
@@ -70,14 +70,14 @@ func TestSendNewTask(t *testing.T) {
 	// make sure that initializeNewTask was called on the blsAggService
 	// maybe there's a better way to do this? There's a saying "don't mock 3rd party code"
 	// see https://hynek.me/articles/what-to-mock-in-5-mins/
-	mockBlsAggService.EXPECT().InitializeNewTask(TASK_INDEX, BLOCK_NUMBER, types.QUORUM_NUMBERS, []uint32{types.QUORUM_THRESHOLD_NUMERATOR}, taskTimeToExpiry)
+	mockBlsAggService.EXPECT().InitializeNewTask(TASK_INDEX, BLOCK_NUMBER, types.QUORUM_NUMBERS, sdktypes.QuorumThresholdPercentages{types.QUORUM_THRESHOLD_NUMERATOR}, taskTimeToExpiry)
 
 	err = aggregator.sendNewTask(NUMBER_TO_SQUARE_BIG_INT)
 	assert.Nil(t, err)
 }
 
 func createMockAggregator(
-	mockCtrl *gomock.Controller, operatorPubkeyDict map[bls.OperatorId]types.OperatorInfo,
+	mockCtrl *gomock.Controller, operatorPubkeyDict map[sdktypes.OperatorId]types.OperatorInfo,
 ) (*Aggregator, *chainiomocks.MockAvsWriterer, *blsaggservmock.MockBlsAggregationService, error) {
 	logger := sdklogging.NewNoopLogger()
 	mockAvsWriter := chainiomocks.NewMockAvsWriterer(mockCtrl)

aggregator/mocks/chain.go

@@ -15,8 +15,8 @@ func MockSendNewTaskNumberToSquareCall(blockNum, taskNum, numberToSquare uint32)
 	task := cstaskmanager.IIncredibleSquaringTaskManagerTask{
 		NumberToBeSquared:         big.NewInt(int64(numberToSquare)),
 		TaskCreatedBlock:          blockNum,
-		QuorumNumbers:             types.QUORUM_NUMBERS,
-		QuorumThresholdPercentage: types.QUORUM_THRESHOLD_NUMERATOR,
+		QuorumNumbers:             types.QUORUM_NUMBERS.UnderlyingType(),
+		QuorumThresholdPercentage: uint32(types.QUORUM_THRESHOLD_NUMERATOR),
 	}
 
 	return task, taskNum, nil

aggregator/rpc_server.go

@@ -10,6 +10,7 @@ import (
 	"github.com/Layr-Labs/incredible-squaring-avs/core"
 
 	"github.com/Layr-Labs/eigensdk-go/crypto/bls"
+	"github.com/Layr-Labs/eigensdk-go/types"
 	sdktypes "github.com/Layr-Labs/eigensdk-go/types"
 )
 
@@ -40,7 +41,7 @@ func (agg *Aggregator) startServer(ctx context.Context) error {
 type SignedTaskResponse struct {
 	TaskResponse cstaskmanager.IIncredibleSquaringTaskManagerTaskResponse
 	BlsSignature bls.Signature
-	OperatorId   bls.OperatorId
+	OperatorId   types.OperatorId
 }
 
 // rpc endpoint which is called by operator

aggregator/rpc_server_test.go

@@ -30,7 +30,7 @@ func TestProcessSignedTaskResponse(t *testing.T) {
 	MOCK_OPERATOR_G1PUBKEY := MOCK_OPERATOR_KEYPAIR.GetPubKeyG1()
 	MOCK_OPERATOR_G2PUBKEY := MOCK_OPERATOR_KEYPAIR.GetPubKeyG2()
 
-	operatorPubkeyDict := map[bls.OperatorId]types.OperatorInfo{
+	operatorPubkeyDict := map[sdktypes.OperatorId]types.OperatorInfo{
 		MOCK_OPERATOR_ID: {
 			OperatorPubkeys: sdktypes.OperatorPubkeys{
 				G1Pubkey: MOCK_OPERATOR_G1PUBKEY,

aggregator/types/types.go

@@ -5,15 +5,16 @@ import (
 	"github.com/ethereum/go-ethereum/common"
 )
 
-// TODO: Hardcoded for now
 // all operators in quorum0 must sign the task response in order for it to be accepted
-const QUORUM_THRESHOLD_NUMERATOR = uint32(100)
-const QUORUM_THRESHOLD_DENOMINATOR = uint32(100)
+// TODO: our contracts require uint8 but right now sdktypes.QuorumThresholdPercentage is uint8
+//       prob need to update our inc-sq contracts to use uint8 as well?
+const QUORUM_THRESHOLD_NUMERATOR = sdktypes.QuorumThresholdPercentage(100)
+const QUORUM_THRESHOLD_DENOMINATOR = sdktypes.QuorumThresholdPercentage(100)
 
 const QUERY_FILTER_FROM_BLOCK = uint64(1)
 
 // we only use a single quorum (quorum 0) for incredible squaring
-var QUORUM_NUMBERS = []byte{0}
+var QUORUM_NUMBERS = sdktypes.QuorumNums{0}
 
 type BlockNumber = uint32
 type TaskIndex = uint32

challenger/challenger.go

@@ -18,7 +18,7 @@ import (
 
 type Challenger struct {
 	logger             logging.Logger
-	ethClient          ethclient.EthClient
+	ethClient          ethclient.Client
 	avsReader          chainio.AvsReaderer
 	avsWriter          chainio.AvsWriterer
 	avsSubscriber      chainio.AvsSubscriberer

challenger/challenger_test.go

@@ -42,8 +42,8 @@ func TestCallChallengeModule(t *testing.T) {
 	challenger.tasks[TASK_INDEX] = cstaskmanager.IIncredibleSquaringTaskManagerTask{
 		NumberToBeSquared:         big.NewInt(3),
 		TaskCreatedBlock:          1000,
-		QuorumNumbers:             aggtypes.QUORUM_NUMBERS,
-		QuorumThresholdPercentage: aggtypes.QUORUM_THRESHOLD_NUMERATOR,
+		QuorumNumbers:             aggtypes.QUORUM_NUMBERS.UnderlyingType(),
+		QuorumThresholdPercentage: uint32(aggtypes.QUORUM_THRESHOLD_NUMERATOR),
 	}
 
 	challenger.taskResponses[TASK_INDEX] = chtypes.TaskResponseData{
@@ -84,8 +84,8 @@ func TestRaiseChallenge(t *testing.T) {
 	challenger.tasks[TASK_INDEX] = cstaskmanager.IIncredibleSquaringTaskManagerTask{
 		NumberToBeSquared:         big.NewInt(3),
 		TaskCreatedBlock:          1000,
-		QuorumNumbers:             aggtypes.QUORUM_NUMBERS,
-		QuorumThresholdPercentage: aggtypes.QUORUM_THRESHOLD_NUMERATOR,
+		QuorumNumbers:             aggtypes.QUORUM_NUMBERS.UnderlyingType(),
+		QuorumThresholdPercentage: uint32(aggtypes.QUORUM_THRESHOLD_NUMERATOR),
 	}
 
 	challenger.taskResponses[TASK_INDEX] = chtypes.TaskResponseData{
@@ -124,8 +124,8 @@ func TestProcessTaskResponseLog(t *testing.T) {
 	challenger.tasks[TASK_INDEX] = cstaskmanager.IIncredibleSquaringTaskManagerTask{
 		NumberToBeSquared:         big.NewInt(3),
 		TaskCreatedBlock:          1000,
-		QuorumNumbers:             aggtypes.QUORUM_NUMBERS,
-		QuorumThresholdPercentage: aggtypes.QUORUM_THRESHOLD_NUMERATOR,
+		QuorumNumbers:             aggtypes.QUORUM_NUMBERS.UnderlyingType(),
+		QuorumThresholdPercentage: uint32(aggtypes.QUORUM_THRESHOLD_NUMERATOR),
 	}
 
 	challenger.taskResponses[TASK_INDEX] = chtypes.TaskResponseData{

config-files/operator.anvil.yaml

@@ -8,8 +8,8 @@ operator_address: 0x860B6912C2d0337ef05bbC89b0C2CB6CbAEAB4A5
 # This is the address of the contracts which are deployed in the anvil saved state
 # The saved eigenlayer state is located in tests/anvil/credible_squaring_avs_deployment_output.json
 # TODO(samlaf): automate updating these addresses when we deploy new contracts
-avs_registry_coordinator_address: 0xc3e53F4d16Ae77Db1c982e75a937B9f60FE63690
-operator_state_retriever_address: 0x1613beB3B2C4f22Ee086B2b38C1476A3cE7f78E8
+avs_registry_coordinator_address: 0xa82fF9aFd8f496c3d6ac40E2a0F282E47488CFc9
+operator_state_retriever_address: 0x95401dc811bb5740090279Ba06cfA8fcF6113778
 
 # ETH RPC URL
 eth_rpc_url: http://localhost:8545
@@ -41,4 +41,4 @@ enable_node_api: true
 register_operator_on_startup: true
 # address of token to deposit tokens into when registering on startup
 # addresses.erc20MockStrategy in tests/anvil/credible_squaring_avs_deployment_output.json
-token_strategy_addr: 0xa85233C63b9Ee964Add6F2cffe00Fd84eb32338f
+token_strategy_addr: 0x09635F643e140090A9A8Dcd712eD6285858ceBef

contracts/script/IncredibleSquaringDeployer.s.sol

@@ -5,6 +5,7 @@ import "@openzeppelin/contracts/proxy/transparent/ProxyAdmin.sol";
 
 import "@eigenlayer/contracts/permissions/PauserRegistry.sol";
 import {IDelegationManager} from "@eigenlayer/contracts/interfaces/IDelegationManager.sol";
+import {IAVSDirectory} from "@eigenlayer/contracts/interfaces/IAVSDirectory.sol";
 import {IStrategyManager, IStrategy} from "@eigenlayer/contracts/interfaces/IStrategyManager.sol";
 import {ISlasher} from "@eigenlayer/contracts/interfaces/ISlasher.sol";
 import {StrategyBaseTVLLimits} from "@eigenlayer/contracts/strategies/StrategyBaseTVLLimits.sol";
@@ -89,6 +90,12 @@ contract IncredibleSquaringDeployer is Script, Utils {
                 ".addresses.delegation"
             )
         );
+        IAVSDirectory avsDirectory = IAVSDirectory(
+            stdJson.readAddress(
+                eigenlayerDeployedContracts,
+                ".addresses.avsDirectory"
+            )
+        );
         ProxyAdmin eigenLayerProxyAdmin = ProxyAdmin(
             stdJson.readAddress(
                 eigenlayerDeployedContracts,
@@ -120,6 +127,7 @@ contract IncredibleSquaringDeployer is Script, Utils {
         );
         _deployCredibleSquaringContracts(
             delegationManager,
+            avsDirectory,
             erc20MockStrategy,
             credibleSquaringCommunityMultisig,
             credibleSquaringPauser
@@ -153,11 +161,17 @@ contract IncredibleSquaringDeployer is Script, Utils {
         );
         IStrategy[] memory strats = new IStrategy[](1);
         strats[0] = erc20MockStrategy;
-        strategyManager.addStrategiesToDepositWhitelist(strats);
+        bool[] memory thirdPartyTransfersForbiddenValues = new bool[](1);
+        thirdPartyTransfersForbiddenValues[0] = false;
+        strategyManager.addStrategiesToDepositWhitelist(
+            strats,
+            thirdPartyTransfersForbiddenValues
+        );
     }
 
     function _deployCredibleSquaringContracts(
         IDelegationManager delegationManager,
+        IAVSDirectory avsDirectory,
         IStrategy strat,
         address incredibleSquaringCommunityMultisig,
         address credibleSquaringPauser
@@ -345,21 +359,17 @@ contract IncredibleSquaringDeployer is Script, Utils {
         }
 
         incredibleSquaringServiceManagerImplementation = new IncredibleSquaringServiceManager(
-            delegationManager,
+            avsDirectory,
             registryCoordinator,
             stakeRegistry,
             incredibleSquaringTaskManager
         );
         // Third, upgrade the proxy contracts to use the correct implementation contracts and initialize them.
-        incredibleSquaringProxyAdmin.upgradeAndCall(
+        incredibleSquaringProxyAdmin.upgrade(
             TransparentUpgradeableProxy(
                 payable(address(incredibleSquaringServiceManager))
             ),
-            address(incredibleSquaringServiceManagerImplementation),
-            abi.encodeWithSelector(
-                incredibleSquaringServiceManager.initialize.selector,
-                incredibleSquaringCommunityMultisig
-            )
+            address(incredibleSquaringServiceManagerImplementation)
         );
 
         incredibleSquaringTaskManagerImplementation = new IncredibleSquaringTaskManager(

contracts/script/output/31337/credible_squaring_avs_deployment_output.json

@@ -1,13 +1,13 @@
 {
   "addresses": {
-    "credibleSquaringServiceManager": "0x67d269191c92Caf3cD7723F116c85e6E9bf55933",
-    "credibleSquaringServiceManagerImplementation": "0x8f86403A4DE0BB5791fa46B8e795C547942fE4Cf",
-    "credibleSquaringTaskManager": "0xE6E340D132b5f46d1e472DebcD681B2aBc16e57E",
-    "credibleSquaringTaskManagerImplementation": "0x5eb3Bc0a489C5A8288765d2336659EbCA68FCd00",
-    "erc20Mock": "0x322813Fd9A801c5507c9de605d63CEA4f2CE6c44",
-    "erc20MockStrategy": "0xa85233C63b9Ee964Add6F2cffe00Fd84eb32338f",
-    "operatorStateRetriever": "0x1613beB3B2C4f22Ee086B2b38C1476A3cE7f78E8",
-    "registryCoordinator": "0xc3e53F4d16Ae77Db1c982e75a937B9f60FE63690",
-    "registryCoordinatorImplementation": "0x99bbA657f2BbC93c02D617f8bA121cB8Fc104Acf"
+    "credibleSquaringServiceManager": "0x84eA74d481Ee0A5332c457a4d796187F6Ba67fEB",
+    "credibleSquaringServiceManagerImplementation": "0x36C02dA8a0983159322a80FFE9F24b1acfF8B570",
+    "credibleSquaringTaskManager": "0x9E545E3C0baAB3E08CdfD552C960A1050f373042",
+    "credibleSquaringTaskManagerImplementation": "0x4c5859f0F772848b2D91F1D83E2Fe57935348029",
+    "erc20Mock": "0x7a2088a1bFc9d81c55368AE168C2C02570cB814F",
+    "erc20MockStrategy": "0x09635F643e140090A9A8Dcd712eD6285858ceBef",
+    "operatorStateRetriever": "0x95401dc811bb5740090279Ba06cfA8fcF6113778",
+    "registryCoordinator": "0xa82fF9aFd8f496c3d6ac40E2a0F282E47488CFc9",
+    "registryCoordinatorImplementation": "0x9d4454B023096f34B160D6B654540c56A1F81688"
   }
 }

contracts/script/output/31337/eigenlayer_deployment_output.json

@@ -1,22 +1,24 @@
 {
   "addresses": {
-    "baseStrategyImplementation": "0xc6e7DF5E7b4f2A278906862b61205850344D4e7d",
-    "delayedWithdrawalRouter": "0xa513E6E4b8f2a923D98304ec87F64353C4D5C853",
-    "delayedWithdrawalRouterImplementation": "0x9A676e781A523b5d0C0e43731313A708CB607508",
+    "avsDirectory": "0x5FC8d32690cc91D4c39d9d3abcBD16989F875707",
+    "avsDirectoryImplementation": "0x0DCd1Bf9A1b36cE34237eEaFef220932846BCD82",
+    "baseStrategyImplementation": "0x322813Fd9A801c5507c9de605d63CEA4f2CE6c44",
+    "delayedWithdrawalRouter": "0x2279B7A0a67DB372996a5FaB50D91eAA73d2eBe6",
+    "delayedWithdrawalRouterImplementation": "0x959922bE3CAee4b8Cd9a407cc3ac1C251C2007B1",
     "delegation": "0xCf7Ed3AccA5a467e9e704C703E8D87F634fB0Fc9",
-    "delegationImplementation": "0x610178dA211FEF7D417bC0e6FeD39F05609AD788",
+    "delegationImplementation": "0xB7f8BC63BbcaD18155201308C8f3540b07f84F5e",
     "eigenLayerPauserReg": "0xe7f1725E7734CE288F8367e1Bb143E90bb3F0512",
     "eigenLayerProxyAdmin": "0x5FbDB2315678afecb367f032d93F642f64180aa3",
-    "eigenPodBeacon": "0x8A791620dd6260079BF849Dc5567aDC3F2FdC318",
-    "eigenPodImplementation": "0x2279B7A0a67DB372996a5FaB50D91eAA73d2eBe6",
-    "eigenPodManager": "0x0165878A594ca255338adfa4d48449f69242Eb8F",
-    "eigenPodManagerImplementation": "0x0DCd1Bf9A1b36cE34237eEaFef220932846BCD82",
+    "eigenPodBeacon": "0x610178dA211FEF7D417bC0e6FeD39F05609AD788",
+    "eigenPodImplementation": "0x8A791620dd6260079BF849Dc5567aDC3F2FdC318",
+    "eigenPodManager": "0xa513E6E4b8f2a923D98304ec87F64353C4D5C853",
+    "eigenPodManagerImplementation": "0x0B306BF915C4d645ff596e518fAf3F9669b97016",
     "emptyContract": "0x9fE46736679d2D9a65F0992F2272dE9f3c7fa6e0",
-    "slasher": "0x5FC8d32690cc91D4c39d9d3abcBD16989F875707",
-    "slasherImplementation": "0xA51c1fc2f0D1a1b8494Ed1FE312d7C3a78Ed91C0",
+    "slasher": "0x0165878A594ca255338adfa4d48449f69242Eb8F",
+    "slasherImplementation": "0x9A676e781A523b5d0C0e43731313A708CB607508",
     "strategies": "",
     "strategyManager": "0xDc64a140Aa3E981100a9becA4E685f962f0cF6C9",
-    "strategyManagerImplementation": "0xB7f8BC63BbcaD18155201308C8f3540b07f84F5e"
+    "strategyManagerImplementation": "0xA51c1fc2f0D1a1b8494Ed1FE312d7C3a78Ed91C0"
   },
   "chainInfo": {
     "chainId": 31337,

contracts/src/IncredibleSquaringServiceManager.sol

@@ -25,13 +25,14 @@ contract IncredibleSquaringServiceManager is ServiceManagerBase {
     }
 
     constructor(
-        IDelegationManager _delegationManager,
+        IAVSDirectory _avsDirectory,
         IRegistryCoordinator _registryCoordinator,
         IStakeRegistry _stakeRegistry,
         IIncredibleSquaringTaskManager _incredibleSquaringTaskManager
     )
         ServiceManagerBase(
-            _delegationManager,
+            _avsDirectory,
+            IPaymentCoordinator(address(0)), // inc-sq doesn't need to deal with payments
             _registryCoordinator,
             _stakeRegistry
         )

core/chainio/avs_reader.go

@@ -35,7 +35,7 @@ var _ AvsReaderer = (*AvsReader)(nil)
 func BuildAvsReaderFromConfig(c *config.Config) (*AvsReader, error) {
 	return BuildAvsReader(c.IncredibleSquaringRegistryCoordinatorAddr, c.OperatorStateRetrieverAddr, c.EthHttpClient, c.Logger)
 }
-func BuildAvsReader(registryCoordinatorAddr, operatorStateRetrieverAddr gethcommon.Address, ethHttpClient eth.EthClient, logger logging.Logger) (*AvsReader, error) {
+func BuildAvsReader(registryCoordinatorAddr, operatorStateRetrieverAddr gethcommon.Address, ethHttpClient eth.Client, logger logging.Logger) (*AvsReader, error) {
 	avsManagersBindings, err := NewAvsManagersBindings(registryCoordinatorAddr, operatorStateRetrieverAddr, ethHttpClient, logger)
 	if err != nil {
 		return nil, err

core/chainio/avs_subscriber.go

@@ -37,7 +37,7 @@ func BuildAvsSubscriberFromConfig(config *config.Config) (*AvsSubscriber, error)
 	)
 }
 
-func BuildAvsSubscriber(registryCoordinatorAddr, blsOperatorStateRetrieverAddr gethcommon.Address, ethclient eth.EthClient, logger sdklogging.Logger) (*AvsSubscriber, error) {
+func BuildAvsSubscriber(registryCoordinatorAddr, blsOperatorStateRetrieverAddr gethcommon.Address, ethclient eth.Client, logger sdklogging.Logger) (*AvsSubscriber, error) {
 	avsContractBindings, err := NewAvsManagersBindings(registryCoordinatorAddr, blsOperatorStateRetrieverAddr, ethclient, logger)
 	if err != nil {
 		logger.Errorf("Failed to create contract bindings", "err", err)