o
    f#                     @  s   d Z ddlmZ ddlZddlmZ ddlmZ ddlm	Z	 er:ddlm
Z
 ddlmZmZmZmZmZ dd	lmZ d
ZejdfdddZG dd dZdS )zDebugging support.    )annotationsN)TYPE_CHECKING)wraps)
get_logger)Logger)AnyCallableDictListOptional)	Transport)setup_logging
LogwrappedloglevelOptional[int]loggersOptional[List[str]]returnNonec                 C  s>   |sddgn|}|D ]}t |}|t  ||  q
dS )zSetup logging to stdout.zkombu.connectionzkombu.channelN)r   
addHandlerloggingStreamHandlersetLevel)r   r   logger_namelogger r   D/var/www/html/venv/lib/python3.10/site-packages/kombu/utils/debug.pyr      s   r   c                   @  sB   e Zd ZdZdZ		ddd
dZdddZdddZdddZdS )r   z(Wrap all object methods, to log on call.)	__enter____exit__Ninstancer   r   Optional[Logger]identOptional[str]c                 C  s   || _ t|| _|| _d S N)r   r   r   r!   )selfr   r   r!   r   r   r   __init__&   s   

zLogwrapped.__init__keystrr   r   c                   s>   t j| t r|jv r S t d	 fdd}|S )
Nargs	List[Any]kwargsDict[str, Any]r   r   c                    s   d}j r|j j7 }| j d7 }| r"|dtt| 7 }|r8| r*|d7 }|ddd | D 7 }|d7 }j	|  | i |S )N (z, c                 s  s"    | ]\}}| d |V  qdS )=Nr   ).0r&   valuer   r   r   	<genexpr>A   s    z<Logwrapped.__getattr__.<locals>.__wrapped.<locals>.<genexpr>))
r!   formatr   __name__joinmaprepritemsr   debug)r(   r*   infomethr$   r   r   	__wrapped6   s   
z)Logwrapped.__getattr__.<locals>.__wrapped)r(   r)   r*   r+   r   r   )getattrr   callable_Logwrapped__ignorer   )r$   r&   _Logwrapped__wrappedr   r;   r   __getattr__0   s   zLogwrapped.__getattr__c                 C  
   t | jS r#   )r7   r   r$   r   r   r   __repr__I      
zLogwrapped.__repr__	List[str]c                 C  rC   r#   )dirr   rD   r   r   r   __dir__L   rF   zLogwrapped.__dir__)NN)r   r   r   r    r!   r"   )r&   r'   r   r   )r   r'   )r   rG   )	r4   
__module____qualname____doc__r@   r%   rB   rE   rI   r   r   r   r   r   !   s    


r   )r   r   r   r   r   r   )rL   
__future__r   r   typingr   
vine.utilsr   	kombu.logr   r   r   r   r	   r
   r   kombu.transport.baser   __all__DEBUGr   r   r   r   r   r   <module>   s    