Skip to content

Commit 51a8652

Browse files
MarakMarak
committed
[dist] Email tail of logs on process restart or crash
1 parent 6647687 commit 51a8652

14 files changed

+57
-63
lines changed

‎scripts/alerts/alert.js‎

Lines changed: 28 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,28 @@
1+
#!/usr/bin/env node
2+
var sendEmailAlert = require('./sendEmailAlert');
3+
var readline = require('readline');
4+
5+
module.exports = function (message) {
6+
if (process.stdin.isTTY) {
7+
sendEmailAlert({
8+
subject: message
9+
});
10+
return;
11+
} else {
12+
var buffer = '';
13+
var rl = readline.createInterface({
14+
input: process.stdin,
15+
output: process.stdout,
16+
terminal: false
17+
});
18+
rl.on('line', function (line) {
19+
buffer += line.toString() + '<br/>';
20+
});
21+
rl.on('close', function (line) {
22+
sendEmailAlert({
23+
subject: message,
24+
html: buffer
25+
});
26+
});
27+
}
28+
}

‎scripts/alerts/cron-exited‎

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
#!/usr/bin/env node
2+
var alert = require('./alert');
3+
alert('cron mon has exited!');

‎scripts/alerts/load-balancer-exited‎

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,3 @@
11
#!/usr/bin/env node
2-
var sendEmailAlert = require('./sendEmailAlert');
3-
sendEmailAlert({
4-
subject: 'load balancer mon has exited!'
5-
});
2+
var alert = require('./alert');
3+
alert('load balancer mon has exited!');

‎scripts/alerts/load-balancer-restarted‎

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,3 @@
11
#!/usr/bin/env node
2-
var sendEmailAlert = require('./sendEmailAlert');
3-
sendEmailAlert({
4-
subject: 'load balancer node has restarted'
5-
});
2+
var alert = require('./alert');
3+
alert('load balancer node has restarted');

‎scripts/alerts/sendEmailAlert.js‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@ module.exports = function (opts) {
1010
to: '[email protected]',
1111
from: '[email protected]',
1212
subject: opts.subject,
13-
html: 'n/a'
13+
html: opts.html || 'n/a'
1414
}, function (err, result) {
1515
if (err) {
1616
return res.end('Error in sending email ' + err.message);

‎scripts/alerts/web-exited‎

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,3 @@
11
#!/usr/bin/env node
2-
var sendEmailAlert = require('./sendEmailAlert');
3-
sendEmailAlert({
4-
subject: 'web mon has exited!'
5-
});
2+
var alert = require('./alert');
3+
alert('web mon has exited!');

‎scripts/alerts/web-restarted‎

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,3 @@
11
#!/usr/bin/env node
2-
var sendEmailAlert = require('./sendEmailAlert');
3-
sendEmailAlert({
4-
subject: 'web node has restarted'
5-
});
2+
var alert = require('./alert');
3+
alert('web node has restarted');

‎scripts/alerts/worker-exited‎

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,3 @@
11
#!/usr/bin/env node
2-
var sendEmailAlert = require('./sendEmailAlert');
3-
sendEmailAlert({
4-
subject: 'worker mon has exited!'
5-
});
2+
var alert = require('./alert');
3+
alert('worker mon has exited!');

‎scripts/alerts/worker-restarted‎

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,3 @@
11
#!/usr/bin/env node
2-
var sendEmailAlert = require('./sendEmailAlert');
3-
sendEmailAlert({
4-
subject: 'worker node has restarted'
5-
});
2+
var alert = require('./alert');
3+
alert('worker node has restarted');

‎scripts/start-production.sh‎

Lines changed: 0 additions & 26 deletions
This file was deleted.

0 commit comments

Comments
 (0)