diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..885c9f0 --- /dev/null +++ b/.gitignore @@ -0,0 +1,2 @@ +node_modules +db diff --git a/courtsopenUtils.js b/courtsopenUtils.js new file mode 100644 index 0000000..2da140e --- /dev/null +++ b/courtsopenUtils.js @@ -0,0 +1,25 @@ +var moment = require('moment-timezone'); + +exports.getLocTimeFromUTC = function(utcDtTm) { + var localTm = moment.utc(new Date(utcDtTm)); + localTm = moment(localTm).tz('America/New_York').format('h:mm:ss a'); + return localTm; +}; + +exports.getLocDateFromUTC = function(utcDtTm) { + var localDt = moment.utc(new Date(utcDtTm)); + localDt = moment(localDt).tz('America/New_York').format('MM-DD-YYYY'); + return localDt; +}; + +// This returned undefined, it probably won't work w/out some fancy dependency injection stuff. +//exports.getCoreNameFromCoreId = function(db, coreId) { + //db.all('SELECT coreName FROM Cores WHERE coreId = ? LIMIT 1;', coreId, function(err, rows){ + //if (err !== null) { + //console.log(err); + //} else { + //return rows.coreName; + //} + //} + //); +//}; diff --git a/package.json b/package.json new file mode 100644 index 0000000..8568ed1 --- /dev/null +++ b/package.json @@ -0,0 +1,16 @@ +{ + "name": "courtsopen", + "version": "0.0.1", + "dependencies": { + "body-parser": "^1.12.4", + "express": "^4.12.4", + "express-hbs": "^0.8.4", + "handlebars-form-helpers": "^0.1.3", + "moment-timezone": "^0.4.0", + "nodemailer": "^1.3.4", + "sqlite3": "^3.0.8" + }, + "scripts": { + "start": "node server.js" + } +} diff --git a/server.js b/server.js new file mode 100644 index 0000000..e91c8be --- /dev/null +++ b/server.js @@ -0,0 +1,247 @@ +var express = require("express"); +var hbs = require('express-hbs'); +require('handlebars-form-helpers').register(hbs.handlebars); +//var nodemailer = require('nodemailer'); +var courtsopenUtils = require('./courtsopenUtils.js'); +var fs = require("fs"); +var bodyParser = require("body-parser"); +var app = express(); +var logfile = fs.createWriteStream('./db/log.log', {flags: 'a'}); + +// Setup email +//var transporter = nodemailer.createTransport({ + //service: 'Gmail', + //auth: { + //user: 'alertmonitorfl@gmail.com', + //pass: '6g*hkvVc%91oo3#$' + //} +//}); +//var mailOptions = { + //from: 'Alert Monitor ', + //to: 'jody@kaplon.us,don@gettner.com', + //subject: 'Alert received', + //text: 'test alert' // Get custom text later on email generation. +//}; + + +var file = "./db/courtsopen.db"; +var exists = fs.existsSync(file); + +if(!exists) { + console.log("Creating DB file."); + fs.openSync(file, "w"); +} + +var sqlite3 = require("sqlite3").verbose(); +var db = new sqlite3.Database(file); + +db.serialize(function() { + if(!exists) { + // Can't create multiple tables w/one statement, semicolons not allowed. + db.run( + "CREATE TABLE Alerts (" + + "origJSON TEXT," + + "coreId TEXT," + + "status TEXT," + + "published_at TEXT)" + ); + db.run( + "CREATE TABLE Cores (" + + "coreId TEXT PRIMARY KEY," + + "coreName TEXT," + + "locationDesc TEXT)" + ); + } +}); + +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)); + 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 "; + db.all(devIndexQry, function(err, rows){ + if(err !== null) { + console.log(err); + } else { + //console.log(rows); + + // Loop over elements in rows array, convert ugly UTC times to pretty local times. + rows.forEach(function(row){ + row.MaxPubDate = courtsopenUtils.getLocDateFromUTC(row.MaxPub); + row.MaxPubTime = courtsopenUtils.getLocTimeFromUTC(row.MaxPub); + + if(row.MaxStatus.toLowerCase().indexOf('alert') > -1){ + row.rowClass = 'alert-row'; + } else { row.rowClass = 'non-alert-row'; } + }); + + res.render('index', {cores: 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)); + + db.all("select coreName, locationDesc from Cores where coreId = ?;", coreId, function(err, rows){ + if(err !== null) { + console.log(err); + } else { + res.render('core-edit', {values: 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 { + // check existence of row in Cores table, if there update, otherwise insert. + var existQry = "SELECT coreId FROM Cores WHERE coreId = ?;" + db.get(existQry, coreId, function(err, row){ + if(err) throw err; + console.log(typeof row); + console.log(row); + if(typeof row == "undefined") { + var insStmt = db.prepare("INSERT INTO Cores (coreId, coreName, locationDesc) VALUES (?, ?, ?);"); + insStmt.run( + coreId, + req.body.deviceName, + req.body.locationDesc + ); + insStmt.finalize(); + } else { + if (req.body.deviceName !== "") { + var stmt = db.prepare("UPDATE Cores SET coreName = ? WHERE coreId = ?"); + stmt.run( + req.body.deviceName, + coreId + ); + stmt.finalize(); + } + + if (req.body.locationDesc !== "") { + var stmt = db.prepare("UPDATE Cores SET locationDesc = ? WHERE coreId = ?"); + stmt.run( + req.body.locationDesc, + coreId + ); + stmt.finalize(); + } + } + }); + + res.redirect('https://tenniscourtsopen.com/'); + } +}); + +app.get('/core/:id', function(req, res){ + //res.sendFile("/usr/src/app/index.html"); + //fs.createReadStream('./log.log').pipe(res); + var d = new Date(); + var coreId = req.params.id; + console.log("GET /core/" + coreId + ", " + JSON.stringify(d, 4)); + 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 = ? ORDER BY al.published_at DESC LIMIT 30;" + db.all(coreMsgQry, coreId, function(err, rows){ + if(err !== null) { + console.log(err); + } else { + //console.log("SELECT coreId, published_at FROM Alerts WHERE coreId = '" + coreId + "' ORDER BY published_at DESC LIMIT 30;"); + //console.log(rows); + + // Loop over elements in rows array, convert ugly UTC times to pretty local times. + rows.forEach(function(row){ + row.pubDate = courtsopenUtils.getLocDateFromUTC(row.published_at); + row.pubTime = courtsopenUtils.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: rows}, function(err, html) { + 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); + var stmt = db.prepare("INSERT INTO Alerts (OrigJSON, coreid, published_at, status) VALUES (?, ?, ?, ?)"); + stmt.run( + JSON.stringify(req.body, null, 4), + coreid, + pubAt, + status + ); + stmt.finalize(); + + // 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, ' + courtsopenUtils.getLocDateFromUTC(pubAt) + ' ' + courtsopenUtils.getLocTimeFromUTC(pubAt) + '\n'; + //mailOptions.text = mailOptions.text + 'From device, ' + courtsopenUtils.getCoreNameFromCoreId(db, coreid) + '\n'; + //var nameQry = 'SELECT coreName FROM Cores WHERE coreId = ?;' + //db.get(nameQry, coreid, function(err, row){ + //if ((err) || (typeof row == undefined)) { + // Don't care about this error or empty result set, still need to send email. + //row.coreName = '# No Name #'; + //} + //mailOptions.text = mailOptions.text + 'From device, ' + row.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)); +}); + +app.listen(3000, function() { + console.log("Started on PORT 3000"); +}) diff --git a/views/core-edit.hbs b/views/core-edit.hbs new file mode 100644 index 0000000..16f3ed5 --- /dev/null +++ b/views/core-edit.hbs @@ -0,0 +1,24 @@ +{{!< default}} + +
+ {{#form url class="form-horzontal"}} + +
+ {{label "deviceName" "Edit Device Name:"}} + {{input "deviceName" coreName class="form-control"}} + {{#if values.0.coreName}} +

* Current value is, {{values.0.coreName}}

+ {{/if}} +
+ +
+ {{label "locationDesc" "Edit Location:"}} + {{input "locationDesc" locationDesc class="form-control"}} + {{#if values.0.locationDesc}} +

* Current value is, {{values.0.locationDesc}}

+ {{/if}} +
+ + {{submit "save" "Save details" class="btn btn-primary"}} + {{/form}} +
diff --git a/views/core.hbs b/views/core.hbs new file mode 100644 index 0000000..4f297fb --- /dev/null +++ b/views/core.hbs @@ -0,0 +1,42 @@ +{{!< default}} + +

+ + {{! Grab 1st coreName value (it will be same value for entire set).}} + {{#if alerts.0.coreName}} + Alerts from Particle Core: {{alerts.0.coreName}} + {{else}} + Alerts from Particle Core: # No Name # + {{/if}} + + + Edit Details + Back to Device Listing +

+ + + + + + + + + + + {{#each alerts}} + + + + + + {{/each}} + +
DateTimeStatus
{{this.pubDate}}{{this.pubTime}}{{this.status}}
+ + diff --git a/views/default.hbs b/views/default.hbs new file mode 100644 index 0000000..af6de45 --- /dev/null +++ b/views/default.hbs @@ -0,0 +1,30 @@ + + + + + + + Tennis Courts Open? + + + + + + + + + + + + + +
+

Tennis Courts Open?

+
+ + {{! Everything else gets inserted here }} + {{{body}}} + + + + diff --git a/views/index.hbs b/views/index.hbs new file mode 100644 index 0000000..6efcb88 --- /dev/null +++ b/views/index.hbs @@ -0,0 +1,43 @@ +{{!< default}} + +

Select a monitor device:

+ + + + + + + + + + + + {{#each cores}} + + + + + + + + {{/each}} + +
Device NameLocationLast Update
+ {{#if this.coreName}} + {{this.coreName}} + {{else}} + # No Name # +
+
+ Edit Details + {{/if}} + 		+ {{#if this.locationDesc}} + {{this.locationDesc}} + {{else}} + # No Location # +
+
+ Edit Details + {{/if}} + 		{{this.MaxPubDate}}{{this.MaxPubTime}}{{this.MaxStatus}}