authservice_app.js

/*******************************************************************************
* Copyright (c) 2015 IBM Corp.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
*    http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*******************************************************************************/

var fs = require('fs');
var settings = JSON.parse(fs.readFileSync('settings.json', 'utf8'));
var log4js = require('log4js');
var logger = log4js.getLogger('authservice_app');
logger.setLevel(settings.loggerLevel);

var port = (process.env.VMC_APP_PORT || process.env.VCAP_APP_PORT || settings.authservice_port);
var host = (process.env.VCAP_APP_HOST || 'localhost');

logger.info("host:port=="+host+":"+port);

var dbtype = process.env.dbtype || "mongo";

//Calculate the backend datastore type if run inside BLuemix or cloud foundry
if(process.env.VCAP_SERVICES){
	var env = JSON.parse(process.env.VCAP_SERVICES);
   	logger.info("env: %j",env);
	var serviceKey = Object.keys(env)[0];
	if (serviceKey && serviceKey.indexOf('cloudant')>-1)
		dbtype="cloudant";
	else if (serviceKey && serviceKey.indexOf('redis')>-1)
		dbtype="redis";
}
logger.info("db type=="+dbtype);

var routes = new require('./authservice/routes/index.js')(dbtype,settings); 

// call the packages we need
var express    = require('express'); 		
var app        = express(); 				
var morgan         = require('morgan');

if (settings.useDevLogger)
	app.use(morgan('dev'));                     		// log every request to the console

var router = express.Router(); 		

router.post('/byuserid/:user', createToken);
router.get('/:tokenid', validateToken);
router.get('/status', checkStatus);
router.delete('/:tokenid', invalidateToken);

// REGISTER OUR ROUTES so that all of routes will have prefix 
app.use(settings.authContextRoot+'/authtoken', router);

var initialized = false;
var serverStarted = false;

initDB();

function initDB(){
    if (initialized ) return;
	routes.initializeDatabaseConnections(function(error) {
			if (error) {
				logger.error('Error connecting to database - exiting process: '+ error);
				// Do not stop the process for debug in container service
				//process.exit(1); 
			}else
			{
				initialized =true;
				logger.info("Initialized database connections");
			}
			startServer();
	});
}


function startServer() {
	if (serverStarted ) return;
	serverStarted = true;
	app.listen(port);
	console.log('Application started port ' + port);
}

function checkStatus(req, res){
	res.sendStatus(200);
}

function createToken(req, res){
	logger.debug('create token by user ' + req.params.user);
	if (!initialized)
    {
		logger.info("please wait for db connection initialized then trigger again.");
		initDB();
		res.send(403);
	}else
	{
		routes.createSessionInDB(req.params.user, function(error, cs){
		if (error){
		 	res.status(404).send(error);
		}
		else{
			res.send(JSON.stringify(cs));
		}
	    })
	}
}

function validateToken(req, res){
	logger.debug('validate token ' + req.params.tokenid);
	if (!initialized)
    {
		logger.info("please wait for db connection initialized then trigger again.");
		initDB();
		res.send(403);
	}else
	{
		routes.validateSessionInDB(req.params.tokenid, function(error, cs){
	     if (error){
		 	res.status(404).send(error);
		}
		else{
			 res.send(JSON.stringify(cs));
		}
	    })
	}
}

function invalidateToken(req, res){
	logger.debug('invalidate token ' + req.params.tokenid);
	if (!initialized)
    {
		logger.info("please wait for db connection initialized then trigger again.");
		initDB();
		res.send(403);
	}else
	{
		routes.invalidateSessionInDB(req.params.tokenid, function(error){
		if (error){
		 	res.status(404).send(error);
		}
		else res.sendStatus(200);
	    })
	}
}