var logging = require('./logging'); var config = require("./config"); var redis = null; var fs = require("fs"); // sets up redis connection // flushes redis when running on heroku (files aren't kept between pushes) function connect_redis() { logging.log("connecting to redis..."); if (process.env.REDISCLOUD_URL) { var redisURL = require("url").parse(process.env.REDISCLOUD_URL); redis = require("redis").createClient(redisURL.port, redisURL.hostname); redis.auth(redisURL.auth.split(":")[1]); } else { redis = require("redis").createClient(); } redis.on("ready", function() { logging.log("Redis connection established."); if(process.env.HEROKU) { logging.log("Running on heroku, flushing redis"); redis.flushall(); } }); redis.on("error", function (err) { logging.error(err); }); redis.on("end", function () { logging.warn("Redis connection lost!"); }); } // sets the date of the face file belonging to +hash+ to now // the helms file is ignored because we only need 1 file to read/write from function update_file_date(hash) { if (hash) { var path = config.faces_dir + hash + ".png"; fs.exists(path, function(exists) { if (exists) { var date = new Date(); fs.utimes(path, date, date, function(err){ if (err) { logging.error(err); } }); } else { logging.error("Tried to update " + path + " date, but it doesn't exist"); } }); } } var exp = {}; exp.get_redis = function() { return redis; }; // sets the timestamp for +uuid+ and its face file's date to now exp.update_timestamp = function(uuid, hash) { logging.log(uuid + " cache: updating timestamp"); var time = new Date().getTime(); redis.hmset(uuid, "t", time); update_file_date(hash); }; // create the key +uuid+, store +hash+ and time exp.save_hash = function(uuid, hash) { logging.log(uuid + " cache: saving hash"); var time = new Date().getTime(); redis.hmset(uuid, "h", hash, "t", time); }; // get a details object for +uuid+ // {hash: "0123456789abcdef", time: 1414881524512} // null when uuid unkown exp.get_details = function(uuid, callback) { redis.hgetall(uuid, function(err, data) { var details = null; if (data) { details = { hash: (data.h == "null" ? null : data.h), time: Number(data.t) }; } callback(err, details); }); }; connect_redis(); module.exports = exp;