Copied files from alertmon, replaced names where needed; runs but doesn't yet make sense for courtsopen project.
This commit is contained in:
parent
5363542936
commit
5595dd474f
2
.gitignore
vendored
Normal file
2
.gitignore
vendored
Normal file
@ -0,0 +1,2 @@
|
||||
node_modules
|
||||
db
|
||||
25
courtsopenUtils.js
Normal file
25
courtsopenUtils.js
Normal file
@ -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;
|
||||
//}
|
||||
//}
|
||||
//);
|
||||
//};
|
||||
16
package.json
Normal file
16
package.json
Normal file
@ -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"
|
||||
}
|
||||
}
|
||||
247
server.js
Normal file
247
server.js
Normal file
@ -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 <alertmonitorfl@gmail.com>',
|
||||
//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");
|
||||
})
|
||||
24
views/core-edit.hbs
Normal file
24
views/core-edit.hbs
Normal file
@ -0,0 +1,24 @@
|
||||
{{!< default}}
|
||||
|
||||
<div id="form-container" class="container">
|
||||
{{#form url class="form-horzontal"}}
|
||||
|
||||
<div class="form-group">
|
||||
{{label "deviceName" "Edit Device Name:"}}
|
||||
{{input "deviceName" coreName class="form-control"}}
|
||||
{{#if values.0.coreName}}
|
||||
<p class="bg-info">* Current value is, {{values.0.coreName}}</p>
|
||||
{{/if}}
|
||||
</div>
|
||||
|
||||
<div class="form-group">
|
||||
{{label "locationDesc" "Edit Location:"}}
|
||||
{{input "locationDesc" locationDesc class="form-control"}}
|
||||
{{#if values.0.locationDesc}}
|
||||
<p class="bg-info">* Current value is, {{values.0.locationDesc}}</p>
|
||||
{{/if}}
|
||||
</div>
|
||||
|
||||
{{submit "save" "Save details" class="btn btn-primary"}}
|
||||
{{/form}}
|
||||
</div>
|
||||
42
views/core.hbs
Normal file
42
views/core.hbs
Normal file
@ -0,0 +1,42 @@
|
||||
{{!< default}}
|
||||
|
||||
<p>
|
||||
<b>
|
||||
{{! 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}}
|
||||
</b>
|
||||
|
||||
<a href="https://particle.kaplon.us/core/edit/{{alerts.0.coreId}}" class="btn btn-primary">Edit Details</a>
|
||||
<a href="https://particle.kaplon.us" class="btn btn-primary">Back to Device Listing</a>
|
||||
</p>
|
||||
|
||||
<table class="table table-striped">
|
||||
<thead>
|
||||
<tr>
|
||||
<th>Date</th>
|
||||
<th>Time</th>
|
||||
<th>Status</th>
|
||||
</tr>
|
||||
</thead>
|
||||
<tbody>
|
||||
{{#each alerts}}
|
||||
<tr class="{{this.rowClass}}">
|
||||
<td>{{this.pubDate}}</td>
|
||||
<td>{{this.pubTime}}</td>
|
||||
<td>{{this.status}}</td>
|
||||
</tr>
|
||||
{{/each}}
|
||||
</tbody>
|
||||
</table>
|
||||
|
||||
<script>
|
||||
setTimeout(
|
||||
function() {
|
||||
location.reload();
|
||||
}, 10000
|
||||
);
|
||||
</script>
|
||||
30
views/default.hbs
Normal file
30
views/default.hbs
Normal file
@ -0,0 +1,30 @@
|
||||
<!DOCTYPE html>
|
||||
<html>
|
||||
<head>
|
||||
<meta charset="utf-8" />
|
||||
<meta http-equiv="X-UA-Compatible" content="IE=edge" />
|
||||
|
||||
<title>Tennis Courts Open?</title>
|
||||
|
||||
<meta name="HandheldFriendly" content="True" />
|
||||
<meta name="MobileOptimized" content="320" />
|
||||
<meta name="viewport" content="width=device-width, initial-scale=1.0" />
|
||||
|
||||
<link rel="stylesheet" href="https://maxcdn.bootstrapcdn.com/bootstrap/3.3.5/css/bootstrap.min.css">
|
||||
<!-- Optional theme -->
|
||||
<!-- <link rel="stylesheet" href="https://maxcdn.bootstrapcdn.com/bootstrap/3.3.5/css/bootstrap-theme.min.css"> -->
|
||||
|
||||
<style type="text/css">tr.alert-row {background-color:#FF0000 !important;} </style>
|
||||
</head>
|
||||
<body class="container-fluid">
|
||||
|
||||
<div style="background:#D1E0E0" class="jumbotron">
|
||||
<h1 class="text-center">Tennis Courts Open?</h1>
|
||||
</div>
|
||||
|
||||
{{! Everything else gets inserted here }}
|
||||
{{{body}}}
|
||||
|
||||
<script src="https://maxcdn.bootstrapcdn.com/bootstrap/3.3.5/js/bootstrap.min.js"></script>
|
||||
</body>
|
||||
</html>
|
||||
43
views/index.hbs
Normal file
43
views/index.hbs
Normal file
@ -0,0 +1,43 @@
|
||||
{{!< default}}
|
||||
|
||||
<h1>Select a monitor device:</h1>
|
||||
<table class="table table-striped">
|
||||
<thead>
|
||||
<tr>
|
||||
<th>Device Name</th>
|
||||
<th>Location</th>
|
||||
<th>Last Update</th>
|
||||
<th></th>
|
||||
<th></th>
|
||||
</tr>
|
||||
</thead>
|
||||
<tbody>
|
||||
{{#each cores}}
|
||||
<tr class="{{this.rowClass}}">
|
||||
<td>
|
||||
{{#if this.coreName}}
|
||||
<a href="https://particle.kaplon.us/core/{{this.coreId}}">{{this.coreName}}</a>
|
||||
{{else}}
|
||||
<a href="https://particle.kaplon.us/core/{{this.coreId}}"># No Name #</a>
|
||||
</br>
|
||||
</br>
|
||||
<a href="https://particle.kaplon.us/core/edit/{{this.coreId}}" class="btn btn-primary">Edit Details</a>
|
||||
{{/if}}
|
||||
</td>
|
||||
<td>
|
||||
{{#if this.locationDesc}}
|
||||
{{this.locationDesc}}
|
||||
{{else}}
|
||||
# No Location #
|
||||
</br>
|
||||
</br>
|
||||
<a href="https://particle.kaplon.us/core/edit/{{this.coreId}}" class="btn btn-primary">Edit Details</a>
|
||||
{{/if}}
|
||||
</td>
|
||||
<td>{{this.MaxPubDate}}</td>
|
||||
<td>{{this.MaxPubTime}}</td>
|
||||
<td>{{this.MaxStatus}}</td>
|
||||
</tr>
|
||||
{{/each}}
|
||||
</tbody>
|
||||
</table>
|
||||
Loading…
Reference in New Issue
Block a user