2 files changed, 63 insertions, 50 deletions

diff --git a/web/routes/index.js b/web/routes/index.js
index ffe1c21..b2ba91f 100644
--- a/web/routes/index.js
+++ b/web/routes/index.js
@@ -1,61 +1,59 @@
 var express = require('express');
 var router = express.Router();
-
-// Mongoose import
-var mongoose = require('mongoose');
-
-var env = process.env.NODE_ENV || 'development';
-var uri;
-if (env === 'development') {
-    uri = 'mongodb://localhost:27017/helpthehome'
-    // use for small testing only if really necessary
-    // uri = 'mongodb+srv://development:dreamteam@cluster0-krnr4.mongodb.net/helpthehome?retryWrites=true'
-} else if (env === 'qa') {
-    uri = process.env.MONGODB_URI
-} else if (env === 'production') {
-    uri = ''
-}
-
-// Mongoose connection to MongoDB
-mongoose.connect(uri, { useNewUrlParser: true }, function (error) {
-    if (error) {
-        console.log(error);
-        console.log("App was not able to connect to the mongo server!");
-        console.log("... double check that the mongo server is running locally");
-    } else {
-	console.log(`connected to ${uri}`);
-    }
-});
-
-// Mongoose Schema definition
-var Schema = mongoose.Schema;
-var JsonSchema = new Schema({
-    name: String,
-    type: Schema.Types.Mixed,
-    coordinates: Array
-});
-
-// Mongoose Model definition
-var Json = mongoose.model('Jstring', JsonSchema, 'pointscollection');
-
+var Mockpoints = require('../models/mockpoints');
+var Points = require('../models/points');
+const connections = [];
 /* GET home page. */
 router.get('/', function(req, res, next) {
-  // for now just redirect to /map
-  //res.render('index', { title: 'Welcome' });
-  res.redirect('/map');
+	// for now just redirect to /map
+	res.redirect('/map');
 });
 
 /* GET Map page. */
 router.get('/map', function(req,res) {
-    // we can use the database to fetch a point, SELECT coordinates
-    Json.findOne({name: "points"}, 'coordinates', function(e,point){
-	if (e) return e;
-	// send the view lat, and long.
-        res.render('map', {
-            lat : point.coordinates[1],
-            lng : point.coordinates[0]
-        });
-    });
+	// load the map with all the points
+	// Mockpoints.get_points(function(err, points){
+	Points.get_points(function(err, points){
+		res.render('map', {
+			lat : 43.665234,
+			lng : -79.383370,
+			points: points
+		});
+	});
+});
+
+router.post('/mobilerequest', function(req, res) {
+	var data = {
+		'coordinates': req.body.coordinates,
+		'type': req.body.type,
+		'isInjured': req.body.isInjured,
+		'reasonForHelp': req.body.reasonForHelp,
+		'ageRange': req.body.ageRange,
+		'clothingDescription': req.body.clothingDescription
+	}
+	Points.save_request(data, function(err, result) {
+		if (err) {
+			console.log(`err inserting mobile request into db: ${err}`);
+			res.status(500).send({ error: "boo:(" });
+		} else {
+			// send event to all connections
+			for(var i = 0; i < connections.length; i++) {
+				connections[i].sseSend(data);
+			}
+			console.log(result);
+			res.status(200).send({'status': 'success', 'data': data});
+		}
+	});
+	
 });
 
+
+router.get('/stream', function(req, res){
+	// set up server side event (communication line between front end and server)
+	res.sseSetup();
+	// send an event to the front end to open the connection
+	res.sseSend('ok');
+	// push connection to connection array
+	connections.push(res);
+});
 module.exports = router;
diff --git a/web/routes/sse.js b/web/routes/sse.js
new file mode 100644
index 0000000..5cd9a3f
--- /dev/null
+++ b/web/routes/sse.js
@@ -0,0 +1,15 @@
+module.exports = function (req, res, next) {
+  res.sseSetup = function() {
+    res.writeHead(200, {
+      'Content-Type': 'text/event-stream',
+      'Cache-Control': 'no-cache',
+      'Connection': 'keep-alive'
+    })
+  }
+
+  res.sseSend = function(data) {
+    res.write("data: " + JSON.stringify(data) + "\n\n");
+  }
+
+  next()
+}
\ No newline at end of file