chore: add logs to refund tokens (#1001)

plugins/tokens/plugin.go

@@ -65,31 +65,33 @@ func EndBlocker(ctx sdk.Context, timelockKeeper timelock.Keeper, swapKeeper swap
  iterator := timelockKeeper.GetTimeLockRecordIterator(ctx)
  defer iterator.Close()
  i := 0
+ failedCount := 0
  for ; iterator.Valid(); iterator.Next() {
- if i >= MaxUnlockItems {
- break
- }
  addr, id, err := timelock.ParseKeyRecord(iterator.Key())
  if err != nil {
  logger.Error("failed to parse timelock record", "error", err)
+ failedCount++
  continue
  }
  err = timelockKeeper.TimeUnlock(ctx, addr, id, true)
  if err != nil {
  logger.Error("failed to unlock the time locks", "error", err)
+ failedCount++
  continue
  }
  logger.Info("succeed to unlock the time locks", "addr", addr, "id", id)
  i++
+ if i >= MaxUnlockItems {
+ break
+ }
  }
+ logger.Info("unlock the time locks done", "blockHeight", ctx.BlockHeight(), "succeed", i, "failed", failedCount)
 
  swapIterator := swapKeeper.GetSwapIterator(ctx)
  defer swapIterator.Close()
  i = 0
+ failedCount = 0
  for ; swapIterator.Valid(); swapIterator.Next() {
- if i >= MaxUnlockItems {
- break
- }
  var automaticSwap swap.AtomicSwap
  swapKeeper.CDC().MustUnmarshalBinaryBare(swapIterator.Value(), &automaticSwap)
  swapID := swapIterator.Key()[len(swap.HashKey):]
@@ -106,12 +108,17 @@ func EndBlocker(ctx sdk.Context, timelockKeeper timelock.Keeper, swapKeeper swap
  })
  if !result.IsOK() {
  logger.Error("failed to refund swap", "swapId", swapID, "result", fmt.Sprintf("%+v", result))
+ failedCount++
  continue
  }
 
  logger.Info("succeed to refund swap", "swapId", swapID, "swap", fmt.Sprintf("%+v", swapItem))
  i++
+ if i >= MaxUnlockItems {
+ break
+ }
  }
+ logger.Info("refund the swaps done", "blockHeight", ctx.BlockHeight(), "succeed", i, "failed", failedCount)
 }
 
 // EndBreatheBlock processes the breathe block lifecycle event.