You've already forked node-redis
mirror of
https://github.com/redis/node-redis.git
synced 2025-08-03 04:01:40 +03:00
74 lines
1.9 KiB
TypeScript
74 lines
1.9 KiB
TypeScript
import { CommandParser } from '../client/parser';
|
|
import { RedisArgument, ArrayReply, BlobStringReply, Command } from '../RESP/types';
|
|
import { transformDoubleArgument } from './generic-transformers';
|
|
|
|
export interface VSimOptions {
|
|
COUNT?: number;
|
|
EPSILON?: number;
|
|
EF?: number;
|
|
FILTER?: string;
|
|
'FILTER-EF'?: number;
|
|
TRUTH?: boolean;
|
|
NOTHREAD?: boolean;
|
|
}
|
|
|
|
export default {
|
|
IS_READ_ONLY: true,
|
|
/**
|
|
* Retrieve elements similar to a given vector or element with optional filtering
|
|
*
|
|
* @param parser - The command parser
|
|
* @param key - The key of the vector set
|
|
* @param query - The query vector (array of numbers) or element name (string)
|
|
* @param options - Optional parameters for similarity search
|
|
* @see https://redis.io/commands/vsim/
|
|
*/
|
|
parseCommand(
|
|
parser: CommandParser,
|
|
key: RedisArgument,
|
|
query: RedisArgument | Array<number>,
|
|
options?: VSimOptions
|
|
) {
|
|
parser.push('VSIM');
|
|
parser.pushKey(key);
|
|
|
|
if (Array.isArray(query)) {
|
|
parser.push('VALUES', query.length.toString());
|
|
for (const value of query) {
|
|
parser.push(transformDoubleArgument(value));
|
|
}
|
|
} else {
|
|
parser.push('ELE', query);
|
|
}
|
|
|
|
if (options?.COUNT !== undefined) {
|
|
parser.push('COUNT', options.COUNT.toString());
|
|
}
|
|
|
|
if (options?.EPSILON !== undefined) {
|
|
parser.push('EPSILON', options.EPSILON.toString());
|
|
}
|
|
|
|
if (options?.EF !== undefined) {
|
|
parser.push('EF', options.EF.toString());
|
|
}
|
|
|
|
if (options?.FILTER) {
|
|
parser.push('FILTER', options.FILTER);
|
|
}
|
|
|
|
if (options?.['FILTER-EF'] !== undefined) {
|
|
parser.push('FILTER-EF', options['FILTER-EF'].toString());
|
|
}
|
|
|
|
if (options?.TRUTH) {
|
|
parser.push('TRUTH');
|
|
}
|
|
|
|
if (options?.NOTHREAD) {
|
|
parser.push('NOTHREAD');
|
|
}
|
|
},
|
|
transformReply: undefined as unknown as () => ArrayReply<BlobStringReply>
|
|
} as const satisfies Command;
|