o h@sddlZddlmZddlmZddlmZmZmZm Z zddl Z e e j dddkZes3edWn ey?dZYnwzddlZd ZWn eySdZYnwzddlZd ZWn eygdZYnwdd lmZd d Zed dZde eefdefddZddZdeeefdeeeffddZddZddZd0ddZd1d d!Z d"d#Z!d$d%Z"d&ed'e#defd(d)Z$d*ed+ede fd,d-Z%d.d/Z&dS)2N)contextmanagerwraps)AnyDictMappingUnion.z"hiredis package should be >= 3.0.0FT)metadatacKsddlm}|j|fi|S)z Returns an active Redis client generated from the given database URL. Will attempt to extract the database id from the path url fragment, if none is provided. r)Redis) redis.clientr from_url)urlkwargsr r=/var/www/html/env/lib/python3.10/site-packages/redis/utils.pyr!s rccs|}|V|dSN)pipelineexecute) redis_objprrrr-s rvaluereturncCst|tr |jdddS|S)Nutf-8replace)errors) isinstancebytesdecoderrrr str_if_bytes4sr!cCs tt|Sr)strr!r rrrsafe_str: r#dictscGsi}|D]}||q|S)za Merge all provided dicts into 1 dict. *dicts : `dict` dictionaries to merge )update)r%mergeddrrr dict_merge>s r)cCs t||Sr)dictfromkeys)key_listcallbackrrrlist_keys_to_dictLr$r.cCs0t}|D] }|D]}||q qt|S)z Merge all items in `res` into a list. This command is used when sending a command to multiple nodes and the result from each node should be merged into a single list. res : 'dict' )setvaluesaddlist)commandresresultvrrrr merge_resultPs   r7cCsPddl}d|d}|r|d|d7}|r|d|d7}|j|t|ddS)NrzCall to deprecated r z ()z -- Deprecated since version )category stacklevel)warningswarnDeprecationWarning)namereasonversionr<r=msgrrrwarn_deprecatedbs rDcsfdd}|S)z5 Decorator to mark a function as deprecated. cstfdd}|S)Ncs$tpjdd|i|S)Nr )r<)rD__name__)argsr)funcr@rArBrrwrapperssz7deprecated_function..decorator..wrapperr)rGrHr@rArB)rGr decoratorrsz&deprecated_function..decoratorr)rArBr@rJrrIrdeprecated_functionmsrKcCsNdtjjjvr%td}|tjt}|tj| |dSdS)zo Set up a logger that log info logs to stdout. (This is used by the default push response handler) push_responseN) loggingrootmanager loggerDictkeys getLoggersetLevelINFO StreamHandler addHandler)loggerhandlerrrr_set_info_logger}s   rYcCs,ztd}W|Stjyd}Y|Sw)Nredisz99.99.99)r rBPackageNotFoundError)libverrrrget_lib_versions r] host_error exceptioncCs\|js d|dSt|jdkrd|jdd|dSd|jdd|d|jddS)NzError connecting to r zError rz connecting to z. )rFlen)r^r_rrrformat_error_messages rbversion1version2cCsttt|d}ttt|d}t|t|kr1t|t|}t|D]}|dq(nt|t|krMt|t|}t|D]}|dqEt|D]\}}||||kr`dS||||krkdSqQdS)z Compare two versions. :return: -1 if version1 > version2 0 if both versions are equal 1 if version1 < version2 r rr`)r2mapintsplitrarangeappend enumerate)rcrd num_versions1 num_versions2diff_iverrrrcompare_versionss$     rrcCs*t|tr |dSt|tr|Std)Nrz$Key must be either a string or bytes)rrrr" TypeError)keyrrr ensure_strings   ru)r8r8r9)r8r8N)'rM contextlibr functoolsrtypingrrrrhiredisrg __version__rhHIREDIS_AVAILABLE ImportErrorssl SSL_AVAILABLE cryptographyCRYPTOGRAPHY_AVAILABLE importlibr rrr"rr!r#r)r.r7rDrKrYr] BaseExceptionrbrrrurrrrsR       "