ACSBridge.py

#!/usr/bin/env python

from ACSBridgeLib.HTTPListener import HTTPListenerProcess
from ACSBridgeLib.DirWatcher import DirWatcherProcess

##  for loading configuration options
import yaml

##  for logging
import logging

##  for looping
import time

from multiprocessing import Queue

def main():
	##  load config:
	f = open( 'config.yaml' )
	config = yaml.safe_load( f )
	f.close()

	##  Set up logging
	logging.basicConfig( filename=config['LOG_FILE'],
						 level=logging.DEBUG,
						 format='%(asctime)s\t%(levelname)s: %(message)s',
						 datefmt='%Y-%m-%d %H:%M' )
	logger = logging.getLogger( 'main' )
	##  extra configuration to make some levels of logging print to the console
	handler = logging.StreamHandler()
	handler.setLevel( logging.INFO )
	##  sets the format for console output (a little less wordy)
	handler.setFormatter( logging.Formatter( '%(asctime)s %(levelname)s: %(message)s',
	 										 '%m-%d %H:%M') )
	logger.addHandler( handler )

	logger.info( "Logging set up writing to " + config['LOG_FILE'] )

	##  Set up process for HTTP listener
	#HTTPQueue = Queue()
	#HTTPProcess = HTTPListenerProcess( HTTPQueue, logger, config['PORT_IN'], config['PORT_OUT'], config['CCURE_DIR'] )
	#HTTPProcess.daemon = True
	#HTTPProcess.run()

	DirWatcherQueue = Queue()
	WatcherProcess = DirWatcherProcess( DirWatcherQueue, logger, config['CCURE_DIR'], config['CCURE_LOG_PATTERN'],
		config['SMTP_SERVER'], config['SMTP_USER'], config['SMTP_PASS'], config['MAIL_FROM'], config['MAIL_TO'] )
	#DirWatcherProcess.daemon = True
	WatcherProcess.run()

	try:
		while True:
			time.sleep(1)
	except (KeyboardInterrupt, SystemExit):
		logger.info( "Keyboard interrupt recieved. Shutting down server." )
	#	HTTPQueue.put( 1 )
		DirWatcherQueue.put( 1 )


##  run main
if __name__ == '__main__':
	main()