Add rename_commands option

2025-08-04 15:02:09 +03:00 · 2015-10-10 05:39:55 +02:00
parent 6d8daef599
commit 972d1cdeb4
5 changed files with 135 additions and 5 deletions
--- a/test/rename.spec.js
+++ b/test/rename.spec.js
@@ -0,0 +1,110 @@
+'use strict';
+
+var assert = require("assert");
+var config = require("./lib/config");
+var helper = require('./helper');
+var redis = config.redis;
+
+describe("rename commands", function () {
+    before(function (done) {
+        helper.stopRedis(function () {
+            helper.startRedis('./conf/rename.conf', done);
+        });
+    });
+
+    helper.allTests(function(parser, ip, args) {
+
+        describe("using " + parser + " and " + ip, function () {
+            var client = null;
+
+            afterEach(function () {
+                client.end();
+            });
+
+            it("allows to use renamed functions", function (done) {
+                if (helper.redisProcess().spawnFailed()) this.skip();
+
+                client = redis.createClient({
+                    rename_commands: {
+                        set: '807081f5afa96845a02816a28b7258c3',
+                        GETRANGE: '9e3102b15cf231c4e9e940f284744fe0'
+                    }
+                });
+
+                client.set('key', 'value', function(err, reply) {
+                    assert.strictEqual(reply, 'OK');
+                });
+
+                client.get('key', function(err, reply) {
+                    assert.strictEqual(err.message, "ERR unknown command 'get'");
+                    assert.strictEqual(err.command, 'GET');
+                    assert.strictEqual(reply, undefined);
+                });
+
+                client.getrange('key', 1, -1, function(err, reply) {
+                    assert.strictEqual(reply, 'alue');
+                    assert.strictEqual(err, null);
+                    done();
+                });
+            });
+
+            it("should also work with multi", function (done) {
+                if (helper.redisProcess().spawnFailed()) this.skip();
+
+                client = redis.createClient({
+                    rename_commands: {
+                        SET: '807081f5afa96845a02816a28b7258c3',
+                        getrange: '9e3102b15cf231c4e9e940f284744fe0'
+                    }
+                });
+
+                client.multi([['set', 'key', 'value']]).exec(function (err, res) {
+                    assert.strictEqual(res[0], 'OK');
+                });
+
+                var multi = client.multi();
+                multi.getrange('key', 1, -1);
+                multi.exec(function (err, res) {
+                    assert(!err);
+                    assert.strictEqual(res.length, 1);
+                    assert.strictEqual(res[0], 'alue');
+                    done();
+                });
+            });
+
+            it("should also work with multi and abort transaction", function (done) {
+                if (helper.redisProcess().spawnFailed()) this.skip();
+
+                client = redis.createClient({
+                    rename_commands: {
+                        SET: '807081f5afa96845a02816a28b7258c3',
+                        getrange: '9e3102b15cf231c4e9e940f284744fe0'
+                    }
+                });
+
+                var multi = client.multi();
+                multi.get('key');
+                multi.getrange('key', 1, -1, function(err, reply) {
+                    assert.strictEqual(reply, 'alue');
+                    assert.strictEqual(err, null);
+                });
+                multi.exec(function (err, res) {
+                    assert(err);
+                    assert.strictEqual(err.message, 'EXECABORT Transaction discarded because of previous errors.');
+                    assert.strictEqual(err.errors[0].message, "ERR unknown command 'get'");
+                    assert.strictEqual(err.errors[0].command, 'GET');
+                    assert.strictEqual(err.code, 'EXECABORT');
+                    assert.strictEqual(err.errors[0].code, 'ERR');
+                    done();
+                });
+            });
+
+        });
+    });
+
+    after(function (done) {
+        helper.stopRedis(function () {
+            helper.startRedis('./conf/redis.conf', done);
+        });
+    });
+});