This repository has been archived by the owner on Sep 9, 2020. It is now read-only.
-
-
Notifications
You must be signed in to change notification settings - Fork 6
/
index.js
106 lines (87 loc) · 2.89 KB
/
index.js
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
99
100
101
102
103
104
105
106
var path = require('path');
var os = require('os');
var fs = require('fs');
var moment = require('moment');
var requests = { total: 0 };
var requests_per_minute = [];
for(var i=0;i<60;i++)
requests_per_minute[i] = 0;
var uptime_start = new Date();
var exec = require('child_process').exec;
var git_data = { };
exec(__dirname+'/lib/get_git_data.sh', function(err, res, stderr) {
var cols = res.trim().split(',');
git_data.branch = cols[0];
git_data.sha = cols[1] && cols[1].substr(0,7);
});
var sum = function(arr, from, length) {
var total = 0;
for(var i=from-length;i<from;i++) {
total += arr[(i+arr.length)%arr.length];
}
return total;
}
var average = function(arr, from, length) {
var total = sum(arr, from, length);
return Math.round(total/arr.length);
}
var resetCounter = function() {
var minute = (new Date).getMinutes();
requests_per_minute[(minute+1)%59] = 0;
}
// Every minute, we reset the oldest entry
setInterval(resetCounter, 60*1000);
module.exports = function(app, options) {
var server = { status: "up" };
var filepath = "package.json";
var i = 0;
do {
filepath = require.main.paths[i++].replace(/\/[^\/]*$/,'/') + "package.json";
}
while(!fs.existsSync(filepath) && i < require.main.paths.length);
try {
var pkg = require(filepath);
server.name = pkg.name;
server.version = pkg.version;
} catch(e) { console.error("express-server-status> Error loading " + filepath, e); }
app.get('*', function(req, res, next) {
requests.total++;
var minute = (new Date).getMinutes();
requests_per_minute[minute]++;
return next();
});
return function(req, res, next) {
req.stats = {}
req.stats.start = new Date;
// decorate response#end method from express
var end = res.end;
res.end = function () {
req.stats.responseTime = (new Date) - req.stats.start;
// call to original express#res.end()
res.setHeader('X-Response-Time', req.stats.responseTime);
end.apply(res, arguments);
}
var minute = (new Date).getMinutes();
server.started_at = moment(uptime_start);
server.uptime = Math.round((new Date() - uptime_start) / 1000);
server.uptime_human = moment(uptime_start).fromNow();
server.env = process.env.NODE_ENV;
var node = {
version: process.version,
memoryUsage: Math.round(process.memoryUsage().rss / 1024 / 1024) + 'M',
uptime: process.uptime()
};
var system = {
loadavg: os.loadavg(),
freeMemory: Math.round(os.freemem() / 1024 / 1024) + 'M',
hostname: os.hostname()
};
// requests.per_minute = requests_per_minute;
requests.last_minute = sum(requests_per_minute, minute, 1);
requests.last_5mn_avg = sum(requests_per_minute, minute, 5);
requests.last_15mn_avg = average(requests_per_minute, 0, 15);
server.requests = requests;
const status = { server, git: git_data, node, system };
res.send(status);
};
}