Adding basic scenario to trigger sync

src/node/api_clients/rest.py

@@ -50,6 +50,12 @@ def delete_relay_auto_subscriptions(self, content_topics):
     def send_relay_message(self, message, pubsub_topic):
         return self.rest_call("post", f"relay/v1/messages/{quote(pubsub_topic, safe='')}", json.dumps(message))
 
+    def send_sync_message(self, message):
+        return self.rest_call("post", "store/v1/messages", json.dumps(message))
+
+    def send_sync_request(self):
+        return self.rest_call("post", "store/v1/sync")
+
     def send_relay_auto_message(self, message):
         return self.rest_call("post", "relay/v1/auto/messages", json.dumps(message))
 

src/node/waku_node.py

@@ -335,6 +335,12 @@ def send_relay_message(self, message, pubsub_topic):
     def send_relay_auto_message(self, message):
         return self._api.send_relay_auto_message(message)
 
+    def send_sync_message(self, message):
+        return self._api.send_sync_message(message)
+
+    def request_sync(self):
+        return self.api.send_sync_request(self)
+
     def send_light_push_message(self, payload):
         return self._api.send_light_push_message(payload)
 

src/steps/store.py

@@ -137,6 +137,9 @@ def publish_message(self, via="relay", pubsub_topic=None, message=None, message_
         delay(message_propagation_delay)
         return self.message
 
+    def trigger_sync(self, sender=None):
+        sender.request_sync(self)
+
     @retry(stop=stop_after_delay(30), wait=wait_fixed(1), reraise=True)
     @allure.step
     def get_messages_from_store_with_retry(self, node):

tests/e2e/test_e2e.py

@@ -512,3 +512,10 @@ def test_store_no_peer_selected(self):
         logger.debug("Check if node3 can inquiry stored message without stor peer specified")
         store_response = self.node3.get_store_messages(pubsub_topic=self.test_pubsub_topic, page_size=5, ascending="true", store_v=store_version)
         assert len(store_response["messages"]) == 2, "Can't find stored message!!"
+
+    def test_sync_trail(self):
+        self.node1.start(store="true", relay="true", sync="true")
+        self.node2.start(store="true", relay="false", discv5_bootstrap_node=self.node1.get_enr_uri())
+        # ogger.debug(f"publish mesage via store { self.publish_message(sender=self.node1,via ="sync")} ")
+
+        # logger.debug(f"return of sync request {self.node2.request_sync(self)}")