233 lines
9.3 KiB
JavaScript
233 lines
9.3 KiB
JavaScript
var express = require("express");
|
|
var hbs = require('express-hbs');
|
|
require('handlebars-form-helpers').register(hbs.handlebars);
|
|
var nodemailer = require('nodemailer');
|
|
var alertmonUtils = require('./alertmonUtils.js');
|
|
var fs = require("fs");
|
|
var bodyParser = require("body-parser");
|
|
var app = express();
|
|
|
|
// Setup email
|
|
var transporter = nodemailer.createTransport({
|
|
service: 'Gmail',
|
|
auth: {
|
|
user: 'alertmonitorfl@gmail.com',
|
|
pass: '6g*hkvVc%91oo3#$'
|
|
}
|
|
});
|
|
var mailOptions = {
|
|
from: 'Alert Monitor <alertmonitorfl@gmail.com>',
|
|
to: 'jody@kaplon.us,don@gettner.com',
|
|
subject: 'Alert received',
|
|
text: 'test alert' // Get custom text later on email generation.
|
|
};
|
|
|
|
|
|
var pg = require("pg");
|
|
var conString = "postgres://alertmon:alertmon@db/alertmon";
|
|
|
|
|
|
app.use(bodyParser.json()); // Needed for JSON POST requests from Particle Cores.
|
|
app.use(bodyParser.urlencoded({ extended: false })); // Needed for web POST requests from edit form.
|
|
|
|
// Use `.hbs` for extensions and find partials in `views/partials`.
|
|
app.engine('hbs', hbs.express4({
|
|
partialsDir: __dirname + '/views/partials'
|
|
}));
|
|
app.set('view engine', 'hbs');
|
|
app.set('views', __dirname + '/views');
|
|
|
|
app.get('/', function(req, res){
|
|
var d = new Date();
|
|
console.log("GET /, " + JSON.stringify(d, 4));
|
|
|
|
pg.connect(conString, function(err, client, done) {
|
|
if(err) {
|
|
return console.error('error fetching client from pool', err);
|
|
}
|
|
var devIndexQry =
|
|
"select al.coreid, max(co.corename) as corename, max(co.locationdesc) as locationdesc, mpub.maxpub, al.status as maxstatus " +
|
|
"from alerts al " +
|
|
"inner join (select coreid, max(published_at) as maxpub from alerts group by coreid) mpub on al.coreid = mpub.coreid and al.published_at = mpub.maxpub " +
|
|
"left join cores co on al.coreid = co.coreid " +
|
|
"group by al.coreid, mpub.maxpub, al.status " +
|
|
"order by mpub.maxpub desc, corename asc ";
|
|
client.query(devIndexQry, function(err, result) {
|
|
//call `done()` to release the client back to the pool
|
|
done();
|
|
|
|
if(err) {
|
|
return console.error('error running query', err);
|
|
}
|
|
|
|
// Loop over elements in rows array, convert ugly UTC times to pretty local times.
|
|
result.rows.forEach(function(row){
|
|
row.maxpubdate = alertmonUtils.getLocDateFromUTC(row.maxpub);
|
|
row.maxpubtime = alertmonUtils.getLocTimeFromUTC(row.maxpub);
|
|
|
|
if(row.maxstatus.toLowerCase().indexOf('alert') > -1){
|
|
row.rowclass = 'alert-row';
|
|
} else { row.rowclass = 'non-alert-row'; }
|
|
});
|
|
|
|
res.render('index', {cores: result.rows}, function(err, html) {
|
|
if(err !== null) {
|
|
console.log(err);
|
|
} else {
|
|
res.send(html);
|
|
}
|
|
});
|
|
});
|
|
});
|
|
});
|
|
|
|
app.get('/core/edit/:id', function(req, res){
|
|
var d = new Date();
|
|
var coreId = req.params.id;
|
|
console.log("GET /core/edit/" + coreId + ", " + JSON.stringify(d, 4));
|
|
|
|
pg.connect(conString, function(err, client, done) {
|
|
if(err) {
|
|
return console.error('error fetching client from pool', err);
|
|
}
|
|
client.query("select corename, locationdesc from cores where coreid = ($1);", [coreId], function(err, result) {
|
|
//call `done()` to release the client back to the pool
|
|
done();
|
|
|
|
if(err) { return console.error('error running query', err); }
|
|
res.render('core-edit', {values: result.rows}, function(err, html) {
|
|
if(err !== null) {
|
|
console.log(err);
|
|
} else {
|
|
res.send(html);
|
|
}
|
|
});
|
|
});
|
|
});
|
|
});
|
|
|
|
app.post('/core/edit/:id', function(req, res){
|
|
var d = new Date();
|
|
var coreId = req.params.id;
|
|
console.log("POST /core/edit/" + coreId + "body: " + JSON.stringify(req.body) + ", " + JSON.stringify(d, 4));
|
|
if (!req.body) {
|
|
return res.sendStatus(400);
|
|
} else {
|
|
pg.connect(conString, function(err, client, done) {
|
|
if(err) { return console.error('error fetching client from pool', err); }
|
|
// check existence of row in Cores table, if not there insert, otherwise update.
|
|
client.query("SELECT coreid FROM cores WHERE coreid = ($1);", [coreId], function(err, result) {
|
|
done();
|
|
|
|
if(err) { return console.error('error running query', err); }
|
|
if(typeof result.rowCount == 0) {
|
|
client.query(
|
|
"INSERT INTO cores (coreid, corename, locationdesc) VALUES ($1, $2, $3);",
|
|
[coreId, req.body.deviceName, req.body.locationDesc]
|
|
);
|
|
} else {
|
|
if (req.body.deviceName !== "") {
|
|
client.query("UPDATE cores SET corename =($1) WHERE coreid =($2)", [req.body.deviceName, coreId]);
|
|
}
|
|
|
|
if (req.body.locationDesc !== "") {
|
|
client.query("UPDATE cores SET locationdesc =($1) WHERE coreid =($2)", [req.body.locationDesc, coreId]);
|
|
}
|
|
}
|
|
});
|
|
});
|
|
|
|
res.redirect(204, 'https://particle.kaplon.us/');
|
|
}
|
|
});
|
|
|
|
app.get('/core/:id', function(req, res){
|
|
var d = new Date();
|
|
var coreId = req.params.id;
|
|
console.log("GET /core/" + coreId + ", " + JSON.stringify(d, 4));
|
|
|
|
pg.connect(conString, function(err, client, done) {
|
|
if(err) { return console.error('error fetching client from pool', err); }
|
|
|
|
var coreMsgQry = "SELECT al.coreid, al.published_at, al.status, co.corename " +
|
|
"FROM alerts al left join cores co on al.coreid = co.coreid " +
|
|
"WHERE al.coreid = ($1) ORDER BY al.published_at DESC LIMIT 30;"
|
|
client.query(coreMsgQry, [coreId], function(err, result) {
|
|
//call `done()` to release the client back to the pool
|
|
done();
|
|
|
|
if(err) {
|
|
return console.error('error running query', err);
|
|
}
|
|
|
|
// Loop over elements in rows array, convert ugly UTC times to pretty local times.
|
|
result.rows.forEach(function(row){
|
|
row.pubdate = alertmonUtils.getLocDateFromUTC(row.published_at);
|
|
row.pubtime = alertmonUtils.getLocTimeFromUTC(row.published_at);
|
|
if(row.status.toLowerCase().indexOf('alert') > -1){
|
|
row.rowclass = 'alert-row';
|
|
} else { row.rowclass = 'non-alert-row'; }
|
|
});
|
|
|
|
res.render('core', {alerts: result.rows}, function(err, html) {
|
|
if(err !== null) {
|
|
console.log(err);
|
|
} else {
|
|
res.send(html);
|
|
}
|
|
});
|
|
});
|
|
});
|
|
});
|
|
|
|
app.post('/', function(req, res){
|
|
var postEvent = req.body.postEvent;
|
|
var source = req.body.source;
|
|
console.log(req.body);
|
|
|
|
var innerDataJSON = JSON.parse(req.body.data);
|
|
var status = JSON.stringify(innerDataJSON.status, null, 4).slice(1,-1);
|
|
var coreid = JSON.stringify(req.body.coreid, null, 4).slice(1,-1);
|
|
var pubAt = JSON.stringify(req.body.published_at, null, 4).slice(1,-1);
|
|
|
|
pg.connect(conString, function(err, client, done) {
|
|
if(err) { return console.error('error fetching client from pool', err); }
|
|
client.query(
|
|
"INSERT INTO alerts (origjson, coreid, published_at, status) VALUES ($1, $2, $3, $4);",
|
|
[JSON.stringify(req.body, null, 4), coreid, pubAt, status]
|
|
);
|
|
});
|
|
|
|
// Send emails on alerts only
|
|
if(status.toLowerCase().indexOf('alert') > -1){
|
|
mailOptions.text = 'An alert message was received: \n\n';
|
|
mailOptions.text = mailOptions.text + 'Status message, ' + status + '\n';
|
|
mailOptions.text = mailOptions.text + 'Published at, ' + alertmonUtils.getLocDateFromUTC(pubAt) + ' ' + alertmonUtils.getLocTimeFromUTC(pubAt) + '\n';
|
|
//mailOptions.text = mailOptions.text + 'From device, ' + alertmonUtils.getCoreNameFromCoreId(db, coreid) + '\n';
|
|
pg.connect(conString, function(err, client, done) {
|
|
if(err) { return console.error('error fetching client from pool', err); }
|
|
client.query('SELECT corename FROM cores WHERE coreid = $1;', [coreid], function(err, result) {
|
|
if ((err) || (typeof result.rowCount == 0)) {
|
|
// Don't care about this error or empty result set, still need to send email.
|
|
result.rows[0].corename = '# No Name #';
|
|
}
|
|
mailOptions.text = mailOptions.text + 'From device, ' + result.rows[0].corename + '\n';
|
|
|
|
transporter.sendMail(mailOptions, function(error, info){
|
|
if(error){
|
|
console.log(error);
|
|
}else{
|
|
console.log('Message sent: ' + info.response);
|
|
}
|
|
});
|
|
});
|
|
});
|
|
}
|
|
//res.send(JSON.stringify(req.body, null, 4));
|
|
res.status(204).send('POST received');
|
|
});
|
|
|
|
app.listen(3000, function() {
|
|
console.log("Started on PORT 3000");
|
|
})
|