
    (ph                     h   S SK r S SKrS SKrS SKJrJrJr  S SKrS SKJr  S SK	J
r
  S SKJr  \R                  " \5      r " S S\ R                   " SS	5      \R"                  5      r " S
 S\5      r " S S\R*                  5      r " S S\5      rS\R0                  S\\   S\R4                  4S jrg)    N)CallableOptionalType)_common)cygrpc)MetadataTypec                       \ rS rSrSrg)_AuthMetadataContext    N)__name__
__module____qualname____firstlineno____static_attributes__r       H/var/www/html/venv/lib/python3.13/site-packages/grpc/_plugin_wrapping.pyr
   r
      s     	r   r
   AuthMetadataContext)service_urlmethod_namec                       \ rS rSrS rSrg)_CallbackState)   c                 T    [         R                  " 5       U l        SU l        S U l        g )NF)	threadingLocklockcalled	exception)selfs    r   __init___CallbackState.__init__*   s    NN$	r   )r   r   r   N)r   r   r   r   r!   r   r   r   r   r   r   )   s    r   r   c                   Z    \ rS rSr% \\S'   \\S'   S\S\4S jrS\S\	\
\      4S	 jrS
rg)_AuthMetadataPluginCallback0   _state	_callbackstatecallbackc                     Xl         X l        g N)r&   r'   )r    r(   r)   s      r   r!   $_AuthMetadataPluginCallback.__init__4   s    !r   metadataerrorc           	      N   U R                   R                     U R                   R                  c8  U R                   R                  (       a  [	        S5      eSU R                   l        O.[	        SR                  U R                   R                  5      5      e S S S 5        Uc,  U R                  U[        R                  R                  S 5        g U R                  S [        R                  R                  [        R                  " [        U5      5      5        g ! , (       d  f       N= f)Nz2AuthMetadataPluginCallback invoked more than once!Tz1AuthMetadataPluginCallback raised exception "{}"!)r&   r   r   r   RuntimeErrorformatr'   r   
StatusCodeokinternalr   encodestr)r    r-   r.   s      r   __call__$_AuthMetadataPluginCallback.__call__8   s     [[{{$$,;;%%&L  *.DKK&"GNN--  '  =NN8V%6%6%9%94@NNf''00'..U2L# s   A>D
D$)r'   r&   N)r   r   r   r   r   __annotations__r   r!   r   r   r   BaseExceptionr7   r   r   r   r   r$   r$   0   s@    "n " "$-5d=6I-Jr   r$   c                   l    \ rS rSr% \R
                  \S'   S\R
                  4S jrS\S\S\	4S jr
S	rg
)_PluginQ   _metadata_pluginmetadata_pluginc                 r    Xl         S U l         SS KnUR                  5       U l        g ! [         a     g f = f)Nr   )r>   _stored_ctxcontextvarscopy_contextImportError)r    r?   rB   s      r   r!   _Plugin.__init__T   s=     /		
  +779D 		s   ) 
66r   r   r)   c           
      >   [        [        R                  " U5      [        R                  " U5      5      n[        5       n U R	                  U[        XS5      5        g ! [         a  n[        R                  SU R                  5        UR                     Xel        UR                  (       a   S S S 5         S nAg  S S S 5        O! , (       d  f       O= fU" S [        R                  R                  [        R                  " [        U5      5      5         S nAg S nAff = f)Nz1AuthMetadataPluginCallback "%s" raised exception!)r
   r   decoder   r>   r$   	Exception_LOGGERr   r   r   r   r2   r4   r5   r6   )r    r   r   r)   contextcallback_stater   s          r   r7   _Plugin.__call__c   s    &NN;')D
 ()	!!4^N  	C%%  $$+4(!(( %$( %$$ f''00'..Y2P 	s7    A 
D&,DC+D9	D
C	ADD)r>   rA   N)r   r   r   r   grpcAuthMetadataPluginr9   r!   r6   r   r7   r   r   r   r   r<   r<   Q   s:    ---(?(? C c X r   r<   r?   namereturnc                    Uc   U R                   nOUn[        R                  " [
        R                  " [        U 5      [        R                  " U5      5      5      $ ! [         a    U R                  R                   n Njf = fr+   )
r   AttributeError	__class__rM   CallCredentialsr   MetadataPluginCallCredentialsr<   r   r5   )r?   rO   effective_names      r    metadata_plugin_call_credentialsrW   z   sy     |	@,55N ,,O$gnn^&D	
 	  	@,66??N	@s   A  A?>A?)collectionsloggingr   typingr   r   r   rM   r   grpc._cythonr   grpc._typingr   	getLoggerr   rI   
namedtupler   r
   objectr   AuthMetadataPluginCallbackr$   r<   rN   r6   rT   rW   r   r   r   <module>ra      s       + +    %


H
%
		
 	
	V $"A"A B&f &R,,4<SM	r   