File tree 1 file changed +7
-9
lines changed 1 file changed +7
-9
lines changed Original file line number Diff line number Diff line change 5
5
6
6
7
7
@lru_cache (maxsize = None )
8
- async def get_modules (conn ) -> List [str ]:
9
- modules = await conn .execute_command ("module" , "list" )
10
- return [m [1 ] for m in modules ]
11
-
8
+ async def check_for_command (conn , cmd ):
9
+ cmd_info = await conn .execute_command ("command" , "info" , cmd )
10
+ return not None in cmd_info
12
11
13
12
@lru_cache (maxsize = None )
14
13
async def has_redis_json (conn = None ):
15
14
if conn is None :
16
15
conn = get_redis_connection ()
17
- names = await get_modules (conn )
18
- return b"ReJSON" in names or "ReJSON" in names
19
-
16
+ command_exists = await check_for_command (conn , "json.set" )
17
+ return command_exists
20
18
21
19
@lru_cache (maxsize = None )
22
20
async def has_redisearch (conn = None ):
23
21
if conn is None :
24
22
conn = get_redis_connection ()
25
23
if has_redis_json (conn ):
26
24
return True
27
- names = await get_modules (conn )
28
- return b"search" in names or "search" in names
25
+ command_exists = await check_for_command (conn , "ft.search" )
26
+ return command_exists
You can’t perform that action at this time.
0 commit comments