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
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
|
#!/usr/bin/env node
var config = require('./config.json');
var fs = require('fs');
var express = require('express');
var app = express();
var queue = require('queue-async');
var tasks = queue(1);
var spawn = require('child_process').spawn;
var email = require('emailjs/email');
var mailer = email.server.connect(config.email);
var crypto = require('crypto');
app.use(express.bodyParser({
verify: function(req,res,buffer){
if(!req.headers['x-hub-signature']){
return;
}
if(!config.secret || config.secret==""){
console.log("Recieved a X-Hub-Signature header, but cannot validate as no secret is configured");
return;
}
var hmac = crypto.createHmac('sha1', config.secret);
var recieved_sig = req.headers['x-hub-signature'].split('=')[1];
var computed_sig = hmac.update(buffer).digest('hex');
if(recieved_sig != computed_sig){
console.warn('Recieved an invalid HMAC: calculated:' + computed_sig + ' != recieved:' + recieved_sig);
var err = new Error('Invalid Signature');
err.status = 403;
throw err;
}
}
}));
// Receive webhook post
app.post('/hooks/jekyll/:branch', function(req, res) {
// Close connection
res.send(202);
// Queue request handler
tasks.defer(function(req, res, cb) {
var data = req.body;
var branch = req.params.branch;
var params = [];
// Parse webhook data for internal variables
data.repo = data.repository.name;
data.branch = data.ref.split('/')[2];
data.owner = data.repository.owner.name;
// End early if not permitted account
if (config.accounts.indexOf(data.owner) === -1) {
console.log(data.owner + ' is not an authorized account.');
if (typeof cb === 'function') cb();
return;
}
// End early if not permitted branch
if (data.branch !== branch) {
console.log('Not ' + branch + ' branch.');
if (typeof cb === 'function') cb();
return;
}
// Process webhook data into params for scripts
/* repo */ params.push(data.repo);
/* branch */ params.push(data.branch);
/* owner */ params.push(data.owner);
/* giturl */
if (config.public_repo) {
params.push('https://' + config.gh_server + '/' + data.owner + '/' + data.repo + '.git');
} else {
params.push('git@' + config.gh_server + ':' + data.owner + '/' + data.repo + '.git');
}
/* source */ params.push(config.temp + '/' + data.owner + '/' + data.repo + '/' + data.branch + '/' + 'code');
/* build */ params.push(config.temp + '/' + data.owner + '/' + data.repo + '/' + data.branch + '/' + 'site');
// Run build script
run(config.scripts.build, params, function(err) {
if (err) {
console.log('Failed to build: ' + data.owner + '/' + data.repo);
send('Your website at ' + data.owner + '/' + data.repo + ' failed to build.', 'Error building site', data);
if (typeof cb === 'function') cb();
return;
}
// Run publish script
run(config.scripts.publish, params, function(err) {
if (err) {
console.log('Failed to publish: ' + data.owner + '/' + data.repo);
send('Your website at ' + data.owner + '/' + data.repo + ' failed to publish.', 'Error publishing site', data);
if (typeof cb === 'function') cb();
return;
}
// Done running scripts
console.log('Successfully rendered: ' + data.owner + '/' + data.repo);
send('Your website at ' + data.owner + '/' + data.repo + ' was successfully published.', 'Successfully published site', data);
if (typeof cb === 'function') cb();
return;
});
});
}, req, res);
});
// Start server
var port = process.env.PORT || 8080;
app.listen(port);
console.log('Listening on port ' + port);
function run(file, params, cb) {
var process = spawn(file, params);
process.stdout.on('data', function (data) {
console.log('' + data);
});
process.stderr.on('data', function (data) {
console.warn('' + data);
});
process.on('exit', function (code) {
if (typeof cb === 'function') cb(code !== 0);
});
}
function send(body, subject, data) {
if (config.email.isActivated) {
if (config.email && data.pusher.email) {
var message = {
text: body,
from: config.email.user,
to: data.pusher.email,
subject: subject
};
mailer.send(message, function(err) { if (err) console.warn(err); });
}
}
}
|
