Ë
    øÿæi–8  ã                   óì  — d Z ddlZddlZddlZddlmZ ddlmZ ddlmZ ddlm	Z	 ddlm
Z
 ddlmZ dd	lmZ dd
lmZ ddlmZ dZ G d„ dej$                  «      Z G d„ dej(                  «      Zd„ Zd„ Z G d„ dej0                  «      Zd„ Zd„ Zd„ Zd„ Zd„ Z G d„ d ej>                  dd«      ej@                  «      Z!d„ Z"d„ Z# G d „ d!ejH                  «      Z% G d"„ d#ejL                  «      Z'd$„ Z(y)%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                   ó   — e Zd Zd„ Zd„ Zd„ Zy)Ú_ServerProtocolContextc                 ó   — || _         y ©N©Ú_servicer_context©ÚselfÚservicer_contexts     úr/Volumes/fast/ai/experiments/voice-extract-mac/.venv/lib/python3.12/site-packages/grpc/beta/_server_adaptations.pyÚ__init__z_ServerProtocolContext.__init__$   ó
   € Ø!1ˆÕó    c                 ó6   — | j                   j                  «       S r   )r   Úpeer©r   s    r   r   z_ServerProtocolContext.peer'   s   € Ø×%Ñ%×*Ñ*Ó,Ð,r   c                  ó   — y r   © r   s    r   Ú!disable_next_response_compressionz8_ServerProtocolContext.disable_next_response_compression*   s   € Ør   N)Ú__name__Ú
__module__Ú__qualname__r   r   r   r   r   r   r   r   #   s   „ ò2ò-ór   r   c                   óN   — e Zd Zd„ Zd„ Zd„ Zd„ Zd„ Zd„ Zd„ Z	d„ Z
d	„ Zd
„ Zd„ Zy)Ú_FaceServicerContextc                 ó   — || _         y r   r   r   s     r   r   z_FaceServicerContext.__init__/   r   r   c                 ó6   — | j                   j                  «       S r   )r   Ú	is_activer   s    r   r'   z_FaceServicerContext.is_active2   s   € Ø×%Ñ%×/Ñ/Ó1Ð1r   c                 ó6   — | j                   j                  «       S r   )r   Útime_remainingr   s    r   r)   z#_FaceServicerContext.time_remaining5   s   € Ø×%Ñ%×4Ñ4Ó6Ð6r   c                 ó   — d}t        |«      ‚)Nz6add_abortion_callback no longer supported server-side!)ÚNotImplementedError)r   Úabortion_callbackÚ	error_msgs      r   Úadd_abortion_callbackz*_FaceServicerContext.add_abortion_callback8   s   € ØLˆ	Ü! )Ó,Ð,r   c                 ó8   — | j                   j                  «        y r   )r   Úcancelr   s    r   r0   z_FaceServicerContext.cancel<   s   € Ø×Ñ×%Ñ%Õ'r   c                 ó,   — t        | j                  «      S r   )r   r   r   s    r   Úprotocol_contextz%_FaceServicerContext.protocol_context?   s   € Ü% d×&<Ñ&<Ó=Ð=r   c                 ó\   — t        j                  | j                  j                  «       «      S r   )r   Úbetar   Úinvocation_metadatar   s    r   r5   z(_FaceServicerContext.invocation_metadataB   s    € Ü�~‰~˜d×4Ñ4×HÑHÓJÓKÐKr   c                 ó`   — | j                   j                  t        j                  |«      «       y r   )r   Úsend_initial_metadatar   Úunbeta)r   Úinitial_metadatas     r   r9   z%_FaceServicerContext.initial_metadataE   s%   € Ø×Ñ×4Ñ4Ü×ÑÐ-Ó.õ	
r   c                 ó`   — | j                   j                  t        j                  |«      «       y r   )r   Úset_terminal_metadatar   r8   )r   Úterminal_metadatas     r   r<   z&_FaceServicerContext.terminal_metadataJ   s%   € Ø×Ñ×4Ñ4Ü×ÑÐ.Ó/õ	
r   c                 ó:   — | j                   j                  |«       y r   )r   Úset_code)r   Úcodes     r   r?   z_FaceServicerContext.codeO   s   € Ø×Ñ×'Ñ'¨Õ-r   c                 ó:   — | j                   j                  |«       y r   )r   Úset_details)r   Údetailss     r   rB   z_FaceServicerContext.detailsR   s   € Ø×Ñ×*Ñ*¨7Õ3r   N)r    r!   r"   r   r'   r)   r.   r0   r2   r5   r9   r<   r?   rB   r   r   r   r$   r$   .   s:   „ ò2ò2ò7ò-ò(ò>òLò
ò

ò
.ó4r   r$   c                 ó   ‡ — ˆ fd„}|S )Nc                 ó(   •—  ‰| t        |«      «      S r   ©r$   )Úrequestr   Úunary_request_inlines     €r   Ú
adaptationz/_adapt_unary_request_inline.<locals>.adaptationW   s   ø€ Ù#ØÔ)Ð*:Ó;ó
ð 	
r   r   )rG   rH   s   ` r   Ú_adapt_unary_request_inlinerI   V   ó   ø€ ô
ð
 Ðr   c                 ó   ‡ — ˆ fd„}|S )Nc                 ó(   •—  ‰| t        |«      «      S r   rE   )Úrequest_iteratorr   Ústream_request_inlines     €r   rH   z0_adapt_stream_request_inline.<locals>.adaptation`   s   ø€ Ù$ØÔ2Ð3CÓDó
ð 	
r   r   )rN   rH   s   ` r   Ú_adapt_stream_request_inlinerO   _   rJ   r   c                   ó6   — e Zd Zd„ Zd„ Zd„ Zd„ Zd„ Zd„ Zd„ Z	y)	Ú	_Callbackc                 ó`   — t        j                  «       | _        g | _        d| _        d| _        y ©NF)Ú	threadingÚ	ConditionÚ
_conditionÚ_valuesÚ_terminatedÚ
_cancelledr   s    r   r   z_Callback.__init__i   s(   € Ü#×-Ñ-Ó/ˆŒØˆŒØ ˆÔØˆ�r   c                 ó°   — | j                   5  | j                  j                  |«       | j                   j                  «        d d d «       y # 1 sw Y   y xY wr   )rV   rW   ÚappendÚ
notify_all©r   Úvalues     r   Úconsumez_Callback.consumeo   s5   € Ø�_‹_Ø�L‰L×Ñ Ô&Ø�O‰O×&Ñ&Ô(÷ �_‰_ús   �6AÁAc                 óˆ   — | j                   5  d| _        | j                   j                  «        d d d «       y # 1 sw Y   y xY w©NT)rV   rX   r\   r   s    r   Ú	terminatez_Callback.terminatet   s+   € Ø�_‹_Ø#ˆDÔØ�O‰O×&Ñ&Ô(÷ �_‰_úó	   �"8¸Ac                 ó¾   — | j                   5  | j                  j                  |«       d| _        | j                   j	                  «        d d d «       y # 1 sw Y   y xY wra   )rV   rW   r[   rX   r\   r]   s     r   Úconsume_and_terminatez_Callback.consume_and_terminatey   s=   € Ø�_‹_Ø�L‰L×Ñ Ô&Ø#ˆDÔØ�O‰O×&Ñ&Ô(÷ �_‰_ús   �=AÁAc                 óˆ   — | j                   5  d| _        | j                   j                  «        d d d «       y # 1 sw Y   y xY wra   )rV   rY   r\   r   s    r   r0   z_Callback.cancel   s*   € Ø�_‹_Ø"ˆDŒOØ�O‰O×&Ñ&Ô(÷ �_‰_úrc   c                 ó8  — | j                   5  	 | j                  rt        j                  «       ‚| j                  r$| j                  j                  d«      cd d d «       S | j                  r
	 d d d «       y | j                   j                  «        Œ�# 1 sw Y   y xY w©Nr   )rV   rY   r   Ú	AbandonedrW   ÚpoprX   Úwaitr   s    r   Údraw_one_valuez_Callback.draw_one_value„   sv   € Ø�_‹_ØØ—?’?Ü%×/Ñ/Ó1Ð1Ø—<’<ØŸ<™<×+Ñ+¨AÓ.÷ ‰_ð ×#Ò#Ø÷ ˆ_ð —‘×$Ñ$Ô&ð ÷ ˆ_ús   �ABÁBÁ5BÂBc                 ó  — | j                   5  	 | j                  rt        j                  «       ‚| j                  r't        | j                  «      }d | _        |cd d d «       S | j                   j                  «        Œn# 1 sw Y   y xY wr   )rV   rY   r   ri   rX   ÚtuplerW   rk   )r   Ú
all_valuess     r   Údraw_all_valuesz_Callback.draw_all_values�   si   € Ø�_‹_ØØ—?’?Ü%×/Ñ/Ó1Ð1Ø×#Ò#Ü!& t§|¡|Ó!4�JØ#'�D”LØ%÷ ‰_ð —‘×$Ñ$Ô&ð ÷ ˆ_ús   �AA=Á"A=Á=BN)
r    r!   r"   r   r_   rb   re   r0   rl   rp   r   r   r   rQ   rQ   h   s%   „ ò ò)ò
)ò
)ò)ò
	'ó	'r   rQ   c                 óž   ‡ ‡‡‡— t        j                  «       Šˆˆ ˆˆfd„}t        j                  |¬«      }d|_        |j	                  «        y )Nc                  óÞ   •— ‰D ]W  } ‰j                  «       r‰j                  «       r y ‰j                  | «       ‰j                  «       r‰j                  «       sŒW y  ‰j                  «        y r   )r'   Úis_setr_   rb   )rF   Úrequest_consumerrM   r   Úthread_joineds    €€€€r   Úpipe_requestsz/_run_request_pipe_thread.<locals>.pipe_requests    s]   ø€ Û'ˆGØ#×-Ñ-Ô/°=×3GÑ3GÔ3IÙØ×$Ñ$ WÔ-Ø#×-Ñ-Ô/°=×3GÑ3GÕ3IÙð (ð 	×"Ñ"Õ$r   )ÚtargetT)rT   ÚEventÚThreadÚdaemonÚstart)rM   rt   r   rv   Úrequest_pipe_threadru   s   ```  @r   Ú_run_request_pipe_threadr}   ›   s>   û€ ô —O‘OÓ%€M÷%ô $×*Ñ*°-Ô@ÐØ!%ÐÔØ×ÑÕr   c                 ó   ‡ — ˆ fd„}|S )Nc                 óÖ   •— t        «       }|j                  |j                  «      st        j                  «       ‚ ‰| |j
                  t        |«      «       |j                  «       d   S rh   )rQ   Úadd_callbackr0   r   ri   re   r$   rp   )rF   r   ÚcallbackÚunary_unary_events      €r   rH   z,_adapt_unary_unary_event.<locals>.adaptation¯   s^   ø€ Ü“;ˆØ×,Ñ,¨X¯_©_Ô=Ü×'Ñ'Ó)Ð)ÙØØ×*Ñ*Ü Ð!1Ó2ô	
ð
 ×'Ñ'Ó)¨!Ñ,Ð,r   r   )r‚   rH   s   ` r   Ú_adapt_unary_unary_eventrƒ   ®   s   ø€ ô	-ð Ðr   c                 ó   ‡ — ˆ fd„}|S )Nc              3   óÖ   •K  — t        «       }|j                  |j                  «      st        j                  «       ‚ ‰| |t        |«      «       	 |j                  «       }|€y |–— Œ­wr   )rQ   r€   r0   r   ri   r$   rl   )rF   r   r�   ÚresponseÚunary_stream_events       €r   rH   z-_adapt_unary_stream_event.<locals>.adaptation¾   sk   øè ø€ Ü“;ˆØ×,Ñ,¨X¯_©_Ô=Ü×'Ñ'Ó)Ð)ÙØ�XÔ3Ð4DÓEô	
ð Ø×.Ñ.Ó0ˆHØÐØà’ð ùs   ƒA&A)r   )r‡   rH   s   ` r   Ú_adapt_unary_stream_eventrˆ   ½   s   ø€ ôð Ðr   c                 ó   ‡ — ˆ fd„}|S )Nc                 óî   •— t        «       }|j                  |j                  «      st        j                  «       ‚ ‰|j
                  t        |«      «      }t        | ||«       |j                  «       d   S rh   )	rQ   r€   r0   r   ri   re   r$   r}   rp   )rM   r   r�   rt   Ústream_unary_events       €r   rH   z-_adapt_stream_unary_event.<locals>.adaptationÐ   sq   ø€ Ü“;ˆØ×,Ñ,¨X¯_©_Ô=Ü×'Ñ'Ó)Ð)Ù-Ø×*Ñ*Ü Ð!1Ó2ó
Ðô 	!ØÐ.Ð0@ô	
ð ×'Ñ'Ó)¨!Ñ,Ð,r   r   )r‹   rH   s   ` r   Ú_adapt_stream_unary_eventrŒ   Ï   s   ø€ ô-ð Ðr   c                 ó   ‡ — ˆ fd„}|S )Nc              3   óî   •K  — t        «       }|j                  |j                  «      st        j                  «       ‚ ‰|t        |«      «      }t        | ||«       	 |j                  «       }|€y |–— Œ­wr   )rQ   r€   r0   r   ri   r$   r}   rl   )rM   r   r�   rt   r†   Ústream_stream_events        €r   rH   z._adapt_stream_stream_event.<locals>.adaptationá   s   øè ø€ Ü“;ˆØ×,Ñ,¨X¯_©_Ô=Ü×'Ñ'Ó)Ð)Ù.ØÔ*Ð+;Ó<ó
Ðô 	!ØÐ.Ð0@ô	
ð Ø×.Ñ.Ó0ˆHØÐØà’ð ùs   ƒA2A5r   )r�   rH   s   ` r   Ú_adapt_stream_stream_eventr�   à   s   ø€ ôð" Ðr   c                   ó   — e Zd Zy)Ú_SimpleMethodHandlerN)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                 óv  — | j                   t         j                  j                  u �r6| j                  t        j                  j
                  u r%t        dd||t        | j                  «      d d d «      S | j                  t        j                  j                  u r%t        dd||d t        | j                  «      d d «      S | j                  t        j                  j                  u r%t        dd||d d t        | j                  «      d «      S | j                  t        j                  j                  u r%t        dd||d d d t        | j                  «      «      S t3        «       ‚| j                   t         j                  j                   u �r,| j                  t        j                  j
                  u r%t        dd||t#        | j$                  «      d d d «      S | j                  t        j                  j                  u r%t        dd||d t'        | j(                  «      d d «      S | j                  t        j                  j                  u r%t        dd||d d t+        | j,                  «      d «      S | j                  t        j                  j                  u r%t        dd||d d d t/        | j0                  «      «      S t3        «       ‚)NFT)r   ÚServiceÚINLINEr   ÚCardinalityÚUNARY_UNARYr’   rI   Úunary_unary_inlineÚUNARY_STREAMÚunary_stream_inlineÚSTREAM_UNARYrO   Ú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ØØØó	ð 	ð ×%Ñ%¬×)@Ñ)@×)MÑ)MÑMÜ'ØØØ$Ø#ØÜ+¨N×,NÑ,NÓOØØó	ð 	ð ×%Ñ%¬×)@Ñ)@×)MÑ)MÑMÜ'ØØØ$Ø#ØØÜ,Ø"×6Ñ6óð óð ð ×%Ñ%¬×)@Ñ)@×)NÑ)NÑNÜ'ØØØ$Ø#ØØØÜ,Ø"×7Ñ7óóð ôr ‹,Ðð[ 
×	Ñ	¤§¡×!4Ñ!4Ò	4Ø×%Ñ%¬×)@Ñ)@×)LÑ)LÑLÜ'ØØØ$Ø#Ü(¨×)IÑ)IÓJØØØó	ð 	ð ×%Ñ%¬×)@Ñ)@×)MÑ)MÑMÜ'ØØØ$Ø#ØÜ)¨.×*KÑ*KÓLØØó	ð 	ð ×%Ñ%¬×)@Ñ)@×)MÑ)MÑMÜ'ØØØ$Ø#ØØÜ)¨.×*KÑ*KÓLØó	ð 	ð ×%Ñ%¬×)@Ñ)@×)NÑ)NÑNÜ'ØØØ$Ø#ØØØÜ*¨>×+MÑ+MÓNó	ð 	ô ‹,Ðr   c                 ól   — | xs i } i }| D ]&  }t        j                  |d   |d   «      }| |   ||<   Œ( |S )Nr   é   )r   Úfully_qualified_method)Úmethod_pair_mapÚflat_mapÚmethod_pairÚmethods       r   Ú_flatten_method_pair_mapr³   l  sK   € Ø%Ò+¨€OØ€HÛ&ˆÜ×/Ñ/°¸A±ÀÈAÁÓOˆØ*¨;Ñ7ˆ�Òð 'ð €Or   c                   ó   — e Zd Zd„ Zd„ Zy)Ú_GenericRpcHandlerc                 ór   — t        |«      | _        t        |«      | _        t        |«      | _        || _        y r   )r³   Ú_method_implementationsÚ_request_deserializersÚ_response_serializersÚ_multi_method_implementation)r   Úmethod_implementationsÚmulti_method_implementationÚrequest_deserializersÚresponse_serializerss        r   r   z_GenericRpcHandler.__init__v  sD   € ô (@Ø"ó(
ˆÔ$ô '?Ø!ó'
ˆÔ#ô &>Ø ó&
ˆÔ"ð -HˆÕ)r   c                 óF  — | j                   j                  |j                  «      }|�St        || j                  j                  |j                  «      | j
                  j                  |j                  «      «      S | j                  €y 	 y # t        j                  $ r Y y w xY wr   )	r·   Úgetr²   r«   r¸   r¹   rº   r   ÚNoSuchMethodError)r   Úhandler_call_detailsÚmethod_implementations      r   Úservicez_GenericRpcHandler.serviceˆ  s¡   € Ø $× <Ñ <× @Ñ @Ø ×'Ñ'ó!
Ðð !Ð,Ü)Ø%Ø×+Ñ+×/Ñ/Ð0D×0KÑ0KÓLØ×*Ñ*×.Ñ.Ð/C×/JÑ/JÓKóð ð
 ×,Ñ,Ð4Øð	ØøÜ×%Ñ%ò 	Ùð	ús   Â
B ÂB N)r    r!   r"   r   rÄ   r   r   r   rµ   rµ   u  s   „ òHó$r   rµ   c                   ó6   — e Zd Zd„ Zd„ Zd„ Zd„ Zd„ Zd„ Zd„ Z	y)	Ú_Serverc                 ó   — || _         y r   )Ú_grpc_server)r   Úgrpc_servers     r   r   z_Server.__init__›  s
   € Ø'ˆÕr   c                 ó8   — | j                   j                  |«      S r   )rÈ   Úadd_insecure_port)r   Úaddresss     r   rË   z_Server.add_insecure_portž  s   € Ø× Ñ ×2Ñ2°7Ó;Ð;r   c                 ó:   — | j                   j                  ||«      S r   )rÈ   Úadd_secure_port)r   rÌ   Úserver_credentialss      r   rÎ   z_Server.add_secure_port¡  s   € Ø× Ñ ×0Ñ0°Ð:LÓMÐMr   c                 ó8   — | j                   j                  «        y r   ©rÈ   r{   r   s    r   r{   z_Server.start¤  s   € Ø×Ñ×ÑÕ!r   c                 ó8   — | j                   j                  |«      S r   ©rÈ   Ústop)r   Úgraces     r   rÔ   z_Server.stop§  s   € Ø× Ñ ×%Ñ% eÓ,Ð,r   c                 ó:   — | j                   j                  «        | S r   rÑ   r   s    r   Ú	__enter__z_Server.__enter__ª  s   € Ø×Ñ×ÑÔ!Øˆr   c                 ó:   — | j                   j                  d «       yrS   rÓ   )r   Úexc_typeÚexc_valÚexc_tbs       r   Ú__exit__z_Server.__exit__®  s   € Ø×Ñ×Ñ˜tÔ$Ør   N)
r    r!   r"   r   rË   rÎ   r{   rÔ   r×   rÜ   r   r   r   rÆ   rÆ   š  s&   „ ò(ò<òNò"ò-òór   rÆ   c                 ó¤   — t        | |||«      }|€t        j                  |€t        n|«      }n|}t	        t        j                  ||f¬«      «      S )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â   ³  sh   € ô -ØØ#ØØó	Ðð ÐÜ ,× 1Ñ 1Ø"2Ð":ÕÐ@Pó!
Ñð !,ÐÜÜ�‰Ð)Ð5HÐ4JÔKóð r   ))Ú__doc__ÚcollectionsrT   rá   r   Ú	grpc.betar   r   Úgrpc.framework.commonr   r   Úgrpc.framework.foundationr   r	   r
   Úgrpc.framework.interfaces.facer   rà   ÚGRPCServicerContextr   ÚServicerContextr$   rI   rO   ÚConsumerrQ   r}   rƒ   rˆ   rŒ   r�   Ú
namedtupleÚRpcMethodHandlerr’   r«   r³   ÚGenericRpcHandlerrµ   ÚServerrÆ   râ   r   r   r   Ú<module>rõ      só   ðñ Jã Û ã Ý Ý Ý  Ý -Ý 'Ý 1Ý 2Ý ,Ý /ð Ð ô˜Z×;Ñ;ô ô%4˜4×/Ñ/ô %4òPòô0'�—‘ô 0'òf ò&òò$ò"ô*	Ø€K×ÑØð		
óð 	×Ñô	ò&aòHô"˜×/Ñ/ô "ôJˆj×Ñô ó2r   