You've already forked node-redis
mirror of
https://github.com/redis/node-redis.git
synced 2025-08-04 15:02:09 +03:00
* Support new muilti pop commands
* remove .only
* clean code
* fix for 4558ec6a31
* fix tests
Co-authored-by: leibale <leibale1998@gmail.com>
66 lines
1.6 KiB
TypeScript
66 lines
1.6 KiB
TypeScript
import { strict as assert } from 'assert';
|
|
import testUtils, { GLOBAL } from '../test-utils';
|
|
import { transformArguments, transformReply } from './BZPOPMIN';
|
|
import { commandOptions } from '../../index';
|
|
|
|
describe('BZPOPMIN', () => {
|
|
describe('transformArguments', () => {
|
|
it('single', () => {
|
|
assert.deepEqual(
|
|
transformArguments('key', 0),
|
|
['BZPOPMIN', 'key', '0']
|
|
);
|
|
});
|
|
|
|
it('multiple', () => {
|
|
assert.deepEqual(
|
|
transformArguments(['1', '2'], 0),
|
|
['BZPOPMIN', '1', '2', '0']
|
|
);
|
|
});
|
|
});
|
|
|
|
describe('transformReply', () => {
|
|
it('null', () => {
|
|
assert.equal(
|
|
transformReply(null),
|
|
null
|
|
);
|
|
});
|
|
|
|
it('member', () => {
|
|
assert.deepEqual(
|
|
transformReply(['key', 'value', '1']),
|
|
{
|
|
key: 'key',
|
|
value: 'value',
|
|
score: 1
|
|
}
|
|
);
|
|
});
|
|
});
|
|
|
|
testUtils.testWithClient('client.bzPopMin', async client => {
|
|
const [ bzPopMinReply ] = await Promise.all([
|
|
client.bzPopMin(
|
|
commandOptions({ isolated: true }),
|
|
'key',
|
|
1
|
|
),
|
|
client.zAdd('key', [{
|
|
value: '1',
|
|
score: 1
|
|
}])
|
|
]);
|
|
|
|
assert.deepEqual(
|
|
bzPopMinReply,
|
|
{
|
|
key: 'key',
|
|
value: '1',
|
|
score: 1
|
|
}
|
|
);
|
|
}, GLOBAL.SERVERS.OPEN);
|
|
});
|