From ac2e020dce91e34255440050a805f738ad74d5fe Mon Sep 17 00:00:00 2001 From: Madhur Shrimal Date: Tue, 2 Jul 2024 09:43:47 -0700 Subject: [PATCH] fix the test because I screwed up --- chainio/clients/avsregistry/bindings.go | 18 ++++++++---------- services/bls_aggregation/blsagg.go | 2 +- 2 files changed, 9 insertions(+), 11 deletions(-) diff --git a/chainio/clients/avsregistry/bindings.go b/chainio/clients/avsregistry/bindings.go index dedc3d1ab..043f6f024 100644 --- a/chainio/clients/avsregistry/bindings.go +++ b/chainio/clients/avsregistry/bindings.go @@ -130,14 +130,12 @@ func NewBindingsFromConfig( var ( err error - serviceManagerAddr gethcommon.Address - registryCoordinatorAddr gethcommon.Address - stakeRegistryAddr gethcommon.Address - blsApkRegistryAddr gethcommon.Address - indexRegistryAddr gethcommon.Address - operatorStateRetrieverAddr gethcommon.Address - delegationManagerAddr gethcommon.Address - avsDirectoryAddr gethcommon.Address + serviceManagerAddr gethcommon.Address + stakeRegistryAddr gethcommon.Address + blsApkRegistryAddr gethcommon.Address + indexRegistryAddr gethcommon.Address + delegationManagerAddr gethcommon.Address + avsDirectoryAddr gethcommon.Address contractBlsRegistryCoordinator *regcoordinator.ContractRegistryCoordinator contractServiceManager *servicemanager.ContractServiceManagerBase @@ -228,11 +226,11 @@ func NewBindingsFromConfig( return &ContractBindings{ ServiceManagerAddr: serviceManagerAddr, - RegistryCoordinatorAddr: registryCoordinatorAddr, + RegistryCoordinatorAddr: cfg.RegistryCoordinatorAddress, StakeRegistryAddr: stakeRegistryAddr, BlsApkRegistryAddr: blsApkRegistryAddr, IndexRegistryAddr: indexRegistryAddr, - OperatorStateRetrieverAddr: operatorStateRetrieverAddr, + OperatorStateRetrieverAddr: cfg.OperatorStateRetrieverAddress, DelegationManagerAddr: delegationManagerAddr, AvsDirectoryAddr: avsDirectoryAddr, ServiceManager: contractServiceManager, diff --git a/services/bls_aggregation/blsagg.go b/services/bls_aggregation/blsagg.go index 57abe8bcd..83525be54 100644 --- a/services/bls_aggregation/blsagg.go +++ b/services/bls_aggregation/blsagg.go @@ -229,13 +229,13 @@ func (a *BlsAggregatorService) singleTaskAggregatorGoroutineFunc( signedTaskRespsC <-chan types.SignedTaskResponseDigest, ) { defer a.closeTaskGoroutine(taskIndex) - quorumThresholdPercentagesMap := make(map[types.QuorumNum]types.QuorumThresholdPercentage) for i, quorumNumber := range quorumNumbers { quorumThresholdPercentagesMap[quorumNumber] = quorumThresholdPercentages[i] } operatorsAvsStateDict, err := a.avsRegistryService.GetOperatorsAvsStateAtBlock(context.Background(), quorumNumbers, taskCreatedBlock) if err != nil { + a.logger.Debug("Task goroutine failed to get operators state from avs registry", "taskIndex", taskIndex, "err", err) a.aggregatedResponsesC <- BlsAggregationServiceResponse{ Err: TaskInitializationErrorFn(fmt.Errorf("AggregatorService failed to get operators state from avs registry at blockNum %d: %w", taskCreatedBlock, err), taskIndex), TaskIndex: taskIndex,