+
    i                       ^ RI Ht ^ RIt^ RIt^ RIt^ RIt^ RIHt ^RIH	t	H
t
 ^RIHt ^RIHt ^RIHt ^RIHt ^R	IHt R
.tR R ltR R lt ! R R]P0                  4      tR R ltR R ltR R ltRR R lltR# )    )annotationsN)	Generator)ClientConnectionconnect)SimpleQueue)ConnectionClosed)Close)StreamReader)versionmainc                    V ^8  d   QhRRRR/#    stringstrreturnNone )formats   "U/home/wkmabra/.openclaw/workspace/venv/lib/python3.14/site-packages/websockets/cli.py__annotate__r      s      s t     c                    \         P                  P                  R V  R24       \         P                  P                  4        R# )z	7
[A[Lz
8[BNsysstdoutwriteflushr   s   &r   print_during_inputr       s<    JJ	 ( 	  JJr   c                    V ^8  d   QhRRRR/# r   r   )r   s   "r   r   r   (   s     	 	S 	T 	r   c                    \         P                  P                  R V  R24       \         P                  P                  4        R# )z[K
Nr   r   s   &r   print_over_inputr$   (   s9    JJ	 (-		! JJr   c                  ^    ] tR t^4tR R ltR R ltR R ltR R ltR	 R
 ltR R lt	Rt
R# )	ReadLinesc                   V ^8  d   QhRR/# r   r   r   r   )r   s   "r   r   ReadLines.__annotate__5   s     8 8$ 8r   c                	B    \        4       V n        \        4       V n        R # N)r
   readerr   messagesselfs   &r   __init__ReadLines.__init__5   s    "n*5-r   c                   V ^8  d   QhRR/# )r   r   zGenerator[None, None, None]r   )r   s   "r   r   r)   9   s     < <2 <r   c              #  	`  "    \         P                  P                  R4       \         P                  P                  4        V P                  P                  \         P                  4       Rj  xL
 pV P                  P                  VP                  4       P                  R4      4       K   L>5i)Tz> Nz
)r   r   r   r   r,   	read_linemaxsizer-   putdecoderstrip)r/   lines   & r   parseReadLines.parse9   sn     JJT"JJ"kk33CKK@@DMMdkkm226:; As   A+B.-B,.?B.c                    V ^8  d   QhRRRR/# )r   	transportzasyncio.BaseTransportr   r   r   )r   s   "r   r   r)   @   s      )> 4 r   c                	Z    V P                  4       V n        \        V P                  4       R # r+   )r:   parsernext)r/   r=   s   &&r   connection_madeReadLines.connection_made@   s    jjlT[[r   c                    V ^8  d   QhRRRR/# )r   databytesr   r   r   )r   s   "r   r   r)   D   s      % D r   c                	f    V P                   P                  V4       \        V P                  4       R # r+   )r,   	feed_datar@   r?   )r/   rD   s   &&r   data_receivedReadLines.data_receivedD   s     d#T[[r   c                   V ^8  d   QhRR/# r(   r   )r   s   "r   r   r)   H   s      d r   c                	:    V P                   P                  4        R # r+   )r,   feed_eofr.   s   &r   eof_receivedReadLines.eof_receivedH   s    r   c                    V ^8  d   QhRRRR/# )r   exczException | Noner   r   r   )r   s   "r   r   r)   L   s      #3  r   c                	n    V P                   P                  4        V P                  P                  4        R # r+   )r,   discardr-   abort)r/   rP   s   &&r   connection_lostReadLines.connection_lostL   s"    r   )r-   r?   r,   N)__name__
__module____qualname____firstlineno__r0   r:   rA   rH   rM   rT   __static_attributes__r   r   r   r&   r&   4   s%    8< r   r&   c                    V ^8  d   QhRRRR/# )r   	websocketr   r   r   r   )r   s   "r   r   r   Q   s     > >-= >$ >r   c                   "   V   R j  xL
  p\        V\        4      '       d   \        RV,           4       K4  \        RVP                  4       ,           4       KV   LQDRR # 5i)Nz< z< (binary) )
isinstancer   r    hex)r\   messages   & r   print_incoming_messagesra   Q   sG     " > >ggs##tg~.}w{{}<=	>s&   A AAAAA AA c               $    V ^8  d   QhRRRRRR/# )r   r\   r   r-   zSimpleQueue[str]r   r   r   )r   s   "r   r   r   Y   s&       
r   c                   "     VP                  4       G Rj  xL
 p T P                  T4      G Rj  xL
  K6   L   \         d     R# i ; i L  \         d     R# i ; i5i)TN)getEOFErrorsendr   )r\   r-   r`   s   && r   send_outgoing_messagesrg   Y   sa      	$LLN*G	..)))	 + 		 * 		s^   A!; 9; A AA A!; A
A!	A

A!A AA!AA!c                    V ^8  d   QhRRRR/# )r   urir   r   r   r   )r   s   "r   r   r   h   s     &< &<# &<$ &<r   c                *  "    \        V 4      G R j  xL
 p\        RV  R24       \
        P                  ! 4       pVP                  \        \        P                  4      G R j  xL
 w  rE\
        P                  ! \        X4      4      p\
        P                  ! \        WP                  4      4      p \
        P                  ! Wg.\
        P                  R7      G R j  xL
  VP#                  4        VP#                  4        VP%                  4        VP%                  4       G R j  xL
  VP&                  e   VP(                  f   Q h\+        VP&                  VP(                  4      p\-        RV R24       R #  ELf  \         d4   p\        RT  RT R24       \        P                  ! ^4        R p?ELR p?ii ; i ELZ L  \
        P                    d     Li ; i  TP#                  4        TP#                  4        TP%                  4        i ; i L5i)NzConnected to .zFailed to connect to z: )return_whenzConnection closed: )r   print	Exceptionr   exitasyncioget_running_loopconnect_read_piper&   stdincreate_taskra   rg   r-   waitFIRST_COMPLETEDCancelledErrorcancelclose
close_codeclose_reasonr	   r$   )	ri   r\   rP   loopr=   protocolincomingoutgoingclose_statuss	   &        r   interactive_clientr   h   s    &!#,&	
 	cU!$%##%D $ 6 6y#)) LLI""	*H ""y*;*;<Hll   //	
 	
 	
 	
//
+	0F0F0RRR--y/E/EFL*<.:;I ' %cU"SE34 M	
 !!  	s   HE; E8E; AH"F<#AH2*G F?G !AH$H%AH8E; ;F9(F4.H4F99H?G GG GG 2HHc                    V ^8  d   QhRRRR/# )r   argvzlist[str] | Noner   r   r   )r   s   "r   r   r      s     ! ! !4 !r   c                v   \         P                  ! R RRR7      pVP                  4       pVP                  RRR7       VP                  RRR	R
7       VP	                  V 4      pVP
                  '       d   \        R\         24       R# VP                  f'   VP                  4        \        P                  ! ^4       \        P                  R8X  d   \        P                  ! R4        ^ RIp \"        P$                  ! \'        VP                  4      4       R#   \          d     L9i ; i  \(         d     R# i ; i)
websocketszInteractive WebSocket client.F)progdescriptionadd_helpz	--version
store_true)actionri   z<uri>?)metavarnargszwebsockets Nwin32 )argparseArgumentParseradd_mutually_exclusive_groupadd_argument
parse_argsr   rm   websockets_versionri   print_usager   ro   platformossystemreadlineImportErrorrp   runr   KeyboardInterrupt)r   r?   groupargsr   s   &    r   r   r      s   $$3F
 //1E	{<8	ugS9T"D|||./01xx ||w
		"
&txx01    s$   (D -)D) D&%D&)D87D8r+   )
__future__r   r   rp   r   r   typingr   asyncio.clientr   r   asyncio.messagesr   
exceptionsr   framesr	   streamsr
   r   r   __all__r    r$   Protocolr&   ra   rg   r   r   r   r   r   <module>r      sh    "   	 
  5 ) (  ! 2 ((	   :>&<R! !r   