Add the backup commands to sync the data.

tui_rsync/core/components/backup/application/__init__.py

@@ -0,0 +1,5 @@
+from .backup_command_port import BackupCommandPort
+from .backup_sync_command import BackupSyncCommand
+from .backup_sync_command_dry_run import BackupSyncCommandDryRun
+
+__all__ = ['BackupCommandPort', 'BackupSyncCommand', 'BackupSyncCommandDryRun']

tui_rsync/core/components/backup/application/backup_command_port.py

@@ -0,0 +1,7 @@
+from abc import ABC, abstractmethod
+
+
+class BackupCommandPort(ABC):
+    @abstractmethod
+    def run(self):
+        pass

tui_rsync/core/components/backup/application/backup_sync_command.py

@@ -0,0 +1,14 @@
+import shlex
+from subprocess import Popen, PIPE
+
+from . import BackupCommandPort
+
+
+class BackupSyncCommand(BackupCommandPort):
+    def __init__(self, source: str, destination: str, args: str):
+        self._args = ["rsync"] + shlex.split(args) + [source, destination]
+
+    def run(self):
+        output = Popen(self._args, stdout=PIPE)
+        response = output.communicate()
+

tui_rsync/core/components/backup/application/backup_sync_command_dry_run.py

@@ -0,0 +1,14 @@
+import shlex
+from subprocess import Popen, PIPE
+
+from . import BackupCommandPort
+
+
+class BackupSyncCommandDryRun(BackupCommandPort):
+    def __init__(self, source: str, destination: str, args: str):
+        self._args = ["rsync"] + shlex.split(args) + ['--dry-run', source, destination]
+
+    def run(self):
+        output = Popen(self._args, stdout=PIPE)
+        return output.communicate()
+