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

commenting max-connection and filter timeout for CI failure

Browse Source
This commit is contained in:
aya 2024-11-07 13:51:40 +02:00
parent 27a5d6fa1f
commit c3a635a722
3 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/env_vars.py
View File

@ -18,7 +18,7 @@ DEFAULT_NWAKU = "wakuorg/nwaku:latest"
DEFAULT_GOWAKU = "wakuorg/go-waku:latest"
STRESS_ENABLED = False
NODE_1 = get_env_var("NODE_1", DEFAULT_NWAKU)
NODE_2 = get_env_var("NODE_2", DEFAULT_NWAKU)
NODE_2 = get_env_var("NODE_2", DEFAULT_GOWAKU)
ADDITIONAL_NODES = get_env_var("ADDITIONAL_NODES", f"{DEFAULT_NWAKU},{DEFAULT_GOWAKU},{DEFAULT_NWAKU}")
# more nodes need to follow the NODE_X pattern
DOCKER_LOG_DIR = get_env_var("DOCKER_LOG_DIR", "./log/docker")

4
src/node/waku_node.py
View File

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

6
tests/e2e/test_e2e.py
View File

@ -181,6 +181,8 @@ class TestE2E(StepsFilter, StepsStore, StepsRelay, StepsLightPush):
@pytest.mark.timeout(60 * 7)
def test_filter_20_senders_1_receiver(self):
total_senders = 20
if "go-waku" in NODE_2:
total_senders = 10
node_list = []
logger.debug(f"Start {total_senders} nodes to publish messages ")
@ -190,7 +192,7 @@ class TestE2E(StepsFilter, StepsStore, StepsRelay, StepsLightPush):
node_list.append(WakuNode(NODE_2, f"node{i + 1}_{self.test_id}"))
delay(0.1)
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 ")
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])
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.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")
for node in node_list[:-1]: