logos-messaging/storenode-messages-counter
1
0
Fork 0
mirror of https://github.com/logos-messaging/storenode-messages-counter.git synced 2026-01-05 23:53:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: use hex for uuid

Browse Source
This commit is contained in:
Richard Ramos 2024-05-29 21:42:22 -04:00
parent eeedcd38f2
commit 584fd8f2c3
No known key found for this signature in database
GPG Key ID: 1CE87DB518195760
2 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
cmd/storemsgcounter/execute.go
View File

@ -3,6 +3,7 @@ package main
import ( import (
"context" "context"
"database/sql" "database/sql"
"encoding/hex"
"errors" "errors"
"fmt" "fmt"
"net" "net"
@ -146,7 +147,8 @@ 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, storenodes []peer.AddrInfo, wakuNode *node.WakuNode, dbStore *persistence.DBStore, logger *zap.Logger) error {
runId := uuid.New().String() tmpUUID := uuid.New()
runId := hex.EncodeToString(tmpUUID[:])
logger = logger.With(zap.String("runId", runId)) logger = logger.With(zap.String("runId", runId))
@ -204,7 +206,7 @@ func verifyHistory(ctx context.Context, storenodes []peer.AddrInfo, wakuNode *no
wg.Add(1) wg.Add(1)
go func(peerID peer.ID, messageHashes []pb.MessageHash) { go func(peerID peer.ID, messageHashes []pb.MessageHash) {
defer wg.Done() defer wg.Done()
verifyMessageExistence(ctx, runId, tx, peerID, messageHashes, wakuNode, dbStore, logger) verifyMessageExistence(ctx, runId, peerID, messageHashes, wakuNode, dbStore, logger)
}(peerID, messageHashes) }(peerID, messageHashes)
} }
wg.Wait() wg.Wait()
@ -359,7 +361,7 @@ func retrieveHistory(ctx context.Context, runId string, storenodes []peer.AddrIn
} }
} }
func verifyMessageExistence(ctx context.Context, runId string, tx *sql.Tx, peerID peer.ID, messageHashes []pb.MessageHash, wakuNode *node.WakuNode, dbStore *persistence.DBStore, logger *zap.Logger) { func verifyMessageExistence(ctx context.Context, runId string, peerID peer.ID, messageHashes []pb.MessageHash, wakuNode *node.WakuNode, dbStore *persistence.DBStore, logger *zap.Logger) {
storeNodeFailure := false storeNodeFailure := false
var result *store.Result var result *store.Result
var err error var err error

2
go.mod
View File

@ -10,6 +10,7 @@ require (
github.com/google/uuid v1.3.0 github.com/google/uuid v1.3.0
github.com/ipfs/go-log/v2 v2.5.1 github.com/ipfs/go-log/v2 v2.5.1
github.com/jackc/pgx/v5 v5.4.1 github.com/jackc/pgx/v5 v5.4.1
github.com/libp2p/go-libp2p v0.32.2
github.com/mattn/go-sqlite3 v1.14.17 github.com/mattn/go-sqlite3 v1.14.17
github.com/multiformats/go-multiaddr v0.12.3 github.com/multiformats/go-multiaddr v0.12.3
github.com/urfave/cli/v2 v2.27.2 github.com/urfave/cli/v2 v2.27.2
@ -75,7 +76,6 @@ require (
github.com/libp2p/go-buffer-pool v0.1.0 // indirect github.com/libp2p/go-buffer-pool v0.1.0 // indirect
github.com/libp2p/go-cidranger v1.1.0 // indirect github.com/libp2p/go-cidranger v1.1.0 // indirect
github.com/libp2p/go-flow-metrics v0.1.0 // indirect github.com/libp2p/go-flow-metrics v0.1.0 // indirect
github.com/libp2p/go-libp2p v0.32.2 // indirect
github.com/libp2p/go-libp2p-asn-util v0.3.0 // indirect github.com/libp2p/go-libp2p-asn-util v0.3.0 // indirect
github.com/libp2p/go-libp2p-pubsub v0.10.1 // indirect github.com/libp2p/go-libp2p-pubsub v0.10.1 // indirect
github.com/libp2p/go-msgio v0.3.0 // indirect github.com/libp2p/go-msgio v0.3.0 // indirect