From 31ef4403f0fa86ba3d738eb7d9977971248543d4 Mon Sep 17 00:00:00 2001 From: Richard Ramos Date: Fri, 20 Sep 2024 09:20:58 -0400 Subject: [PATCH] fix: reduce message hashes limit to 25 --- cmd/storemsgcounter/execute.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/cmd/storemsgcounter/execute.go b/cmd/storemsgcounter/execute.go index 02664b1..60117ef 100644 --- a/cmd/storemsgcounter/execute.go +++ b/cmd/storemsgcounter/execute.go @@ -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))