30 lines
1.3 KiB
Python
30 lines
1.3 KiB
Python
from mediaconfig import AirtimeMediaConfig
|
|
import traceback
|
|
import os
|
|
|
|
class MediaMonitorWorkerProcess:
|
|
|
|
def __init__(self, config, mmc):
|
|
self.config = config
|
|
self.mmc = mmc
|
|
|
|
#this function is run in its own process, and continuously
|
|
#checks the queue for any new file events.
|
|
def process_file_events(self, queue, notifier):
|
|
while True:
|
|
try:
|
|
event = queue.get()
|
|
notifier.logger.info("received event %s", event)
|
|
if event['mode'] == AirtimeMediaConfig.MODE_CREATE:
|
|
filepath = event['filepath']
|
|
if self.mmc.test_file_playability(filepath):
|
|
notifier.update_airtime(event)
|
|
else:
|
|
notifier.logger.warn("Liquidsoap integrity check for file at %s failed. Not adding to media library.", filepath)
|
|
if self.config.storage_directory in filepath:
|
|
self.mmc.move_file(filepath, os.path.join(self.config.problem_directory, os.path.basename(filepath)))
|
|
else:
|
|
notifier.update_airtime(event)
|
|
except Exception, e:
|
|
notifier.logger.error(e)
|
|
notifier.logger.error("traceback: %s", traceback.format_exc())
|