webapi-eca/coffee/webapi-eca.coffee

###

WebAPI-ECA Engine
=================

>This is the main module that is used to run the whole application:
>
>     node webapi-eca [opt]
>
> See below in the optimist CLI preparation for allowed optional parameters `[opt]`.
###

# **Loads Modules:**

# - [Logging](logging.html)
logger = require './logging'

# - [Configuration](config.html)
conf = require './config'

# - [Persistence](persistence.html)
db = require './persistence'

# - [ECA Components Manager](components-manager.html)
cm = require './components-manager'

# - [Engine](engine.html)
engine = require './engine'

# - [HTTP Listener](http-listener.html)
http = require './http-listener'

# - [Encryption](encryption.html)
encryption = require './encryption'

# - [Event Poller](event-poller.html) *(will be forked into a child process)*
nameEP = 'event-poller'

# - Node.js Modules: [fs](http://nodejs.org/api/fs.html),
# [path](http://nodejs.org/api/path.html)
# and [child_process](http://nodejs.org/api/child_process.html)
fs = require 'fs'
path = require 'path'
cp = require 'child_process'

# - External Modules: [optimist](https://github.com/substack/node-optimist)
optimist = require 'optimist'

procCmds = {}

###
Let's prepare the optimist CLI optional arguments `[opt]`:
###
usage = 'This runs your webapi-based ECA engine'
opt =
#  `-h`, `--help`: Display the help
	'h':
		alias : 'help',
		describe: 'Display this'

#  `-c`, `--config-path`: Specify a path to a custom configuration file, other than "config/config.json"
	'c':
		alias : 'config-path',
		describe: 'Specify a path to a custom configuration file, other than "config/config.json"'

#  `-w`, `--http-port`: Specify a HTTP port for the web server 
	'w':
		alias : 'http-port',
		describe: 'Specify a HTTP port for the web server'

#  `-d`, `--db-port`: Specify a port for the redis DB
	'd':
		alias : 'db-port',
		describe: 'Specify a port for the redis DB'

#  `-s`, `--db-select`: Specify a database
	's':
		alias : 'db-select',
		describe: 'Specify a database identifier'

#  `-m`, `--log-mode`: Specify a log mode: [development|productive]
	'm':
		alias : 'log-mode',
		describe: 'Specify a log mode: [development|productive]'

#  `-i`, `--log-io-level`: Specify the log level for the I/O. in development expensive origin
#                           lookups are made and added to the log entries
	'i':
		alias : 'log-io-level',
		describe: 'Specify the log level for the I/O'

#  `-f`, `--log-file-level`: Specify the log level for the log file
	'f':
		alias : 'log-file-level',
		describe: 'Specify the log level for the log file'

#  `-p`, `--log-file-path`: Specify the path to the log file within the "logs" folder
	'p':
		alias : 'log-file-path',
		describe: 'Specify the path to the log file within the "logs" folder'

#  `-n`, `--nolog`: Set this true if no output shall be generated
	'n':
		alias : 'nolog',
		describe: 'Set this if no output shall be generated'

# now fetch the CLI arguments and exit if the help has been called.
argv = optimist.usage( usage ).options( opt ).argv
if argv.help
	console.log optimist.help()
	process.exit()

conf argv.c
# > Check whether the config file is ready, which is required to start the server.
if !conf.isReady()
	console.error 'FAIL: Config file not ready! Shutting down...'
	process.exit()

logconf = conf.getLogConf()

if argv.m
	logconf[ 'mode' ] = argv.m
if argv.i
	logconf[ 'io-level' ] = argv.i
if argv.f
	logconf[ 'file-level' ] = argv.f
if argv.p
	logconf[ 'file-path' ] = argv.p
if argv.n
	logconf[ 'nolog' ] = true
try
	fs.unlinkSync path.resolve __dirname, '..', 'logs', logconf[ 'file-path' ]
@log = logger.getLogger logconf
@log.info 'RS | STARTING SERVER'

###
This function is invoked right after the module is loaded and starts the server.

@private init()
###
init = =>

	args =
		logger: @log
		logconf: logconf
	# > Fetch the `http-port` argument
	args[ 'http-port' ] = parseInt argv.w || conf.getHttpPort()
	args[ 'db-port' ] = parseInt argv.d || conf.getDbPort()
	args[ 'db-select' ] = parseInt argv.s || conf.fetchProp 'db-select'

	#FIXME this has to come from user input for security reasons:
	args[ 'keygen' ] = conf.getKeygenPassphrase()
	args[ 'webhooks' ] = conf.fetchProp 'webhooks'

	encryption args
	
	@log.info 'RS | Initialzing DB'
	db args
	# > We only proceed with the initialization if the DB is ready
	db.isConnected ( err ) =>
		db.selectDatabase parseInt( args[ 'db-select' ] ) || 0
		if err
			@log.error 'RS | No DB connection, shutting down system!'
			shutDown()

		else
			# > Initialize all required modules with the args object.
			@log.info 'RS | Initialzing engine'
			#TODO We could in the future make the engine a child process as well
			engine args
			
			# Start the event poller. The module manager will emit events for it
			@log.info 'RS | Forking a child process for the event poller'
			# Grab all required log config fields
			
			cliArgs = [
				# - the log mode: [development|productive], in development expensive origin
				# lookups are made and added to the log entries
				args.logconf[ 'mode' ]
				# - the I/O log level, refer to logging.coffee for the different levels
				args.logconf[ 'io-level' ]
				# - the file log level, refer to logging.coffee for the different levels
				args.logconf[ 'file-level' ]
				# - the optional path to the log file
				args.logconf[ 'file-path' ]
				# - whether a log file shall be written at all [true|false]
				args.logconf[ 'nolog' ]
				# - The selected database
				args[ 'db-select' ]
				# - The keygen phrase, this has to be handled differently in the future!
				args[ 'keygen' ]
			]
			# Initialize the event poller with the required CLI arguments
			poller = cp.fork path.resolve( __dirname, nameEP ), cliArgs

			# after the engine and the event poller have been initialized we can
			# initialize the module manager and register event listener functions
			# from engine and event poller
			@log.info 'RS | Initialzing module manager'
			cm args
			cm.addRuleListener engine.internalEvent
			cm.addRuleListener ( evt ) -> poller.send evt

			@log.info 'RS | Initialzing http listener'
			# The request handler passes certain requests to the components manager
			args[ 'request-service' ] = cm.processRequest
			# We give the HTTP listener the ability to shutdown the whole system
			args[ 'shutdown-function' ] = shutDown
			http args
			
###
Shuts down the server.

@private shutDown()
### 
shutDown = () =>
	@log.warn 'RS | Received shut down command!'
	db?.shutDown()
	engine.shutDown()
	# We need to call process.exit() since the express server in the http-listener
	# can't be stopped gracefully. Why would you stop this system anyways!?? 
	process.exit()

###
## Process Commands

When the server is run as a child process, this function handles messages
from the parent process (e.g. the testing suite)
###
process.on 'message', ( cmd ) -> procCmds[cmd]?()

process.on 'SIGINT', shutDown
process.on 'SIGTERM', shutDown

# The die command redirects to the shutDown function.
procCmds.die = shutDown

# *Start initialization*
init()