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

test: runId logger

Browse Source
This commit is contained in:
Richard Ramos 2024-05-30 08:54:41 -04:00
parent 73a5e9cfdb
commit 2f9bbfe337
No known key found for this signature in database
GPG Key ID: 1CE87DB518195760
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
cmd/storemsgcounter/execute.go
View File

@ -131,12 +131,16 @@ func Execute(ctx context.Context, options Options) error {
case <-ctx.Done(): case <-ctx.Done():
return nil return nil
case <-timer.C: case <-timer.C:
logger.Info("verifying message history...") tmpUUID := uuid.New()
err := verifyHistory(ctx, storenodes, wakuNode, dbStore, logger) runId := hex.EncodeToString(tmpUUID[:])
runIdLogger := logger.With(zap.String("runId", runId))
runIdLogger.Info("verifying message history...")
err := verifyHistory(ctx, runId, storenodes, wakuNode, dbStore, runIdLogger)
if err != nil { if err != nil {
return err return err
} }
logger.Info("verification complete") runIdLogger.Info("verification complete")
timer.Reset(timeInterval) timer.Reset(timeInterval)
} }
@ -147,11 +151,7 @@ var msgMapLock sync.Mutex
var msgMap map[pb.MessageHash]map[peer.ID]MessageExistence var msgMap map[pb.MessageHash]map[peer.ID]MessageExistence
var msgAttr map[pb.MessageHash]MessageAttr var msgAttr map[pb.MessageHash]MessageAttr
func verifyHistory(ctx context.Context, storenodes []peer.AddrInfo, wakuNode *node.WakuNode, dbStore *persistence.DBStore, logger *zap.Logger) error { func verifyHistory(ctx context.Context, runId string, storenodes []peer.AddrInfo, wakuNode *node.WakuNode, dbStore *persistence.DBStore, logger *zap.Logger) error {
tmpUUID := uuid.New()
runId := hex.EncodeToString(tmpUUID[:])
logger = logger.With(zap.String("runId", runId))
// [MessageHash][StoreNode] = exists? // [MessageHash][StoreNode] = exists?
msgMapLock.Lock() msgMapLock.Lock()