You've already forked node-redis
mirror of
https://github.com/redis/node-redis.git
synced 2025-08-06 02:15:48 +03:00
45 lines
1.2 KiB
TypeScript
45 lines
1.2 KiB
TypeScript
import { RedisArgument, VerbatimStringReply, Command } from '../RESP/types';
|
|
import { pushVariadicArguments } from './generic-transformers';
|
|
import CLIENT_INFO, { ClientInfoReply } from './CLIENT_INFO';
|
|
|
|
export interface ListFilterType {
|
|
TYPE: 'NORMAL' | 'MASTER' | 'REPLICA' | 'PUBSUB';
|
|
ID?: never;
|
|
}
|
|
|
|
export interface ListFilterId {
|
|
ID: Array<RedisArgument>;
|
|
TYPE?: never;
|
|
}
|
|
|
|
export type ListFilter = ListFilterType | ListFilterId;
|
|
|
|
export default {
|
|
FIRST_KEY_INDEX: undefined,
|
|
IS_READ_ONLY: true,
|
|
transformArguments(filter?: ListFilter) {
|
|
let args: Array<RedisArgument> = ['CLIENT', 'LIST'];
|
|
|
|
if (filter) {
|
|
if (filter.TYPE !== undefined) {
|
|
args.push('TYPE', filter.TYPE);
|
|
} else {
|
|
args.push('ID');
|
|
args = pushVariadicArguments(args, filter.ID);
|
|
}
|
|
}
|
|
|
|
return args;
|
|
},
|
|
transformReply(rawReply: VerbatimStringReply): Array<ClientInfoReply> {
|
|
const split = rawReply.toString().split('\n'),
|
|
length = split.length - 1,
|
|
reply: Array<ClientInfoReply> = [];
|
|
for (let i = 0; i < length; i++) {
|
|
reply.push(CLIENT_INFO.transformReply(split[i] as unknown as VerbatimStringReply));
|
|
}
|
|
|
|
return reply;
|
|
}
|
|
} as const satisfies Command;
|