h8FddlZddlZddlZddlmZmZmZddlZddlm Z ddl m Z m Z ddlmZmZddlmZddlmZdZdd Zdd Zd Zd Zd ZdZdej8fdZdej<fdZde j<fdZ dZ!de j<fdZ"dZ#de$ddfdZ%y)N)ListOptionalUnion) get_secretget_secret_str)REDIS_CONNECTION_POOL_TIMEOUTREDIS_SOCKET_TIMEOUT)SensitiveDataMasker)verbose_loggerctjtj}hd}dg}|jDcgc] }||vs| c}|z}|Scc}wN>selfretryconnection_poolurl)inspectgetfullargspecredisRedisargs)arg_spec exclude_args include_argsxavailable_argss J/var/www/Befach/backend/env/lib/python3.12/site-packages/litellm/_redis.py_get_redis_kwargsrsR%%ekk2HL 7L!)HA!<2GaH<WN Is AAc|tjj}tjtjj}hd}dg}|j Dcgc] }||vs| c}|z}|Scc}wr)rrfrom_urlrrr)clientrrrrrs r_get_redis_url_kwargsr",sl ~%%%%ekk&:&:;HL 7L!)HA!<2GaH<WN Is  A5)A5c8|tjj}tjtj }hd}|j Dcgc] }||vs| }}|jd|jd|jd|Scc}w)N>hostportrr startup_nodesrpasswordusernamessl)rrr rr RedisClusterrappend)r!rrrrs r_get_redis_cluster_kwargsr,?s ~%%%%e&8&89HYL!)HA!<2GaHNH*%*%%  Is  BBcfd}tDcic]}||j|c}Scc}w)NREDIS_)rupper)PREFIXrs r_get_redis_env_kwarg_mappingr1Os2 F/@/B C!vhqwwyk "A % CC Cs.cxt}i}|jD]\}}t|d}||||<|S)N) default_value)r1itemsr)mapping return_dictkvvalues r_redis_kwargs_from_environmentr:UsF*,GK 11D1  "KN  cZdtjvrtjdSdtjvsdtjvr tddtjvrdtjdd}nd}d |tjddtjdS) N REDIS_URL REDIS_HOST REDIS_PORTzUEither 'REDIS_URL' or both 'REDIS_HOST' and 'REDIS_PORT' must be specified for Redis.REDIS_PASSWORD:@zredis://)osenviron ValueError)redis_passwords rget_redis_url_from_environmentrH`sbjj zz+&&2::%RZZ)G c  2::%RZZ(89:!< >"2::l#;"V=WXr;c |jD]J\}}t|ts|jds)|j dd}t |}|||<Lit |}|jddxs t d}|(t|trtj||d<|jddxs t d}|(t|trtj||d<|jddxs td }|||d<|jd dxs t d }|||d <d |vrO|d J|jd d|jdd|jdd|jdd|Sd|vr|d |Sd|vr|d |Sd |vs|d  td|S)zO Common functionality across sync + async redis client implementations z os.environ/rCr&NREDIS_CLUSTER_NODESsentinel_nodesREDIS_SENTINEL_NODESsentinel_passwordREDIS_SENTINEL_PASSWORD service_nameREDIS_SERVICE_NAMErr$r%dbr'z3Either 'host' or 'url' must be specified for redis.) r4 isinstancestr startswithreplacerr:getjsonloadsrpoprF) env_overridesr7r8r9 redis_kwargs_startup_nodes_sentinel_nodes_sentinel_password _service_names r_get_redis_client_logicr`ss/ ##%1 a !,,}"= -,AqME$M!  &  ( * L 2>1A1A/SW1X2\f]N!j&E(, >(B _%2>2B2BCSUY2Z3^h_O"z/3'G)-O)D %&(4(8(8T))3 1 2%,> ()#/#3#3ND#I$ZNM '4 ^$ e!4!@&&t$T*  L (\/-J-V   L(\:J-K-W  | #|F';'CNOO r;returnctd}| tj||d<t j dddlm}t}i}|D]}||vs||||<g}|dD]}|j|di||jdtjdd|i|S#tj$r t dwxYw)NrJr&zbREDIS_CLUSTER_NODES environment variable is not valid JSON. Please ensure it's properly formatted.z8init_redis_cluster: startup nodes are being initialized.r ClusterNode)rrWrXJSONDecodeErrorrFr debug redis.clusterrdr,r+rYrr*)r[_redis_cluster_nodes_in_envrdrcluster_kwargsargnew_startup_nodesitems rinit_redis_clusterrns1;4'   64Hx8.335JC eT*o-%&'E |?$C  00U&'E |3C$D $'J #E I$$S)46$+  " "? 3-O $ $%5 6.O $ $U +1O(%  jEgX6,o>  d eE78 j! l# d K$&$..|<34G3HIJ PJ1#NOOPs*;G?A7G?6EG??rs  (( #.QP$"&  D &;|Q(:(:Q8-%++-0- 0A0A-0'***Z"TPTTPdTPr;