app.js

/*
 _______   ______   ______    .___  ___.      ___      .______     _______.
|   ____| /      | /      |   |   \/   |     /   \     |   _  \   /       |
|  |__   |  ,----'|  ,----'   |  \  /  |    /  ^  \    |  |_)  | |   (----`
|   __|  |  |     |  |        |  |\/|  |   /  /_\  \   |   ___/   \   \    
|  |     |  `----.|  `----.   |  |  |  |  /  _____  \  |  |   .----)   |   
|__|      \______| \______|   |__|  |__| /__/     \__\ | _|   |_______/    

*/

// **********************************************************

"use strict";

// **********************************************************
// require 

var express = require('express');
var serveStatic = require('serve-static');
var fsr = require('file-stream-rotator');
var fs = require('fs');
var morgan = require('morgan');
var cors = require('cors');
var bodyparser = require('body-parser');
var request = require('request');
var maps = require('./controllers/maps.js');

// **********************************************************
// config

var configEnv = require('./config/env.json');

var NODE_ENV = process.env.NODE_ENV;
var NODE_PORT =  process.env.PORT || configEnv[NODE_ENV].NODE_PORT;
var CONTENT_API = process.env.CONTENT_API || configEnv[NODE_ENV].CONTENT_API;
var DEPLOY_INTERVAL = configEnv[NODE_ENV].DEPLOY_INTERVAL || 300000; //microseconds
var PROXY_PATH = configEnv[NODE_ENV].PROXY_PATH || '';
var ALLOWED_IP = configEnv[NODE_ENV].ALLOWED_IP || ["165.135.*", "127.0.0.1"];

console.log('NODE_ENV : '+ NODE_ENV );
console.log('NODE_PORT : '+ NODE_PORT );
console.log('CONTENT_API : '+ CONTENT_API );
console.log('DEPLOY_INTERVAL : '+ DEPLOY_INTERVAL );
console.log('PROXY_PATH : '+ PROXY_PATH );
console.log('ALLOWED_IP : '+ ALLOWED_IP );

// **********************************************************
// deploy
maps.deployMap(true);

// **********************************************************
// app

var app = express();

app.use(cors());

// **********************************************************
// log

var logDirectory = __dirname + '/log';

fs.existsSync(logDirectory) || fs.mkdirSync(logDirectory);

var accessLogStream = fsr.getStream({
    filename: logDirectory + '/fccmaps.log',   
    verbose: false
});
app.use(morgan('combined', {stream: accessLogStream}))

// **********************************************************
// parser

app.use(bodyparser.json());
app.use(bodyparser.urlencoded({ extended: false }));

// **********************************************************
// validate
function checkAllowed(req, res, next) {
	
	var ip = req.headers['x-forwarded-for'] || 
		req.connection.remoteAddress || 
		req.socket.remoteAddress ||
		req.connection.socket.remoteAddress;		
	//console.log('ip : ' + ip );

	//check allowed IP
	var isAllowed = false;
	if (ip != undefined) {
	
		ip = ip.replace(/ +/g, '').split(',')[0]
		for (var i = 0; i < ALLOWED_IP.length; i++) {
			var re = new RegExp('^' + ALLOWED_IP[i].replace('*', ''));
			if (ip.match(re)) {
				isAllowed = true;
			}
		 }	 
	 }
	 
	 if (isAllowed) {
		//console.log('maps.pullMap isAllowed');
		next();
	 }
	 else {		
		//console.log('checkAllowed error : IP not allowed');
		res.status(404);
		res.sendFile('404.html', { root: __dirname + '/public' });
		return;
	 }
}

// **********************************************************
// route

//api routing
app.get('/api/raw', function(req, res, next){
	maps.getRawAPI(req, res, next);
});
app.get('/api/raw.json', function(req, res, next){
	maps.getRawAPI(req, res, next);
});

app.get('/api', function(req, res, next){
	maps.getDataAPI(req, res, next);
});
app.get('/api.json', function(req, res, next){
	maps.getDataAPI(req, res, next);
});
app.get('/api/data.json', function(req, res, next){
	maps.getDataAPI(req, res, next);
});
app.get('/api/content.json', function(req, res, next){
	maps.getDataAPI(req, res, next);
});

app.get('/:mapId/api', function(req, res, next){
	maps.getDataAPI(req, res, next);	
});
app.get('/:mapId/api.json', function(req, res, next){
	maps.getDataAPI(req, res, next);	
});

app.get('/:mapId/embed/api', function(req, res, next){
	maps.getDataAPI(req, res, next);	
});
app.get('/:mapId/embed/api.json', function(req, res, next){
	maps.getDataAPI(req, res, next);	
});

// **********************************************************
//static routing

app.use('/', express.static(__dirname + '/public'));

// **********************************************************
//map thumb routing
app.use('/:mapId/thumb', function(req, res, next){
	
	//console.log('\n map thumb routing ' );

	var mapId = req.params.mapId;  //req.url.replace(/\//g, '');	
	//console.log('mapId thumb : ' + mapId);
		
	if ((req.url == '/') && (req.originalUrl.slice(-1) != '/')) {		
		//console.log('trailing slash redirect ');	
		var redUrl = PROXY_PATH + req.originalUrl + '/';
		//console.log('redUrl : ' + redUrl);
		
		res.redirect(301, redUrl);
		return;
	}	
	
	var isMap = maps.checkMapId(mapId);
	//console.log('isMap : ' + isMap);
	
	if (isMap) {
	
		var thumbURL =  maps.getThumbUrl(mapId);
		//console.log('thumbURL : ' + thumbURL);
		
		if (thumbURL) {

			//console.log('thumbURL proxy pipe ');
			req.pipe(request(thumbURL)).pipe(res);
			return;	
		}
	}
	
	next(); 	
});

// **********************************************************
//map embed routing
app.use('/:mapId/embed', function(req, res, next){
	
	//console.log('\n map embed routing ' );

	var mapId = req.params.mapId;  //req.url.replace(/\//g, '');	
	//console.log('mapId : ' + mapId);

	if ((req.url == '/') && (req.originalUrl.slice(-1) != '/')) {		
		//console.log('trailing slash redirect ');	
		var redUrl = PROXY_PATH + req.originalUrl + '/';
		//console.log('redUrl : ' + redUrl);
		
		res.redirect(301, redUrl);
		return;
	}		
	
	var isMap = maps.checkMapId(mapId);
	//console.log('isMap : ' + isMap);
	
	if (isMap) {
	
		var mapType = maps.getMapType(mapId);
		//console.log('mapType : ' + mapType);

		if ((mapType == 'proxy') || (mapType == 'redirect')) {
			//console.log('skip embed if mapType proxy or redirect ');
			next();
		}
		else if ((mapType == 'layers') || (mapType == 'iframe')) {
		
			//console.log('no app id - assume to be a map');

			var mapType = maps.getMapType(mapId);
			
			if (mapType == 'layers') {			
				//console.log('layers embed sendFile ');
				res.sendFile('map-embed.html', { root: __dirname + '/public' });
				return;			
			}
			else if (mapType == 'iframe') {
				//console.log('iframe embed pipe ');
				
				var iframeUrl = maps.getWebUrl(mapId);
				//console.log('iframeUrl : ' + iframeUrl);
				
				iframeUrl = iframeUrl.replace(/\?$/, '');
				//console.log('iframeUrl : ' + iframeUrl);
						
				if (iframeUrl.slice(-1) == '/' ){
					iframeUrl = iframeUrl.slice(0, -1);		
				}
				//console.log('iframeUrl : ' + iframeUrl);			

				//console.log('mapType redirect 302 ');
				res.redirect(302, iframeUrl);
				return;	
			}		
		}
	}

	next(); 	
});

// **********************************************************
//map routing
app.use('/:mapId', function(req, res, next){

	//console.log('\n map routing ' );

	var mapId = req.params.mapId;  //req.url.replace(/\//g, '');	
	//console.log('mapId routing : ' + mapId);
			
	if ((req.url == '/') && (req.originalUrl.slice(-1) != '/')) {		
		//console.log('trailing slash redirect ');	
		var redUrl = PROXY_PATH + req.originalUrl + '/';
		console.log('redUrl : ' + redUrl);
		
		res.redirect(301, redUrl);
		return;
	}	
	
	var isMap = maps.checkMapId(mapId);	
	
	if (isMap) {
	
		var mapType = maps.getMapType(mapId);		

		if ((mapType == 'proxy') || (mapType == 'redirect')) {
			
			var appUrl = maps.getWebUrl(mapId);
			
			appUrl = appUrl.replace(/\?$/, '');
					
			if (appUrl.slice(-1) == '/' ){
				appUrl = appUrl.slice(0, -1);		
			}
			
			var appReqUrl = appUrl + req.url;
			
			if (mapType == "proxy") {				
				req.pipe(request(appReqUrl)).pipe(res);
				return;
			}
			else if (mapType == "redirect") {				
				res.redirect(302, appReqUrl);
				return;
			}	
		}
		else if ((mapType == 'layers') || (mapType == 'iframe')) {
		
			var mapIndex = 'map-'+ mapType +'.html';
			
			var serve = serveStatic(__dirname + '/public', {'index': [mapIndex]});			
			serve(req, res, next);
			return;
			
		}
	}

	next(); 
	
});

// **********************************************************
// error

app.use(function(req, res) {

	console.log('\n app.use file not found ' );
    console.error('404 file not found'); 

    //res.status(404);
    //res.sendFile('/public/404.html');
	//res.sendFile('404.html', { root: __dirname + '/public' });
	
	var app404Url = PROXY_PATH + '/404.html#'+ req.url;
	console.log('\n app404Url : ' + app404Url );
	
	//res.redirect(404, app404Url);
	res.redirect(301, app404Url);
	
	return;
});

app.use(function(err, req, res, next) {
    
    console.log('\n app.use error: ' + err );
    console.error(err.stack); 
    
    //res.status(500);
    //res.sendFile('/public/500.html');
	//res.sendFile('500.html', { root: __dirname + '/public' });
	
	var app500Url = PROXY_PATH + '/500.html#'+ req.url;
	console.log('\n app500Url : ' + app500Url );
	
	//res.redirect(500, app500Url);
	res.redirect(301, app500Url);
	
	return;
});

process.on('uncaughtException', function (err) {
    console.log('\n uncaughtException: '+ err);
    console.error(err.stack);
});

// **********************************************************
// server

var server = app.listen(NODE_PORT, function () {

  var host = server.address().address;
  var port = server.address().port;

  console.log('\n  listening at http://%s:%s', host, port);

});

// **********************************************************
// deploy
//maps.deployMap(true);

// **********************************************************
// export
module.exports = app;