fix rename and increment

v1.18.x
barisusakli 10 years ago
parent 410d9fa4fa
commit 7cf3719c80

@ -117,12 +117,16 @@ module.exports = function(db, module) {
if (!key) { if (!key) {
return callback(); return callback();
} }
db.collection('objects').update({_key: key}, { $inc: { value: 1 } }, callback); db.collection('objects').findAndModify({_key: key}, {}, {$inc: {value: 1}}, {new: true, upsert: true}, function(err, result) {
callback(err, result ? result.value : null);
});
}; };
module.rename = function(oldKey, newKey, callback) { module.rename = function(oldKey, newKey, callback) {
callback = callback || helpers.noop; callback = callback || helpers.noop;
db.collection('objects').update({_key: oldKey}, {$set:{_key: newKey}}, {multi: true}, callback); db.collection('objects').update({_key: oldKey}, {$set:{_key: newKey}}, {multi: true}, function(err, res) {
callback(err);
});
}; };
module.expire = function(key, seconds, callback) { module.expire = function(key, seconds, callback) {

@ -99,7 +99,9 @@ module.exports = function(redisClient, module) {
}; };
module.rename = function(oldKey, newKey, callback) { module.rename = function(oldKey, newKey, callback) {
redisClient.rename(oldKey, newKey, callback); redisClient.rename(oldKey, newKey, function(err, res) {
callback(err);
});
}; };
module.expire = function(key, seconds, callback) { module.expire = function(key, seconds, callback) {

@ -57,6 +57,12 @@ module.exports = function(app, middleware, controllers) {
}); });
router.get('/test', function(req, res) { router.get('/test', function(req, res) {
res.redirect(404); //res.redirect(404);
var db = require('../database');
db.increment('someDerpKey', function(err, value) {
console.log(err, value);
db.delete('someDerpKey');
res.json('ok');
})
}); });
}; };

Loading…
Cancel
Save