redis/node-redis
1
0
Fork 0
mirror of https://github.com/redis/node-redis.git synced 2025-08-06 02:15:48 +03:00
Code Activity

fix TOPK commands

Browse Source
This commit is contained in:
Leibale
2023-07-26 11:10:28 -04:00
parent 8369448d05
commit 61c3e8b95b
3 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
packages/bloom/lib/commands/top-k/ADD.ts
View File

@@ -1,4 +1,4 @@
import { ArrayReply, SimpleStringReply, Command, RedisArgument } from '@redis/client/dist/lib/RESP/types';
import { RedisArgument, ArrayReply, BlobStringReply, Command } from '@redis/client/dist/lib/RESP/types';
import { RedisVariadicArgument, pushVariadicArguments } from '@redis/client/dist/lib/commands/generic-transformers';
export default {
@@ -7,5 +7,5 @@ export default {
transformArguments(key: RedisArgument, items: RedisVariadicArgument) {
return pushVariadicArguments(['TOPK.ADD', key], items);
},
transformReply: undefined as unknown as () => ArrayReply<SimpleStringReply>
transformReply: undefined as unknown as () => ArrayReply<BlobStringReply>
} as const satisfies Command;

4
packages/bloom/lib/commands/top-k/LIST.ts
View File

@@ -1,4 +1,4 @@
import { RedisArgument, ArrayReply, SimpleStringReply, Command } from '@redis/client/dist/lib/RESP/types';
import { RedisArgument, ArrayReply, BlobStringReply, Command } from '@redis/client/dist/lib/RESP/types';
export default {
FIRST_KEY_INDEX: 1,
@@ -6,5 +6,5 @@ export default {
transformArguments(key: RedisArgument) {
return ['TOPK.LIST', key];
},
transformReply: undefined as unknown as () => ArrayReply<SimpleStringReply>
transformReply: undefined as unknown as () => ArrayReply<BlobStringReply>
} as const satisfies Command;

8
packages/bloom/lib/commands/top-k/LIST_WITHCOUNT.ts
View File

@@ -1,4 +1,4 @@
import { RedisArgument, ArrayReply, SimpleStringReply, NumberReply, UnwrapReply, Command } from '@redis/client/dist/lib/RESP/types';
import { RedisArgument, ArrayReply, BlobStringReply, NumberReply, UnwrapReply, Command } from '@redis/client/dist/lib/RESP/types';
export default {
FIRST_KEY_INDEX: 1,
@@ -6,15 +6,15 @@ export default {
transformArguments(key: RedisArgument) {
return ['TOPK.LIST', key, 'WITHCOUNT'];
},
transformReply(rawReply: UnwrapReply<ArrayReply<SimpleStringReply | NumberReply>>) {
transformReply(rawReply: UnwrapReply<ArrayReply<BlobStringReply | NumberReply>>) {
const reply: Array<{
item: SimpleStringReply;
item: BlobStringReply;
count: NumberReply;
}> = [];
for (let i = 0; i < rawReply.length; i++) {
reply.push({
item: rawReply[i] as SimpleStringReply,
item: rawReply[i] as BlobStringReply,
count: rawReply[++i] as NumberReply
});
}