Changeset 40923 for branches/ipp-259_genericise_backups/tools/backups/backup.py

Timestamp:

Oct 8, 2019, 3:17:21 PM (7 years ago)

Author:

fairlamb

Message:

Fleshed out basic copy functionality; based off of atlassian backups

File:

• branches/ipp-259_genericise_backups/tools/backups/backup.py (modified) (3 diffs)

branches/ipp-259_genericise_backups/tools/backups/backup.py

@@ -4 +4 @@
 
 import backups.utils.config_parse_helper as cfg_help
-from backups.utils.errors import ConfigError
+import backups.utils.errors as errs
+import backups.utils.subprocess_utils as sub_utils
 from configparser import ConfigParser
 
@@ -24 +25 @@
         config = ConfigParser()
         if config_class_or_filepath is None:
-            raise ConfigError(config_class_or_filepath, "Neither config settings or filepath of config given")
+            raise errs.ConfigError(config_class_or_filepath, "Neither config settings or filepath of config given")
         elif isinstance(config_class_or_filepath, configparser.ConfigParser):
             config = config_class_or_filepath
@@ -119 +120 @@
         actual_hostname = socket.gethostname()
         return actual_hostname == self.default_dict['source_machine']
+
+    def run_backup(self):
+            self._run_copy()
+            self._run_tar()
+            self._run_rsync()
+            self._run_mysqldump()
+
+    def _run_copy(self):
+        if self.run_copy is None or False:
+            return 0
+
+        for bp in self.default_dict['backup_paths']:
+            if not path.exists(bp):
+                    raise errs.ValidationError(f"ValidationError: target path does not exist: {bp}")
+
+            for s in self.copy_dict['sources']:
+                if not path.exists(s):
+                    raise errs.ValidationError(f"ValidationError: target path does not exist: {s}")
+                try:
+                    args = [s, bp]
+                    if 'additional_args' in self.copy_dict.keys():
+                        print("hiya")
+                        args = args + self.copy_dict['additional_args']
+                    sub_utils.cp_wrapper(args)
+                except errs.SubprocessError as e:
+                    raise errs.SubprocessError( f"Error: copying\n"
+                                                f"    from: {s}\n"
+                                                f"    to: {bp}\n"
+                                              ) from e
+        return 0
+
+    def _run_tar(self):
+        if self.run_tar is None or False:
+            return False
+        return True
+
+    def _run_rsync(self):
+        if self.run_rsync is None or False:
+            return False
+        return True
+
+    def _run_mysqldump(self):
+        if self.run_mysqldump is None or False:
+            return False
+        return True