NodeBB/src/controllers/admin/info.js

'use strict';

var async = require('async');
var os = require('os');
var winston = require('winston');
var nconf = require('nconf');
var exec = require('child_process').exec;

var pubsub = require('../../pubsub');
var rooms = require('../../socket.io/admin/rooms');

var infoController = module.exports;

var info = {};

infoController.get = function (req, res) {
	info = {};
	pubsub.publish('sync:node:info:start');
	var timeoutMS = 1000;
	setTimeout(function () {
		var data = [];
		Object.keys(info).forEach(function (key) {
			data.push(info[key]);
		});
		data.sort(function (a, b) {
			if (a.id < b.id) {
				return -1;
			}
			if (a.id > b.id) {
				return 1;
			}
			return 0;
		});
		res.render('admin/development/info', {
			info: data,
			infoJSON: JSON.stringify(data, null, 4),
			host: os.hostname(),
			port: nconf.get('port'),
			nodeCount: data.length,
			timeout: timeoutMS,
		});
	}, timeoutMS);
};

pubsub.on('sync:node:info:start', function () {
	getNodeInfo(function (err, data) {
		if (err) {
			return winston.error(err);
		}
		data.id = os.hostname() + ':' + nconf.get('port');
		pubsub.publish('sync:node:info:end', { data: data, id: data.id });
	});
});

pubsub.on('sync:node:info:end', function (data) {
	info[data.id] = data.data;
});

function getNodeInfo(callback) {
	var data = {
		process: {
			port: nconf.get('port'),
			pid: process.pid,
			title: process.title,
			version: process.version,
			memoryUsage: process.memoryUsage(),
			uptime: process.uptime(),
			cpuUsage: process.cpuUsage(),
		},
		os: {
			hostname: os.hostname(),
			type: os.type(),
			platform: os.platform(),
			arch: os.arch(),
			release: os.release(),
			load: os.loadavg().map(function (load) { return load.toFixed(2); }).join(', '),
		},
	};
	data.process.cpuUsage.user /= 1000000;
	data.process.cpuUsage.user = data.process.cpuUsage.user.toFixed(2);
	data.process.cpuUsage.system /= 1000000;
	data.process.cpuUsage.system = data.process.cpuUsage.system.toFixed(2);
	data.process.memoryUsage.humanReadable = (data.process.memoryUsage.rss / (1024 * 1024)).toFixed(2);

	async.waterfall([
		function (next) {
			async.parallel({
				stats: function (next) {
					rooms.getLocalStats(next);
				},
				gitInfo: function (next) {
					getGitInfo(next);
				},
			}, next);
		},
		function (results, next) {
			data.git = results.gitInfo;
			data.stats = results.stats;
			next(null, data);
		},
	], callback);
}

function getGitInfo(callback) {
	function get(cmd, callback) {
		exec(cmd, function (err, stdout) {
			if (err) {
				winston.error(err);
			}
			callback(null, stdout ? stdout.replace(/\n$/, '') : 'no-git-info');
		});
	}
	async.parallel({
		hash: function (next) {
			get('git rev-parse HEAD', next);
		},
		branch: function (next) {
			get('git rev-parse --abbrev-ref HEAD', next);
		},
	}, callback);
}