@@ -150,22 +150,23 @@ procSuite "WakuNode - RLN relay":
150
150
nodes[2 ].subscribe (pubsubTopics[1 ], relayHandler)
151
151
await sleepAsync (1000 .millis)
152
152
153
- # publish 5+5 messages to both pubsub topics and content topics
154
- for i in 0 ..< 5 :
153
+ # publish 3 messages from node[0] (last 2 are spam, window is 10 secs)
154
+ for i in 0 ..< 3 :
155
155
var message1 = WakuMessage (payload: (" Payload_" & $ i).toBytes (), contentTopic: contentTopics[0 ])
156
156
doAssert (nodes[0 ].wakuRlnRelay.appendRLNProof (message1, epochTime ()))
157
+ await nodes[0 ].publish (pubsubTopics[0 ], message1)
157
158
159
+ # publish 3 messages from node[1] (last 2 are spam, window is 10 secs)
160
+ for i in 0 ..< 3 :
158
161
var message2 = WakuMessage (payload: (" Payload_" & $ i).toBytes (), contentTopic: contentTopics[1 ])
159
162
doAssert (nodes[1 ].wakuRlnRelay.appendRLNProof (message2, epochTime ()))
160
-
161
- await nodes[0 ].publish (pubsubTopics[0 ], message1)
162
163
await nodes[1 ].publish (pubsubTopics[1 ], message2)
163
164
164
165
# wait for gossip to propagate
165
- await sleepAsync (2000 .millis)
166
+ await sleepAsync (5000 .millis)
166
167
167
168
# check that node[2] got messages from both topics
168
- # and that rln was applied (4+4 messages were spam)
169
+ # and that rln was applied (just 1 msg is rx, rest are spam)
169
170
check:
170
171
rxMessagesTopic1 == 1
171
172
rxMessagesTopic2 == 1
0 commit comments