From ca01fb9f7d5994989409df1bc9e7060621aa6f83 Mon Sep 17 00:00:00 2001 From: Baris Soner Usakli Date: Wed, 4 Dec 2013 12:25:53 -0500 Subject: [PATCH] added key methods to mongo --- src/database/mongo.js | 15 +++++++++------ src/routes/debug.js | 40 +++++++++++++++++++++++++++++++++++++++- 2 files changed, 48 insertions(+), 7 deletions(-) diff --git a/src/database/mongo.js b/src/database/mongo.js index 1e8c6ff564..051d7aa930 100644 --- a/src/database/mongo.js +++ b/src/database/mongo.js @@ -55,19 +55,21 @@ // key module.exists = function(key, callback) { - throw new Error('not-implemented'); + module.isObjectField('global', key, callback); } module.delete = function(key, callback) { - throw new Error('not-implemented'); + module.deleteObjectField('global', key, callback); } module.get = function(key, callback) { - throw new Error('not-implemented'); + module.getObjectField('global', key, callback); } module.set = function(key, value, callback) { - throw new Error('not-implemented'); + var data = {}; + data[key] = value; + module.setObject('global', data, callback); } module.keys = function(key, callback) { @@ -238,6 +240,7 @@ throw new Error('not-implemented'); } + // sorted sets module.sortedSetAdd = function(key, score, value, callback) { @@ -352,9 +355,9 @@ return callback(err); } if(data && data.array) { - callback(err, data.array); + callback(null, data.array); } else { - callback(err, []); + callback(null, []); } }); } diff --git a/src/routes/debug.js b/src/routes/debug.js index d59a922f18..807ea584f5 100644 --- a/src/routes/debug.js +++ b/src/routes/debug.js @@ -204,6 +204,34 @@ var DebugRoute = function(app) { }); } + function get(callback) { + db.get('testingStr', function(err, data) { + console.log('get return', data); + callback(err, {'get': data}); + }); + } + + function set(callback) { + db.set('testingStr', 'opppa gangastayla', function(err, data) { + console.log('set return', data); + callback(err, {'set': data}); + }); + } + + function deleteKey(callback) { + db.delete('testingStr', function(err, data) { + console.log('delete return', data); + callback(err, {'delete': data}); + }); + } + + function exists(callback) { + db.exists('testingStr', function(err, data) { + console.log('exists return', data); + callback(err, {'exists': data}); + }); + } + var objectTasks = [ //createUser, @@ -239,7 +267,17 @@ var DebugRoute = function(app) { getListRange ]; - require('async').series(listTasks, function(err, results) { + var keyTasks = [ + get, + set, + get, + exists, + deleteKey, + get, + exists + ]; + + require('async').series(keyTasks, function(err, results) { if(err) { console.log(err); res.send(err.message);