logos-messaging/storenode-messages-counter
1
0
Fork 0
mirror of https://github.com/logos-messaging/storenode-messages-counter.git synced 2026-01-07 16:43:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: more logs

Browse Source
This commit is contained in:
Richard Ramos 2024-05-29 23:05:28 -04:00
parent 7a98002155
commit 91ca415b19
No known key found for this signature in database
GPG Key ID: 1CE87DB518195760
1 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
cmd/storemsgcounter/execute.go
View File

@ -316,7 +316,16 @@ func retrieveHistory(ctx context.Context, runId string, storenodes []peer.AddrIn
iteratorLbl: iteratorLbl:
for !result.IsComplete() { for !result.IsComplete() {
msgMapLock.Lock() 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() { for _, mkv := range result.Messages() {
hash := mkv.WakuMessageHash() hash := mkv.WakuMessageHash()
_, ok := msgMap[hash] _, ok := msgMap[hash]