server.js

//  OpenShift sample Node application
var express = require('express'),
    fs = require('fs'),
    app = express(),
    eps = require('ejs'),
    morgan = require('morgan');

Object.assign = require('object-assign')

app.engine('html', require('ejs').renderFile);
app.use(morgan('combined'))

var port = process.env.PORT || process.env.OPENSHIFT_NODEJS_PORT || 8080,
    ip = process.env.IP || process.env.OPENSHIFT_NODEJS_IP || '0.0.0.0',
    mongoURL = process.env.OPENSHIFT_MONGODB_DB_URL || process.env.MONGO_URL,
    mongoURLLabel = "";

if (mongoURL == null && process.env.DATABASE_SERVICE_NAME) {
    var mongoServiceName = process.env.DATABASE_SERVICE_NAME.toUpperCase(),
        mongoHost = process.env[mongoServiceName + '_SERVICE_HOST'],
        mongoPort = process.env[mongoServiceName + '_SERVICE_PORT'],
        mongoDatabase = process.env[mongoServiceName + '_DATABASE'],
        mongoPassword = process.env[mongoServiceName + '_PASSWORD']
    mongoUser = process.env[mongoServiceName + '_USER'];

    if (mongoHost && mongoPort && mongoDatabase) {
        mongoURLLabel = mongoURL = 'mongodb://';
        if (mongoUser && mongoPassword) {
            mongoURL += mongoUser + ':' + mongoPassword + '@';
        }
        // Provide UI label that excludes user id and pw
        mongoURLLabel += mongoHost + ':' + mongoPort + '/' + mongoDatabase;
        mongoURL += mongoHost + ':' + mongoPort + '/' + mongoDatabase;

    }
}
var db = null,
    dbDetails = new Object();

var initDb = function (callback) {
    if (mongoURL == null) return;

    var mongodb = require('mongodb');
    if (mongodb == null) return;

    mongodb.connect(mongoURL, function (err, conn) {
        if (err) {
            callback(err);
            return;
        }

        db = conn;
        dbDetails.databaseName = db.databaseName;
        dbDetails.url = mongoURLLabel;
        dbDetails.type = 'MongoDB';

        console.log('Connected to MongoDB at: %s', mongoURL);
    });
};

app.get('/', function (req, res) {
    // try to initialize the db on every request if it's not already
    // initialized.
    if (!db) {
        initDb(function (err) { });
    }
    if (db) {
        var data = req.query['data'];
        var rand = req.query['rand'];
        var date = Date.now();
        var col = db.collection('counts');
        var test = "123";

        // Create a document with request IP and current time of request
        //col.insert({ id: rand, plot: data, ip: req.ip, date: date });

        //test = "'" + data + "'";
        
        // update with new data if request param found
        if (data != undefined) {
            var doc = { id: rand, plot: data, ip: req.ip, date: date };
            col.insert(doc, { w: 1 }, function (err, result) {
                col.update({ id: rand }, { $set: { plot: data } }, { w: 1 }, function (err, result) { });
            });
        }
        
        // retrieve old (or just updated) data - check remotely
        var latestDoc;
        col.find({ id: rand }).toArray(function (err, results) {
            latestDoc = results[results.length - 1];
            data = latestDoc.plot;
            rand = latestDoc.id;
            //test += "-" + latestDoc.plot;

            col.count(function (err, count) {
                //console.log(count);
                res.render('index.html', {
                    pageCountMessage: count + 8619,
                    dbInfo: dbDetails,
                    data: data,
                    test: test
                });
            });
        })
        
        /*
        col.count(function (err, count) {
            //console.log(count);
            res.render('index.html', {
                pageCountMessage: count + 8619,
                dbInfo: dbDetails,
                data: data,
                test: test
            });
        });
        */
    } else {
        res.render('index.html', { pageCountMessage: null });
    }
});

app.get('/pagecount', function (req, res) {
    // try to initialize the db on every request if it's not already
    // initialized.
    if (!db) {
        initDb(function (err) { });
    }
    if (db) {
        db.collection('counts').count(function (err, count) {
            res.send('{ pageCount: ' + count + '}');
        });
    } else {
        res.send('{ pageCount: -1 }');
    }
});

// error handling
app.use(function (err, req, res, next) {
    console.error(err.stack);
    res.status(500).send('Something bad happened!');
});

initDb(function (err) {
    console.log('Error connecting to Mongo. Message:\n' + err);
});

app.listen(port, ip);
console.log('Server running on http://%s:%s', ip, port);

module.exports = app;