(function(RedisDB) { var redis = require('redis'), utils = require('./../public/src/utils.js'), winston = require('winston'), nconf = require('nconf'), redis_socket_or_host = nconf.get('redis:host'); if (redis_socket_or_host && redis_socket_or_host.indexOf('/')>=0) { /* If redis.host contains a path name character, use the unix dom sock connection. ie, /tmp/redis.sock */ RedisDB.exports = redis.createClient(nconf.get('redis:host')) } else { /* Else, connect over tcp/ip */ RedisDB.exports = redis.createClient(nconf.get('redis:port'), nconf.get('redis:host')); } if (nconf.get('redis:password')) { RedisDB.exports.auth(nconf.get('redis:password')); } if( (db = nconf.get('redis:database')) ){ RedisDB.exports.select(db, function(error){ if(error !== null){ winston.err(error); if (global.env !== 'production') { throw new Error(error); } } }); } RedisDB.exports.handle = function(error) { if (error !== null) { winston.err(error); if (global.env !== 'production') { throw new Error(error); } } } /* * A possibly more efficient way of doing multiple sismember calls */ RedisDB.exports.sismembers = function(key, needles, callback) { var tempkey = key + ':temp:' + utils.generateUUID(); RedisDB.exports.sadd(tempkey, needles, function() { RedisDB.exports.sinter(key, tempkey, function(err, data) { RedisDB.exports.del(tempkey); callback(err, data); }); }); }; /* * gets fields of a hash as an object instead of an array */ RedisDB.exports.hmgetObject = function(key, fields, callback) { RedisDB.exports.hmget(key, fields, function(err, data) { if (err === null) { var returnData = {}; for (var i = 0, ii = fields.length; i < ii; ++i) { returnData[fields[i]] = data[i]; } callback(null, returnData); } else { console.log(err); callback(err, null); } }); } }(module));