fix triggers

internal/services/delegation.go

@@ -149,12 +149,17 @@ func (s *Service) processCovenantQuorumReachedEvent(
 		)
 	}
 	newState := types.DelegationState(covenantQuorumReachedEvent.NewState)
-	// Emit consumer event if the new state is active
 	if newState == types.StateActive {
+		// Emit consumer event if the new state is active
 		err = s.emitConsumerEvent(ctx, newState, delegation)
 		if err != nil {
 			return err
 		}
+
+		// Register spend notification
+		if err := s.registerStakingSpendNotification(ctx, delegation); err != nil {
+			return err
+		}
 	}
 
 	if dbErr := s.db.UpdateBTCDelegationState(
@@ -203,12 +208,17 @@ func (s *Service) processBTCDelegationInclusionProofReceivedEvent(
 	}
 
 	newState := types.DelegationState(inclusionProofEvent.NewState)
-	// Emit consumer event if the new state is active
 	if newState == types.StateActive {
+		// Emit consumer event if the new state is active
 		err = s.emitConsumerEvent(ctx, newState, delegation)
 		if err != nil {
 			return err
 		}
+
+		// Register spend notification
+		if err := s.registerStakingSpendNotification(ctx, delegation); err != nil {
+			return err
+		}
 	}
 
 	if dbErr := s.db.UpdateBTCDelegationDetails(
@@ -310,11 +320,6 @@ func (s *Service) processBTCDelegationUnbondedEarlyEvent(
 		)
 	}
 
-	// Register unbonding spend notification
-	if err := s.registerUnbondingSpendNotification(ctx, delegation); err != nil {
-		return err
-	}
-
 	return nil
 }
 
@@ -383,11 +388,6 @@ func (s *Service) processBTCDelegationExpiredEvent(
 		)
 	}
 
-	// Register spend notification
-	if err := s.registerStakingSpendNotification(ctx, delegation); err != nil {
-		return err
-	}
-
 	return nil
 }
 

internal/services/watch_btc_events.go

@@ -175,8 +175,9 @@ func (s *Service) handleSpendingStakingTransaction(
 			Str("staking_tx", delegation.StakingTxHashHex).
 			Str("unbonding_tx", spendingTx.TxHash().String()).
 			Msg("staking tx has been spent through unbonding path")
-		// It's a valid unbonding tx, no further action needed at this stage
-		return nil
+
+		// Register unbonding spend notification
+		return s.registerUnbondingSpendNotification(ctx, delegation)
 	}
 
 	// Try to validate as withdrawal transaction