i)ddlZddlmZddlmZddlmZmZmZm Z  ddl Z e e jjdddk\Z ddlZdZ ddlZdZdd lmZd Zed Zd e eefd efdZdZdeeefd eeeffdZdZdZddZddZ dZ!dZ"dede#d efdZ$y#e$rdZYiwxYw#e$rdZYowxYw#e$rdZYuwxYw)N)contextmanagerwraps)AnyDictMappingUnion.FT)metadatac 4ddlm}|j|fi|S)z Returns an active Valkey client generated from the given database URL. Will attempt to extract the database id from the path url fragment, if none is provided. r)Valkey) valkey.clientrfrom_url)urlkwargsrs ?/root/searxng-venv/lib/python3.12/site-packages/valkey/utils.pyrrs% 6??3 )& ))c#TK|j}||jywN)pipelineexecute) valkey_objps rrr+s"A GIIKs&(valuereturncLt|tr|jddS|S)Nzutf-8replace)errors) isinstancebytesdecoders r str_if_bytesr$2s(3=eU3K WY /QVrc*tt|Sr)strr$r#s rsafe_strr'8s |E" ##rdictsc:i}|D]}|j||S)za Merge all provided dicts into 1 dict. *dicts : `dict` dictionaries to merge )update)r(mergedds r dict_merger-<s+ F  a Mrc.tj||Sr)dictfromkeys)key_listcallbacks rlist_keys_to_dictr3Js ==8 ,,rct}|jD]}|D]}|j|t|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)commandresresultvrs r merge_resultr=NsGUF ZZ\ E JJu   <rctddl}d|d}|r |d|dz }|r |d|dz }|j|t|y)NrzCall to deprecated r z ()z -- Deprecated since version )category stacklevel)warningswarnDeprecationWarning)namereasonversionrArBmsgs rwarn_deprecatedrI`sR vQ 'C  F81~ .wiq99 MM# 2zMJrcfd}|S)z5 Decorator to mark a function as deprecated. c6tfd}|S)NcNtxs jd|i|S)N)rA)rI__name__)argsrfuncrErFrGs rwrapperz7deprecated_function..decorator..wrapperqs* D1DMM67q Q(( (rr)rPrQrErFrGs` r decoratorz&deprecated_function..decoratorps t )  )r)rFrGrErRs``` rdeprecated_functionrTks  rc^dtjjjj vrytj d}|j tjtj}|j tj|j|yy)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)loggerhandlers r_set_info_loggerrc{sy gll22==BBDD""?3 %'')&'" Ercj tjd}|S#tj$rd}Y|SwxYw)Nvalkeyz99.99.99)r rGPackageNotFoundError)libvers rget_lib_versionrhs?!!(+ M  ( ( Ms 22 host_error exceptionc|jsd|dSt|jdk(rd|jdd|dSd|jdd|d|jddS)NzError connecting to r zError rz connecting to z. )rOlen)rirjs rformat_error_messagerns~ >>%j\33 Y^^  ! q)*/*QGGY^^A&'zl"~~a ! $ r)ro)roroN)%rW contextlibr functoolsrtypingrrrr libvalkeyint __version__splitLIBVALKEY_AVAILABLE ImportErrorssl SSL_AVAILABLE cryptographyCRYPTOGRAPHY_AVAILABLE importlibr rrr&r!r$r'r-r3r=rIrTrcrh BaseExceptionrnrSrrrs>%,, i3399#>qABaGM#! * c5j)c $ wsCx( T#s(^ -$K  #  S  ]  s  K  M#"#s5+B) B6C)B32B36C?CC  C