adds record model, pushes and retrieves records from MongoLab

Author: ElGrecode

client/index.html

@@ -68,5 +68,6 @@
 
       <!-- Angular Services -->
       <script src="scripts/services/APIService.js"></script>
+      <script src="scripts/services/LocalService.js"></script>
 </body>
 </html>

client/scripts/controllers/AdminCtrl.js

@@ -7,7 +7,7 @@
   // 'save-complete' notifies that we have persisted the data to our own local storage
 
   angular.module('frontendEngineeringChallengeApp')
-    .controller('AdminCtrl', function ($scope, $rootScope, $timeout, $interval, APIService) {
+    .controller('AdminCtrl', function ($scope, $rootScope, $timeout, $interval, APIService, LocalService) {
 
       // After a successful API call, we will replace our API objects
       var receivedPostsData = false;
@@ -16,7 +16,8 @@
       var receivedLikesData = false;
       $scope.APIlikesData = undefined;
 
-      $scope.spreadsheet = [];
+      // Attempt to get past records
+      LocalService.getRecords();
 
       // Persist the data received from API to our own storage
       function persistData(data){
@@ -26,8 +27,12 @@
           $timeout(function(){
             // Persist record and push record onto our spreadsheet
             var record = constructRecordObj();
+            // Get it to show locally
             $scope.spreadsheet.push(record);
 
+            // Persist it to our Mongo Database
+            LocalService.postRecord(record);
+
             $scope.lastTimestamp = record.time;
             $scope.$broadcast('save-complete');
           }, 2000);
@@ -92,6 +97,13 @@
 
       });
 
+      // When we receive our spreadsheet object
+      $rootScope.$on('spreadsheet-data', function(){
+        console.log('this is our spreadsheet object');
+        $scope.spreadsheet = LocalService.spreadsheet().records;
+        console.log($scope.spreadsheet);
+      })
+
 
       /***** Helper Functions *****/
 

client/scripts/services/LocalService.js

@@ -0,0 +1,57 @@
+// This service allows us to persist information to our own MongoDB
+
+(function(angular){
+
+  angular.module('frontendEngineeringChallengeApp')
+  .service('LocalService', function($http, $q, $rootScope){
+
+  	// Initializations
+  	var spreadsheetObj = [];
+
+
+  	function handleError(response) {
+  		// todo: Handle Errors
+  		console.log('handling error for our own data persistance');
+	}
+
+	function handleSuccess(response) {
+		console.log('successly received spreadsheet object');
+
+		// Return spreadsheet array for our admin view
+		spreadsheetObj = response.data;
+
+		// Finally, broadcast a singular data-received event
+		$rootScope.$broadcast('spreadsheet-data');
+	}
+
+  	// Expose Local Methods for our own Data Peristence
+  	return {
+  		spreadsheet: function spreadsheet(){
+  			return spreadsheetObj;
+  		},
+  		// Pulls Data For Posts and Likes
+  		getRecords: function getRecords(getRecords){
+  			var request = $http({
+	            method: "get",
+	            url: '/records',
+	            params: {
+	                action: "get"
+	            }
+	        });
+
+	        return( request.then(handleSuccess, handleError) )
+  		},
+    	postRecord: function postRecord(recordObj){
+    		var request = $http({
+	            method: "post",
+	            url: '/record',
+	            params: {
+	                action: "post"
+	            },
+	            // attach the data name so we know which data object the response belongs to
+	            data: recordObj
+	        });
+    	}
+    }
+  });
+}(window.angular));

server/app.js

@@ -11,14 +11,24 @@ var express = require('express');
 var mongoose = require('mongoose');
 var config = require('./config/environment');
 
-// Connect to database
-mongoose.connect(config.mongo.uri, config.mongo.options);
-
 // Setup server
 var app = express();
 var server = require('http').createServer(app);
 require('./config/express')(app);
 require('./routes')(app);
+app.set('env', 'development');
+
+// Models
+var Record       = require('../server/models/record.js');
+
+// Connect to database
+var options = {
+    server: {
+        socketOptions: { keepAlive: 1 }
+    }
+};
+mongoose.connect('mongodb://narwhaldo:[email protected]:47950/impressions', options);
+
 
 // Start server
 server.listen(config.port, config.ip, function () {

server/models/record.js

@@ -0,0 +1,10 @@
+var mongoose = require('mongoose');
+
+var recordSchema = mongoose.Schema({
+  date: String,
+  time: String,
+  id:  	String
+});
+
+var Record = mongoose.model('Record', recordSchema);
+module.exports = Record;

server/routes.js

@@ -5,6 +5,7 @@
 'use strict';
 
 var errors = require('./components/errors');
+var Record = require('./models/record.js');
 
 module.exports = function(app) {
 
@@ -17,6 +18,37 @@ module.exports = function(app) {
     res.render('partials/' + name);
   });
 
+  app.get('/records', function(req, res){
+    var records = Record.find()
+    .limit(20)
+    .exec(function(err, records){
+      // create the json data for our API endpoint
+      res.json({
+        records: records
+      });
+    });
+
+  });
+
+  app.post('/record', function(req, res){
+    var id = req.body.id;
+    var time = req.body.time;
+    var datetime = req.body.date;
+
+    // Create Blazon object
+    var recordObj = new Record({
+      id: id,
+      time: time,
+      date: datetime
+    });
+
+    console.log(recordObj);
+
+    // Save the Blazon
+    recordObj.save();
+
+  });
+
   // All other routes should redirect to the index.html
   app.route('/*')
     .get(function(req, res) {