Merge branch '1.9.1' into devel
Conflicts: VERSION airtime_mvc/application/configs/constants.php airtime_mvc/application/models/Preference.php install_minimal/include/airtime-db-install.php install_minimal/include/airtime-upgrade.php python_apps/api_clients/api_client.py
This commit is contained in:
commit
9eb21cb327
27 changed files with 686 additions and 95 deletions
|
@ -43,6 +43,7 @@ try:
|
|||
time.sleep(5)
|
||||
|
||||
storage_directory = apc.encode_to(response["stor"], 'utf-8')
|
||||
watched_dirs = apc.encode_to(response["watched_dirs"], 'utf-8')
|
||||
logger.info("Storage Directory is: %s", storage_directory)
|
||||
config.storage_directory = os.path.normpath(storage_directory)
|
||||
config.imported_directory = os.path.normpath(storage_directory + '/imported')
|
||||
|
@ -77,6 +78,11 @@ try:
|
|||
wdd = notifier.watch_directory(storage_directory)
|
||||
logger.info("Added watch to %s", storage_directory)
|
||||
logger.info("wdd result %s", wdd[storage_directory])
|
||||
|
||||
for dir in watched_dirs:
|
||||
wdd = notifier.watch_directory(dir)
|
||||
logger.info("Added watch to %s", dir)
|
||||
logger.info("wdd result %s", wdd[dir])
|
||||
|
||||
notifier.loop(callback=pe.notifier_loop_callback)
|
||||
|
||||
|
|
|
@ -30,7 +30,6 @@ class AirtimeNotifier(Notifier):
|
|||
self.wm = watch_manager
|
||||
self.mask = pyinotify.ALL_EVENTS
|
||||
|
||||
|
||||
while not self.init_rabbit_mq():
|
||||
self.logger.error("Error connecting to RabbitMQ Server. Trying again in few seconds")
|
||||
time.sleep(5)
|
||||
|
|
|
@ -102,6 +102,8 @@ class AirtimeProcessEvent(ProcessEvent):
|
|||
#we don't care about moved_from events from the organize dir.
|
||||
if self.mmc.is_audio_file(event.name):
|
||||
self.cookies_IN_MOVED_FROM[event.cookie] = (event, time.time())
|
||||
else:
|
||||
self.cookies_IN_MOVED_FROM[event.cookie] = event.pathname
|
||||
|
||||
|
||||
#Some weird thing to note about this event: it seems that if a file is moved to a newly
|
||||
|
@ -141,17 +143,23 @@ class AirtimeProcessEvent(ProcessEvent):
|
|||
#When we move a directory into a watched_dir, we only get a notification that the dir was created,
|
||||
#and no additional information about files that came along with that directory.
|
||||
#need to scan the entire directory for files.
|
||||
|
||||
if event.cookie in self.cookies_IN_MOVED_FROM:
|
||||
del self.cookies_IN_MOVED_FROM[event.cookie]
|
||||
mode = self.config.MODE_MOVED
|
||||
else:
|
||||
mode = self.config.MODE_CREATE
|
||||
|
||||
files = self.mmc.scan_dir_for_new_files(event.pathname)
|
||||
if self.mmc.is_parent_directory(event.pathname, self.config.organize_directory):
|
||||
for file in files:
|
||||
self.mmc.organize_new_file(file)
|
||||
filepath = self.mmc.organize_new_file(file)
|
||||
if (filepath is not None):
|
||||
self.file_events.append({'mode': mode, 'filepath': filepath})
|
||||
else:
|
||||
for file in files:
|
||||
if self.mmc.is_parent_directory(pathname, self.config.recorded_directory):
|
||||
is_recorded = True
|
||||
else :
|
||||
is_recorded = False
|
||||
self.file_events.append({'mode': self.config.MODE_CREATE, 'filepath': file, 'is_recorded_show': is_recorded})
|
||||
self.file_events.append({'mode': mode, 'filepath': file})
|
||||
|
||||
|
||||
def process_IN_DELETE(self, event):
|
||||
self.logger.info("process_IN_DELETE: %s", event)
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue