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

fix: add more relay to fleet tests

Browse Source
This commit is contained in:
Roman 2026-04-22 19:06:00 +08:00
parent 109b02dc09
commit f305992ab3
No known key found for this signature in database
GPG Key ID: 583BDF43C238B83E
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
tests/relay/test_publish.py
View File

@ -62,6 +62,7 @@ class TestRelayPublish(StepsRelay):
except Exception as ex: except Exception as ex:
assert "couldn't find any messages" in str(ex) or "Bad Request" in str(ex) or "Internal Server Error" in str(ex) assert "couldn't find any messages" in str(ex) or "Bad Request" in str(ex) or "Internal Server Error" in str(ex)
@pytest.mark.waku_test_fleet
def test_publish_with_valid_content_topics(self): def test_publish_with_valid_content_topics(self):
failed_content_topics = [] failed_content_topics = []
for content_topic in SAMPLE_INPUTS: for content_topic in SAMPLE_INPUTS:
@ -121,6 +122,7 @@ class TestRelayPublish(StepsRelay):
except Exception as ex: except Exception as ex:
assert "Bad Request" in str(ex) or "Internal Server Error" in str(ex) assert "Bad Request" in str(ex) or "Internal Server Error" in str(ex)
@pytest.mark.waku_test_fleet
def test_publish_with_valid_timestamps(self): def test_publish_with_valid_timestamps(self):
failed_timestamps = [] failed_timestamps = []
for timestamp in SAMPLE_TIMESTAMPS: for timestamp in SAMPLE_TIMESTAMPS:
@ -147,10 +149,12 @@ class TestRelayPublish(StepsRelay):
pass pass
assert not success_timestamps, f"Invalid Timestamps that didn't failed: {success_timestamps}" assert not success_timestamps, f"Invalid Timestamps that didn't failed: {success_timestamps}"
@pytest.mark.waku_test_fleet
def test_publish_with_no_timestamp(self): def test_publish_with_no_timestamp(self):
message = {"payload": to_base64(self.test_payload), "contentTopic": self.test_content_topic} message = {"payload": to_base64(self.test_payload), "contentTopic": self.test_content_topic}
self.check_published_message_reaches_relay_peer(message) self.check_published_message_reaches_relay_peer(message)
@pytest.mark.waku_test_fleet
def test_publish_with_valid_version(self): def test_publish_with_valid_version(self):
self.check_published_message_reaches_relay_peer(self.create_message(version=10)) self.check_published_message_reaches_relay_peer(self.create_message(version=10))
@ -171,6 +175,7 @@ class TestRelayPublish(StepsRelay):
except Exception as ex: except Exception as ex:
assert "Bad Request" in str(ex) assert "Bad Request" in str(ex)
@pytest.mark.waku_test_fleet
def test_publish_with_ephemeral(self): def test_publish_with_ephemeral(self):
failed_ephemeral = [] failed_ephemeral = []
for ephemeral in [True, False]: for ephemeral in [True, False]: