mirror of
https://github.com/ComradCollective/Comrad
synced 2024-11-09 13:10:44 +00:00
68 lines
1.8 KiB
Python
68 lines
1.8 KiB
Python
import time,os,subprocess
|
|
from watchdog.observers import Observer
|
|
from watchdog.events import FileSystemEventHandler
|
|
|
|
p = None
|
|
|
|
def run_command():
|
|
global p
|
|
|
|
if p!=None: p.terminate()
|
|
|
|
cmd = 'python3 main.py'
|
|
p = subprocess.Popen(cmd.split(), stdout=subprocess.PIPE)
|
|
|
|
class Watcher:
|
|
DIRECTORY_TO_WATCH = '.' #os.path.join(os.path.expanduser('~'),"/github/Komrade/")
|
|
|
|
def __init__(self):
|
|
self.observer = Observer()
|
|
|
|
def run(self):
|
|
event_handler = Handler()
|
|
self.observer.schedule(event_handler, self.DIRECTORY_TO_WATCH, recursive=True)
|
|
self.observer.start()
|
|
try:
|
|
while True:
|
|
time.sleep(5)
|
|
except:
|
|
self.observer.stop()
|
|
print("Error")
|
|
|
|
self.observer.join()
|
|
|
|
|
|
class Handler(FileSystemEventHandler):
|
|
|
|
@staticmethod
|
|
def on_any_event(event):
|
|
if '/cache/' in str(event.src_path): return None
|
|
if '__pycache__' in str(event.src_path): return None
|
|
if 'sto.dat' in str(event.src_path): return None
|
|
if '/dbm.' in str(event.src_path): return None
|
|
|
|
if event.is_directory:
|
|
return None
|
|
|
|
elif event.event_type == 'created':
|
|
# Take any action here when a file is first created.
|
|
print("Received created event - %s." % event.src_path)
|
|
|
|
elif event.event_type == 'modified':
|
|
# Taken any action here when a file is modified.
|
|
if event.src_path.endswith('.json'): return None
|
|
if '.json' in str(event.src_path): return None
|
|
|
|
if event.src_path.endswith('log.txt'): return None
|
|
print(" \n\n\n\n\nReceived modified event - %s." % event.src_path)
|
|
run_command()
|
|
#
|
|
|
|
|
|
if __name__ == '__main__':
|
|
run_command()
|
|
w = Watcher()
|
|
w.run()
|
|
|
|
|