import subprocess, time, threading

class SyncingDirectory:
    def __init__(self,source,destination,sync_deletions=False,sync_time=60):
        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
        self.sync_time = sync_time

    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(self.sync_time)

    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()}")