mirror of
https://github.com/logos-messaging/logos-messaging-interop-tests.git
synced 2026-01-09 01:13:07 +00:00
6aa7716793
* test: establish basic node setup for pe * test: debug peer retrieval error with nwaku * fix: disable discovery v5 on the requester node * fix: assert node3 peer store to exact content * test: get peers for filter node * test: get peers after node1 was restarted * fix: allow tests to run only when Node2 is Go-waku * fix: revert NODE_1 to its original default
31 lines
915 B
Python
31 lines
915 B
Python
from uuid import uuid4
|
|
|
|
from src.env_vars import NODE_2
|
|
from src.node.waku_node import WakuNode
|
|
|
|
import allure
|
|
|
|
from src.steps.relay import StepsRelay
|
|
|
|
|
|
class StepsPeerExchange(StepsRelay):
|
|
responder_multiaddr = ""
|
|
|
|
@allure.step
|
|
def setup_third_node_as_peer_exchange_requester(self, **kwargs):
|
|
self.node3 = WakuNode(NODE_2, f"node3_{self.test_id}")
|
|
self.node3.start(
|
|
relay="false",
|
|
peer_exchange_node=self.responder_multiaddr,
|
|
**kwargs,
|
|
)
|
|
self.add_node_peer(self.node3, [self.multiaddr_with_id])
|
|
self.main_nodes.extend([self.node3])
|
|
|
|
@allure.step
|
|
def setup_fourth_node_as_filter(self, **kwargs):
|
|
self.node4 = WakuNode(NODE_2, f"node4_{self.test_id}")
|
|
self.node4.start(relay="false", **kwargs)
|
|
self.add_node_peer(self.node4, [self.multiaddr_with_id])
|
|
self.main_nodes.extend([self.node4])
|