U g@sddlZddlmZddlmZddlmZmZmZm Z z0ddl Z e e j dddkZesfedWnek rdZYnXzddlZd ZWnek rdZYnXzddlZd ZWnek rdZYnXdd lmZd d Zed dZe eefedddZddZeeefeeefdddZddZddZd-ddZd.dd Z d!d"Z!d#d$Z"ee#ed%d&d'Z$eee d(d)d*Z%d+d,Z&dS)/N)contextmanagerwraps)AnyDictMappingUnion.z"hiredis package should be >= 3.0.0FT)metadatacKsddlm}|j|f|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)Z redis.clientr from_url)urlkwargsr r//tmp/pip-unpacked-wheel-f3sx1i9r/redis/utils.pyr !s r ccs|}|V|dSN)pipelineexecute)Z redis_objprrrr-sr)valuereturncCst|tr|jdddS|S)Nutf-8replace)errors) isinstancebytesdecoderrrr str_if_bytes4srcCs tt|Sr)strrrrrrsafe_str:sr!)dictsrcGsi}|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)Zkey_listcallbackrrrlist_keys_to_dictLsr*cCs0t}|D]}|D]}||qqt|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  r3cCsPddl}d|d}|r(|d|d7}|r<|d|d7}|j|t|ddS)NrzCall to deprecated r z ()z -- Deprecated since version )category stacklevel)warningswarnDeprecationWarning)namereasonversionr8r9msgrrrwarn_deprecatedbs r@csfdd}|S)z5 Decorator to mark a function as deprecated. cstfdd}|S)Ncs tp jdd||S)Nr )r8)r@__name__)argsr)funcr<r=r>rrwrapperssz7deprecated_function..decorator..wrapperr)rCrDr<r=r>)rCr decoratorrsz&deprecated_function..decoratorr)r=r>r<rFrrErdeprecated_functionmsrGcCsJdtjjjkrFtd}|tjt}|tj| |dS)zo Set up a logger that log info logs to stdout. (This is used by the default push response handler) Z push_responseN) loggingrootmanager loggerDictkeys getLoggersetLevelINFO StreamHandler addHandler)loggerhandlerrrr_set_info_logger}s    rTcCs.ztd}Wntjk r(d}YnX|S)NZredisz99.99.99)r r>ZPackageNotFoundError)Zlibverrrrget_lib_versions  rU) host_error exceptionrcCs`|jsd|dSt|jdkr8d|jdd|dSd|jdd|d|jddSdS)NzError connecting to r zError rz connecting to z. )rBlen)rVrWrrrformat_error_messages  "rZ)version1version2rcCsttt|d}ttt|d}t|t|krbt|t|}t|D]}|dqPn8t|t|krt|t|}t|D]}|dqt|D]4\}}||||krdS||||krdSqdS)z Compare two versions. :return: -1 if version1 > version2 0 if both versions are equal 1 if version1 < version2 r rrX)r.mapintsplitrYrangeappend enumerate)r[r\Z num_versions1Z num_versions2Zdiff_iverrrrcompare_versionss    rgcCs.t|tr|dSt|tr"|StddS)Nrz$Key must be either a string or bytes)rrrr TypeError)keyrrr ensure_strings    rj)r4r4r5)r4r4N)'rH contextlibr functoolsrtypingrrrrZhiredisr_ __version__r`ZHIREDIS_AVAILABLE ImportErrorsslZ SSL_AVAILABLE cryptographyZCRYPTOGRAPHY_AVAILABLE importlibr r rr rrr!r&r*r3r@rGrTrU BaseExceptionrZrgrjrrrrsH