fix: ResubscribeToMissedBtcNotifications error

babylonlabs-io · Dec 3, 2024 · 7fef454 · 7fef454
1 parent 1f0f728
commit 7fef454
Show file tree

Hide file tree

Showing 4 changed files with 3 additions and 10 deletions.
diff --git a/config/config-docker.yml b/config/config-docker.yml
@@ -16,7 +16,7 @@ btc:
   retryinterval: 500ms
   netparams: signet  
 bbn:
-  rpc-addr: https://rpc.devnet.babylonlabs.io:443
+  rpc-addr: https://rpc-dapp.devnet.babylonlabs.io:443
   timeout: 30s
   maxretrytimes: 5
   retryinterval: 500ms

diff --git a/config/config-local.yml b/config/config-local.yml
@@ -16,7 +16,7 @@ btc:
   retryinterval: 500ms
   netparams: signet  
 bbn:
-  rpc-addr: https://rpc.devnet.babylonlabs.io:443
+  rpc-addr: https://rpc-dapp.devnet.babylonlabs.io:443
   timeout: 30s
   maxretrytimes: 5
   retryinterval: 500ms

diff --git a/internal/db/delegation.go b/internal/db/delegation.go
@@ -314,12 +314,5 @@ func (db *Database) GetBTCDelegationsByStates(
 		return nil, err
 	}
 
-	if len(delegations) == 0 {
-		return nil, &NotFoundError{
-			Key:     "specified states",
-			Message: "No BTC delegations found for the specified states",
-		}
-	}
-
 	return delegations, nil
 }
diff --git a/internal/services/subscription.go b/internal/services/subscription.go
@@ -54,7 +54,7 @@ func (s *Service) SubscribeToBbnEvents(ctx context.Context) {
 // Resubscribe to missed BTC notifications
 func (s *Service) ResubscribeToMissedBtcNotifications(ctx context.Context) {
 	go func() {
-		defer s.wg.Done()
+		log.Info().Msg("Resubscribing to missed BTC notifications")
 		delegations, err := s.db.GetBTCDelegationsByStates(ctx, []types.DelegationState{types.StateUnbonding, types.StateSlashed})
 		if err != nil {
 			log.Fatal().Msgf("Failed to get BTC delegations: %v", err)