node-redis/packages/client/lib/commands/XREAD.spec.ts

import { strict as assert } from 'assert';
import testUtils, { GLOBAL } from '../test-utils';
import { FIRST_KEY_INDEX, transformArguments } from './XREAD';

describe('XREAD', () => {
    describe('FIRST_KEY_INDEX', () => {
        it('single stream', () => {
            assert.equal(
                FIRST_KEY_INDEX({ key: 'key', id: '' }),
                'key'
            );
        });

        it('multiple streams', () => {
            assert.equal(
                FIRST_KEY_INDEX([{ key: '1', id: '' }, { key: '2', id: '' }]),
                '1'
            );
        });
    });

    describe('transformArguments', () => {
        it('single stream', () => {
            assert.deepEqual(
                transformArguments({
                    key: 'key',
                    id: '0'
                }),
                ['XREAD', 'STREAMS', 'key', '0']
            );
        });

        it('multiple streams', () => {
            assert.deepEqual(
                transformArguments([{
                    key: '1',
                    id: '0'
                }, {
                    key: '2',
                    id: '0'
                }]),
                ['XREAD', 'STREAMS', '1', '2', '0', '0']
            );
        });

        it('with COUNT', () => {
            assert.deepEqual(
                transformArguments({
                    key: 'key',
                    id: '0'
                }, {
                    COUNT: 1
                }),
                ['XREAD', 'COUNT', '1', 'STREAMS', 'key', '0']
            );
        });

        it('with BLOCK', () => {
            assert.deepEqual(
                transformArguments({
                    key: 'key',
                    id: '0'
                }, {
                    BLOCK: 0
                }),
                ['XREAD', 'BLOCK', '0', 'STREAMS', 'key', '0']
            );
        });

        it('with COUNT, BLOCK', () => {
            assert.deepEqual(
                transformArguments({
                    key: 'key',
                    id: '0'
                }, {
                    COUNT: 1,
                    BLOCK: 0
                }),
                ['XREAD', 'COUNT', '1', 'BLOCK', '0', 'STREAMS', 'key', '0']
            );
        });
    });

    testUtils.testWithClient('client.xRead', async client => {
        assert.equal(
            await client.xRead({
                key: 'key',
                id: '0'
            }),
            null
        );
    }, GLOBAL.SERVERS.OPEN);

    testUtils.testWithCluster('cluster.xRead', async cluster => {
        assert.equal(
            await cluster.xRead({
                key: 'key',
                id: '0'
            }),
            null
        );
    }, GLOBAL.CLUSTERS.OPEN);
});