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

fix pring typo

Browse Source
This commit is contained in:
fbarbu15 2023-12-15 16:44:16 +02:00
parent 4074a5e783
commit 8950275c9e
No known key found for this signature in database
GPG Key ID: D75221C8DEA22501
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/node/waku_node.py
View File

@ -160,7 +160,7 @@ class WakuNode:
else:
return self._api.delete_all_filter_subscriptions(request_id)
def pring_filter_subscriptions(self, request_id):
def ping_filter_subscriptions(self, request_id):
if PROTOCOL == "RPC":
pytest.skip("This method doesn't exist for RPC protocol")
else:

8
src/steps/filter.py
View File

@ -36,7 +36,7 @@ class StepsFilter:
def setup_main_filter_node(self, request):
logger.debug(f"Running fixture setup: {inspect.currentframe().f_code.co_name}")
self.node2 = WakuNode(NODE_2, f"node2_{request.cls.test_id}")
self.node2.start(filter="true", discv5_bootstrap_node=self.enr_uri, filternode=self.multiaddr_with_id)
self.node2.start(relay="false", filter="true", discv5_bootstrap_node=self.enr_uri, filternode=self.multiaddr_with_id)
self.main_nodes = [self.node2]
self.optional_nodes = []
@ -53,8 +53,8 @@ class StepsFilter:
else:
pytest.skip("ADDITIONAL_NODES is empty, cannot run test")
for index, node in enumerate(nodes):
node = WakuNode(node, f"node{index}_{request.cls.test_id}")
node.start(filter="true", discv5_bootstrap_node=self.enr_uri, filternode=self.multiaddr_with_id)
node = WakuNode(node, f"additional_node{index}_{request.cls.test_id}")
node.start(relay="false", filter="true", discv5_bootstrap_node=self.enr_uri, filternode=self.multiaddr_with_id)
self.optional_nodes.append(node)
@pytest.fixture(scope="function")
@ -144,7 +144,7 @@ class StepsFilter:
def ping_filter_subscriptions(self, request_id, node=None):
if node is None:
node = self.node2
ping_sub_response = node.pring_filter_subscriptions(request_id)
ping_sub_response = node.ping_filter_subscriptions(request_id)
assert ping_sub_response["requestId"] == request_id
assert ping_sub_response["statusDesc"] in ["OK", ""] # until https://github.com/waku-org/nwaku/issues/2286 is fixed