a

��bv�@s�dd
lm
Z

ddlmZmZmZmZ
zddlZdZWne	yJ


dZYn0zddl
Z
dZWne	yr


dZYn0dd�Ze
dd	��
Z
eeefed
�dd�Zd
d�Zeeefeeefd�dd�Zdd�Zdd�ZdS)�)
�contextmanager)�Any�Dict�Mapping�UnionNTFc
Ksd
dlm
}
|j|f
i|
�
�
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)�url�kwargsr�r�//usr/lib/python3.9/site-packages/redis/utils.pyrsrc
cs|��}
|
V
|
�
�
dS�
N)�pipelineZexecute)Z	redis_obj�
prrrrs

r)�value�returnc

Cst|t
�r|jd
dd�S|S)Nzutf-8�replace)
�errors)�
isinstance�bytes�decode�
rrrr�str_if_bytes&s�rc

Cstt
|�
�
Sr
)�strrrrrr�safe_str,s
r)�dictsrcGsi}
|D]}|
�|�

q|
S)
za
    Merge all provided dicts into 1 dict.
    *dicts : `dict`
        dictionaries to merge
    )
�update)rZmerged�
drrr�
dict_merge0s
rcCst�
||
�Sr
)�dict�fromkeys)Zkey_list�callbackrrr�list_keys_to_dict>s
r"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'
    )�set�values�add�list)Zcommand�res�result�
vrrrr�merge_resultBs
	

r*)�
contextlibr�typingrrrrZhiredisZHIREDIS_AVAILABLE�ImportErrorZcryptographyZCRYPTOGRAPHY_AVAILABLErrrrrrrr"r*rrrr�<module>
s&