fix the test because I screwed up

Layr-Labs · Jul 2, 2024 · ac2e020 · ac2e020
1 parent e9d888a
commit ac2e020
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 11 deletions.
diff --git 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
@@ -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,