Loads a JSON object into redis - good for testing. Supports flat keys as well as nested values

redis-loader.js

var redis = require('redis');
var async = require('async');

module.exports = loadRedis;

function loadRedis(opts, cb) {
  var errored = false;
  var client = redis.createClient(opts.redis.port, opts.redis.host);

  client.once('error', function (e) {
    errored = true;
    cb(e);
  });
  client.on('connect', loadIt);

  function loadIt() {
    if (errored) return; // stop if redis failed somehow
    if (!opts.data) return cb();

    async.forEach(Object.keys(opts.data), loadKey.bind(null, opts.data), cb);
  }

  function loadKey(data, key, done) {
    var val = data[key];

    // flat value set
    if (typeof val !== 'object') {
      client.set(key, val, done);
      return;
    }

    // hash set
    async.forEach(Object.keys(val), loadNestedKey.bind(null, val, key), done);
  }

  function loadNestedKey(data, parent, key, done) {
    var val = data[key];
    if (typeof val === 'object') val = JSON.stringify(val);
    client.hset(parent, key, val, done);
  }

  return client;
}