mirror of
https://github.com/logos-messaging/logos-messaging-interop-tests.git
synced 2026-01-07 16:33:13 +00:00
Adding more smoke tests
This commit is contained in:
parent
f424a42aa7
commit
bc0679c4f6
@ -5,6 +5,7 @@ from src.steps.filter import StepsFilter
|
|||||||
|
|
||||||
@pytest.mark.usefixtures("setup_main_relay_node", "setup_main_filter_node")
|
@pytest.mark.usefixtures("setup_main_relay_node", "setup_main_filter_node")
|
||||||
class TestFilterPing(StepsFilter):
|
class TestFilterPing(StepsFilter):
|
||||||
|
@pytest.mark.smoke
|
||||||
def test_filter_ping_on_subscribed_peer(self, subscribe_main_nodes):
|
def test_filter_ping_on_subscribed_peer(self, subscribe_main_nodes):
|
||||||
self.ping_filter_subscriptions(str(uuid4()))
|
self.ping_filter_subscriptions(str(uuid4()))
|
||||||
|
|
||||||
|
|||||||
@ -18,6 +18,7 @@ logger = get_custom_logger(__name__)
|
|||||||
class TestRelayRLN(StepsRLN, StepsRelay):
|
class TestRelayRLN(StepsRLN, StepsRelay):
|
||||||
SAMPLE_INPUTS_RLN = SAMPLE_INPUTS + SAMPLE_INPUTS + SAMPLE_INPUTS
|
SAMPLE_INPUTS_RLN = SAMPLE_INPUTS + SAMPLE_INPUTS + SAMPLE_INPUTS
|
||||||
|
|
||||||
|
@pytest.mark.smoke
|
||||||
def test_valid_payloads_lightpush_at_spam_rate(self, pytestconfig):
|
def test_valid_payloads_lightpush_at_spam_rate(self, pytestconfig):
|
||||||
message_limit = 1
|
message_limit = 1
|
||||||
epoch_sec = 1
|
epoch_sec = 1
|
||||||
@ -58,6 +59,7 @@ class TestRelayRLN(StepsRLN, StepsRelay):
|
|||||||
if i == message_limit - 1:
|
if i == message_limit - 1:
|
||||||
break
|
break
|
||||||
|
|
||||||
|
@pytest.mark.smoke
|
||||||
def test_valid_payloads_at_spam_rate(self, pytestconfig):
|
def test_valid_payloads_at_spam_rate(self, pytestconfig):
|
||||||
message_limit = 20
|
message_limit = 20
|
||||||
epoch_sec = 600
|
epoch_sec = 600
|
||||||
|
|||||||
@ -59,6 +59,7 @@ class TestRunningNodes(StepsStore):
|
|||||||
except Exception as ex:
|
except Exception as ex:
|
||||||
assert "failed to negotiate protocol: protocols not supported" in str(ex) or "PEER_DIAL_FAILURE" in str(ex)
|
assert "failed to negotiate protocol: protocols not supported" in str(ex) or "PEER_DIAL_FAILURE" in str(ex)
|
||||||
|
|
||||||
|
@pytest.mark.smoke
|
||||||
def test_store_lightpushed_message(self):
|
def test_store_lightpushed_message(self):
|
||||||
self.setup_first_publishing_node(store="true", relay="true", lightpush="true")
|
self.setup_first_publishing_node(store="true", relay="true", lightpush="true")
|
||||||
self.setup_second_publishing_node(store="false", relay="true")
|
self.setup_second_publishing_node(store="false", relay="true")
|
||||||
@ -67,6 +68,7 @@ class TestRunningNodes(StepsStore):
|
|||||||
self.publish_message(via="lightpush", sender=self.store_node1)
|
self.publish_message(via="lightpush", sender=self.store_node1)
|
||||||
self.check_published_message_is_stored(page_size=5, ascending="true")
|
self.check_published_message_is_stored(page_size=5, ascending="true")
|
||||||
|
|
||||||
|
@pytest.mark.smoke
|
||||||
def test_store_with_filter(self):
|
def test_store_with_filter(self):
|
||||||
self.setup_first_publishing_node(store="true", relay="true", filter="true")
|
self.setup_first_publishing_node(store="true", relay="true", filter="true")
|
||||||
self.setup_first_store_node(store="false", relay="false", filter="true")
|
self.setup_first_store_node(store="false", relay="false", filter="true")
|
||||||
|
|||||||
@ -68,6 +68,7 @@ class TestTopics(StepsStore):
|
|||||||
)
|
)
|
||||||
assert len(store_response["messages"]) == 0, "Message count mismatch"
|
assert len(store_response["messages"]) == 0, "Message count mismatch"
|
||||||
|
|
||||||
|
@pytest.mark.smoke
|
||||||
def test_store_with_both_pubsub_topic_and_content_topic(self):
|
def test_store_with_both_pubsub_topic_and_content_topic(self):
|
||||||
for node in self.store_nodes:
|
for node in self.store_nodes:
|
||||||
for index, content_topic in enumerate(CONTENT_TOPICS_DIFFERENT_SHARDS):
|
for index, content_topic in enumerate(CONTENT_TOPICS_DIFFERENT_SHARDS):
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user