You've already forked node-redis
mirror of
https://github.com/redis/node-redis.git
synced 2025-08-06 02:15:48 +03:00
fix #2205 - reject commands in connect phase when disableOfflineQueue
is true
This commit is contained in:
@@ -3,7 +3,7 @@ import testUtils, { GLOBAL, waitTillBeenCalled } from '../test-utils';
|
||||
import RedisClient, { RedisClientType } from '.';
|
||||
import { RedisClientMultiCommandType } from './multi-command';
|
||||
import { RedisCommandArguments, RedisCommandRawReply, RedisModules, RedisFunctions, RedisScripts } from '../commands';
|
||||
import { AbortError, ClientClosedError, ConnectionTimeoutError, DisconnectsClientError, SocketClosedUnexpectedlyError, WatchError } from '../errors';
|
||||
import { AbortError, ClientClosedError, ClientOfflineError, ConnectionTimeoutError, DisconnectsClientError, SocketClosedUnexpectedlyError, WatchError } from '../errors';
|
||||
import { defineScript } from '../lua-script';
|
||||
import { spy } from 'sinon';
|
||||
import { once } from 'events';
|
||||
@@ -874,4 +874,20 @@ describe('Client', () => {
|
||||
pingInterval: 1
|
||||
}
|
||||
});
|
||||
|
||||
testUtils.testWithClient('should reject commands in connect phase when `disableOfflineQueue`', async client => {
|
||||
const connectPromise = client.connect();
|
||||
await assert.rejects(
|
||||
client.ping(),
|
||||
ClientOfflineError
|
||||
);
|
||||
await connectPromise;
|
||||
await client.disconnect();
|
||||
}, {
|
||||
...GLOBAL.SERVERS.OPEN,
|
||||
clientOptions: {
|
||||
disableOfflineQueue: true
|
||||
},
|
||||
disableClientSetup: true
|
||||
});
|
||||
});
|
||||
|
Reference in New Issue
Block a user