+
    ~jL                         ^ RI HtHtHtHt ^ RIt^ RIHt ^ RIH	t	 Rt
 ! R R]4      t ! R R	4      t]! R
]R7      t ! R R4      tR# )    )DictTypeTypeVarOptionalN)Message)urlparsetwirpc                      a  ] tR t^t o RR/V 3R lR llt]V 3R lR l4       t]V 3R lR l4       t]V 3R	 lR
 l4       t]V 3R lR l4       t	V 3R lR lt
RtV tR# )
TwirpErrormetadataNc                \   < V ^8  d   QhRS[ RS[ RS[RS[S[S[ S[ 3,          ,          RR/# )   codemsgstatusr   returnN)strintr   r   )format__classdict__s   "m/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/livekit/api/twirp_client.py__annotate__TwirpError.__annotate__   sJ     ( (( (
 ( 4S>*( 
(    c               L    Wn         W n        W0n        T;'       g    / V n        R # N)_code_msg_status	_metadata)selfr   r   r   r   s   &&&$$r   __init__TwirpError.__init__   s      
	!Rr   c                    < V ^8  d   QhRS[ /# r   r   r   )r   r   s   "r   r   r   '   s      c r   c                    V P                   # r   )r   r!   s   &r   r   TwirpError.code&   s    zzr   c                    < V ^8  d   QhRS[ /# r%   r&   )r   r   s   "r   r   r   +   s       r   c                    V P                   # r   )r   r(   s   &r   messageTwirpError.message*   s    yyr   c                    < V ^8  d   QhRS[ /# r%   )r   )r   r   s   "r   r   r   /   s       r   c                    V P                   # )zHTTP status code)r   r(   s   &r   r   TwirpError.status.   s     ||r   c                6   < V ^8  d   QhRS[ S[S[3,          /# r%   )r   r   )r   r   s   "r   r   r   4   s      $sCx. r   c                    V P                   # )zTwirp metadata)r    r(   s   &r   r   TwirpError.metadata3   s     ~~r   c                    < V ^8  d   QhRS[ /# r%   r&   )r   r   s   "r   r   r   8   s       r   c                    R V P                    RV P                   RV P                   2pV P                  '       d   VRV P                   2,          pVR,          pV# )zTwirpError(code=z
, message=z	, status=z, metadata=))r   r,   r   r   )r!   results   & r   __str__TwirpError.__str__8   sU    #DII;jiPTP[P[}]===DMM?33F#r   )r   r    r   r   )__name__
__module____qualname____firstlineno__r"   propertyr   r,   r   r   r8   __static_attributes____classdictcell__r   s   @r   r   r      ss     ( .2( (         r   r   c                   ^    ] tR t^@tRtRtRtRtRtRt	Rt
RtR	tR
tRtRtRtRtRtRtRtRtRtR# )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dataloss 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_LOSSr?   rV   r   r   rC   rC   @   sa    HG)I+II%N+'O-/G!L#MHKIr   rC   T)boundc                   R   a  ] tR t^Xt o ]3V 3R lR lltRR/V 3R lR lltRtV tR# )TwirpClientc          
      J   < V ^8  d   QhRS[ P                  RS[RS[RS[RR/# )r   sessionhostpkgprefixr   N)aiohttpClientSessionr   )r   r   s   "r   r   TwirpClient.__annotate__Y   sC        &&    	 
   
 r   c                   \        V4      pVP                  pVP                  R 4      '       d   VP                  R R4      pV RVP                   RVP
                   2pVP                  R4      V n        W0n        W@n	        Wn
        R# )wshttpz:///N)r   scheme
startswithreplacenetlocpathrstripro   rp   rq   _session)r!   rn   ro   rp   rq   	parse_resry   s   &&&&&  r   r"   TwirpClient.__init__Y   sz     TN	!!T""^^D&1FY--.a	/?@KK$	r   timeoutNc                   < V ^8  d   QhRS[ RS[ RS[RS[S[ S[ 3,          RS[S[,          RS[S[P                  ,          RS[/# )r   servicemethoddataheadersresponse_classr   r   )r   r   r   r   ri   r   rr   ClientTimeout)r   r   s   "r   r   rt   k   sh        	
 c3h Q '//0 
r   c          
       "   V P                    R V P                   R V P                   RV R V 2	pRVR&   VP                  4       pV P                  P                  WtWR7      ;_uu_4       GRj  xL
 p	V	P                  ^8X  d:   TP                  V	P                  4       G Rj  xL
 4      uuRRR4      GRj  xL
  # V	P                  4       G Rj  xL
 p
\        V
P                  RR4      V
P                  RR	4      V	P                  V
P                  R
4      R7      h L L| Li LR  + GRj  xL 
 '       g   i     R# ; i5i)rx   .zapplication/protobufzContent-Type)r   r   r   Nr   rE   r    meta)r   r   )ro   rq   rp   SerializeToStringr   postr   
FromStringreadjsonr   get)r!   r   r   r   r   r   r   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	
 /
 
 
 
s   A-E/D0E30D&#D $D&+E8D"9E>D&D$AD&E D&"E$D&&E 	,D/-
E 	8E 	:	E)r   ro   rp   rq   )	r:   r;   r<   r=   DEFAULT_PREFIXr"   r   r?   r@   rA   s   @r   rl   rl   X   s-      %   $ 48  r   rl   )typingr   r   r   r   rr   google.protobuf.messager   urllib.parser   r   	Exceptionr   rC   ri   rl   rV   r   r   <module>r      sJ    1 0  + !% %P * Cw. .r   