CNS-870: small fixes

lavanet · Feb 26, 2024 · a4062fe · a4062fe
1 parent e1da79c
commit a4062fe
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 5 deletions.
diff --git a/x/rewards/keeper/iprpc.go b/x/rewards/keeper/iprpc.go
@@ -63,6 +63,7 @@ func (k Keeper) addSpecFunds(ctx sdk.Context, spec string, fund sdk.Coins, durat
 				if iprpcReward.SpecFunds[i].Spec == spec {
 					specFound = true
 					iprpcReward.SpecFunds[i].Fund = iprpcReward.SpecFunds[i].Fund.Add(fund...)
+					break
 				}
 			}
 			if !specFound {

diff --git a/x/rewards/keeper/providers.go b/x/rewards/keeper/providers.go
@@ -67,8 +67,8 @@ func (k Keeper) distributeMonthlyBonusRewards(ctx sdk.Context) {
 			specTotalPayout = k.specTotalPayout(ctx, total, sdk.NewDecFromInt(totalbasepay), spec)
 		}
 		// distribute the rewards to all providers
-		if !specTotalPayout.IsZero() {
-			for _, basepay := range basepays {
+		for _, basepay := range basepays {
+			if !specTotalPayout.IsZero() {
 				// calculate the providers bonus base on adjusted base pay
 				reward := specTotalPayout.Mul(basepay.TotalAdjusted).QuoInt(totalbasepay).TruncateInt()
 				totalRewarded = totalRewarded.Add(reward)
@@ -90,10 +90,10 @@ func (k Keeper) distributeMonthlyBonusRewards(ctx sdk.Context) {
 				}
 
 				details[providerAddr.String()+" "+spec.ChainID] = reward.String()
-
-				// count iprpc cu
-				k.countIprpcCu(specCuMap, basepay.IprpcCu, spec.ChainID, basepay.Provider)
 			}
+
+			// count iprpc cu
+			k.countIprpcCu(specCuMap, basepay.IprpcCu, spec.ChainID, basepay.Provider)
 		}
 	}