mirror of
https://github.com/logos-messaging/logos-messaging-interop-tests.git
synced 2026-01-08 00:43:07 +00:00
First test added
This commit is contained in:
parent
037f8f0390
commit
6e6c6742dd
0
tests/rendezvous/__init__.py
Normal file
0
tests/rendezvous/__init__.py
Normal file
38
tests/rendezvous/test_rendezvous_e2e.py
Normal file
38
tests/rendezvous/test_rendezvous_e2e.py
Normal file
@ -0,0 +1,38 @@
|
|||||||
|
import pytest
|
||||||
|
from src.env_vars import NODE_1, NODE_2, STRESS_ENABLED
|
||||||
|
from src.libs.common import delay
|
||||||
|
from src.libs.custom_logger import get_custom_logger
|
||||||
|
from src.node.waku_node import WakuNode
|
||||||
|
from src.steps.filter import StepsFilter
|
||||||
|
from src.steps.light_push import StepsLightPush
|
||||||
|
from src.steps.relay import StepsRelay
|
||||||
|
from src.steps.store import StepsStore
|
||||||
|
|
||||||
|
logger = get_custom_logger(__name__)
|
||||||
|
|
||||||
|
"""
|
||||||
|
|
||||||
|
This tests will cover rendezvous protocol e2e scenarios
|
||||||
|
|
||||||
|
"""
|
||||||
|
|
||||||
|
|
||||||
|
class TestE2E(StepsRelay):
|
||||||
|
@pytest.fixture(scope="function", autouse=True)
|
||||||
|
def nodes(self):
|
||||||
|
self.node1 = WakuNode(NODE_2, f"node1_{self.test_id}")
|
||||||
|
self.node2 = WakuNode(NODE_1, f"node2_{self.test_id}")
|
||||||
|
self.node3 = WakuNode(NODE_2, f"node3_{self.test_id}")
|
||||||
|
|
||||||
|
def test_basic_rendezvous_register_and_discover(self):
|
||||||
|
self.node1.start(rendezvous="true")
|
||||||
|
node1_enr = self.node1.get_enr_uri()
|
||||||
|
|
||||||
|
self.node2.start(rendezvous="true")
|
||||||
|
delay(5)
|
||||||
|
|
||||||
|
self.node2.stop()
|
||||||
|
self.node2.start(rendezvous="true")
|
||||||
|
delay(10)
|
||||||
|
discovered = self.node2.get_peers()
|
||||||
|
assert len(discovered) > 0, "No peers discovered via Rendezvous"
|
||||||
Loading…
x
Reference in New Issue
Block a user