some improvements

Author: cekk

src/redturtle/rsync/adapters/adapter.py

@@ -179,6 +179,10 @@ def set_args(self, parser):
         """
         return
 
+    def setup_environment(self):
+        """ """
+        return
+
     def get_data(self):
         """ """
         try:
@@ -212,6 +216,13 @@ def find_item_from_row(self, row):
             self.log_info(msg=msg, type="error")
             return None
 
+    def create_or_update_item(self, row):
+        item = self.find_item_from_row(row=row)
+        if not item:
+            self.create_item(row=row)
+        else:
+            self.update_item(item=item, row=row)
+
     def create_item(self, row):
         """
         Create the item.
@@ -223,8 +234,8 @@ def create_item(self, row):
             self.log_info(msg=msg, type="error")
             return
         if not res:
-            msg = f"[Error] item {row} not created."
-            self.log_info(msg=msg, type="error")
+            msg = f"[SKIPPED] item {row} not created."
+            self.log_info(msg=msg)
             return
 
         # adapter could create a list of items (maybe also children or related items)

src/redturtle/rsync/scripts/rsync.py

@@ -68,6 +68,7 @@ def rsync(self):
         """
         start = datetime.now()
         logger.info(f"[{start}] - START RSYNC")
+        self.adapter.setup_environment()
         data = self.adapter.get_data()
         if data:
             n_items = len(data)
@@ -80,11 +81,7 @@ def rsync(self):
                 if i % 100 == 0:
                     logger.info(f"Progress: {i}/{n_items}")
 
-                item = self.adapter.find_item_from_row(row=row)
-                if not item:
-                    self.adapter.create_item(row=row)
-                else:
-                    self.adapter.update_item(item=item, row=row)
+                self.adapter.create_or_update_item(row=row)
 
         self.adapter.delete_items(data)