
    ^f#                        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Z G 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                    |sddgn|}|D ]L}t          |          }|                    t          j                               |                    |            MdS )zSetup logging to stdout.zkombu.connectionzkombu.channelN)r   
addHandlerloggingStreamHandlersetLevel)r   r   logger_nameloggers       C/var/www/html/env/lib/python3.11/site-packages/kombu/utils/debug.pyr   r      sr    
 <CO!?33G " "K(('/11222!!!!" "    c                  <    e Zd ZdZdZ	 	 ddd
ZddZddZ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                J    || _         t          |          | _        || _        d S N)r"   r   r   r$   )selfr"   r   r$   s       r   __init__zLogwrapped.__init__&   s%     ! ((


r   keystrr   r	   c                     t           j        |          t                    r	| j        v rS t	                    d fd            }|S )	Nargs	List[Any]kwargsDict[str, Any]r   r	   c                    d}j         r"|j                             j                  z  }|j         dz  }| r+|d                    t          t          |                     z  }|r;| r|dz  }|d                    d |                                D                       z  }|dz  }j        	                    |            | i |S )N (z, c              3  *   K   | ]\  }}| d |V  dS )=N ).0r*   values      r   	<genexpr>z<Logwrapped.__getattr__.<locals>.__wrapped.<locals>.<genexpr>A   sP       "D "D&0c5 &)"4"45"4"4 "D "D "D "D "D "Dr   ))
r$   formatr"   __name__joinmaprepritemsr   debug)r-   r/   infomethr(   s      r   	__wrappedz)Logwrapped.__getattr__.<locals>.__wrapped6   s    Dz 9
))$-888t}''''D 3		#dD//222 D !DLD		 "D "D4:LLNN"D "D "D D D DCKDKd###4((((r   )r-   r.   r/   r0   r   r	   )getattrr"   callable_Logwrapped__ignorer   )r(   r*   _Logwrapped__wrappedrC   s   `  @r   __getattr__zLogwrapped.__getattr__0   so    t}c**~~ 	!5!5K	t	) 	) 	) 	) 	) 	) 
	)  r   c                *    t          | j                  S r'   )r?   r"   r(   s    r   __repr__zLogwrapped.__repr__I   s    DM"""r   	List[str]c                *    t          | j                  S r'   )dirr"   rK   s    r   __dir__zLogwrapped.__dir__L   s    4=!!!r   )NN)r"   r   r   r#   r$   r%   )r*   r+   r   r	   )r   r+   )r   rM   )	r<   
__module____qualname____doc__rG   r)   rI   rL   rP   r6   r   r   r   r   !   s|        22(H
 $(#	       2# # # #" " " " " "r   r   )r   r   r   r   r   r   )rS   
__future__r   r   typingr   
vine.utilsr   	kombu.logr   r   r   r	   r
   r   r   kombu.transport.baser   __all__DEBUGr   r   r6   r   r   <module>r[      s     " " " " " "                                /::::::::::::::......
) &m#'	" 	" 	" 	" 	"," ," ," ," ," ," ," ," ," ,"r   