logos-messaging/logos-messaging-interop-tests
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-interop-tests.git synced 2026-01-05 23:43:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

Increase delay when NODE2= go-waku

Browse Source
This commit is contained in:
aya 2024-11-07 13:34:13 +02:00
parent ccc6721926
commit 2eafc050ed
2 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/node/waku_node.py
View File

@ -117,8 +117,8 @@ class WakuNode:
"rln-creds-id": None, "rln-creds-id": None,
"rln-creds-source": None, "rln-creds-source": None,
"nodekey": self.generate_random_nodekey(), "nodekey": self.generate_random_nodekey(),
"max-connections": "1000", # "max-connections": "1000",
"filter-subscription-timeout": "600", # "filter-subscription-timeout": "600",
} }
if self.is_gowaku(): if self.is_gowaku():

10
tests/e2e/test_e2e.py
View File

@ -181,16 +181,18 @@ class TestE2E(StepsFilter, StepsStore, StepsRelay, StepsLightPush):
@pytest.mark.timeout(60 * 7) @pytest.mark.timeout(60 * 7)
def test_filter_20_senders_1_receiver(self): def test_filter_20_senders_1_receiver(self):
total_senders = 20 total_senders = 20
if "go-waku" in NODE_2:
total_senders = 10
node_list = [] node_list = []
logger.debug(f"Start {total_senders} nodes to publish messages ") logger.debug(f"Start {total_senders} nodes to publish messages ")
self.node1.start(relay="true") self.node1.start(relay="true")
node_list.append(self.node1) node_list.append(self.node1)
for i in range(total_senders - 1): for i in range(total_senders - 1):
node_list.append(WakuNode(NODE_2, f"node{i + 1}_{self.test_id}")) node_list.append(WakuNode(NODE_2, f"nodes{i + 1}_{self.test_id}"))
delay(0.1) delay(1)
node_list[i + 1].start(relay="true", discv5_bootstrap_node=node_list[i].get_enr_uri()) node_list[i + 1].start(relay="true", discv5_bootstrap_node=node_list[i].get_enr_uri())
delay(2) delay(3)
logger.debug(f"Start filter node and subscribed filter node ") logger.debug(f"Start filter node and subscribed filter node ")
self.node21 = WakuNode(NODE_1, f"node21_{self.test_id}") self.node21 = WakuNode(NODE_1, f"node21_{self.test_id}")
@ -207,7 +209,7 @@ class TestE2E(StepsFilter, StepsStore, StepsRelay, StepsLightPush):
node.set_relay_subscriptions([self.test_pubsub_topic]) node.set_relay_subscriptions([self.test_pubsub_topic])
logger.debug(f"Node22 make filter request to pubsubtopic {self.test_pubsub_topic} and content topic {self.test_content_topic}") logger.debug(f"Node22 make filter request to pubsubtopic {self.test_pubsub_topic} and content topic {self.test_content_topic}")
self.node22.set_filter_subscriptions({"requestId": "1", "contentFilters": [self.test_content_topic], "pubsubTopic": self.test_pubsub_topic}) self.node22.set_filter_subscriptions({"requestId": "1", "contentFilters": [self.test_content_topic], "pubsubTopic": self.test_pubsub_topic})
self.wait_for_autoconnection(node_list, hard_wait=50) self.wait_for_autoconnection(node_list, hard_wait=80)
logger.debug(f"{total_senders} Nodes publish {total_senders} messages") logger.debug(f"{total_senders} Nodes publish {total_senders} messages")
for node in node_list[:-1]: for node in node_list[:-1]: