
    hL                         S SK JrJrJrJr  S SKrS SKJr  S SKJ	r	  Sr
 " S S\5      r " S S	5      r\" S
\S9r " S S5      rg)    )DictTypeTypeVarOptionalN)Message)urlparsetwirpc                       \ rS rSrSS.S\S\S\S\\\\4      SS4
S	 jjr\	S\4S
 j5       r
\	S\4S j5       r\	S\4S j5       r\	S\\\4   4S j5       rS\4S jrSrg)
TwirpError   N)metadatacodemsgstatusr   returnc                H    Xl         X l        X0l        U=(       d    0 U l        g N)_code_msg_status	_metadata)selfr   r   r   r   s        J/var/www/html/env/lib/python3.13/site-packages/livekit/api/twirp_client.py__init__TwirpError.__init__   s     
	!R    c                     U R                   $ r   )r   r   s    r   r   TwirpError.code&   s    zzr   c                     U R                   $ r   )r   r   s    r   messageTwirpError.message*   s    yyr   c                     U R                   $ )zHTTP status code)r   r   s    r   r   TwirpError.status.   s     ||r   c                     U R                   $ )zTwirp metadata)r   r   s    r   r   TwirpError.metadata3   s     ~~r   c                     SU R                    SU R                   SU R                   3nU R                  (       a  USU R                   3-  nUS-  nU$ )NzTwirpError(code=z
, message=z	, status=z, metadata=))r   r!   r   r   )r   results     r   __str__TwirpError.__str__8   sS    #DII;jiPTP[P[}]==DMM?33F#r   )r   r   r   r   )__name__
__module____qualname____firstlineno__strintr   r   r   propertyr   r!   r   r   r*   __static_attributes__ r   r   r   r      s     .2(( (
 ( 4S>*( 
( c         $sCx.   r   r   c                   \    \ 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SrSrSrSrSrSrSrg)TwirpErrorCode@   canceledunknowninvalid_argument	malformeddeadline_exceeded	not_found	bad_routealready_existspermission_deniedunauthenticatedresource_exhaustedfailed_preconditionabortedout_of_rangeunimplementedinternalunavailabledatalossr4   N)r,   r-   r.   r/   CANCELEDUNKNOWNINVALID_ARGUMENT	MALFORMEDDEADLINE_EXCEEDED	NOT_FOUND	BAD_ROUTEALREADY_EXISTSPERMISSION_DENIEDUNAUTHENTICATEDRESOURCE_EXHAUSTEDFAILED_PRECONDITIONABORTEDOUT_OF_RANGEUNIMPLEMENTEDINTERNALUNAVAILABLE	DATA_LOSSr3   r4   r   r   r6   r6   @   sa    HG)I+II%N+'O-/G!L#MHKIr   r6   T)boundc                       \ rS rSr\4S\R                  S\S\S\SS4
S jjrSS	.S
\S\S\	S\
\\4   S\\   S\\R                     S\4S jjrSrg)TwirpClientX   sessionhostpkgprefixr   Nc                    [        U5      nUR                  nUR                  S5      (       a  UR                  SS5      nU SUR                   SUR
                   3nUR                  S5      U l        X0l        X@l	        Xl
        g )Nwshttpz:///)r   scheme
startswithreplacenetlocpathrstriprb   rc   rd   _session)r   ra   rb   rc   rd   	parse_resri   s          r   r   TwirpClient.__init__Y   sz     TN	!!T""^^D&1FY--.a	/?@KK$	r   )timeoutservicemethoddataheadersresponse_classrr   c          	      d  #    U R                    SU R                   SU R                   SU SU 3	nSUS'   UR                  5       nU R                  R                  XtXS9 IS h  vN n	U	R                  S:X  a8  UR                  U	R                  5       I S h  vN 5      sS S S 5      IS h  vN   $ U	R                  5       I S h  vN n
[        U
R                  SS5      U
R                  S	S
5      U	R                  U
R                  S5      S9e N Nx Nf NO! , IS h  vN  (       d  f       g = f7f)Nrh   .zapplication/protobufzContent-Type)rv   ru   rr      r   r9   r    meta)r   r   )rb   rd   rc   SerializeToStringro   postr   
FromStringreadjsonr   get)r   rs   rt   ru   rv   rw   rr   urlserialized_dataresp
error_datas              r   requestTwirpClient.requestk   s     1T[[M488*AgYaxH"8002==%% & 
 
{{c!%00tyy{1BC	
 
 
 $(99;.
 NN695NN5"-;;'^^F3	 
 2C	
 /
 
 
sy   A"D0$D%D0(/DD
DD0+D,D01DDA	DD0DD0DD-DD-)D0)ro   rb   rc   rd   )r,   r-   r.   r/   DEFAULT_PREFIXaiohttpClientSessionr0   r   r   r   r   r\   r   ClientTimeoutr   r3   r4   r   r   r_   r_   X   s     % &&    	 
   
 4 48  	
 c3h Q '//0 
 r   r_   )typingr   r   r   r   r   google.protobuf.messager   urllib.parser   r   	Exceptionr   r6   r\   r_   r4   r   r   <module>r      sJ    1 0  + !% %P * Cw. .r   