You've already forked node-redis
mirror of
https://github.com/redis/node-redis.git
synced 2025-08-09 00:22:08 +03:00
fix INCRBY
This commit is contained in:
@@ -1,91 +1,91 @@
|
|||||||
import { strict as assert } from 'assert';
|
import { strict as assert } from 'assert';
|
||||||
import testUtils, { GLOBAL } from '../test-utils';
|
import testUtils, { GLOBAL } from '../test-utils';
|
||||||
import { transformArguments } from './INCRBY';
|
import INCRBY from './INCRBY';
|
||||||
|
|
||||||
describe('INCRBY', () => {
|
describe('INCRBY', () => {
|
||||||
describe('transformArguments', () => {
|
describe('transformArguments', () => {
|
||||||
it('without options', () => {
|
it('without options', () => {
|
||||||
assert.deepEqual(
|
assert.deepEqual(
|
||||||
transformArguments('key', 1),
|
INCRBY.transformArguments('key', 1),
|
||||||
['TS.INCRBY', 'key', '1']
|
['TS.INCRBY', 'key', '1']
|
||||||
);
|
);
|
||||||
});
|
|
||||||
|
|
||||||
it('with TIMESTAMP', () => {
|
|
||||||
assert.deepEqual(
|
|
||||||
transformArguments('key', 1, {
|
|
||||||
TIMESTAMP: '*'
|
|
||||||
}),
|
|
||||||
['TS.INCRBY', 'key', '1', 'TIMESTAMP', '*']
|
|
||||||
);
|
|
||||||
});
|
|
||||||
|
|
||||||
it('with RETENTION', () => {
|
|
||||||
assert.deepEqual(
|
|
||||||
transformArguments('key', 1, {
|
|
||||||
RETENTION: 1
|
|
||||||
}),
|
|
||||||
['TS.INCRBY', 'key', '1', 'RETENTION', '1']
|
|
||||||
);
|
|
||||||
});
|
|
||||||
|
|
||||||
it('with UNCOMPRESSED', () => {
|
|
||||||
assert.deepEqual(
|
|
||||||
transformArguments('key', 1, {
|
|
||||||
UNCOMPRESSED: true
|
|
||||||
}),
|
|
||||||
['TS.INCRBY', 'key', '1', 'UNCOMPRESSED']
|
|
||||||
);
|
|
||||||
});
|
|
||||||
|
|
||||||
it('without UNCOMPRESSED', () => {
|
|
||||||
assert.deepEqual(
|
|
||||||
transformArguments('key', 1, {
|
|
||||||
UNCOMPRESSED: false
|
|
||||||
}),
|
|
||||||
['TS.INCRBY', 'key', '1']
|
|
||||||
);
|
|
||||||
});
|
|
||||||
|
|
||||||
it('with CHUNK_SIZE', () => {
|
|
||||||
assert.deepEqual(
|
|
||||||
transformArguments('key', 1, {
|
|
||||||
CHUNK_SIZE: 1
|
|
||||||
}),
|
|
||||||
['TS.INCRBY', 'key', '1', 'CHUNK_SIZE', '1']
|
|
||||||
);
|
|
||||||
});
|
|
||||||
|
|
||||||
it('with LABELS', () => {
|
|
||||||
assert.deepEqual(
|
|
||||||
transformArguments('key', 1, {
|
|
||||||
LABELS: { label: 'value' }
|
|
||||||
}),
|
|
||||||
['TS.INCRBY', 'key', '1', 'LABELS', 'label', 'value']
|
|
||||||
);
|
|
||||||
});
|
|
||||||
|
|
||||||
it('with TIMESTAMP, RETENTION, UNCOMPRESSED, CHUNK_SIZE and LABELS', () => {
|
|
||||||
assert.deepEqual(
|
|
||||||
transformArguments('key', 1, {
|
|
||||||
TIMESTAMP: '*',
|
|
||||||
RETENTION: 1,
|
|
||||||
UNCOMPRESSED: true,
|
|
||||||
CHUNK_SIZE: 1,
|
|
||||||
LABELS: { label: 'value' }
|
|
||||||
}),
|
|
||||||
['TS.INCRBY', 'key', '1', 'TIMESTAMP', '*', 'RETENTION', '1', 'UNCOMPRESSED',
|
|
||||||
'CHUNK_SIZE', '1', 'LABELS', 'label', 'value']
|
|
||||||
);
|
|
||||||
});
|
|
||||||
});
|
});
|
||||||
|
|
||||||
testUtils.testWithClient('client.ts.incrBy', async client => {
|
it('with TIMESTAMP', () => {
|
||||||
assert.equal(
|
assert.deepEqual(
|
||||||
await client.ts.incrBy('key', 1, {
|
INCRBY.transformArguments('key', 1, {
|
||||||
TIMESTAMP: 0
|
TIMESTAMP: '*'
|
||||||
}),
|
}),
|
||||||
0
|
['TS.INCRBY', 'key', '1', 'TIMESTAMP', '*']
|
||||||
);
|
);
|
||||||
}, GLOBAL.SERVERS.OPEN);
|
});
|
||||||
|
|
||||||
|
it('with RETENTION', () => {
|
||||||
|
assert.deepEqual(
|
||||||
|
INCRBY.transformArguments('key', 1, {
|
||||||
|
RETENTION: 1
|
||||||
|
}),
|
||||||
|
['TS.INCRBY', 'key', '1', 'RETENTION', '1']
|
||||||
|
);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('with UNCOMPRESSED', () => {
|
||||||
|
assert.deepEqual(
|
||||||
|
INCRBY.transformArguments('key', 1, {
|
||||||
|
UNCOMPRESSED: true
|
||||||
|
}),
|
||||||
|
['TS.INCRBY', 'key', '1', 'UNCOMPRESSED']
|
||||||
|
);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('without UNCOMPRESSED', () => {
|
||||||
|
assert.deepEqual(
|
||||||
|
INCRBY.transformArguments('key', 1, {
|
||||||
|
UNCOMPRESSED: false
|
||||||
|
}),
|
||||||
|
['TS.INCRBY', 'key', '1']
|
||||||
|
);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('with CHUNK_SIZE', () => {
|
||||||
|
assert.deepEqual(
|
||||||
|
INCRBY.transformArguments('key', 1, {
|
||||||
|
CHUNK_SIZE: 1
|
||||||
|
}),
|
||||||
|
['TS.INCRBY', 'key', '1', 'CHUNK_SIZE', '1']
|
||||||
|
);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('with LABELS', () => {
|
||||||
|
assert.deepEqual(
|
||||||
|
INCRBY.transformArguments('key', 1, {
|
||||||
|
LABELS: { label: 'value' }
|
||||||
|
}),
|
||||||
|
['TS.INCRBY', 'key', '1', 'LABELS', 'label', 'value']
|
||||||
|
);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('with TIMESTAMP, RETENTION, UNCOMPRESSED, CHUNK_SIZE and LABELS', () => {
|
||||||
|
assert.deepEqual(
|
||||||
|
INCRBY.transformArguments('key', 1, {
|
||||||
|
TIMESTAMP: '*',
|
||||||
|
RETENTION: 1,
|
||||||
|
UNCOMPRESSED: true,
|
||||||
|
CHUNK_SIZE: 1,
|
||||||
|
LABELS: { label: 'value' }
|
||||||
|
}),
|
||||||
|
['TS.INCRBY', 'key', '1', 'TIMESTAMP', '*', 'RETENTION', '1', 'UNCOMPRESSED',
|
||||||
|
'CHUNK_SIZE', '1', 'LABELS', 'label', 'value']
|
||||||
|
);
|
||||||
|
});
|
||||||
|
});
|
||||||
|
|
||||||
|
testUtils.testWithClient('client.ts.incrBy', async client => {
|
||||||
|
assert.equal(
|
||||||
|
await client.ts.incrBy('key', 1, {
|
||||||
|
TIMESTAMP: 0
|
||||||
|
}),
|
||||||
|
0
|
||||||
|
);
|
||||||
|
}, GLOBAL.SERVERS.OPEN);
|
||||||
});
|
});
|
||||||
|
@@ -1,10 +1,11 @@
|
|||||||
import { RedisCommandArguments } from '@redis/client/dist/lib/commands';
|
|
||||||
import { IncrDecrOptions, transformIncrDecrArguments } from '.';
|
import { IncrDecrOptions, transformIncrDecrArguments } from '.';
|
||||||
|
import { RedisArgument, NumberReply, Command } from '@redis/client/dist/lib/RESP/types';
|
||||||
|
|
||||||
export const FIRST_KEY_INDEX = 1;
|
export default {
|
||||||
|
FIRST_KEY_INDEX: 1,
|
||||||
export function transformArguments(key: string, value: number, options?: IncrDecrOptions): RedisCommandArguments {
|
IS_READ_ONLY: false,
|
||||||
|
transformArguments(key: RedisArgument, value: number, options?: IncrDecrOptions) {
|
||||||
return transformIncrDecrArguments('TS.INCRBY', key, value, options);
|
return transformIncrDecrArguments('TS.INCRBY', key, value, options);
|
||||||
}
|
},
|
||||||
|
transformReply: undefined as unknown as () => NumberReply
|
||||||
export declare function transformReply(): number;
|
} as const satisfies Command;
|
||||||
|
Reference in New Issue
Block a user