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-02 14:03:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

test

Browse Source
This commit is contained in:
Richard Ramos 2023-10-19 09:12:10 -04:00
parent b83f5b0816
commit bbe3f94668
No known key found for this signature in database
GPG Key ID: 1CE87DB518195760
2 changed files with 6 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
main_test.go
View File

@ -24,7 +24,7 @@ func (s *StoreSuite) TestBasic() {
startTime := time.Now()
endTime := time.Now()
ctx, cancel := context.WithTimeout(context.Background(), 60*time.Second) // Test shouldnt take more than 60s
ctx, cancel := context.WithTimeout(context.Background(), 500*time.Second) // Test shouldnt take more than 60s
defer cancel()
// Connecting to nodes

13
utils_test.go
View File

@ -104,9 +104,10 @@ func queryNode(ctx context.Context, node *node.WakuNode, addr string, pubsubTopi
cursorIterations := 0
result, err := node.Store().Query(ctx, store.Query{
Topic: pubsubTopic,
StartTime: 1694630160000000000,
EndTime: 1694630700000000000,
Topic: "/waku/2/default-waku/proto",
StartTime: time.Now().Add(time.Duration(-30) * time.Minute).UnixNano(),
EndTime: time.Now().UnixNano(),
ContentTopics: []string{"/waku/1/0xee3a5ba0/rfc26"},
}, 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
@ -127,11 +128,7 @@ func queryNode(ctx context.Context, node *node.WakuNode, addr string, pubsubTopi
env := protocol.NewEnvelope(msg, time.Now().UnixNano(), relay.DefaultWakuTopic)
envHash := hexutil.Encode(env.Hash())
hash := "0x322090c57231578a86adb5ab4cbcf4d1d66458ef7f6a579e551cc71c88be5e75"
if envHash == hash {
fmt.Println("FOUND!!!!!!")
panic("BYE")
}
fmt.Println(envHash, env.Message().ContentTopic, env.Message().Timestamp)
}
cnt += len(result.GetMessages())