-
Notifications
You must be signed in to change notification settings - Fork 1
/
server.js
74 lines (59 loc) · 1.8 KB
/
server.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
var express = require("express");
var bodyParser = require("body-parser");
var exec = require('child_process').exec;
var moment = require('moment');
var fs = require('fs');
var app = express();
function deep_value (obj, path) {
for (var i = 0, path = path.split('.'), len = path.length; i < len; i++) {
if (obj[path[i]] === undefined) return;
obj = obj[path[i]];
};
return obj;
}
var logger = null;
function log(message) {
var text = moment().format('YYYY-MM-DD HH:mm:ss') + ' - ' + message;
if (logger) {
logger.write(text + '\n');
}
else {
console.log(text);
}
}
log("Starting server...");
try {
var config = require("./config.json");
}
catch(e) {
console.error("Invalid configuration file (config.json).");
process.exit();
}
if (config.logfile) {
logger = fs.createWriteStream(config.logfile, { flags: 'a' });
}
app.use(bodyParser.json({ limit: '1mb' }));
app.post('/event', (req, res) => {
if (!req.body || !req.body.object_kind || !req.body.repository || !req.body.repository.name) {
return res.sendStatus(400);
}
log('Receive event ' + req.body.object_kind + ' for repository ' + req.body.repository.name);
var specificConf = config.hooks.find(hook =>
(!hook.token || hook.token == req.headers['x-gitlab-token'])
&& (!hook.event || hook.event == req.body.object_kind)
&& (!hook.repository || hook.repository == req.body.repository.name)
);
if (specificConf && specificConf.command) {
var cmd = specificConf.command.replace(/\${([^}]+)}/g, (match, path) => (deep_value(req.body, path) || ''));
log('Executing ' + cmd + ' ...');
exec(cmd, (err, stdout, stderr) => {
log(cmd + ' executed');
});
res.sendStatus(200);
}
else {
log('No hook found for this event');
res.sendStatus(404);
}
});
app.listen(config.port);