From 91ca415b19dd8a41ac050a0f8f7b9280b7296e7c Mon Sep 17 00:00:00 2001 From: Richard Ramos Date: Wed, 29 May 2024 23:05:28 -0400 Subject: [PATCH] test: more logs --- cmd/storemsgcounter/execute.go | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) diff --git a/cmd/storemsgcounter/execute.go b/cmd/storemsgcounter/execute.go index 789b965..fed223e 100644 --- a/cmd/storemsgcounter/execute.go +++ b/cmd/storemsgcounter/execute.go @@ -316,7 +316,16 @@ func retrieveHistory(ctx context.Context, runId string, storenodes []peer.AddrIn iteratorLbl: for !result.IsComplete() { msgMapLock.Lock() - logger.Info("OBTAINED MESSAGES", zap.Any("len", len(result.Messages()))) + + oldMessageT := zap.Skip() + newMessageT := zap.Skip() + if len(result.Messages()) > 0 { + oldMessageT = zap.Int64("oldMessageT", result.Messages()[0].Message.GetTimestamp()) + newMessageT = zap.Int64("newMessageT", result.Messages()[len(result.Messages())-1].Message.GetTimestamp()) + } + + logger.Info("OBTAINED MESSAGES", zap.Any("len", len(result.Messages())), newMessageT, oldMessageT) + for _, mkv := range result.Messages() { hash := mkv.WakuMessageHash() _, ok := msgMap[hash]