Ë
    |¾�j‡  ã                   ól   — d dl Z d dlZd dlZd dlmZ d dlmZ  ej                  e«      Z	 G d„ d«      Z
y)é    N)ÚProtocol)Ú
AdbLoggingc                   ó^   — e Zd Zdd„Zd„ Zd„ Zd„ Zd„ Zd„ Zd„ Z	d	„ Z
d
„ Zd„ Zd„ Zdd„Zd„ Zy)ÚConnectionAsyncNc                 ó\   — || _         t        |«      | _        || _        d | _        d | _        y ©N)ÚhostÚintÚportÚtimeoutÚreaderÚwriter)Úselfr	   r   r   s       úW/var/www/api.ozpay.ru/ozpay/venv/lib/python3.12/site-packages/ppadb/connection_async.pyÚ__init__zConnectionAsync.__init__   s)   € ØˆŒ	Ü˜“IˆŒ	ØˆŒàˆŒØˆ�ó    c              ƒ   ó   K  — | S ­wr   © ©r   s    r   Ú
__aenter__zConnectionAsync.__aenter__   s   è ø€ Øˆùs   ‚c              ƒ   ó@   K  — | j                  «       ƒ d {  –—†  y 7 Œ­wr   )Úclose)r   ÚtypeÚvalueÚ	tracebacks       r   Ú	__aexit__zConnectionAsync.__aexit__   s   è ø€ Ø�j‰j‹l×Òús   ‚–—c              ƒ   óf  K  — t         j                  d| j                  | j                  «       	 | j                  r_t        j                  t        j                  | j                  | j                  «      | j                  «      ƒ d {  –—† \  | _        | _	        | S t        j                  | j                  | j                  «      ƒ d {  –—† \  | _        | _	        	 | S 7 ŒU7 Œ# t        t
        j                  f$ r5}t        dj                  | j                  | j                  |«      «      ‚d }~ww xY w­w)NzConnect to ADB server - %s:%dz?ERROR: connecting to {}:{} {}.
Is adb running on your computer?)ÚloggerÚdebugr	   r   r   ÚasyncioÚwait_forÚopen_connectionr   r   ÚOSErrorÚTimeoutErrorÚRuntimeErrorÚformat)r   Úes     r   ÚconnectzConnectionAsync.connect   s  è ø€ Ü�‰Ð4°d·i±iÀÇÁÔKð	CØ�|Š|Ü18×1AÑ1AÄ'×BYÑBYÐZ^×ZcÑZcÐei×enÑenÓBoÐqu×q}Ñq}Ó1~×+~Ñ(�”˜Tœ[ð ˆô 29×1HÑ1HÈÏÉÐTX×T]ÑT]Ó1^×+^Ñ(�”˜T�[ð
 ˆð ,øà+^ùäœ×-Ñ-Ð.ò 	CÜÐa×hÑhÐim×irÑirÐtx×t}Ñt}ð  @Aó   Bó  Cð  Cûð	CüsY   ‚,D1¯AC  ÂCÂC  ÂD1Â-C  ÃCÃC  ÃD1ÃC  ÃC  Ã D.Ã90D)Ä)D.Ä.D1c              ƒ   ó  K  — t         j                  d«       | j                  r=	 | j                  j                  «        | j                  j	                  «       ƒ d {  –—†  d | _        d | _        y 7 Œ# t
        $ r Y Œw xY w­w)NzConnection closed...)r   r   r   r   Úwait_closedr#   r   r   s    r   r   zConnectionAsync.close(   sk   è ø€ Ü�‰Ð+Ô,à�;Š;ðØ—‘×!Ñ!Ô#Ø—k‘k×-Ñ-Ó/×/Ð/ð ˆŒØˆ�ð 0ùÜò Ùðüs:   ‚"B¥7A2 ÁA0ÁA2 Á!BÁ0A2 Á2	A>Á;BÁ=A>Á>Bc              ƒ   ó�   K  — t        j                  | j                  j                  |«      | j                  «      ƒ d {  –—† S 7 Œ­wr   )r    r!   r   Úreadr   )r   Úlengths     r   Ú_recvzConnectionAsync._recv:   s2   è ø€ Ü×%Ñ% d§k¡k×&6Ñ&6°vÓ&>ÀÇÁÓM×MÐMÐMús   ‚=A¿AÁ Ac              ƒ   óÆ   K  — | j                   j                  |«       t        j                  | j                   j	                  «       | j
                  «      ƒ d {  –—†  y 7 Œ­wr   )r   Úwriter    r!   Údrainr   ©r   Údatas     r   Ú_sendzConnectionAsync._send=   s?   è ø€ Ø�‰×Ñ˜$ÔÜ×Ñ˜tŸ{™{×0Ñ0Ó2°D·L±LÓA×AÒAús   ‚AA!ÁAÁA!c              ƒ   óÆ   K  — t        | j                  d«      ƒ d {  –—† j                  d«      d«      }| j                  |«      ƒ d {  –—† j                  d«      S 7 Œ@7 Œ­w)Né   úutf-8é   )r
   r.   Údecode)r   Únobs     r   ÚreceivezConnectionAsync.receiveA   sM   è ø€ Ü˜Ÿ™ A›×&×.Ñ.¨wÓ7¸Ó<ˆØ—j‘j “o×%×-Ñ-¨gÓ6Ð6ð 'øØ%ús!   ‚A!œA�,A!Á	AÁ
A!ÁA!c              ƒ   óÈ   K  — t        j                  |«      }t        j                  |«       | j	                  |«      ƒ d {  –—†  | j                  «       ƒ d {  –—† S 7 Œ7 Œ­wr   )r   Úencode_datar   r   r4   Ú_check_status)r   Úmsgs     r   ÚsendzConnectionAsync.sendE   sN   è ø€ Ü×"Ñ" 3Ó'ˆÜ�‰�SÔØ�j‰j˜‹o×ÐØ×'Ñ'Ó)×)Ð)ð 	øØ)ús#   ‚?A"ÁAÁA"ÁA ÁA"Á A"c              ƒ   ó"  K  — | j                  d«      ƒ d {  –—† j                  d«      }|t        j                  k7  rL| j                  d«      ƒ d {  –—† j                  d«      }t	        dj                  t        |«      |«      «      ‚y7 Œs7 Œ:­w)Nr6   r7   i   zERROR: {} {}T)r.   r9   r   ÚOKAYr%   r&   Úrepr)r   ÚrecvÚerrors      r   r>   zConnectionAsync._check_statusK   sq   è ø€ Ø—j‘j “m×#×+Ñ+¨GÓ4ˆØ”8—=‘=Ò ØŸ:™: dÓ+×+×3Ñ3°GÓ<ˆEÜ˜~×4Ñ4´T¸$³ZÀÓGÓHÐHàð $øà+ús!   ‚B—B˜:BÁBÁ9BÂBc              ƒ   ól   K  — t        «       }	 | j                  d«      ƒ d {  –—† }|s	 |S ||z  }Œ$7 Œ­w)Ni   )Ú	bytearrayr.   )r   r3   rD   s      r   Úread_allzConnectionAsync.read_allX   sA   è ø€ Ü‹{ˆàØŸ™ DÓ)×)ˆDÙØð ˆð �D‰LˆDð	 Ø)ús   ‚ 4¢2£4c              ƒ   óD   K  — | j                  |«      ƒ d {  –—† }|S 7 Œ­wr   )r.   )r   r-   r3   s      r   r,   zConnectionAsync.readc   s!   è ø€ Ø—Z‘Z Ó'×'ˆØˆð (ús   ‚ —˜ c              ƒ   óB   K  — | j                  |«      ƒ d {  –—†  y 7 Œ­wr   )r4   r2   s     r   r0   zConnectionAsync.writeg   s   è ø€ Ø�j‰j˜Ó×Òús   ‚—˜)Ú	localhosti­  N)r   )Ú__name__Ú
__module__Ú__qualname__r   r   r   r(   r   r.   r4   r;   r@   r>   rH   r,   r0   r   r   r   r   r      sE   „ óòòòòò$NòBò7ò*òò	óór   r   )r    ÚstructÚsocketÚppadb.protocolr   Úppadb.utils.loggerr   Ú
get_loggerrL   r   r   r   r   r   ú<module>rT      s2   ðÛ Û Û å #Ý )à	ˆ×	Ñ	˜xÓ	(€÷]ò ]r   