Upload easy_sync.py

easy_sync.py

@@ -0,0 +1,50 @@
+import subprocess, time, threading
+
+class SyncingDirectory:
+    def __init__(self,source,destination,sync_deletions=False):
+        self.source = source
+        self.destination = destination
+        self.stop = threading.Event()
+        self.syncing_thread = threading.Thread(target=self._sync,args=(),daemon=True)
+        self.sync_deletions = sync_deletions
+
+    def _sync(self):
+        if self.sync_deletions:
+            command = ['rsync','-aP',f'{self.source}/',f'{self.destination}','--delete']
+        else: 
+            command = ['rsync','-aP',f'{self.source}/',f'{self.destination}']
+        while not self.stop.is_set():
+            subprocess.run(command)
+            time.sleep(5)
+
+    def quick_sync(self):
+        if self.sync_deletions:
+            command = ['rsync','-aP',f'{self.source}/',f'{self.destination}','--delete']
+        else: 
+            command = ['rsync','-aP',f'{self.source}/',f'{self.destination}']
+        subprocess.run(command)
+        return True
+    
+    def background_sync(self,verbose=False):
+        if self.syncing_thread.is_alive():
+            if verbose: print("Active thread detected... ",end="")
+            self.stop.set()
+            self.syncing_thread.join()
+            if verbose: print("Stopped.")
+        if self.syncing_thread._started.is_set():
+            if verbose: print("Creating a fresh new thread... ",end="")
+            self.syncing_thread = threading.Thread(target=self._sync,args=(),daemon=True)
+            if verbose: print("Done.")
+        if self.stop.is_set():
+            if verbose: print("Creating new stop event... ",end="")
+            self.stop.clear()
+            if verbose: print("Done.")
+        if verbose: print("Starting new thread...",end="")
+        self.syncing_thread.start()
+        if verbose: print("Done!")
+        return True
+
+    def print_status(self):
+        print(f"The background thread has been started: {self.syncing_thread._started.is_set()}")
+        print(f"The background thread is alive: {self.syncing_thread.is_alive()}")
+        print(f"The background thread is stopped: {self.stop.is_set()}")