app.js

var express = require('express');
var path = require('path');
var favicon = require('serve-favicon');
var logger = require('morgan');
var cookieParser = require('cookie-parser');
var bodyParser = require('body-parser');
var request = require('request');

var routes = require('./routes/index');

var app = express();
var server = require('http').Server(app);
var io = require('socket.io')(server);

var CronJob = require('cron').CronJob;

var requests = require('./requests.json');

var googleapis = require('googleapis'),
	JWT = googleapis.auth.JWT,
	analytics = googleapis.analytics('v3');

var SERVICE_ACCOUNT_EMAIL = '211839318900-57ulskbmk7nkq9bccf8cmi1flkuo8232@developer.gserviceaccount.com';
var SERVICE_ACCOUNT_KEY_FILE = 'key.pem';

var authClient = new JWT(
	SERVICE_ACCOUNT_EMAIL,
	SERVICE_ACCOUNT_KEY_FILE,
	null,
	['https://www.googleapis.com/auth/analytics.readonly']
);

server.listen(3000);

app.engine('.html', require('ejs').__express);
// view engine setup
app.set('views', path.join(__dirname, 'views'));
app.set('view engine', 'html');

// uncomment after placing your favicon in /public
//app.use(favicon(path.join(__dirname, 'public', 'favicon.ico')));
app.use(logger('dev'));
app.use(bodyParser.json());
app.use(bodyParser.urlencoded({ extended: false }));
app.use(cookieParser());
app.use(express.static(path.join(__dirname, 'public')));

app.use('/', routes);
app.use('/7days', routes);
app.use('/30days', routes);
app.use('/1year', routes);
app.use('/custom', routes);

// catch 404 and forward to error handler
app.use(function(req, res, next) {
  var err = new Error('Not Found');
  err.status = 404;
  next(err);
});

// error handlers

// development error handler
// will print stacktrace
if (app.get('env') === 'development') {
  app.use(function(err, req, res, next) {
    res.status(err.status || 500);
    res.render('error', {
      message: err.message,
      error: err
    });
  });
}

// production error handler
// no stacktraces leaked to user
app.use(function(err, req, res, next) {
  res.status(err.status || 500);
  res.render('error', {
    message: err.message,
    error: {}
  });
});

//real time data
var realtime = [];
var sources = [];
var pages = [];
var searches = [];

setInterval(function(){
  authClient.authorize(function(err, tokens) {
      if (err) {
        console.log(err);
        return;
      }
      var d = new Date();
      //bad fix for node-cron issue
      if (realtime.length == 0 ||
          Math.round(d.getTime()/1000) - realtime[realtime.length-1].time > 7) {
				sources = [];
				pages = [];
				searches = [];
        analytics.data.realtime.get({
          auth: authClient,
          'ids': requests['viewid'],
          'metrics': 'rt:activeUsers',
          'dimensions': 'rt:keyword, rt:source, rt:pageTitle, rt:pagePath',
          'sort': '-rt:activeUsers'
        }, function(err, result) {
          if (err) {
            console.log(err);
            return;
          }
          if (realtime.length >= 360) {
            realtime.shift();
            realtime.forEach(function(r, i) {
              r.x = i/360;
            })
	          realtime.push({x: realtime.length/360,
	                         y: +result["totalsForAllResults"]["rt:activeUsers"],
	                         time: Math.round(d.getTime()/1000)});
					} else {
						var rlength = 360-realtime.length;
						realtime.forEach(function(r, i) {
              r.x = (rlength+i)/360;
            })
						realtime.push({x: 1,
	                         y: +result["totalsForAllResults"]["rt:activeUsers"],
	                         time: Math.round(d.getTime()/1000)});
					}
          io.sockets.emit("realtime", realtime);

          //stats
          var pagesBool = true;
					for (var i = 0; i < result["rows"].length; i++) {
						for (var j = 0; j < pages.length; j++) {
							if (pages[j].title === result["rows"][i][2]) {
								pages[j].views += +result["rows"][i][4];
								pagesBool = false;
							}
						}
						if (pagesBool) {
							pages.push({title: result["rows"][i][2],
													path: result["rows"][i][3],
													views: +result["rows"][i][4]});
						}
						pagesBool = true;
					}
					pages.sort(function(a, b){
					 	return b.views-a.views;
				 	});

					var searchesBool = true;
					for (var i = 0; i < result["rows"].length; i++) {
						for (var j = 0; j < searches.length; j++) {
							if (searches[j].word === result["rows"][i][0]) {
								searches[j].views += +result["rows"][i][4];
								searchesBool = false;
							}
						}
						if (searchesBool) {
							searches.push({word: result["rows"][i][0],
													views: +result["rows"][i][4]});
						}
						searchesBool = true;
					}
					searches.sort(function(a, b){
					 	return b.views-a.views;
				 	});

					var sourcesBool = true;
					for (var i = 0; i < result["rows"].length; i++) {
						for (var j = 0; j < sources.length; j++) {
							if (sources[j].source === result["rows"][i][1]) {
								sources[j].views += +result["rows"][i][4];
								sourcesBool = false;
							}
						}
						if (sourcesBool) {
							sources.push({source: result["rows"][i][1],
													views: +result["rows"][i][4]});
						}
						sourcesBool = true;
					}
					sources.sort(function(a, b){
						return b.views-a.views;
					});
          io.sockets.emit("realtimeStats", {pageStats: pages,
                                            searchStats: searches,
																						sourceStats: sources});
        });
      }
    });
  }, 10000);

var customLimit = 100;
var defaultData = {};

io.on('connection', function (socket) {
  socket.on('initialRealtime', function(message) {
    io.sockets.emit("realtime", realtime);
		io.sockets.emit("realtimeStats", {pageStats: pages,
																			searchStats: searches,
																			sourceStats: sources});
  })
	
	io.sockets.emit("default", defaultData);

  socket.on('custom', function (message) {
    if (message.initial) {
      socket.emit("customresponse", {result: false, error: false, limit: customLimit})
    }
    else if (customLimit > 0) {
      customLimit--;
      authClient.authorize(function(err, tokens) {
        	if (err) {
        		console.log(err);
        		return;
        	}
        	analytics.data.ga.get({
        		auth: authClient,
        		'ids': requests['viewid'],
        		'start-date': message['startdate'],
        		'end-date': message['enddate'],
        		'metrics': message['metrics'],
            'dimensions': message['dimensions']
        	}, function(err, result) {
            if (err) {
              console.log(err.toString());
              socket.emit("customresponse", {result: false, limit: customLimit, error: err.toString()});
              return;
            }
            socket.emit("customresponse", {result: result, limit: customLimit, error: false});
        	});
      });
    }
  })
});
for (var r in requests) {
	if (requests.hasOwnProperty(r) && r != 'viewid') {
		makeRequest(r, requests[r]);
	}
}

var job = new CronJob('00 01 00 * * *', function(){
		// Runs every day
		// at 12:01:00 AM.
		//set custom limit to 100
		customLimit = 100;

		for (var r in requests) {
			if (requests.hasOwnProperty(r) && r != 'viewid') {
				makeRequest(r, requests[r]);
			}
		}
	},
	null,
	true /* Start the job right now */,
	"America/Los_Angeles" /* Time zone of this job. */
);

function makeRequest(emitName, queryurl) {
	var result;
	request(queryurl, function (error, response, body) {
		if (!error && response.statusCode == 200) {
			result = JSON.parse(body);
			defaultData[emitName] = result["rows"];
		} else {
			defaultData[emitName] = "error";
		}
	})
}

module.exports = app;