bugfixes (#49)

This commit is contained in:
fbarbu15 2024-07-01 13:32:14 +03:00 committed by GitHub
parent ccad2a12f6
commit c9ce9314c6
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 1 additions and 4 deletions

View File

@ -65,7 +65,6 @@ class TestFilterGetMessages(StepsFilter):
except Exception as ex: except Exception as ex:
assert "Bad Request" in str(ex) assert "Bad Request" in str(ex)
@pytest.mark.xfail("nwaku" in NODE_1, reason="Bug reported: https://github.com/waku-org/nwaku/issues/2320")
def test_filter_get_message_duplicate_message(self): def test_filter_get_message_duplicate_message(self):
message = self.create_message() message = self.create_message()
self.check_published_message_reaches_filter_peer(message) self.check_published_message_reaches_filter_peer(message)

View File

@ -22,7 +22,6 @@ class TestFilterMultipleNodes(StepsFilter):
self.check_published_message_reaches_filter_peer(peer_list=self.main_nodes) self.check_published_message_reaches_filter_peer(peer_list=self.main_nodes)
self.check_publish_without_filter_subscription(peer_list=self.optional_nodes) self.check_publish_without_filter_subscription(peer_list=self.optional_nodes)
@pytest.mark.xfail("nwaku" in NODE_1, reason="Bug reported: https://github.com/waku-org/nwaku/issues/2319")
def test_filter_get_message_while_one_peer_is_paused(self): def test_filter_get_message_while_one_peer_is_paused(self):
self.setup_optional_filter_nodes() self.setup_optional_filter_nodes()
self.wait_for_subscriptions_on_main_nodes([self.test_content_topic]) self.wait_for_subscriptions_on_main_nodes([self.test_content_topic])
@ -38,7 +37,6 @@ class TestFilterMultipleNodes(StepsFilter):
filter_messages = self.get_filter_messages(content_topic=self.test_content_topic, pubsub_topic=self.test_pubsub_topic, node=self.node2) filter_messages = self.get_filter_messages(content_topic=self.test_content_topic, pubsub_topic=self.test_pubsub_topic, node=self.node2)
assert len(filter_messages) == 2, "Both messages should've been returned" assert len(filter_messages) == 2, "Both messages should've been returned"
@pytest.mark.xfail("nwaku" in NODE_1, reason="Bug reported: https://github.com/waku-org/nwaku/issues/2319")
def test_filter_get_message_after_one_peer_was_stopped(self): def test_filter_get_message_after_one_peer_was_stopped(self):
self.setup_optional_filter_nodes() self.setup_optional_filter_nodes()
self.wait_for_subscriptions_on_main_nodes([self.test_content_topic]) self.wait_for_subscriptions_on_main_nodes([self.test_content_topic])

View File

@ -32,7 +32,7 @@ class TestFilterSubscribeCreate(StepsFilter):
self.wait_for_subscriptions_on_main_nodes([self.test_content_topic], pubsub_topic=self.another_cluster_pubsub_topic) self.wait_for_subscriptions_on_main_nodes([self.test_content_topic], pubsub_topic=self.another_cluster_pubsub_topic)
self.check_published_message_reaches_filter_peer(pubsub_topic=self.another_cluster_pubsub_topic) self.check_published_message_reaches_filter_peer(pubsub_topic=self.another_cluster_pubsub_topic)
@pytest.mark.xfail("go-waku" in NODE_2, reason="Bug reported: https://github.com/waku-org/nwaku/issues/2319") @pytest.mark.xfail("go-waku" in NODE_2, reason="Bug reported: https://github.com/waku-org/go-waku/issues/1054")
def test_filter_subscribe_to_pubsub_topics_from_multiple_clusters(self): def test_filter_subscribe_to_pubsub_topics_from_multiple_clusters(self):
pubsub_topic_list = [self.test_pubsub_topic, self.another_cluster_pubsub_topic, self.second_pubsub_topic] pubsub_topic_list = [self.test_pubsub_topic, self.another_cluster_pubsub_topic, self.second_pubsub_topic]
failed_pubsub_topics = [] failed_pubsub_topics = []