You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
111 lines
2.8 KiB
JavaScript
111 lines
2.8 KiB
JavaScript
"use strict";
|
|
|
|
var winston = require('winston');
|
|
|
|
module.exports = function(db, module) {
|
|
var helpers = module.helpers.mongo;
|
|
|
|
module.searchIndex = function(key, content, id, callback) {
|
|
callback = callback || function() {};
|
|
var data = {
|
|
id: id,
|
|
key: key,
|
|
content: content
|
|
};
|
|
|
|
db.collection('search').update({key:key, id:id}, {$set:data}, {upsert:true, w: 1}, function(err) {
|
|
if(err) {
|
|
winston.error('Error indexing ' + err.message);
|
|
}
|
|
callback(err);
|
|
});
|
|
};
|
|
|
|
module.search = function(key, term, limit, callback) {
|
|
db.collection('search').find({ $text: { $search: term }, key: key}, {limit: limit}).toArray(function(err, results) {
|
|
if(err) {
|
|
return callback(err);
|
|
}
|
|
|
|
if(!results || !results.length) {
|
|
return callback(null, []);
|
|
}
|
|
|
|
var data = results.map(function(item) {
|
|
return item.id;
|
|
});
|
|
|
|
callback(null, data);
|
|
});
|
|
};
|
|
|
|
module.searchRemove = function(key, id, callback) {
|
|
callback = callback || helpers.noop;
|
|
db.collection('search').remove({key:key, id:id}, callback);
|
|
};
|
|
|
|
module.flushdb = function(callback) {
|
|
callback = callback || helpers.noop;
|
|
db.dropDatabase(callback);
|
|
};
|
|
|
|
module.info = function(callback) {
|
|
db.stats({scale:1024}, function(err, stats) {
|
|
if(err) {
|
|
return callback(err);
|
|
}
|
|
|
|
stats.avgObjSize = (stats.avgObjSize / 1024).toFixed(2);
|
|
stats.raw = JSON.stringify(stats, null, 4);
|
|
stats.mongo = true;
|
|
|
|
callback(null, stats);
|
|
});
|
|
};
|
|
|
|
module.exists = function(key, callback) {
|
|
db.collection('objects').findOne({_key:key}, function(err, item) {
|
|
callback(err, item !== undefined && item !== null);
|
|
});
|
|
};
|
|
|
|
module.delete = function(key, callback) {
|
|
callback = callback || helpers.noop;
|
|
db.collection('objects').remove({_key:key}, callback);
|
|
};
|
|
|
|
module.get = function(key, callback) {
|
|
module.getObjectField(key, 'value', callback);
|
|
};
|
|
|
|
module.set = function(key, value, callback) {
|
|
var data = {value:value};
|
|
module.setObject(key, data, callback);
|
|
};
|
|
|
|
module.increment = function(key, callback) {
|
|
callback = callback || helpers.noop;
|
|
db.collection('objects').update({_key: key}, { $inc: { value: 1 } }, callback);
|
|
};
|
|
|
|
module.rename = function(oldKey, newKey, callback) {
|
|
callback = callback || helpers.noop;
|
|
db.collection('objects').update({_key: oldKey}, {$set:{_key: newKey}}, callback);
|
|
};
|
|
|
|
module.expire = function(key, seconds, callback) {
|
|
module.expireAt(key, Math.round(Date.now() / 1000) + seconds, callback);
|
|
};
|
|
|
|
module.expireAt = function(key, timestamp, callback) {
|
|
module.setObjectField(key, 'expireAt', new Date(timestamp * 1000), callback);
|
|
};
|
|
|
|
module.pexpire = function(key, ms, callback) {
|
|
module.expireAt(key, Date.now() + parseInt(ms, 10), callback);
|
|
};
|
|
|
|
module.pexpireAt = function(key, timestamp, callback) {
|
|
module.setObjectField(key, 'expireAt', new Date(timestamp), callback);
|
|
};
|
|
}; |