@@ -36,23 +36,17 @@ def get_connection(cls, decode_responses=True) -> Redis:
36
36
"username" : REDIS_CFG ["username" ],
37
37
"password" : REDIS_CFG ["password" ],
38
38
"ssl" : REDIS_CFG ["ssl" ],
39
+ "ssl_ca_path" : REDIS_CFG ["ssl_ca_path" ],
40
+ "ssl_keyfile" : REDIS_CFG ["ssl_keyfile" ],
41
+ "ssl_certfile" : REDIS_CFG ["ssl_certfile" ],
42
+ "ssl_cert_reqs" : _get_ssl_cert_reqs (REDIS_CFG ["ssl_cert_reqs" ]),
43
+ "ssl_ca_certs" : REDIS_CFG ["ssl_ca_certs" ],
39
44
"decode_responses" : decode_responses ,
40
45
"lib_name" : f"redis-py(mcp-server_v{ __version__ } )" ,
41
46
"max_connections_per_node" : 10
42
47
}
43
-
44
- # Add SSL parameters only if they are not None
45
- if REDIS_CFG ["ssl_ca_path" ]:
46
- connection_params ["ssl_ca_path" ] = REDIS_CFG ["ssl_ca_path" ]
47
- if REDIS_CFG ["ssl_keyfile" ]:
48
- connection_params ["ssl_keyfile" ] = REDIS_CFG ["ssl_keyfile" ]
49
- if REDIS_CFG ["ssl_certfile" ]:
50
- connection_params ["ssl_certfile" ] = REDIS_CFG ["ssl_certfile" ]
51
- if REDIS_CFG ["ssl_ca_certs" ]:
52
- connection_params ["ssl_ca_certs" ] = REDIS_CFG ["ssl_ca_certs" ]
53
- if REDIS_CFG ["ssl_cert_reqs" ]:
54
- connection_params ["ssl_cert_reqs" ] = _get_ssl_cert_reqs (REDIS_CFG ["ssl_cert_reqs" ])
55
48
else :
49
+ print ("Redis config:" , REDIS_CFG , file = sys .stderr )
56
50
redis_class : Type [Union [Redis , RedisCluster ]] = redis .Redis
57
51
connection_params = {
58
52
"host" : REDIS_CFG ["host" ],
@@ -61,22 +55,15 @@ def get_connection(cls, decode_responses=True) -> Redis:
61
55
"username" : REDIS_CFG ["username" ],
62
56
"password" : REDIS_CFG ["password" ],
63
57
"ssl" : REDIS_CFG ["ssl" ],
58
+ "ssl_ca_path" : REDIS_CFG ["ssl_ca_path" ],
59
+ "ssl_keyfile" : REDIS_CFG ["ssl_keyfile" ],
60
+ "ssl_certfile" : REDIS_CFG ["ssl_certfile" ],
61
+ "ssl_cert_reqs" : _get_ssl_cert_reqs (REDIS_CFG ["ssl_cert_reqs" ]),
62
+ "ssl_ca_certs" : REDIS_CFG ["ssl_ca_certs" ],
64
63
"decode_responses" : decode_responses ,
65
64
"lib_name" : f"redis-py(mcp-server_v{ __version__ } )" ,
66
65
"max_connections" : 10
67
66
}
68
-
69
- # Add SSL parameters only if they are not None
70
- if REDIS_CFG ["ssl_ca_path" ]:
71
- connection_params ["ssl_ca_path" ] = REDIS_CFG ["ssl_ca_path" ]
72
- if REDIS_CFG ["ssl_keyfile" ]:
73
- connection_params ["ssl_keyfile" ] = REDIS_CFG ["ssl_keyfile" ]
74
- if REDIS_CFG ["ssl_certfile" ]:
75
- connection_params ["ssl_certfile" ] = REDIS_CFG ["ssl_certfile" ]
76
- if REDIS_CFG ["ssl_ca_certs" ]:
77
- connection_params ["ssl_ca_certs" ] = REDIS_CFG ["ssl_ca_certs" ]
78
- if REDIS_CFG ["ssl_cert_reqs" ]:
79
- connection_params ["ssl_cert_reqs" ] = _get_ssl_cert_reqs (REDIS_CFG ["ssl_cert_reqs" ])
80
67
81
68
cls ._instance = redis_class (** connection_params )
82
69
0 commit comments