| 46 | |
| 47 | |
| 48 | class FileMonitor: |
| 49 | def __init__(self): |
| 50 | self.observer = Observer() |
| 51 | self.log_filename = None |
| 52 | self.log_filename_dump = None |
| 53 | self.stop_execution = False |
| 54 | self.DIRECTORY_TO_WATCH = None |
| 55 | self.EXCLUDES = [] |
| 56 | self.module_name = None |
| 57 | |
| 58 | def stop(self): |
| 59 | self.self_execution = True |
| 60 | self.observer.stop() |
| 61 | |
| 62 | def run(self): |
| 63 | event_handler = ContainerFilesHandler() |
| 64 | event_handler.log_filename = self.log_filename |
| 65 | event_handler.EXCLUDES = self.EXCLUDES |
| 66 | event_handler.module_name = self.module_name |
| 67 | |
| 68 | # set 777 permission and allow container read/write/execute |
| 69 | oschmod.set_mode(self.DIRECTORY_TO_WATCH, '777') |
| 70 | |
| 71 | self.observer.schedule(event_handler, self.DIRECTORY_TO_WATCH, recursive=True) |
| 72 | self.observer.start() |
| 73 | while not self.stop_execution: |
| 74 | try: |
| 75 | time.sleep(0.1) |
| 76 | except Exception: |
| 77 | pass |