create target directory more efficiently

Author: falkoschindler

livesync/folder.py

@@ -4,7 +4,7 @@
 import subprocess
 import sys
 from pathlib import Path
-from typing import Callable, List, Optional, Set, Union
+from typing import Callable, List, Optional, Union
 
 import pathspec
 import watchfiles
@@ -84,7 +84,8 @@ async def watch(self) -> None:
     def sync(self) -> None:
         args = ' '.join(self._rsync_args)
         args += ''.join(f' --exclude="{e}"' for e in self._get_ignores())
-        args += f' -e "ssh -p {self.ssh_port}"'
+        args += f' -e "ssh -p {self.ssh_port}"'  # NOTE: use SSH with custom port
+        args += f' --rsync-path="mkdir -p {self.target_path} && rsync"'  # NOTE: create target folder if not exists
         run_subprocess(f'rsync {args} {self.source_path}/ {self.target}/', quiet=True)
         if isinstance(self.on_change, str):
             run_subprocess(f'ssh {self.host} -p {self.ssh_port} "cd {self.target_path}; {self.on_change}"')

livesync/sync.py

@@ -4,7 +4,6 @@
 
 from .folder import Folder
 from .mutex import Mutex
-from .run_subprocess import run_subprocess
 
 
 def get_summary(folders: Iterable[Folder]) -> str:
@@ -13,10 +12,6 @@ def get_summary(folders: Iterable[Folder]) -> str:
 
 async def run_folder_tasks(folders: Iterable[Folder], mutex_interval: float) -> None:
     try:
-        for folder in folders:
-            print(f'Creating target folder {folder.target_path}', flush=True)
-            run_subprocess(f'ssh {folder.host} -p {folder.ssh_port} "mkdir -p {folder.target_path}"')
-
         summary = get_summary(folders)
         mutexes = {folder.host: Mutex(folder.host, folder.ssh_port) for folder in folders}
         for mutex in mutexes.values():