only modify the store if there is a change.. add more robust logging …

…so we can see what exactly is happening.

x/gridnode/keeper/keeper.go

@@ -265,7 +265,7 @@ func (k Keeper) QueryAllDelegations(ctx context.Context) ([]types.DelegationInfo
 			var delegationData types.DelegationData
 			err := json.Unmarshal(value, &delegationData)
 			if err != nil {
-				fmt.Printf("Error unmarshalling delegation data: %v\n", err)
+				fmt.Printf("Error unmarshalling delegation data: %v. Raw data: %x\n", err, value)
 				return // or return an error
 			}
 
@@ -395,7 +395,7 @@ func (k Keeper) SetDelegatedAmount(ctx context.Context, delegator sdk.AccAddress
 		// Handle negative amounts, perhaps log an error or panic
 	}
 	store.Set(k.keyForDelegator(delegator), amount.BigInt().Bytes())
-	//fmt.Println("Set delegated amount for address", delegator, "to:", amount)
+	fmt.Println("Set delegated amount for address", delegator, "to:", amount)
 }
 
 // AddUnbondingEntry adds a new unbonding entry for a given account.

x/gridnode/module/abci.go

@@ -47,6 +47,8 @@ func BeginBlocker(goCtx context.Context, k keeper.Keeper) {
 			continue
 		}
 
+		var entriesChanged bool
+
 		// Filter out entries that have completed unbonding
 		newEntries := make([]types.UnbondingEntry, 0, len(entries))
 		for _, entry := range entries {
@@ -85,27 +87,30 @@ func BeginBlocker(goCtx context.Context, k keeper.Keeper) {
 						sdk.NewAttribute(types.AttributeKeyAmount, strconv.FormatInt(entry.Amount, 10)),
 					),
 				)
+				entriesChanged = true
 			} else {
 				newEntries = append(newEntries, entry)
 			}
 		}
 
 		// Update the store with the new list of unbonding entries
-		if len(newEntries) == 0 {
-			fmt.Printf("All unbonding entries processed for key: %s. Deleting key from store.\n", key)
-			store.Delete(key)
-		} else {
-			newBz, err := json.Marshal(newEntries)
-			if err != nil {
-				fmt.Printf("Error marshalling new entries for key %x: %v\n", key, err)
-				continue
-			}
+		if entriesChanged {
+			if len(newEntries) == 0 {
+				fmt.Printf("All unbonding entries processed for key: %s. Deleting key from store.\n", key)
+				store.Delete(key)
+			} else {
+				newBz, err := json.Marshal(newEntries)
+				if err != nil {
+					fmt.Printf("Error marshalling new entries for key %x: %v\n", key, err)
+					continue
+				}
 
-			// Log the data that is about to be stored
-			fmt.Printf("Updating store for key %x with data: %s\n", key, string(newBz))
+				// Log the data that is about to be stored
+				fmt.Printf("Updating store for key %x with data: %s\n", key, string(newBz))
 
-			store.Set(key, newBz)
-			fmt.Printf("Updated store for key %x\n", key)
+				store.Set(key, newBz)
+				fmt.Printf("Updated store for key %x\n", key)
+			}
 		}
 	}