Chore: store v3 edge test cases

tests/store/test_api_flags.py

@@ -1,16 +1,49 @@
 import pytest
+from src.libs.custom_logger import get_custom_logger
 from src.libs.common import to_base64
 from src.node.waku_message import WakuMessage
 from src.steps.store import StepsStore
 from src.test_data import SAMPLE_INPUTS
 
+logger = get_custom_logger(__name__)
+
 
 @pytest.mark.usefixtures("node_setup")
 class TestApiFlags(StepsStore):
     def test_store_with_peerAddr(self):
         self.publish_message()
         self.check_published_message_is_stored(store_node=self.store_node1, peer_addr=self.multiaddr_list[0])
 
+    def test_store_with_wrongPeerAddr(self):
+        self.publish_message()
+        wrong_peer_addr = self.multiaddr_list[0][1:]
+        logger.debug(f"logger is {wrong_peer_addr}")
+        try:
+            self.check_published_message_is_stored(store_node=self.store_node1, peer_addr=wrong_peer_addr)
+            raise Exception("message restored with wrong peer address")
+        except Exception as ex:
+            logger.debug(f" response with wrong peer address is { ex.args[0]}")
+            assert ex.args[0].find("Invalid MultiAddress") != -1
+        # try to send wrong peer id
+        wrong_peer_id = self.multiaddr_list[0][:-1]
+        logger.debug(f"logger is {wrong_peer_id}")
+        try:
+            self.check_published_message_is_stored(store_node=self.store_node1, peer_addr=wrong_peer_id)
+            raise Exception("message restored with wrong peer id")
+        except Exception as ex:
+            logger.debug(f" response with wrong peer id is { ex.args[0]}")
+            assert ex.args[0].find("Failed parsing remote peer info") != -1
+
+        # send address without /tcp number
+        wrong_peer_addr = self.multiaddr_list[0].replace("/tcp", "")
+        logger.debug(f"logger is {wrong_peer_addr}")
+        try:
+            self.check_published_message_is_stored(store_node=self.store_node1, peer_addr=wrong_peer_addr)
+            raise Exception("message restored with wrong peer address")
+        except Exception as ex:
+            logger.debug(f" response with wrong peer address is { ex.args[0]}")
+            assert ex.args[0].find("Unsupported protocol") != -1
+
     def test_store_include_data(self):
         message_list = []
         for payload in SAMPLE_INPUTS:
@@ -25,3 +58,10 @@ def test_store_include_data(self):
                 assert store_response.message_pubsub_topic(index) == self.test_pubsub_topic
                 waku_message = WakuMessage([store_response.message_at(index)])
                 waku_message.assert_received_message(message_list[index])
+
+    def test_store_not_include_data(self):
+        message = self.create_message()
+        self.publish_message(message=message)
+        store_response = self.get_messages_from_store(self.store_node1, include_data="false")
+        logger.debug(f" message restored with hash only is {store_response.messages} ")
+        assert "message" not in store_response.messages