logos-messaging/logos-messaging-test-query
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-test-query.git synced 2026-01-03 06:23:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

test

Browse Source
This commit is contained in:
Richard Ramos 2023-09-13 14:51:41 -04:00
parent fe5814f875
commit b83f5b0816
No known key found for this signature in database
GPG Key ID: 1CE87DB518195760
2 changed files with 20 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
main_test.go
View File

@ -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()
}

23
utils_test.go
View File

@ -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())
}