express

gistfile1.txt

'use strict';

/**
 * Module dependencies.
 */
var fs = require('fs'),
	http = require('http'),
	https = require('https'),
	express = require('express'),
	morgan = require('morgan'),
	bodyParser = require('body-parser'),
	session = require('express-session'),
	compress = require('compression'),
	methodOverride = require('method-override'),
	cookieParser = require('cookie-parser'),
	helmet = require('helmet'),
	passport = require('passport'),
	requestUrl = require('url'),
	mongoStore = require('connect-mongo')({
		session: session
	}),
	flash = require('connect-flash'),
	config = require('./config'),
	consolidate = require('consolidate'),
	path = require('path');

var multer  = require('multer');
var myParser = require('excel-file-parser');

var mongodb = require('mongodb');
var assert = require('assert');
var MongoClient = mongodb.MongoClient;

var url = 'mongodb://localhost/datamanager-03-test';

module.exports = function(db) {
	// Initialize express app
	var app = express();

	// Globbing model files
	config.getGlobbedFiles('./app/models/**/*.js').forEach(function(modelPath) {
		require(path.resolve(modelPath));
	});

	// Setting application local variables
	app.locals.title = config.app.title;
	app.locals.description = config.app.description;
	app.locals.keywords = config.app.keywords;
	app.locals.facebookAppId = config.facebook.clientID;
	app.locals.jsFiles = config.getJavaScriptAssets();
	app.locals.cssFiles = config.getCSSAssets();

	// Passing the request url to environment locals
	app.use(function(req, res, next) {
		res.locals.url = req.protocol + '://' + req.headers.host + req.url;
		next();
	});

	// Should be placed before express.static
	app.use(compress({
		filter: function(req, res) {
			return (/json|text|javascript|css/).test(res.getHeader('Content-Type'));
		},
		level: 9
	}));

	app.use(multer({ dest: './uploads/',
		rename: function (fieldname, filename) {
			return filename+Date.now();
		},
		onFileUploadStart: function (file) {
			console.log(file.originalname + ' is starting ...');
		},
		onFileUploadComplete: function (file) {
			console.log(file.fieldname + ' uploaded to  ' + file.path);
			var fileName = file.name;
			var done=true;
		}
	}));

    app.use(bodyParser.urlencoded({
        extended: true
    }));
    app.use(bodyParser.json());

    app.use(session({
        saveUninitialized: true,
        resave: true,
        secret: config.sessionSecret,
        store: new mongoStore({
            db: db.connection.db,
            collection: config.sessionCollection
        })
    }));

	app.get('/mongodata', function(req, res){
		console.log('Request Successful');
		console.log('_parsedUrl.query:  ' + req._parsedUrl.query);

		var url_parts = requestUrl.parse(req.url, true);
		var query = url_parts.query;

		var dataVersion = req.query.dataVersion;

		MongoClient.connect(url, function (err, db) {
			if (err) {
				console.log('Unable to connect to the mongoDB server. Error:', err);
			} else {
				console.log('Connection established to', url);

				var collection = db.collection(query.collectionName);

				if(query.dataVersion && query.subject){
					collection.find({DataVersion: query.dataVersion,
						Subject: query.subject
					}).toArray(function(err, docs) {
						//console.log(docs);
						res.json(docs);
						assert.equal(null, err);
						db.close();
					});
				}

				if(query.dataVersion){
					collection.find({DataVersion: query.dataVersion
					}).toArray(function(err, docs) {
						//console.log(docs);
						res.json(docs);
						assert.equal(null, err);
						db.close();
					});
				}

				if(query.subject){
					collection.find({Subject: query.subject
					}).toArray(function(err, docs) {
						//console.log(docs);
						res.json(docs);
						assert.equal(null, err);
						db.close();
					});
				}
			}
		});
	});

    //app.get('/user/?id=' + req.session.passport.user, function(req,res){
    //    var url_parts = requestUrl.parse(req.url, true);
    //    var query = url_parts.query;
    //    MongoClient.connect(url, function (err, db) {
    //        if (err) {
    //            console.log('Unable to connect to the mongoDB server. Error:', err);
    //        } else {
    //            console.log('Connection established to', url);
    //
    //            var collection = db.collection('users');
    //
    //            collection.find({_id: query.id},function(err, docs) {
    //                //console.log(docs);
    //                res.json(docs);
    //                assert.equal(null, err);
    //                db.close();
    //            });
    //        }
    //    });
    //});

	app.get('/opportunity_ids', function(req, res){
		console.log('opportunity_idsRequest Successful');
		console.log('_parsedUrl.query:  ' + req._parsedUrl.query);

		var url_parts = requestUrl.parse(req.url, true);
		var query = url_parts.query;

		var dataVersion = req.query.dataVersion;

        console.log('the user id is: ');

        var user = req.user;

		MongoClient.connect(url, function (err, db) {
			if (err) {
				console.log('Unable to connect to the mongoDB server. Error:', err);
			} else {

                //var collection = db.collection('users');
                //collection.find({_id: query.id},function(err, docs) {
                //    docs.forEach(function(doc){
                //        user = doc;
                //    })
                //});

                var collection = db.collection('users');
                collection.find({}).toArray(function(err, docs) {
                    docs.forEach(function(user){
                        console.log('user id:  ' + user._id.toString())
                    });
                    //res.json(docs);
                    assert.equal(null, err);
                    //db.close();
                });


				console.log('Connection established to', url);

				var collection = db.collection('DC_Facilities');

					collection.distinct('CSCOpportunityID', {OpportunityOwner: query.opportunityOwner},
					(function(err, docs) {
						//console.log(docs);
                        var idList = [];
                        docs.forEach(function(doc){
                            idList.push({name: doc});
                        });
						res.json(idList);
						assert.equal(null, err);
						db.close();
					}));
				}
		});
	});

	app.get('/environment', function(req, res){

		var env = process.env.NODE_ENV;

		console.log('OUR ENVIRONMENT IS:  ' + env);

		res.send({environment: env});
	});

	app.get('/collections_metadata', function(req, res){
		console.log('Request Successful');
		console.log('_parsedUrl.query:  ' + req._parsedUrl.query);

		MongoClient.connect(url, function (err, db) {
			if (err) {
				console.log('Unable to connect to the mongoDB server. Error:', err);
			} else {
				console.log('Connection established to', url);

				var collection = db.collection('collections_metadata');

				collection.find({collectionName: req._parsedUrl.query}).toArray(function(err, docs) {
					//console.log(docs);
					res.json(docs);
					assert.equal(null, err);
					db.close();
				});

			}
		});
	});

	app.post('/collections_metadata', function(req, res){
		console.log('Request Successful');
		console.log('_parsedUrl.query:  ' + req._parsedUrl.query);

		MongoClient.connect(url, function (err, db) {
			if (err) {
				console.log('Unable to connect to the mongoDB server. Error:', err);
			} else {
				console.log('Connection established to', url);

				//re-calculate the distinct value of 'DataFialds':

				var distinctDataFields;

				var collection = db.collection('Fixed_Asset_Register');

				collection.distinct('DataFields',function(err, docs){
					console.log('Distinct Data Fields:  ' + docs);
					distinctDataFields = docs;
					assert.equal(null, err);
				});

			}
		});
	});

	app.post('/salesforce_update', function(req, res){
		console.log('Salesforce update Request Received');
		console.log('request body:  ' + req.body);
	});



	// Showing stack errors
	app.set('showStackError', true);

	// Set swig as the template engine
	app.engine('server.view.html', consolidate[config.templateEngine]);

	// Set views path and view engine
	app.set('view engine', 'server.view.html');
	app.set('views', './app/views');

	// Environment dependent middleware
	if (process.env.NODE_ENV === 'development') {
		// Enable logger (morgan)
		app.use(morgan('dev'));

		// Disable views cache
		app.set('view cache', false);
	} else if (process.env.NODE_ENV === 'production') {
		app.locals.cache = 'memory';
	}

	// Request body parsing middleware should be above methodOverride
	app.use(bodyParser.urlencoded({
		extended: true
	}));
	app.use(bodyParser.json());
	app.use(methodOverride());

	// CookieParser should be above session
	app.use(cookieParser());

	// Express MongoDB session storage
	app.use(session({
		saveUninitialized: true,
		resave: true,
		secret: config.sessionSecret,
		store: new mongoStore({
			db: db.connection.db,
			collection: config.sessionCollection
		})
	}));

	// use passport session
	app.use(passport.initialize());
	app.use(passport.session());

	// connect flash for flash messages
	app.use(flash());

	// Use helmet to secure Express headers
	app.use(helmet.xframe());
	app.use(helmet.xssFilter());
	app.use(helmet.nosniff());
	app.use(helmet.ienoopen());
	app.disable('x-powered-by');

	// Setting the app router and static folder
	app.use(express.static(path.resolve('./public')));

	// Globbing routing files
	config.getGlobbedFiles('./app/routes/**/*.js').forEach(function(routePath) {
		require(path.resolve(routePath))(app);
	});

	// Assume 'not found' in the error msgs is a 404. this is somewhat silly, but valid, you can do whatever you like, set properties, use instanceof etc.
	app.use(function(err, req, res, next) {
		// If the error object doesn't exists
		if (!err) return next();

		// Log it
		console.error(err.stack);

		// Error page
		res.status(500).render('500', {
			error: err.stack
		});
	});

	// Assume 404 since no middleware responded
	app.use(function(req, res) {
		res.status(404).render('404', {
			url: req.originalUrl,
			error: 'Not Found'
		});
	});

	if (process.env.NODE_ENV === 'secure') {
		// Log SSL usage
		console.log('Securely using https protocol');

		// Load SSL key and certificate
		var privateKey = fs.readFileSync('./config/sslcerts/key.pem', 'utf8');
		var certificate = fs.readFileSync('./config/sslcerts/cert.pem', 'utf8');

		// Create HTTPS Server
		var httpsServer = https.createServer({
			key: privateKey,
			cert: certificate
		}, app);

		// Return HTTPS server instance
		return httpsServer;
	}

	// Return Express server instance
	return app;
};