From b83f5b0816a4575e5342d57b80be078bdd43269d Mon Sep 17 00:00:00 2001
From: Richard Ramos <info@richardramos.me>
Date: Wed, 13 Sep 2023 14:51:41 -0400
Subject: [PATCH] test

---
 main_test.go  |  4 ++--
 utils_test.go | 23 ++++++++++++++++++-----
 2 files changed, 20 insertions(+), 7 deletions(-)

diff --git a/main_test.go b/main_test.go
index 0dc6b55..a837a11 100644
--- a/main_test.go
+++ b/main_test.go
@@ -21,7 +21,6 @@ var nodeList = []string{
 
 func (s *StoreSuite) TestBasic() {
 	pubsubTopic := relay.DefaultWakuTopic
-	contentTopics := []string{"test1"}
 	startTime := time.Now()
 	endTime := time.Now()
 
@@ -49,9 +48,10 @@ func (s *StoreSuite) TestBasic() {
 		wg.Add(1)
 		func(addr string) {
 			defer wg.Done()
-			_, err := queryNode(ctx, s.node, addr, pubsubTopic, contentTopics, startTime, endTime)
+			_, err := queryNode(ctx, s.node, addr, pubsubTopic, startTime, endTime)
 			s.NoError(err)
 		}(addr)
 	}
+
 	wg.Wait()
 }
diff --git a/utils_test.go b/utils_test.go
index cdada83..fa3cbec 100644
--- a/utils_test.go
+++ b/utils_test.go
@@ -7,10 +7,13 @@ import (
 	"sync"
 	"time"
 
+	"github.com/ethereum/go-ethereum/common/hexutil"
 	"github.com/libp2p/go-libp2p/core/peer"
 	"github.com/multiformats/go-multiaddr"
 	"github.com/waku-org/go-waku/waku/v2/node"
+	"github.com/waku-org/go-waku/waku/v2/protocol"
 	"github.com/waku-org/go-waku/waku/v2/protocol/pb"
+	"github.com/waku-org/go-waku/waku/v2/protocol/relay"
 	"github.com/waku-org/go-waku/waku/v2/protocol/store"
 	"go.uber.org/zap"
 )
@@ -86,7 +89,7 @@ func sendMessagesConcurrent(ctx context.Context, node *node.WakuNode, numMsgToSe
 	return nil
 }
 
-func queryNode(ctx context.Context, node *node.WakuNode, addr string, pubsubTopic string, contentTopics []string, startTime time.Time, endTime time.Time) (int, error) {
+func queryNode(ctx context.Context, node *node.WakuNode, addr string, pubsubTopic string, startTime time.Time, endTime time.Time) (int, error) {
 	p, err := multiaddr.NewMultiaddr(addr)
 	if err != nil {
 		return -1, err
@@ -101,10 +104,9 @@ func queryNode(ctx context.Context, node *node.WakuNode, addr string, pubsubTopi
 	cursorIterations := 0
 
 	result, err := node.Store().Query(ctx, store.Query{
-		Topic:         pubsubTopic,
-		ContentTopics: contentTopics,
-		StartTime:     startTime.UnixNano(),
-		EndTime:       endTime.UnixNano(),
+		Topic:     pubsubTopic,
+		StartTime: 1694630160000000000,
+		EndTime:   1694630700000000000,
 	}, store.WithPeer(info.ID), store.WithPaging(false, 100), store.WithRequestId([]byte{1, 2, 3, 4, 5, 6, 7, 8}))
 	if err != nil {
 		return -1, err
@@ -121,6 +123,17 @@ func queryNode(ctx context.Context, node *node.WakuNode, addr string, pubsubTopi
 		}
 		cursorIterations += 1
 
+		for _, msg := range result.GetMessages() {
+			env := protocol.NewEnvelope(msg, time.Now().UnixNano(), relay.DefaultWakuTopic)
+
+			envHash := hexutil.Encode(env.Hash())
+			hash := "0x322090c57231578a86adb5ab4cbcf4d1d66458ef7f6a579e551cc71c88be5e75"
+			if envHash == hash {
+				fmt.Println("FOUND!!!!!!")
+				panic("BYE")
+			}
+		}
+
 		cnt += len(result.GetMessages())
 	}