logos-messaging/logos-messaging-interop-tests
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-interop-tests.git synced 2026-08-24 23:21:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'master' into dependabot/pip/requests-2.33.0

Browse Source
This commit is contained in:
AYAHASSAN287
2026-08-03 01:10:11 +03:00
committed by GitHub
parent ddf5cc201b b1ed375491
commit f671125382
5 changed files with 11 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
.github/workflows/test_common.yml
+1 -1
View File
@@ -273,7 +273,7 @@ jobs:
du -sh all-results || true
- name: Setup allure report
uses: simple-elf/allure-report-action@master
uses: simple-elf/allure-report-action@v1.15
if: always()
id: allure-report
with:
src/steps/filter.py
+1 -1
View File
@@ -18,7 +18,7 @@ logger = get_custom_logger(__name__)
class StepsFilter(StepsCommon):
test_pubsub_topic = VALID_PUBSUB_TOPICS[1]
second_pubsub_topic = VALID_PUBSUB_TOPICS[2]
another_cluster_pubsub_topic = "/waku/2/rs/2/2"
another_cluster_pubsub_topic = "/waku/2/rs/199/2"
test_content_topic = "/test/1/waku-filter/proto"
second_content_topic = "/test/2/waku-filter/proto"
test_payload = "Filter works!!"
src/test_data.py
+4 -2
View File
@@ -124,8 +124,10 @@ PUBSUB_TOPICS_STORE = [
INVALID_PUBSUB_TOPICS = ["/test/2/rs/0/1", "/waku/3/rs/0/1", "/waku/2/test/0/1", "/waku/2/rs/3/b", "/waku/2/rs/0"]
PUBSUB_TOPICS_DIFFERENT_CLUSTERS = [
"/waku/2/rs/2/0",
"/waku/2/rs/2/1",
# cluster 2 is the logos.dev default cluster with its own settings, so it is
# reserved; use the safe cluster 199 instead.
"/waku/2/rs/199/0",
"/waku/2/rs/199/1",
"/waku/2/rs/5/0",
"/waku/2/rs/5/1",
"/waku/2/rs/5/999",
tests/sharding/test_relay_static_sharding.py
+3 -3
View File
@@ -22,8 +22,8 @@ class TestRelayStaticSharding(StepsSharding):
def test_subscribe_and_publish_on_another_shard(self):
self.setup_main_relay_nodes(pubsub_topic=self.test_pubsub_topic)
self.subscribe_main_relay_nodes(pubsub_topics=["/waku/2/rs/2/1"])
self.check_published_message_reaches_relay_peer(pubsub_topic="/waku/2/rs/2/1")
self.subscribe_main_relay_nodes(pubsub_topics=["/waku/2/rs/199/1"])
self.check_published_message_reaches_relay_peer(pubsub_topic="/waku/2/rs/199/1")
try:
self.check_published_message_reaches_relay_peer(pubsub_topic=self.test_pubsub_topic)
if self.node2.is_nwaku():
@@ -36,7 +36,7 @@ class TestRelayStaticSharding(StepsSharding):
def test_cant_publish_on_not_subscribed_shard(self):
self.setup_main_relay_nodes(pubsub_topic=self.test_pubsub_topic)
self.subscribe_main_relay_nodes(pubsub_topics=[self.test_pubsub_topic])
self.check_publish_fails_on_not_subscribed_pubsub_topic("/waku/2/rs/2/1")
self.check_publish_fails_on_not_subscribed_pubsub_topic("/waku/2/rs/199/1")
def test_subscribe_via_api_to_new_pubsub_topics(self):
self.setup_main_relay_nodes(pubsub_topic=PUBSUB_TOPICS_SAME_CLUSTER[:1])
tests/sharding/test_running_nodes_static_sharding.py
+2 -1
View File
@@ -57,7 +57,8 @@ class TestRunningNodesStaticSharding(StepsSharding):
assert f"Peer NODE_2:{NODE_2} couldn't find any messages" in str(ex)
def test_start_node_with_50_pubsub_topics(self):
topics = ["/waku/2/rs/2/" + str(i) for i in range(50)]
# cluster 2 is the reserved logos.dev default cluster; use the safe cluster 199
topics = ["/waku/2/rs/199/" + str(i) for i in range(50)]
self.setup_main_relay_nodes(pubsub_topic=topics)
self.subscribe_main_relay_nodes(pubsub_topics=topics)
for pubsub_topic in topics: