Cloud-Backup

packages/helpermodules/setdata.py

@@ -910,7 +910,8 @@ def process_system_topic(self, msg: mqtt.MQTTMessage):
             enthält Topic und Payload
         """
         try:
-            if "openWB/set/system/lastlivevaluesJson" in msg.topic:
+            if ("openWB/set/system/lastlivevaluesJson" in msg.topic or
+                    "openWB/set/system/cloud_backup" in msg.topic):
                 self._validate_value(msg, "json")
             elif ("openWB/set/system/perform_update" in msg.topic or
                     "openWB/set/system/wizard_done" in msg.topic or

packages/helpermodules/system.py

@@ -9,6 +9,7 @@
 
 from helpermodules import pub
 from control import data
+from modules.common import req
 
 log = logging.getLogger(__name__)
 
@@ -17,9 +18,9 @@ class System:
     def __init__(self):
         """
         """
-        self.data = {}
-        self.data["update_in_progress"] = False
-        self.data["perform_update"] = False
+        self.data = {"cloud_backup": {"ip_address": None, "password": None, "user": None},
+                     "update_in_progress": False,
+                     "perform_update": False}
 
     def perform_update(self):
         """ markiert ein aktives Update, triggert das Update auf dem Master und den externen WBs.
@@ -72,3 +73,29 @@ def update_ip_address(self) -> None:
         if new_ip != self.data["ip_address"] and new_ip != "":
             self.data["ip_address"] = new_ip
             pub.Pub().pub("openWB/set/system/ip_address", new_ip)
+
+    def create_backup_and_send_to_cloud(self):
+        cloud_backup = self.data["cloud_backup"]
+        if cloud_backup["ip_address"] is not None:
+            backup_filename = self.create_backup()
+            with open(self._get_parent_file()/'data'/'backup'/backup_filename, 'rb') as f:
+                data = f.read()
+            req.get_http_session().put(
+                f'{cloud_backup["ip_address"]}/public.php/webdav/{backup_filename}',
+                headers={'X-Requested-With': 'XMLHttpRequest', },
+                data=data,
+                auth=(cloud_backup["user"], '' if cloud_backup["password"] is None else cloud_backup["password"]),
+            )
+            log.debug(f'Sicherung erstellt und unter {cloud_backup["ip_address"]}/public.php/webdav/'
+                      f'{backup_filename} hochgeladen.')
+
+    def create_backup(self) -> str:
+        result = subprocess.run([str(self._get_parent_file() / "runs" / "backup.sh"), "1"], stdout=subprocess.PIPE)
+        if result.returncode == 0:
+            file_name = result.stdout.decode("utf-8").rstrip('\n')
+            return file_name
+        else:
+            raise Exception(f'Backup-Status: {result.returncode}, Meldung: {result.stdout.decode("utf-8")}')
+
+    def _get_parent_file(self) -> Path:
+        return Path(__file__).resolve().parents[2]

packages/helpermodules/update_config.py

@@ -318,6 +318,7 @@ class UpdateConfig:
                    "^openWB/LegacySmartHome/Devices/[1-2]+/TemperatureSensor[0-2]$",
 
                    "^openWB/system/boot_done$",
+                   "^openWB/system/cloud_backup$",
                    "^openWB/system/dataprotection_acknowledged$",
                    "^openWB/system/debug_level$",
                    "^openWB/system/lastlivevaluesJson$",
@@ -407,6 +408,7 @@ class UpdateConfig:
         ("openWB/optional/int_display/theme", dataclass_utils.asdict(CardsDisplayTheme())),
         ("openWB/optional/led/active", False),
         ("openWB/optional/rfid/active", False),
+        ("openWB/system/cloud_backup", {"ip_address": None, "password": None, "user": None}),
         ("openWB/system/dataprotection_acknowledged", False),
         ("openWB/system/debug_level", 30),
         ("openWB/system/device/module_update_completed", True),

packages/main.py

@@ -123,6 +123,7 @@ def handler5Min(self):
     def handler_midnight(self):
         try:
             measurement_log.save_log("monthly")
+            data.data.system_data["system"].create_backup_and_send_to_cloud()
         except KeyboardInterrupt:
             log.critical("Ausführung durch exit_after gestoppt: "+traceback.format_exc())
         except Exception: