1
0
Fork 0
mirror of https://github.com/morpheus65535/bazarr synced 2025-03-01 17:15:44 +00:00

Basic implementation of the file watcher. Action functions still need to be define but right now it output to log.

This commit is contained in:
morpheus65535 2021-09-18 09:50:33 -04:00
parent 8e2333f510
commit c13b833d37

View file

@ -22,8 +22,17 @@ class FileWatcher:
self.ignore_patterns, self.ignore_patterns,
self.ignore_directories, self.ignore_directories,
self.case_sensitive) self.case_sensitive)
self.series_observer = Observer()
self.movies_observer = Observer() try:
self.timeout = int(settings.general.filewatcher_timeout)
except:
self.timeout = 60
logging.info(f'BAZARR file watcher is using the default interval of {self.timeout} seconds.')
else:
logging.info(f'BAZARR file watcher is using the configured interval of {self.timeout} seconds.')
self.series_observer = Observer(timeout=self.timeout)
self.movies_observer = Observer(timeout=self.timeout)
self.series_directories = None self.series_directories = None
self.movies_directories = None self.movies_directories = None
@ -63,10 +72,11 @@ class FileWatcher:
self.movies_observer.schedule(self.fs_event_handler, movies_directory, recursive=True) self.movies_observer.schedule(self.fs_event_handler, movies_directory, recursive=True)
def start(self): def start(self):
logging.info('BAZARR is starting file system watchers...')
self.config() self.config()
self.series_observer.start() self.series_observer.start()
self.movies_observer.start() self.movies_observer.start()
logging.info('BAZARR is watching file system changes.') logging.info('BAZARR is watching for file system changes.')
fileWatcher = FileWatcher() fileWatcher = FileWatcher()