fix

internal/db/timelock.go

@@ -44,7 +44,7 @@ func (db *Database) FindExpiredDelegations(ctx context.Context, btcTipHeight, li
 
 func (db *Database) DeleteExpiredDelegation(ctx context.Context, stakingTxHashHex string) error {
 	client := db.client.Database(db.dbName).Collection(model.TimeLockCollection)
-	filter := bson.M{"_id": stakingTxHashHex}
+	filter := bson.M{"staking_tx_hash_hex": stakingTxHashHex}
 
 	result, err := client.DeleteOne(ctx, filter)
 	if err != nil {

internal/services/events.go

@@ -399,11 +399,11 @@ func (s *Service) validateBTCDelegationExpiredEvent(ctx context.Context, event *
 			Str("stakingTxHashHex", event.StakingTxHash).
 			Str("currentState", delegation.State.String()).
 			Str("event_type", "EventBTCDelegationExpired").
-			Msg("Current state is not qualified for transition")
+			Msg("current state is not qualified for transition")
 		return false, false, types.NewErrorWithMsg(
 			http.StatusForbidden,
 			types.Forbidden,
-			"Current state is not qualified for transition",
+			"current state is not qualified for transition",
 		)
 	}
 

internal/services/expiry_checker.go

@@ -50,13 +50,13 @@ func (s *Service) checkExpiry(ctx context.Context) *types.Error {
 			Str("current_state", delegation.State.String()).
 			Str("new_sub_state", tlDoc.DelegationSubState.String()).
 			Str("expire_height", strconv.FormatUint(uint64(tlDoc.ExpireHeight), 10)).
-			Msg("checking if delegation is expired")
+			Msg("checking if delegation is withdrawable")
 
-		if utils.Contains(types.OutdatedStatesForExpired(), delegation.State) {
+		if utils.Contains(types.OutdatedStatesForWithdrawable(), delegation.State) {
 			log.Debug().
 				Str("staking_tx", delegation.StakingTxHashHex).
 				Str("current_state", delegation.State.String()).
-				Msg("current state is outdated for expired")
+				Msg("current state is outdated for withdrawable")
 
 			if err := s.emitWithdrawableDelegationEvent(ctx, delegation); err != nil {
 				log.Error().