Merge pull request martinyung#1 from martinyung/feature/object-model

Feature/object model

Author: martinyung

app.js

@@ -3,4 +3,7 @@ var express = require('express');
 var app = express();
 var db = require('./db');
 
+var ItemController = require('./item/ItemController');
+app.use('/items', ItemController);
+
 module.exports = app;

item/Item.js

@@ -0,0 +1,12 @@
+var mongoose = require('mongoose');
+var ItemSchema = new mongoose.Schema({
+	key: String,
+	value: String,
+	timestamp: {
+		type: Number,
+		default: Math.floor(Date.now() / 1000)
+	}
+});
+
+mongoose.model('Item', ItemSchema);
+module.exports = mongoose.model('Item');

item/ItemController.js

@@ -0,0 +1,53 @@
+var express = require('express');
+var router = express.Router();
+var bodyParser = require('body-parser');
+router.use(bodyParser.urlencoded({ extended: true }));
+
+var Item = require('./Item');
+module.exports = router;
+
+// Create an item or update existing item
+router.post('/', (req, res) => {
+	var query = { 'key': req.body.key };
+	var update = {
+		value: req.body.value,
+		timestamp: Math.floor(Date.now() / 1000)
+	};
+	var options = {
+		upsert: true,
+		new: true
+	}
+	Item.findOneAndUpdate(query, update, options, (err, item) => {
+		if (err) return res.status(500).send('error');
+		res.status(200).send(item);
+	});
+});
+
+// Get the value according to key
+router.get('/:key', (req, res) => {
+	var timestampQuery = parseInt(req.query.timestamp)
+	// Get the value less than or equal to the timestamp in query string
+	if (timestampQuery) {
+		Item.find({ 
+			'key': req.params.key,
+			'timestamp': { $lte : timestampQuery }
+		}).
+		sort({ 'timestamp': -1 }).
+		limit(1).
+		exec((err, item) => {
+			if (err) return res.status(500).send('error');
+			if (item.length === 0) return res.status(404).send('not found');
+			res.status(200).send('value: ' + item[0].value)
+		});
+	}
+	// Get the latest value accroding to key when no timestamp query string is given
+	else {
+		Item.find({ 'key': req.params.key }).
+		sort({ 'timestamp': -1 }).
+		exec((err, item) => {
+			if (err) return res.status(500).send('error');
+			if (item.length === 0) return res.status(404).send('not found');
+			res.status(200).send('value: ' + item[0].value);
+		});
+	}	
+});