Skip to content

Commit 9dde283

Browse files
committed
Merge remote-tracking branch 'upstream/v5' into v5-search-broken
2 parents 418f79e + 949b944 commit 9dde283

File tree

6 files changed

+25
-6
lines changed

6 files changed

+25
-6
lines changed

packages/client/lib/commands/CLIENT_KILL.spec.ts

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -65,6 +65,16 @@ describe('CLIENT KILL', () => {
6565
);
6666
});
6767

68+
it('MAXAGE', () => {
69+
assert.deepEqual(
70+
CLIENT_KILL.transformArguments({
71+
filter: CLIENT_KILL_FILTERS.MAXAGE,
72+
maxAge: 10
73+
}),
74+
['CLIENT', 'KILL', 'MAXAGE', '10']
75+
);
76+
});
77+
6878
describe('SKIP_ME', () => {
6979
it('undefined', () => {
7080
assert.deepEqual(

packages/client/lib/commands/CLIENT_KILL.ts

Lines changed: 11 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,8 @@ export const CLIENT_KILL_FILTERS = {
66
ID: 'ID',
77
TYPE: 'TYPE',
88
USER: 'USER',
9-
SKIP_ME: 'SKIPME'
9+
SKIP_ME: 'SKIPME',
10+
MAXAGE: 'MAXAGE'
1011
} as const;
1112

1213
type CLIENT_KILL_FILTERS = typeof CLIENT_KILL_FILTERS;
@@ -39,7 +40,11 @@ export type ClientKillSkipMe = CLIENT_KILL_FILTERS['SKIP_ME'] | (ClientKillFilte
3940
skipMe: boolean;
4041
});
4142

42-
export type ClientKillFilter = ClientKillAddress | ClientKillLocalAddress | ClientKillId | ClientKillType | ClientKillUser | ClientKillSkipMe;
43+
export interface ClientKillMaxAge extends ClientKillFilterCommon<CLIENT_KILL_FILTERS['MAXAGE']> {
44+
maxAge: number;
45+
}
46+
47+
export type ClientKillFilter = ClientKillAddress | ClientKillLocalAddress | ClientKillId | ClientKillType | ClientKillUser | ClientKillSkipMe | ClientKillMaxAge;
4348

4449
export default {
4550
FIRST_KEY_INDEX: undefined,
@@ -96,5 +101,9 @@ function pushFilter(args: Array<RedisArgument>, filter: ClientKillFilter): void
96101
case CLIENT_KILL_FILTERS.SKIP_ME:
97102
args.push(filter.skipMe ? 'yes' : 'no');
98103
break;
104+
105+
case CLIENT_KILL_FILTERS.MAXAGE:
106+
args.push(filter.maxAge.toString());
107+
break;
99108
}
100109
}

packages/search/lib/commands/SUGADD.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@ export interface FtSugAddOptions {
66
}
77

88
export default {
9-
FIRST_KEY_INDEX: undefined,
9+
FIRST_KEY_INDEX: 1,
1010
IS_READ_ONLY: true,
1111
transformArguments(key: RedisArgument, string: RedisArgument, score: number, options?: FtSugAddOptions) {
1212
const args = ['FT.SUGADD', key, string, score.toString()];

packages/search/lib/commands/SUGDEL.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
import { RedisArgument, NumberReply, Command } from '@redis/client/dist/lib/RESP/types';
22

33
export default {
4-
FIRST_KEY_INDEX: undefined,
4+
FIRST_KEY_INDEX: 1,
55
IS_READ_ONLY: true,
66
transformArguments(key: RedisArgument, string: RedisArgument) {
77
return ['FT.SUGDEL', key, string];

packages/search/lib/commands/SUGGET.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@ export interface FtSugGetOptions {
66
}
77

88
export default {
9-
FIRST_KEY_INDEX: undefined,
9+
FIRST_KEY_INDEX: 1,
1010
IS_READ_ONLY: true,
1111
transformArguments(key: RedisArgument, prefix: RedisArgument, options?: FtSugGetOptions) {
1212
const args = ['FT.SUGGET', key, prefix];

packages/search/lib/commands/SUGLEN.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
import { RedisArgument, NumberReply, Command } from '@redis/client/dist/lib/RESP/types';
22

33
export default {
4-
FIRST_KEY_INDEX: undefined,
4+
FIRST_KEY_INDEX: 1,
55
IS_READ_ONLY: true,
66
transformArguments(key: RedisArgument) {
77
return ['FT.SUGLEN', key];

0 commit comments

Comments
 (0)