waku-org
/
storenode-messages-counter
mirror of https://github.com/waku-org/storenode-messages-counter.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix: reduce message hashes limit to 25

This commit is contained in:
Richard Ramos 2024-09-20 09:20:58 -04:00
parent cea218f57a
commit 31ef4403f0
No known key found for this signature in database
GPG Key ID: 1CE87DB518195760
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
cmd/storemsgcounter/execute.go
View File

@ -41,7 +41,7 @@ const (
const timeInterval = 2 * time.Minute
const delay = 5 * time.Minute
const maxAttempts = 3
const maxMsgHashesPerRequest = 100
const maxMsgHashesPerRequest = 25
type Application struct {
node *node.WakuNode
@ -619,7 +619,7 @@ func (app *Application) verifyMessageExistence(ctx context.Context, runId string
queryLogger.Info("querying by hash", zap.Int("attempt", count))
tCtx, cancel := context.WithTimeout(ctx, 1*time.Minute)
result, err = app.node.Store().QueryByHash(tCtx, messageHashes, store.IncludeData(false), store.WithPeer(peerInfo.ID), store.WithPaging(false, 100))
result, err = app.node.Store().QueryByHash(tCtx, messageHashes, store.IncludeData(false), store.WithPeer(peerInfo.ID), store.WithPaging(false, uint64(len(messageHashes))))
cancel()
if err != nil {
queryLogger.Error("could not query storenode", zap.Error(err), zap.Int("attempt", count))