'use strict'; var assert = require('assert'); var config = require("../lib/config"); var helper = require('../helper'); var redis = config.redis; describe("The 'select' method", function () { helper.allTests(function(parser, ip, args) { describe("using " + parser + " and " + ip, function () { describe("when not connected", function () { var client; beforeEach(function (done) { client = redis.createClient.apply(redis.createClient, args); client.once("ready", function () { client.quit(); }); client.on('end', function () { return done(); }); }); it("returns an error if redis is not connected", function (done) { var buffering = client.select(1, function (err, res) { assert(err.message.match(/The connection has already been closed/)); done(); }); assert(typeof buffering === 'boolean'); }); }); describe("when connected", function () { var client; beforeEach(function (done) { client = redis.createClient.apply(redis.createClient, args); client.once("ready", function () { done(); }); }); afterEach(function () { client.end(); }); it("changes the database and calls the callback", function (done) { // default value of null means database 0 will be used. assert.strictEqual(client.selected_db, null, "default db should be null"); var buffering = client.SELECT(1, function (err, res) { helper.isNotError()(err, res); assert.strictEqual(client.selected_db, 1, "db should be 1 after select"); done(); }); assert(typeof buffering === 'boolean'); }); describe("and a callback is specified", function () { describe("with a valid db index", function () { it("selects the appropriate database", function (done) { assert.strictEqual(client.selected_db, null, "default db should be null"); client.select(1, function (err) { assert.equal(err, null); assert.equal(client.selected_db, 1, "we should have selected the new valid DB"); return done(); }); }); }); describe("with an invalid db index", function () { it("returns an error", function (done) { assert.strictEqual(client.selected_db, null, "default db should be null"); client.select(9999, function (err) { assert.equal(err.code, 'ERR'); assert.equal(err.message, 'ERR invalid DB index'); return done(); }); }); }); }); describe("and no callback is specified", function () { describe("with a valid db index", function () { it("selects the appropriate database", function (done) { assert.strictEqual(client.selected_db, null, "default db should be null"); client.select(1); setTimeout(function () { assert.equal(client.selected_db, 1, "we should have selected the new valid DB"); return done(); }, 100); }); }); describe("with an invalid db index", function () { it("emits an error when callback not provided", function (done) { assert.strictEqual(client.selected_db, null, "default db should be null"); client.on('error', function (err) { assert.strictEqual(err.command, 'SELECT'); assert.equal(err.message, 'ERR invalid DB index'); done(); }); client.select(9999); }); }); }); }); }); }); });