waku-org/waku-interop-tests
1
0
Fork 0
mirror of https://github.com/waku-org/waku-interop-tests.git synced 2025-01-14 17:34:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix for 150 kb max messages adjustments (#10)

Browse Source 
* fix for 150 kb max messages adjustments

* fix reruns

* small fixes
This commit is contained in:
Florin Barbu 2024-01-05 15:36:07 +02:00 committed by GitHub
parent ea6a48a80a
commit d1e624e2e0
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
4 changed files with 10 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/steps/filter.py
View File

@ -183,7 +183,7 @@ class StepsFilter:
self.ping_filter_subscriptions(str(uuid4()), node=node) self.ping_filter_subscriptions(str(uuid4()), node=node)
raise AssertionError("Ping without any subscription worked") raise AssertionError("Ping without any subscription worked")
except Exception as ex: except Exception as ex:
assert "peer has no subscriptions" in str(ex) assert "peer has no subscription" in str(ex)
@allure.step @allure.step
def add_new_relay_subscription(self, pubsub_topics, node=None): def add_new_relay_subscription(self, pubsub_topics, node=None):

4
tests/filter/test_get_messages.py
View File

@ -119,7 +119,7 @@ class TestFilterGetMessages(StepsFilter):
f"M_{index}" f"M_{index}"
), f'Incorrect payload at index: {index}. Published {to_base64(f"M_{index}")} Received {message["payload"]}' ), f'Incorrect payload at index: {index}. Published {to_base64(f"M_{index}")} Received {message["payload"]}'
def test_filter_get_message_with_1MB_payload(self): def test_filter_get_message_with_150_kb_payload(self):
payload_length = 1024 * 1023 payload_length = 1024 * 100 # after encoding to base64 this will be close to 150KB
message = self.create_message(payload=to_base64("a" * (payload_length))) message = self.create_message(payload=to_base64("a" * (payload_length)))
self.check_published_message_reaches_filter_peer(message, message_propagation_delay=2) self.check_published_message_reaches_filter_peer(message, message_propagation_delay=2)

2
tests/filter/test_multiple_nodes.py
View File

@ -1,4 +1,5 @@
import pytest import pytest
from src.libs.common import delay
from src.libs.custom_logger import get_custom_logger from src.libs.custom_logger import get_custom_logger
from src.steps.filter import StepsFilter from src.steps.filter import StepsFilter
@ -31,6 +32,7 @@ class TestFilterMultipleNodes(StepsFilter):
self.node1.send_relay_message(relay_message1, self.test_pubsub_topic) self.node1.send_relay_message(relay_message1, self.test_pubsub_topic)
self.node2.unpause() self.node2.unpause()
self.node1.send_relay_message(relay_message2, self.test_pubsub_topic) self.node1.send_relay_message(relay_message2, self.test_pubsub_topic)
delay(0.5)
filter_messages = self.get_filter_messages(content_topic=self.test_content_topic, pubsub_topic=self.test_pubsub_topic, node=self.node2) filter_messages = self.get_filter_messages(content_topic=self.test_content_topic, pubsub_topic=self.test_pubsub_topic, node=self.node2)
assert len(filter_messages) == 2, "Both messages should've been returned" assert len(filter_messages) == 2, "Both messages should've been returned"

9
tests/relay/test_publish.py
View File

@ -43,14 +43,14 @@ 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)
def test_publish_with_payload_less_than_one_mb(self): def test_publish_with_payload_less_than_one_150_kb(self):
payload_length = 1024 * 700 # after encoding to base64 this be close to 1MB payload_length = 1024 * 100 # after encoding to base64 this will be close to 150KB
logger.debug(f"Running test with payload length of {payload_length} bytes") logger.debug(f"Running test with payload length of {payload_length} bytes")
message = self.create_message(payload=to_base64("a" * (payload_length))) message = self.create_message(payload=to_base64("a" * (payload_length)))
self.check_published_message_reaches_relay_peer(message, message_propagation_delay=2) self.check_published_message_reaches_relay_peer(message, message_propagation_delay=2)
def test_publish_with_payload_equal_or_more_than_one_mb(self): def test_publish_with_payload_equal_or_more_150_kb(self):
for payload_length in [1024 * 1024, 1024 * 1024 * 10]: for payload_length in [1024 * 200, 1024 * 1024, 1024 * 1024 * 10]:
logger.debug(f"Running test with payload length of {payload_length} bytes") logger.debug(f"Running test with payload length of {payload_length} bytes")
message = self.create_message(payload=to_base64("a" * (payload_length))) message = self.create_message(payload=to_base64("a" * (payload_length)))
try: try:
@ -226,6 +226,7 @@ class TestRelayPublish(StepsRelay):
self.node2.unpause() self.node2.unpause()
self.check_published_message_reaches_relay_peer(self.create_message(payload=to_base64("M2"))) self.check_published_message_reaches_relay_peer(self.create_message(payload=to_base64("M2")))
@pytest.mark.flaky(reruns=5)
def test_publish_after_node1_restarts(self): def test_publish_after_node1_restarts(self):
self.check_published_message_reaches_relay_peer() self.check_published_message_reaches_relay_peer()
self.node1.restart() self.node1.restart()