From 10474f8e2a75d4bc4fcc511bcb6bf271abdf7b0f Mon Sep 17 00:00:00 2001
From: Baris Usakli <barisusakli@gmail.com>
Date: Tue, 3 Dec 2013 15:17:42 -0500
Subject: [PATCH] more mongo work

---
 src/database/mongo.js | 33 ++++++++++++++++++------
 src/routes/debug.js   | 60 +++++++++++++++++++++++++++++++++++++++++++
 2 files changed, 85 insertions(+), 8 deletions(-)

diff --git a/src/database/mongo.js b/src/database/mongo.js
index 801abb6dd7..d0768ccba7 100644
--- a/src/database/mongo.js
+++ b/src/database/mongo.js
@@ -32,6 +32,7 @@
 			db.createCollection('sets', function(err, collection) {
 			});
 
+
 			callback(err);
 		});
 		// look up how its done in mongo
@@ -74,20 +75,27 @@
 	//hashes
 
 	module.setObject = function(key, data, callback) {
+		console.log('SET OBJECT CALLED', key, data);
 		data['_key'] = key;
-		db.collection('objects').insert(data, {w:1}, function(err, result) {
+		db.collection('objects').update({_key:key}, {$set:data}, {upsert:true, w: 1}, function(err, result) {
+			console.log('SET OBJECT COMPLETE', err, result);
 			callback(err, result);
 		});
 	}
 
 	module.setObjectField = function(key, field, value, callback) {
-		db.collection('objects').update();
+		var data = {};
+		data[field] = value;
+		db.collection('objects').update({_key:key}, {$set:data}, {upsert:true, w: 1}, function(err, result) {
+			console.log('SET OBJECT COMPLETE', err, result);
+			callback(err, result);
+		});
 	}
 
 	module.getObject = function(key, callback) {
-		console.log('calling findOne');
+		console.log('GET OBJECT', key);
 		db.collection('objects').findOne({_key:key}, function(err, item) {
-			console.log(item);
+			console.log('RETURNING OBJECT', item);
 			callback(err, item);
 		});
 	}
@@ -106,7 +114,7 @@
 
 		var _fields = {};
 		for(var i=0; i<fields.length; ++i) {
-			_fields[fields[i]] = 1;
+			_fields[fields[i]] = 'baris';
 		}
 
 		db.collection('objects').findOne({_key:key}, {fields:_fields}, function(err, item) {
@@ -172,10 +180,19 @@
 	}
 
 	module.getSetMembers = function(key, callback) {
-		console.log('getting set members');
+		console.log('GETTING SET MEMBERS', key);
 		db.collection('sets').findOne({_key:key}, function(err, data) {
-			console.log('derp', err, data);
-			callback(err, data);
+			if(err) {
+				return callback(err);
+			}
+
+			if(!data) {
+				console.log('GOT SET MEMBERS', []);
+				callback(null, []);
+			} else {
+				console.log('GOT SET MEMBERS', data);
+				callback(null, data);
+			}
 		});
 	}
 
diff --git a/src/routes/debug.js b/src/routes/debug.js
index d089a48b2c..0dd450aa19 100644
--- a/src/routes/debug.js
+++ b/src/routes/debug.js
@@ -78,6 +78,66 @@ var	DebugRoute = function(app) {
 				});
 			});
 		});
+
+
+		app.get('/mongo', function(req, res) {
+
+			var db = require('./../database');
+			var objectKey = 'someotherObj';
+
+			function setObject(callback) {
+				db.setObject(objectKey, {name:'baris', 'lastname':'usakli', age:3}, function(err, result) {
+					console.log('setObject return ', result);
+					callback(err, {'setObject':result});
+				});
+			}
+
+			function getObject(callback) {
+				db.getObject(objectKey, function(err, data) {
+					console.log('getObject return ', data);
+					callback(err, {'getObject':data});
+				});
+			}
+
+			function setObjectField(callback) {
+				db.setObjectField(objectKey, 'reputation', 5, function(err, result) {
+					console.log('setObjectField return', result);
+					callback(err, {'setObjectField': result});
+				});
+			}
+
+			function getObjectField(callback) {
+				db.getObjectField(objectKey, 'age', function(err, age) {
+					console.log('getObjectField return', age);
+					callback(err, {'getObjectField' : age});
+				});
+			}
+
+			function getObjectFields(callback) {
+				db.getObjectFields(objectKey, ['name', 'lastname'], function(err, data) {
+					console.log('getObjectFields return', data);
+					callback(err, {'getObjectFields':data});
+				});
+			}
+
+			var tasks = [
+				//setObject,
+				getObject,
+				setObjectField,
+				getObject,
+				getObjectField,
+				getObjectFields,
+			];
+
+			require('async').series(tasks, function(err, results) {
+				if(err) {
+					console.log(err);
+					res.send(err.message);
+				} else {
+					res.json(results);
+				}
+			});
+		});
 	});
 };