redis/node-redis
1
0
Fork 0
mirror of https://github.com/redis/node-redis.git synced 2025-08-06 02:15:48 +03:00
Code Activity

Attempt evalsha before eval

Browse Source 
Fix #253

Signed-off-by: DTrejo <david.trejo@voxer.com>
This commit is contained in:
Kevin Ingersoll
2012-08-14 20:17:41 -07:00
committed by DTrejo
parent 58804e6e27
commit c8103928b4
1 changed files with 31 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
index.js
View File

@@ -5,6 +5,7 @@ var net = require("net"),
Queue = require("./lib/queue"), Queue = require("./lib/queue"),
to_array = require("./lib/to_array"), to_array = require("./lib/to_array"),
events = require("events"), events = require("events"),
crypto = require("crypto"),
parsers = [], commands, parsers = [], commands,
connection_id = 0, connection_id = 0,
default_port = 6379, default_port = 6379,
@@ -1059,6 +1060,36 @@ RedisClient.prototype.MULTI = function (args) {
return new Multi(this, args); return new Multi(this, args);
}; };
// stash original eval method
var eval = RedisClient.prototype.eval;
// hook eval with an attempt to evalsha for cached scripts
RedisClient.prototype.eval =
RedisClient.prototype.EVAL = function () {
var self = this,
args = to_array(arguments),
callback;
if (typeof args[args.length - 1] === "function") {
callback = args.pop();
}
// replace script source with sha value
var source = args[0];
args[0] = crypto.createHash("sha1").update(source).digest("hex");
self.evalsha(args, function (err, reply) {
if (err && /NOSCRIPT/.test(err.message)) {
args[0] = source;
eval.call(self, args, callback);
} else if (callback) {
callback(err, reply);
}
});
};
exports.createClient = function (port_arg, host_arg, options) { exports.createClient = function (port_arg, host_arg, options) {
var port = port_arg || default_port, var port = port_arg || default_port,
host = host_arg || default_host, host = host_arg || default_host,