redis/node-redis
1
0
Fork 0
mirror of https://github.com/redis/node-redis.git synced 2025-08-07 13:22:56 +03:00
Code Activity

Added a test case for detect_buffer behavior in a multi/exec

Browse Source
This commit is contained in:
Raymond Myers
2015-04-01 01:17:13 -07:00
committed by Ray Myers
parent ded75c8ea2
commit 19c5571229
1 changed files with 89 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

89
test/test.js
View File

@@ -792,6 +792,95 @@ tests.detect_buffers = function () {
});
};
tests.detect_buffers_multi = function () {
var name = "detect_buffers_multi", detect_client = redis.createClient({detect_buffers: true});
detect_client.on("ready", function () {
// single Buffer or String
detect_client.set("string key 1", "string value");
detect_client.multi().get("string key 1").exec(require_string("string value", name));
detect_client.multi().get(new Buffer("string key 1")).exec(function (err, reply) {
assert.strictEqual(null, err, name);
assert.strictEqual(1, reply.length, name);
assert.strictEqual(true, Buffer.isBuffer(reply[0]), name);
assert.strictEqual("<Buffer 73 74 72 69 6e 67 20 76 61 6c 75 65>", reply[0].inspect(), name);
});
detect_client.hmset("hash key 2", "key 1", "val 1", "key 2", "val 2");
// array of Buffers or Strings
detect_client.multi().hmget("hash key 2", "key 1", "key 2").exec(function (err, reply) {
assert.strictEqual(null, err, name);
assert.strictEqual(true, Array.isArray(reply), name);
assert.strictEqual(1, reply.length, name);
assert.strictEqual(2, reply[0].length, name);
assert.strictEqual("val 1", reply[0][0], name);
assert.strictEqual("val 2", reply[0][1], name);
});
detect_client.multi().hmget(new Buffer("hash key 2"), "key 1", "key 2").exec(function (err, reply) {
assert.strictEqual(null, err, name);
assert.strictEqual(true, Array.isArray(reply));
assert.strictEqual(1, reply.length, name);
assert.strictEqual(2, reply[0].length, name);
assert.strictEqual(true, Buffer.isBuffer(reply[0][0]));
assert.strictEqual(true, Buffer.isBuffer(reply[0][1]));
assert.strictEqual("<Buffer 76 61 6c 20 31>", reply[0][0].inspect(), name);
assert.strictEqual("<Buffer 76 61 6c 20 32>", reply[0][1].inspect(), name);
});
// array of strings with undefined values (repro #344)
detect_client.multi().hmget("hash key 2", "key 3", "key 4").exec(function(err, reply) {
assert.strictEqual(null, err, name);
assert.strictEqual(true, Array.isArray(reply), name);
assert.strictEqual(1, reply.length, name);
assert.strictEqual(2, reply[0].length, name);
assert.equal(null, reply[0][0], name);
assert.equal(null, reply[0][1], name);
});
// Object of Buffers or Strings
detect_client.multi().hgetall("hash key 2").exec(function (err, reply) {
assert.strictEqual(null, err, name);
assert.strictEqual(1, reply.length, name);
assert.strictEqual("object", typeof reply[0], name);
assert.strictEqual(2, Object.keys(reply[0]).length, name);
assert.strictEqual("val 1", reply[0]["key 1"], name);
assert.strictEqual("val 2", reply[0]["key 2"], name);
});
detect_client.multi().hgetall(new Buffer("hash key 2")).exec(function (err, reply) {
assert.strictEqual(null, err, name);
assert.strictEqual(1, reply.length, name);
assert.strictEqual("object", typeof reply, name);
assert.strictEqual(2, Object.keys(reply[0]).length, name);
assert.strictEqual(true, Buffer.isBuffer(reply[0]["key 1"]));
assert.strictEqual(true, Buffer.isBuffer(reply[0]["key 2"]));
assert.strictEqual("<Buffer 76 61 6c 20 31>", reply[0]["key 1"].inspect(), name);
assert.strictEqual("<Buffer 76 61 6c 20 32>", reply[0]["key 2"].inspect(), name);
});
// Can interleave string and buffer results:
detect_client.multi()
.hget("hash key 2", "key 1")
.hget(new Buffer("hash key 2"), "key 1")
.hget("hash key 2", new Buffer("key 2"))
.hget("hash key 2", "key 2")
.exec(function (err, reply) {
assert.strictEqual(null, err, name);
assert.strictEqual(true, Array.isArray(reply));
assert.strictEqual(4, reply.length, name);
assert.strictEqual("val 1", reply[0], name);
assert.strictEqual(true, Buffer.isBuffer(reply[1]));
assert.strictEqual("<Buffer 76 61 6c 20 31>", reply[1].inspect(), name);
assert.strictEqual(true, Buffer.isBuffer(reply[2]));
assert.strictEqual("<Buffer 76 61 6c 20 32>", reply[2].inspect(), name);
assert.strictEqual("val 2", reply[3], name);
});
detect_client.quit(function (err, res) {
next(name);
});
});
};
tests.socket_nodelay = function () {
var name = "socket_nodelay", c1, c2, c3, ready_count = 0, quit_count = 0;