You've already forked node-redis
mirror of
https://github.com/redis/node-redis.git
synced 2025-08-06 02:15:48 +03:00
49 lines
1.0 KiB
TypeScript
49 lines
1.0 KiB
TypeScript
import { RedisArgument, CommandArguments, BlobStringReply, ArrayReply, Command } from '../RESP/types';
|
|
|
|
export interface ScanCommonOptions {
|
|
MATCH?: string;
|
|
COUNT?: number;
|
|
}
|
|
|
|
export function pushScanArguments(
|
|
args: CommandArguments,
|
|
cursor: RedisArgument,
|
|
options?: ScanOptions
|
|
): CommandArguments {
|
|
args.push(cursor.toString());
|
|
|
|
if (options?.MATCH) {
|
|
args.push('MATCH', options.MATCH);
|
|
}
|
|
|
|
if (options?.COUNT) {
|
|
args.push('COUNT', options.COUNT.toString());
|
|
}
|
|
|
|
return args;
|
|
}
|
|
|
|
export interface ScanOptions extends ScanCommonOptions {
|
|
TYPE?: RedisArgument;
|
|
}
|
|
|
|
export default {
|
|
FIRST_KEY_INDEX: undefined,
|
|
IS_READ_ONLY: true,
|
|
transformArguments(cursor: RedisArgument, options?: ScanOptions) {
|
|
const args = pushScanArguments(['SCAN'], cursor, options);
|
|
|
|
if (options?.TYPE) {
|
|
args.push('TYPE', options.TYPE);
|
|
}
|
|
|
|
return args;
|
|
},
|
|
transformReply([cursor, keys]: [BlobStringReply, ArrayReply<BlobStringReply>]) {
|
|
return {
|
|
cursor,
|
|
keys
|
|
};
|
|
}
|
|
} as const satisfies Command;
|