http://www.python.org/dev/peps/pep-0008/#package-and-module-names

python_apps/media-monitor/media_monitor.py

@@ -0,0 +1,112 @@
+import time
+import logging
+import logging.config
+import sys
+import os
+import signal
+import traceback
+import locale
+
+from api_clients import api_client as apc
+from std_err_override import LogWriter
+
+from multiprocessing import Process, Queue as mpQueue
+
+from threading import Thread
+
+from pyinotify import WatchManager
+
+from airtimefilemonitor.airtimenotifier import AirtimeNotifier
+from airtimefilemonitor.mediamonitorcommon import MediaMonitorCommon
+from airtimefilemonitor.airtimeprocessevent import AirtimeProcessEvent
+from airtimefilemonitor.mediaconfig import AirtimeMediaConfig
+from airtimefilemonitor.workerprocess import MediaMonitorWorkerProcess
+from airtimefilemonitor.airtimemediamonitorbootstrap import AirtimeMediaMonitorBootstrap
+
+# configure logging
+try:
+    logging.config.fileConfig("logging.cfg")
+    
+    #need to wait for Python 2.7 for this..
+    #logging.captureWarnings(True)
+    
+    logger = logging.getLogger()
+    LogWriter.override_std_err(logger)
+    
+except Exception, e:
+    print 'Error configuring logging: ', e
+    sys.exit(1)
+
+logger.info("\n\n*** Media Monitor bootup ***\n\n")
+
+
+try:
+    fs_encoding = locale.getdefaultlocale()[1].lower()
+    if fs_encoding not in ['utf-8', 'utf8']:
+        logger.error("Filesystem encoding needs to be UTF-8. Currently '%s'. Exiting..." % fs_encoding)
+        sys.exit(1)
+    else:
+        logger.debug("Filesystem encoding: '%s'" % fs_encoding)
+
+    
+    config = AirtimeMediaConfig(logger)
+    api_client = apc.api_client_factory(config.cfg)
+    api_client.register_component("media-monitor")
+    
+    logger.info("Setting up monitor")
+    response = None
+    while response is None:
+        response = api_client.setup_media_monitor()
+        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')
+    config.organize_directory = os.path.normpath(storage_directory + '/organize')
+    config.recorded_directory = os.path.normpath(storage_directory + '/recorded')
+    
+    multi_queue = mpQueue()
+    logger.info("Initializing event processor")
+except Exception, e:
+    logger.error('Exception: %s', e)
+    logger.error("traceback: %s", traceback.format_exc())
+    
+try:
+
+
+    wm = WatchManager()
+    mmc = MediaMonitorCommon(config, wm=wm)
+    pe = AirtimeProcessEvent(queue=multi_queue, airtime_config=config, wm=wm, mmc=mmc, api_client=api_client)
+
+    bootstrap = AirtimeMediaMonitorBootstrap(logger, pe, api_client, mmc, wm)
+    bootstrap.scan()
+    
+    notifier = AirtimeNotifier(wm, pe, read_freq=0, timeout=0, airtime_config=config, api_client=api_client, bootstrap=bootstrap, mmc=mmc)
+    notifier.coalesce_events()
+        
+    #create 5 worker threads
+    wp = MediaMonitorWorkerProcess()
+    for i in range(5):
+        threadName = "Thread #%d" % i
+        t = Thread(target=wp.process_file_events, name=threadName, args=(multi_queue, notifier))
+        t.start()
+        
+    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)
+        
+except KeyboardInterrupt:
+    notifier.stop()
+    logger.info("Keyboard Interrupt")
+except Exception, e:
+    logger.error('Exception: %s', e)
+    logger.error("traceback: %s", traceback.format_exc())