| 1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98 |
1×
1×
1×
1×
1×
1×
1×
1×
1×
1×
1×
1×
1×
1×
1×
1× | '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 = {};
var info = {};
infoController.get = function(req, res, next) {
info = {};
pubsub.publish('sync:node:info:start');
setTimeout(function() {
var data = [];
Object.keys(info).forEach(function(key) {
data.push(info[key]);
});
data.sort(function(a, b) {
return (a.os.hostname < b.os.hostname) ? -1 : (a.os.hostname > b.os.hostname) ? 1 : 0;
});
res.render('admin/development/info', {info: data, infoJSON: JSON.stringify(data, null, 4), host: os.hostname(), port: nconf.get('port')});
}, 300);
};
pubsub.on('sync:node:info:start', function() {
getNodeInfo(function(err, data) {
if (err) {
return winston.error(err);
}
pubsub.publish('sync:node:info:end', {data: data, id: os.hostname() + ':' + nconf.get('port')});
});
});
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()
},
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(', ')
}
};
async.parallel({
pubsub: function(next) {
pubsub.publish('sync:stats:start');
next();
},
gitInfo: function(next) {
getGitInfo(next);
}
}, function(err, results) {
if (err) {
return callback(err);
}
data.git = results.gitInfo;
data.stats = rooms.stats[data.os.hostname + ':' + data.process.port];
callback(null, data);
});
}
function getGitInfo(callback) {
function get(cmd, callback) {
exec(cmd, function(err, stdout) {
callback(err, stdout ? stdout.replace(/\n$/, '') : '');
});
}
async.parallel({
hash: function(next) {
get('git rev-parse HEAD', next);
},
branch: function(next) {
get('git rev-parse --abbrev-ref HEAD', next);
}
}, callback);
}
module.exports = infoController; |