index.js

module.exports = RedisJSONify;

RedisJSONify.blacklist = ["info"];

function RedisJSONify (redis, opts) {
    var lastArgType;
    
    opts = opts || {};

    //save a reference to the real send_command method
    var send_command = redis.internal_send_command || redis.send_command;

    //define the send_command proxy method
    redis.internal_send_command = redis.send_command = function (command, args, callback) {
        var objectMode = false;
        var applyArgs;

        //don't do json stuff on blacklisted commands or if we are not ready yet
        if (!this.ready || ~RedisJSONify.blacklist.indexOf(command) || (command && command.command && ~RedisJSONify.blacklist.indexOf(command.command))) {
            return send_command.apply(redis, arguments);
        }

        if (typeof command === 'object') {
            objectMode = true;

            callback = command.callback;
            args = command.args;
            command.callback = finish;
        }
        else if (!callback) {
            lastArgType = typeof args[args.length - 1];
            if (lastArgType === "function" || lastArgType === "undefined") {
                callback = args.pop();
            }
        }

        //loop through each arg converting to JSON if possible
        args.forEach(function (arg, ix) {
            //only stringify the key if that has been requested
            if (ix === 0 && !opts.jsonKey) {
		        //don't do anything: args[ix] = arg;
            }
            //make sure the arg is not a buffer
            else if (!(arg instanceof Buffer)) {
                args[ix] = JSON.stringify(arg);
            }
        });

        if (objectMode) {
            applyArgs = [command];
        }
        else {
            applyArgs = [command, args, finish];
        }

        //call the real send_command method
        send_command.apply(redis, applyArgs);

        function finish (err, result) {
            if (Array.isArray(result)) {
                //loop through each array element
                result.forEach(function (value, ix) {
                    if (!value instanceof Buffer) {
                        result[ix] = JSON.parse(value);
                    }
                });
            }
            else if (!(result instanceof Buffer) && result !== "OK") {
                try {
                    result = JSON.parse(result);
                }
                catch (e) {
                    console.error("JSON.parse failed on command '%s' with value"
                        + " '%s'. This command may need to be black listed"
                        , command, result);
                }
            }

            return callback && callback(err, result);
        }
    };

    return redis;
}