1
0
mirror of https://github.com/redis/node-redis.git synced 2025-08-06 02:15:48 +03:00
Files
node-redis/packages/client/lib/commands/PUBSUB_SHARDNUMSUB.ts
2023-09-19 19:23:24 -04:00

25 lines
821 B
TypeScript

import { ArrayReply, BlobStringReply, NumberReply, UnwrapReply, Command } from '../RESP/types';
import { RedisVariadicArgument, pushVariadicArguments } from './generic-transformers';
export default {
FIRST_KEY_INDEX: undefined,
IS_READ_ONLY: true,
transformArguments(channels?: RedisVariadicArgument) {
const args = ['PUBSUB', 'SHARDNUMSUB'];
if (channels) return pushVariadicArguments(args, channels);
return args;
},
transformReply(reply: UnwrapReply<ArrayReply<BlobStringReply | NumberReply>>) {
const transformedReply: Record<string, NumberReply> = Object.create(null);
for (let i = 0; i < reply.length; i += 2) {
transformedReply[(reply[i] as BlobStringReply).toString()] = reply[i + 1] as NumberReply;
}
return transformedReply;
}
} as const satisfies Command;