Added debug logs when exporting/importing the account ledger and the performance stats

Author: alexsporn

pkg/protocol/engine/accounts/accountsledger/snapshot.go

@@ -27,7 +27,7 @@ func (m *Manager) Import(reader io.ReadSeeker) error {
 			return ierrors.Wrapf(err, "unable to set account %s", accountData.ID)
 		}
 
-		m.LogDebug("Imported account", "accountID", accountData.ID, "outputID", accountData.OutputID, "credits.value", accountData.Credits.Value, "credits.updateSlot", accountData.Credits.UpdateSlot)
+		m.LogDebug("Imported account", "accountData", accountData)
 
 		return nil
 	}); err != nil {
@@ -189,6 +189,8 @@ func (m *Manager) readSlotDiffs(reader io.ReadSeeker) error {
 				accountDiff = model.NewAccountDiff()
 			}
 
+			m.LogDebug("Imported account diff", "slot", slot, "accountID", accountID, "destroyed", destroyed, "accountDiff", accountDiff)
+
 			if err := diffStore.Store(accountID, accountDiff, destroyed); err != nil {
 				return ierrors.Wrapf(err, "unable to store slot diff for accountID %s", accountID)
 			}
@@ -250,6 +252,8 @@ func (m *Manager) writeSlotDiffs(writer io.WriteSeeker, targetSlot iotago.SlotIn
 					}
 				}
 
+				m.LogDebug("Exported account diff", "slot", slot, "accountID", accountID, "destroyed", destroyed, "accountDiff", accountDiff)
+
 				accountsInDiffCount++
 
 				return true

pkg/protocol/sybilprotection/sybilprotectionv1/performance/snapshot.go

@@ -95,6 +95,8 @@ func (t *Tracker) importPerformanceFactor(reader io.ReadSeeker) error {
 				return ierrors.Wrapf(err, "unable to store performance factor for account %s and slot index %d", accountID, slot)
 			}
 
+			t.LogDebug("Importing performance factor", "accountID", accountID, "slot", slot, "performanceFactor", performanceFactor)
+
 			return nil
 		}); err != nil {
 			return ierrors.Wrapf(err, "unable to read performance factors for slot %d", slot)
@@ -131,6 +133,8 @@ func (t *Tracker) importPoolRewards(reader io.ReadSeeker) error {
 				return ierrors.Wrapf(err, "unable to read reward for account %s and epoch index %d", accountID, epoch)
 			}
 
+			t.LogDebug("Importing reward", "accountID", accountID, "epoch", epoch, "reward", reward)
+
 			if err = rewardsTree.Set(accountID, reward); err != nil {
 				return ierrors.Wrapf(err, "unable to set reward for account %s and epoch index %d", accountID, epoch)
 			}
@@ -168,6 +172,8 @@ func (t *Tracker) importPoolsStats(reader io.ReadSeeker) error {
 			return ierrors.Wrapf(err, "unable to store pool stats for the epoch index %d", epoch)
 		}
 
+		t.LogDebug("Importing pool stats", "epoch", epoch, "poolStats", poolStats)
+
 		return nil
 	}); err != nil {
 		return ierrors.Wrap(err, "unable to read pool stats collection")
@@ -206,6 +212,8 @@ func (t *Tracker) importCommittees(reader io.ReadSeeker) error {
 			committee.SetReused()
 		}
 
+		t.LogDebug("Importing committee", "epoch", epoch, "committee", committee)
+
 		if err = t.committeeStore.Store(epoch, committee); err != nil {
 			return ierrors.Wrap(err, "unable to store committee")
 		}
@@ -247,6 +255,8 @@ func (t *Tracker) exportPerformanceFactor(writer io.WriteSeeker, startSlot iotag
 						return ierrors.Wrapf(err, "unable to write performance factor for accountID %s and slot index %d", accountID, currentSlot)
 					}
 
+					t.LogDebug("Exporting performance factor", "accountID", accountID, "slot", currentSlot, "performanceFactor", pf)
+
 					accountsCount++
 
 					return nil
@@ -292,9 +302,12 @@ func (t *Tracker) exportPoolRewards(writer io.WriteSeeker, targetEpoch iotago.Ep
 			}
 			// if the map was not present in storage we can skip this epoch
 			if !rewardsMap.WasRestoredFromStorage() {
+				t.LogDebug("Skipping epoch", "epoch", epoch, "reason", "not restored from storage")
 				continue
 			}
 
+			t.LogDebug("Exporting Pool Rewards", "epoch", epoch)
+
 			if err := stream.Write(writer, epoch); err != nil {
 				return 0, ierrors.Wrapf(err, "unable to write epoch index for epoch index %d", epoch)
 			}
@@ -311,6 +324,8 @@ func (t *Tracker) exportPoolRewards(writer io.WriteSeeker, targetEpoch iotago.Ep
 						return ierrors.Wrapf(err, "unable to write account rewards for epoch index %d and accountID %s", epoch, key)
 					}
 
+					t.LogDebug("Exporting Pool Reward", "epoch", epoch, "accountID", key, "rewards", value)
+
 					accountCount++
 
 					return nil
@@ -347,6 +362,7 @@ func (t *Tracker) exportPoolsStats(writer io.WriteSeeker, targetEpoch iotago.Epo
 
 			if epoch > targetEpoch {
 				// continue
+				t.LogDebug("Skipping epoch", "epoch", epoch, "reason", "epoch is greater than target epoch")
 				return nil
 			}
 
@@ -358,6 +374,8 @@ func (t *Tracker) exportPoolsStats(writer io.WriteSeeker, targetEpoch iotago.Epo
 				return ierrors.Wrapf(err, "unable to write pools stats for epoch %d", epoch)
 			}
 
+			t.LogDebug("Exporting Pool Stats", "epoch", epoch, "poolStats", lo.Return1(model.PoolsStatsFromBytes(value)))
+
 			epochCount++
 
 			return nil
@@ -399,6 +417,7 @@ func (t *Tracker) exportCommittees(writer io.WriteSeeker, targetSlot iotago.Slot
 			// - we were able to rotate a committee, then we export it
 			// - we were not able to rotate a committee (reused), then we don't export it
 			if epoch > epochFromTargetSlot && targetSlot < pointOfNoReturn && committee.IsReused() {
+				t.LogDebug("Skipping committee", "epoch", epoch, "reason", "epoch is greater than target epoch and committee is reused")
 				return nil
 			}
 
@@ -427,6 +446,8 @@ func (t *Tracker) exportCommittees(writer io.WriteSeeker, targetSlot iotago.Slot
 				return ierrors.Wrapf(err, "unable to write reused flag for epoch %d", epoch)
 			}
 
+			t.LogDebug("Exporting committee", "epoch", epoch, "committee", committee)
+
 			epochCount++
 
 			return nil