mongo.js

var MongoClient = require('mongodb').MongoClient;
var ObjectId = require('mongodb').ObjectID;
var url =
	'mongodb://chatomation:nothanks@ds125255.mlab.com:25255/heroku_9zhjv4th';
var dbName = 'heroku_9zhjv4th';
var collectionName = 'chatomation-users';
var liveHappyCollectionName = 'live-happy-users';
var monthNames = [
	'January',
	'February',
	'March',
	'April',
	'May',
	'June',
	'July',
	'August',
	'September',
	'October',
	'November',
	'December'
];
var self = this;

self.insertNewUserDocument = function(userObject, callback) {
	MongoClient.connect(
		url,
		{ useNewUrlParser: true },
		function(err, db) {
			if (err) throw err;
			var dbo = db.db(dbName);
			var collection = dbo.collection(collectionName);
			collection.insert(userObject, function(err, result) {
				if (err) throw err;
				callback(result);
				db.close();
			});
		}
	);
};
self.getEmail = function(queryObject, callback) {
	MongoClient.connect(
		url,
		{ useNewUrlParser: true },
		function(err, db) {
			if (err) throw err;
			var dbo = db.db(dbName);
			dbo
				.collection(collectionName)
				.find(queryObject)
				.toArray(function(error, docs) {
					if (error) throw error;
					//random doc
					var doc = docs[Math.floor(Math.random() * docs.length)];
					callback(doc);
					db.close();
				});
		}
	);
};
self.updateDocument = function(queryObject, updateObject, callback) {
	MongoClient.connect(
		url,
		{ useNewUrlParser: true },
		function(err, db) {
			if (err) throw err;
			var dbo = db.db(dbName);
			var collection = dbo.collection(collectionName);
			collection.updateOne({ queryObject }, { $set: updateObject }, function(
				err,
				result
			) {
				if (err) throw err;
				callback(result);
				db.close();
			});
		}
	);
};
self.liveHappyUsersCount = function(callback) {
	MongoClient.connect(
		url,
		{ useNewUrlParser: true },
		function(err, db) {
			if (err) throw err;
			var dbo = db.db(dbName);
			dbo
				.collection(liveHappyCollectionName)
				.count({}, function(error, numOfDocs) {
					if (error) throw error;
					callback(numOfDocs);
					db.close();
				});
		}
	);
};

self.liveHappyUsersCountByMonth = function(callback) {
	MongoClient.connect(
		url,
		{ useNewUrlParser: true },
		function(err, db) {
			if (err) throw err;
			var dbo = db.db(dbName);
			dbo
				.collection(liveHappyCollectionName)
				.find({}, { projection: { _id: 1 } })
				.toArray(function(error, result) {
					if (error) throw error;
					var yearObject = {},
						monthObject = {},
						monthCount = 0;
					for (var i = 0; i < result.length; i++) {
						var date = new Date(ObjectId(result[i]._id).getTimestamp());
						var previousDate = new Date(
							ObjectId(result[i == 0 ? 0 : i - 1]._id).getTimestamp()
						);
						date.getMonth() !== previousDate.getMonth()
							? (monthCount = 0)
							: monthCount++;

						var month = date.getMonth();
						monthObject[monthNames[month]] = monthCount;
						yearObject[date.getFullYear()] = monthObject;
					}
					/*result.forEach(function(doc) {
						var date = new Date(ObjectId(doc._id).getTimestamp());
						var month = date.getMonth() + 1;
						monthCount++;
						monthObject[month] = monthCount;
						yearObject[date.getFullYear()] = monthObject;
					});*/
					callback(yearObject);
					db.close();
				});
		}
	);
};