
    ij                     f   d dl Z d dlZd dlZd dlmZmZmZmZ d dlZd dlm	Z	 d dl
mZ d dlmZ  ej                  e      Z G d d e j"                  dd	      ej$                        Z G d
 d      Z G d dej*                        Z G d d      Zdej0                  dee   dej4                  fdZy)    N)CallableOptionalTypeUnion)_common)cygrpc)MetadataTypec                       e Zd Zy)_AuthMetadataContextN)__name__
__module____qualname__     j/var/www/html/emotional.easysim.app/public_html/venv/lib/python3.12/site-packages/grpc/_plugin_wrapping.pyr   r      s     	r   r   AuthMetadataContext)service_urlmethod_namec                       e Zd Zd Zy)_CallbackStatec                 R    t        j                         | _        d| _        d | _        y )NF)	threadingLocklockcalled	exception)selfs    r   __init__z_CallbackState.__init__*   s    NN$	r   N)r   r   r   r   r   r   r   r   r   )   s    r   r   c                   R    e Zd ZU eed<   eed<   dedefdZdedee	e
      dd	fd
Zy	)_AuthMetadataPluginCallback_state	_callbackstatecallbackc                      || _         || _        y N)r!   r"   )r   r#   r$   s      r   r   z$_AuthMetadataPluginCallback.__init__4   s    !r   metadataerrorreturnNc           	         | j                   j                  5  | j                   j                  5| j                   j                  rd}t	        |      d| j                   _        nd}t	        |      	 d d d        |,| j                  |t        j                  j                  d        y | j                  d t        j                  j                  t        j                  t        |                   y # 1 sw Y   xY w)Nz2AuthMetadataPluginCallback invoked more than once!TzEAuthMetadataPluginCallbackraised exception "{self._state.exception}"!)r!   r   r   r   RuntimeErrorr"   r   
StatusCodeokinternalr   encodestr)r   r'   r(   	error_msgs       r   __call__z$_AuthMetadataPluginCallback.__call__8   s     [[ 	.{{$$,;;%%L  'y11%)"B  #9-- #	. =NN8V%6%6%9%94@NNf''00'..U2L#	. 	.s   AC//C8)r   r   r   r   __annotations__r   r   r	   r   r   BaseExceptionr2   r   r   r   r    r    0   sH    "n " "$-5d=6I-J	r   r    c                   x    e Zd ZU ej                  ed<   dej                  fdZdeee	f   deee	f   de
ddfd	Zy)
_Plugin_metadata_pluginmetadata_pluginc                 r    || _         d | _        	 dd l}|j                         | _        y # t        $ r Y y w xY w)Nr   )r7   _stored_ctxcontextvarscopy_contextImportError)r   r8   r;   s      r   r   z_Plugin.__init__T   s?     /		
  +779D 		s   * 	66r   r   r$   r)   Nc           
      &   t        t        j                  |      t        j                  |            }t               }	 | j	                  |t        ||             y # t        $ r}t        j                  d| j                         |j                  5  ||_        |j                  r	 d d d        Y d }~y 	 d d d        n# 1 sw Y   nxY w |d t        j                  j                  t        j                  t        |                   Y d }~y d }~ww xY w)Nz1AuthMetadataPluginCallback "%s" raised exception!)r   r   decoder   r7   r    	Exception_LOGGERr   r   r   r   r,   r.   r/   r0   )r   r   r   r$   contextcallback_stater   s          r   r2   z_Plugin.__call__c   s     'NN;')D
 ()	!!4^XN  	C%%  $$ +4(!(( (   f''00'..Y2P 	s6   A 	D$,DB<%D3	D<C	ADD)r   r   r   grpcAuthMetadataPluginr3   r   r   r0   bytesr   r2   r   r   r   r6   r6   Q   s]    ---(?(? 3:& 3:& 	
 
r   r6   r8   namer)   c                     |	 | j                   }n|}t        j                  t        j                  t        |       t        j                  |                  S # t        $ r | j                  j                   }Y fw xY wr&   )
r   AttributeError	__class__rD   CallCredentialsr   MetadataPluginCallCredentialsr6   r   r/   )r8   rG   effective_names      r    metadata_plugin_call_credentialsrN      sy     |	@,55N ,,O$gnn^&D	
 	  	@,66??N	@s   A A:9A:)collectionsloggingr   typingr   r   r   r   rD   r   grpc._cythonr   grpc._typingr	   	getLoggerr   rA   
namedtupler   r   r   AuthMetadataPluginCallbackr    r6   rE   r0   rK   rN   r   r   r   <module>rW      s       2 2    %
'

H
%
	K	
 	
	 $"A"A B+ +\,,4<SM	r   