
    (ph9                        S r SSKrSSKrSSKrSSKJr  SSKJr  SSKJr  SSKJ	r	  SSKJ
r
  SSKJr  SS	KJr  SS
KJr  SSKJr  Sr " S S\R$                  5      r " S S\R(                  5      rS rS r " S S\R0                  5      rS rS rS rS rS r " S S\R>                  " SS5      \R@                  5      r!S r"S r# " S  S!\RH                  5      r% " S" S#\RL                  5      r'S$ r(g)%zCTranslates gRPC's server-side API into gRPC's server-side Beta API.    N)_common)	_metadata)
interfaces)cardinality)style)abandonment)logging_pool)stream)face   c                   &    \ rS rSrS rS rS rSrg)_ServerProtocolContext#   c                     Xl         g N_servicer_contextselfservicer_contexts     P/var/www/html/venv/lib/python3.13/site-packages/grpc/beta/_server_adaptations.py__init___ServerProtocolContext.__init__$       !1    c                 6    U R                   R                  5       $ r   )r   peerr   s    r   r   _ServerProtocolContext.peer'   s    %%**,,r   c                     g r    r   s    r   !disable_next_response_compression8_ServerProtocolContext.disable_next_response_compression*   s    r   r   N)__name__
__module____qualname____firstlineno__r   r   r"   __static_attributes__r!   r   r   r   r   #   s    2-r   r   c                   V    \ rS rSrS rS rS rS rS rS r	S r
S	 rS
 rS rS rSrg)_FaceServicerContext.   c                     Xl         g r   r   r   s     r   r   _FaceServicerContext.__init__/   r   r   c                 6    U R                   R                  5       $ r   )r   	is_activer   s    r   r/   _FaceServicerContext.is_active2   s    %%//11r   c                 6    U R                   R                  5       $ r   )r   time_remainingr   s    r   r2   #_FaceServicerContext.time_remaining5   s    %%4466r   c                     [        S5      e)Nz6add_abortion_callback no longer supported server-side!)NotImplementedError)r   abortion_callbacks     r   add_abortion_callback*_FaceServicerContext.add_abortion_callback8   s    !D
 	
r   c                 8    U R                   R                  5         g r   )r   cancelr   s    r   r:   _FaceServicerContext.cancel=   s    %%'r   c                 ,    [        U R                  5      $ r   )r   r   r   s    r   protocol_context%_FaceServicerContext.protocol_context@   s    %d&<&<==r   c                 ^    [         R                  " U R                  R                  5       5      $ r   )r   betar   invocation_metadatar   s    r   rA   (_FaceServicerContext.invocation_metadataC   s     ~~d44HHJKKr   c                 b    U R                   R                  [        R                  " U5      5        g r   )r   send_initial_metadatar   unbeta)r   initial_metadatas     r   rF   %_FaceServicerContext.initial_metadataF   s%    44-.	
r   c                 b    U R                   R                  [        R                  " U5      5        g r   )r   set_terminal_metadatar   rE   )r   terminal_metadatas     r   rJ   &_FaceServicerContext.terminal_metadataK   s%    44./	
r   c                 :    U R                   R                  U5        g r   )r   set_code)r   codes     r   rN   _FaceServicerContext.codeP   s    ''-r   c                 :    U R                   R                  U5        g r   )r   set_details)r   detailss     r   rR   _FaceServicerContext.detailsS   s    **73r   r   N)r$   r%   r&   r'   r   r/   r2   r7   r:   r=   rA   rF   rJ   rN   rR   r(   r!   r   r   r*   r*   .   s:    227

(>L



.4r   r*   c                    ^  U 4S jnU$ )Nc                 (   > T" U [        U5      5      $ r   r*   )requestr   unary_request_inlines     r   
adaptation/_adapt_unary_request_inline.<locals>.adaptationX   s    #)*:;
 	
r   r!   )rX   rY   s   ` r   _adapt_unary_request_inliner[   W       

 r   c                    ^  U 4S jnU$ )Nc                 (   > T" U [        U5      5      $ r   rV   )request_iteratorr   stream_request_inlines     r   rY   0_adapt_stream_request_inline.<locals>.adaptationa   s    $23CD
 	
r   r!   )r`   rY   s   ` r   _adapt_stream_request_inlinerb   `   r\   r   c                   >    \ rS rSrS rS rS rS rS rS r	S r
S	rg
)	_Callbacki   c                 b    [         R                  " 5       U l        / U l        SU l        SU l        g NF)	threading	Condition
_condition_values_terminated
_cancelledr   s    r   r   _Callback.__init__j   s(    #--/ r   c                     U R                      U R                  R                  U5        U R                   R                  5         S S S 5        g ! , (       d  f       g = fr   )rj   rk   append
notify_allr   values     r   consume_Callback.consumep   s5    __LL&OO&&( __s   6A
Ac                     U R                      SU l        U R                   R                  5         S S S 5        g ! , (       d  f       g = fNT)rj   rl   rq   r   s    r   	terminate_Callback.terminateu   s+    __#DOO&&( __	   "8
Ac                     U R                      U R                  R                  U5        SU l        U R                   R	                  5         S S S 5        g ! , (       d  f       g = frw   )rj   rk   rp   rl   rq   rr   s     r   consume_and_terminate_Callback.consume_and_terminatez   s=    __LL&#DOO&&( __s   =A
A!c                     U R                      SU l        U R                   R                  5         S S S 5        g ! , (       d  f       g = frw   )rj   rm   rq   r   s    r   r:   _Callback.cancel   s*    __"DOOO&&( __rz   c                 d   U R                       U R                  (       a  [        R                  " 5       eU R                  (       a$  U R                  R                  S5      sS S S 5        $ U R                  (       a
   S S S 5        g U R                   R                  5         M  ! , (       d  f       g = fNr   )rj   rm   r   	Abandonedrk   poprl   waitr   s    r   draw_one_value_Callback.draw_one_value   sv    __??%//11\\<<++A. _ %% _ OO((*  _s   AB!*B!B!!
B/c                 4   U R                       U R                  (       a  [        R                  " 5       eU R                  (       a'  [        U R                  5      nS U l        UsS S S 5        $ U R                   R                  5         Mz  ! , (       d  f       g = fr   )rj   rm   r   r   rl   tuplerk   r   )r   
all_valuess     r   draw_all_values_Callback.draw_all_values   si    __??%//11%%!&t||!4J#'DL% _ OO((*  _s   AB	-B		
B)rm   rj   rl   rk   N)r$   r%   r&   r'   r   rt   rx   r|   r:   r   r   r(   r!   r   r   rd   rd   i   s%     )
)
))

+
+r   rd   c                    ^ ^^^ [         R                  " 5       mUU UU4S jn[         R                  " US9nSUl        UR	                  5         g )Nc                  
  > T Hl  n TR                  5       (       a  TR                  5       (       a    g TR                  U 5        TR                  5       (       a  TR                  5       (       d  Ml    g    TR                  5         g r   )r/   is_setrt   rx   )rW   request_consumerr_   r   thread_joineds    r   pipe_requests/_run_request_pipe_thread.<locals>.pipe_requests   si    'G#--//=3G3G3I3I$$W-#--//=3G3G3I3I ( 	""$r   )targetT)rh   EventThreaddaemonstart)r_   r   r   r   request_pipe_threadr   s   ```  @r   _run_request_pipe_threadr      sC     OO%M% % $**-@!%r   c                    ^  U 4S jnU$ )Nc                    > [        5       nUR                  UR                  5      (       d  [        R                  " 5       eT" U UR
                  [        U5      5        UR                  5       S   $ r   )rd   add_callbackr:   r   r   r|   r*   r   )rW   r   callbackunary_unary_events      r   rY   ,_adapt_unary_unary_event.<locals>.adaptation   sa    ;,,X__==''))** !12	

 '')!,,r   r!   )r   rY   s   ` r   _adapt_unary_unary_eventr      s    	- r   c                    ^  U 4S jnU$ )Nc              3      >#    [        5       nUR                  UR                  5      (       d  [        R                  " 5       eT" X[        U5      5         UR                  5       nUc  g Uv   M  7fr   )rd   r   r:   r   r   r*   r   )rW   r   r   responseunary_stream_events       r   rY   -_adapt_unary_stream_event.<locals>.adaptation   sk     ;,,X__==''))34DE	
 ..0H s   A-A0r!   )r   rY   s   ` r   _adapt_unary_stream_eventr      s     r   c                    ^  U 4S jnU$ )Nc                    > [        5       nUR                  UR                  5      (       d  [        R                  " 5       eT" UR
                  [        U5      5      n[        XU5        UR                  5       S   $ r   )	rd   r   r:   r   r   r|   r*   r   r   )r_   r   r   r   stream_unary_events       r   rY   -_adapt_stream_unary_event.<locals>.adaptation   sq    ;,,X__==''))-** !12
 	!0@	
 '')!,,r   r!   )r   rY   s   ` r   _adapt_stream_unary_eventr      s    - r   c                    ^  U 4S jnU$ )Nc              3      >#    [        5       nUR                  UR                  5      (       d  [        R                  " 5       eT" U[        U5      5      n[        XU5         UR                  5       nUc  g Uv   M  7fr   )rd   r   r:   r   r   r*   r   r   )r_   r   r   r   r   stream_stream_events        r   rY   ._adapt_stream_stream_event.<locals>.adaptation   s~     ;,,X__=='')).*+;<
 	!0@	
 ..0H s   A9A<r!   )r   rY   s   ` r   _adapt_stream_stream_eventr      s    " r   c                       \ rS rSrSrg)_SimpleMethodHandler   r!   N)r$   r%   r&   r'   r(   r!   r   r   r   r      s      	r   r   _MethodHandler)request_streamingresponse_streamingrequest_deserializerresponse_serializerunary_unaryunary_streamstream_unarystream_streamc                    U R                   [         R                  R                  L Ga;  U R                  [        R                  R
                  L a%  [        SSUU[        U R                  5      S S S 5      $ U R                  [        R                  R                  L a%  [        SSUUS [        U R                  5      S S 5      $ U R                  [        R                  R                  L a%  [        SSUUS S [        U R                  5      S 5      $ U R                  [        R                  R                  L a%  [        SSUUS S S [        U R                  5      5      $  [3        5       eU R                   [         R                  R                   L Ga0  U R                  [        R                  R
                  L a%  [        SSUU[#        U R$                  5      S S S 5      $ U R                  [        R                  R                  L a%  [        SSUUS ['        U R(                  5      S S 5      $ U R                  [        R                  R                  L a%  [        SSUUS S [+        U R,                  5      S 5      $ U R                  [        R                  R                  L a%  [        SSUUS S S [/        U R0                  5      5      $ [3        5       e)NFT)r   ServiceINLINEr   CardinalityUNARY_UNARYr   r[   unary_unary_inlineUNARY_STREAMunary_stream_inlineSTREAM_UNARYrb   stream_unary_inlineSTREAM_STREAMstream_stream_inlineEVENTr   r   r   r   r   r   r   r   
ValueError)implementationr   r   s      r   _simple_method_handlerr     s    u}}333%%)@)@)L)LL'$#+N,M,MN	 	 '';+B+B+O+OO'$#+N,N,NO	 	 '';+B+B+O+OO'$#,"66   &&+*A*A*O*OO'$#,"77  Pz ,_ 
		!4!4	4%%)@)@)L)LL'$#()I)IJ	 	 '';+B+B+O+OO'$#).*K*KL	 	 '';+B+B+O+OO'$#).*K*KL	 	 &&+*A*A*O*OO'$#*>+M+MN	 	 ,r   c                 x    U =(       d    0 n 0 nU  H&  n[         R                  " US   US   5      nX   X'   M(     U$ )Nr      )r   fully_qualified_method)method_pair_mapflat_mapmethod_pairmethods       r   _flatten_method_pair_mapr   s  sG    %+OH&//AAO*7 ' Or   c                        \ rS rSrS rS rSrg)_GenericRpcHandleri|  c                 p    [        U5      U l        [        U5      U l        [        U5      U l        X l        g r   )r   _method_implementations_request_deserializers_response_serializers_multi_method_implementation)r   method_implementationsmulti_method_implementationrequest_deserializersresponse_serializerss        r   r   _GenericRpcHandler.__init__}  sB     (@"(
$ '?!'
# &> &
" -H)r   c                 L   U R                   R                  UR                  5      nUbS  [        UU R                  R                  UR                  5      U R
                  R                  UR                  5      5      $ U R                  c  g  g ! [        R                   a     g f = fr   )	r   getr   r   r   r   r   r   NoSuchMethodError)r   handler_call_detailsmethod_implementations      r   service_GenericRpcHandler.service  s     $ < < @ @ ''!
 !,)%++//0D0K0KL**../C/J/JK 
 ..6)) s   B#"B#)r   r   r   r   N)r$   r%   r&   r'   r   r   r(   r!   r   r   r   r   |  s    H$r   r   c                   >    \ rS rSrS rS rS rS rS rS r	S r
S	rg
)_Serveri  c                     Xl         g r   _grpc_server)r   grpc_servers     r   r   _Server.__init__  s    'r   c                 8    U R                   R                  U5      $ r   )r   add_insecure_port)r   addresss     r   r   _Server.add_insecure_port  s      227;;r   c                 8    U R                   R                  X5      $ r   )r   add_secure_port)r   r   server_credentialss      r   r   _Server.add_secure_port  s      00MMr   c                 8    U R                   R                  5         g r   r   r   r   s    r   r   _Server.start  s    !r   c                 8    U R                   R                  U5      $ r   r   stop)r   graces     r   r   _Server.stop  s      %%e,,r   c                 :    U R                   R                  5         U $ r   r   r   s    r   	__enter___Server.__enter__  s    !r   c                 :    U R                   R                  S 5        grg   r   )r   exc_typeexc_valexc_tbs       r   __exit___Server.__exit__  s    t$r   r   N)r$   r%   r&   r'   r   r   r   r   r   r   r  r(   r!   r   r   r   r     s&    (<N"-r   r   c                     [        U UUU5      nUc   [        R                  " Uc  [        OU5      nOUn[	        [
        R                  " Xv4S95      $ )N)handlers)r   r	   pool_DEFAULT_POOL_SIZEr   grpcserver)service_implementationsr   r   r   thread_poolthread_pool_sizegeneric_rpc_handlereffective_thread_pools           r   r  r    se     -#	  , 1 1"2":@P!
 !,)4JK r   ))__doc__collectionsrh   r  r   	grpc.betar   r   grpc.framework.commonr   r   grpc.framework.foundationr   r	   r
   grpc.framework.interfaces.facer   r  GRPCServicerContextr   ServicerContextr*   r[   rb   Consumerrd   r   r   r   r   r   
namedtupleRpcMethodHandlerr   r   r   GenericRpcHandlerr   Serverr   r  r!   r   r   <module>r      s    J        - ' 1 2 , /  Z;; &44// &4R2+ 2+j &$"*			
 		&eP#// #Lj 2r   