Ë
    |¾�jŽ  ã                   ód   — 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                   ój   — 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„ Zd„ Zdd„Zd„ Zy)Ú
ConnectionNc                 ó<   — || _         || _        || _        d | _        y ©N)ÚhostÚportÚtimeoutÚsocket)Úselfr	   r
   r   s       úQ/var/www/api.ozpay.ru/ozpay/venv/lib/python3.12/site-packages/ppadb/connection.pyÚ__init__zConnection.__init__   s   € ØˆŒ	ØˆŒ	ØˆŒØˆ�ó    c                 ó   — | S r   © ©r   s    r   Ú	__enter__zConnection.__enter__   s   € Øˆr   c                 ó$   — | j                  «        y r   )Úclose)r   ÚtypeÚvalueÚ	tracebacks       r   Ú__exit__zConnection.__exit__   s   € Ø�
‰
�r   c           	      ó  — t         j                  dj                  | j                  | j                  «      «       t        j
                  t
        j                  t
        j                  «      | _        d}d}| j
                  j                  t
        j                  t
        j                  t        j                  d||«      «       | j                  r%| j
                  j                  | j                  «       	 | j
                  j                  | j                  | j                  f«       | j
                  S # t
        j                   $ rE}| j#                  «        t%        dj                  | j                  | j                  |«      «      ‚d }~ww xY w)NzConnect to adb server - {}:{}é   r   Úiiz?ERROR: connecting to {}:{} {}.
Is adb running on your computer?)ÚloggerÚdebugÚformatr	   r
   r   ÚAF_INETÚSOCK_STREAMÚ
setsockoptÚ
SOL_SOCKETÚ	SO_LINGERÚstructÚpackr   Ú
settimeoutÚconnectÚerrorr   ÚRuntimeError)r   Úl_onoffÚl_lingerÚes       r   r)   zConnection.connect   s  € Ü�‰Ð4×;Ñ;¸D¿I¹IÀtÇyÁyÓQÔRä—m‘m¤F§N¡N´F×4FÑ4FÓGˆŒàˆØˆà�‰×Ñœv×0Ñ0´&×2BÑ2BÄFÇKÁKÐPTÐV]Ð_gÓDhÔiØ�<Š<Ø�K‰K×"Ñ" 4§<¡<Ô0ð	Ø�K‰K×Ñ §¡¨D¯I©IÐ 6Ô7ð �{‰{Ðøô �|‰|ò 	Ø�J‰JŒLÜÐa×hÑhØ—	‘	Ø—	‘	Øó ó ð ûð	ús   Ã51D2 Ä2F
ÅA FÆF
c                 óœ   — | j                   sy t        j                  d«       	 | j                   j                  «        y # t        $ r Y y w xY w)NzConnection closed...)r   r   r   r   ÚOSErrorr   s    r   r   zConnection.close/   s@   € Ø�{Š{Øä�‰Ð+Ô,ð	Ø�K‰K×ÑÕøÜò 	Ùð	ús   ¤? ¿	AÁ
Ac                 ó8   — | j                   j                  |«      S r   )r   Úrecv)r   Úlengths     r   Ú_recvzConnection._recv>   s   € Ø�{‰{×Ñ Ó'Ð'r   c                 óh   — t        |«      }t        |«      }| j                  j                  |«       |S r   )Ú	bytearrayÚ
memoryviewr   Ú	recv_into)r   r3   r2   Úviews       r   Ú
_recv_intozConnection._recv_intoA   s-   € Ü˜Ó ˆÜ˜$ÓˆØ�‰×Ñ˜dÔ#Øˆr   c                 ó:   — | j                   j                  |«       y r   )r   Úsend©r   Údatas     r   Ú_sendzConnection._sendG   s   € Ø�‰×Ñ˜Õr   c                 óš   — t        | j                  d«      j                  d«      d«      }| j                  |«      }|j                  d«      S )Né   úutf-8é   )Úintr4   Údecoder:   )r   Únobr2   s      r   ÚreceivezConnection.receiveJ   s>   € Ü�$—*‘*˜Q“-×&Ñ& wÓ/°Ó4ˆØ�‰˜sÓ#ˆà�{‰{˜7Ó#Ð#r   c                 ó˜   — t        j                  |«      }t        j                  |«       | j	                  |«       | j                  «       S r   )r   Úencode_datar   r   r?   Ú_check_status)r   Úmsgs     r   r<   zConnection.sendP   s8   € Ü×"Ñ" 3Ó'ˆÜ�‰�SÔØ�
‰
�3ŒØ×!Ñ!Ó#Ð#r   c                 óò   — | j                  d«      j                  d«      }|t        j                  k7  rD| j                  d«      j                  d«      }t	        dj                  t        |«      |«      «      ‚y)NrA   rB   i   zERROR: {} {}T)r4   rE   r   ÚOKAYr+   r    Úrepr)r   r2   r*   s      r   rJ   zConnection._check_statusV   s^   € Ø�z‰z˜!‹}×#Ñ# GÓ,ˆØ”8—=‘=Ò Ø—J‘J˜tÓ$×+Ñ+¨GÓ4ˆEÜ˜~×4Ñ4´T¸$³ZÀÓGÓHÐHàr   c                 ó"   — | j                  «       S r   )rJ   r   s    r   Úcheck_statuszConnection.check_status^   s   € Ø×!Ñ!Ó#Ð#r   c                 óP   — t        «       }	 | j                  d«      }|s	 |S ||z  }Œ)Ni   )r6   r4   )r   r>   r2   s      r   Úread_allzConnection.read_allf   s7   € Ü‹{ˆàØ—:‘:˜dÓ#ˆDÙØð ˆð �D‰LˆDð	 r   c                 ó(   — | j                  |«      }|S r   )r4   )r   r3   r>   s      r   ÚreadzConnection.readq   s   € Ø�z‰z˜&Ó!ˆØˆr   c                 ó&   — | j                  |«       y r   )r?   r=   s     r   ÚwritezConnection.writeu   s   € Ø�
‰
�4Õr   )Ú	localhosti­  N)r   )Ú__name__Ú
__module__Ú__qualname__r   r   r   r)   r   r4   r:   r?   rG   r<   rJ   rP   rR   rT   rV   r   r   r   r   r   
   sM   „ óòòòò0ò(òòò$ò$òò$ò	óór   r   )
r&   r   Úppadb.protocolr   Úppadb.utils.loggerr   Ú
get_loggerrX   r   r   r   r   r   ú<module>r^      s/   ðÛ Û å #Ý )à	ˆ×	Ñ	˜xÓ	(€÷lò lr   