mirror of
https://github.com/logos-messaging/logos-messaging-interop-tests.git
synced 2026-01-07 00:13:06 +00:00
address review comments
This commit is contained in:
parent
b355fe5eab
commit
d693b7b6af
@ -44,8 +44,8 @@ class RPC(BaseClient):
|
||||
set_subscriptions_response = self.rpc_call(
|
||||
"post_waku_v2_filter_v1_subscription",
|
||||
[
|
||||
subscription["contentFilters"] if "contentFilters" in subscription else [],
|
||||
subscription["pubsubTopic"] if "pubsubTopic" in subscription else None,
|
||||
subscription.get("contentFilters", []),
|
||||
subscription.get("pubsubTopic", None),
|
||||
],
|
||||
)
|
||||
return set_subscriptions_response.json()["result"]
|
||||
|
||||
@ -59,7 +59,7 @@ class StepsRelay:
|
||||
except Exception as ex:
|
||||
raise TimeoutError(f"WARM UP FAILED WITH: {ex}")
|
||||
|
||||
# this method should be used only for the tests that use the warm_up fixture
|
||||
# this method should be used only for the tests that use the relay_warm_up fixture
|
||||
# otherwise use wait_for_published_message_to_reach_relay_peer
|
||||
@allure.step
|
||||
def check_published_message_reaches_relay_peer(self, message=None, pubsub_topic=None, message_propagation_delay=0.1, sender=None, peer_list=None):
|
||||
|
||||
@ -67,7 +67,7 @@ class TestFilterSubscribeCreate(StepsFilter):
|
||||
except Exception as ex:
|
||||
assert "Bad Request" in str(ex)
|
||||
|
||||
def test_filter_update_subscription_with_invalid_pubsub_topic_format(self, subscribe_main_nodes):
|
||||
def test_filter_update_subscription_with_pubsub_topic_list_instead_of_string(self, subscribe_main_nodes):
|
||||
try:
|
||||
self.update_filter_subscription({"requestId": "1", "contentFilters": [self.test_content_topic], "pubsubTopic": [self.test_pubsub_topic]})
|
||||
raise AssertionError(f"Subscribe with invalid pubusub topics worked!!!")
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user