Ë
    S"“j°  ã                   ól   — d dl Z d dlZd dlmZ ddlmZmZ ddlmZm	Z	  G d„ de«      Z
 G d	„ d
e«      Zy)é    N)Úcrc32é   )Ú
ConnectionÚPacketCodecé   )ÚInvalidChecksumErrorÚInvalidBufferErrorc                   ó.   ‡ — e Zd ZdZˆ fd„Zd„ Zd„ Zˆ xZS )ÚFullPacketCodecNc                 ó2   •— t         ‰| �  |«       d| _        y )Nr   )ÚsuperÚ__init__Ú_send_counter)ÚselfÚ
connectionÚ	__class__s     €úd/var/www/api.ozpay.ru/ozpay/venv/lib/python3.12/site-packages/telethon/network/connection/tcpfull.pyr   zFullPacketCodec.__init__   s   ø€ Ü‰Ñ˜Ô$ØˆÕó    c                 óØ   — t        |«      dz   }t        j                  d|| j                  «      |z   }t        j                  dt	        |«      «      }| xj                  dz  c_        ||z   S )Né   ú<iiú<Ir   )ÚlenÚstructÚpackr   r   )r   ÚdataÚlengthÚcrcs       r   Úencode_packetzFullPacketCodec.encode_packet   s]   € ô �T“˜R‘ˆÜ�{‰{˜5 &¨$×*<Ñ*<Ó=ÀÑDˆÜ�k‰k˜$¤ d£Ó,ˆØ×Ò˜aÑÕØ�c‰zÐr   c              ƒ   ó&  K  — 	 |j                  d«      ƒ d {  –—† }t	        j
                  d|«      \  }}|dk  r)|dk  r$|j                  d«      ƒ d {  –—† }t        |«      ‚|dk  rt        |«      ‚|j                  |dz
  «      ƒ d {  –—† }t	        j
                  d|dd  «      d   }|d d }t        ||z   «      }||k7  rt        ||«      ‚|S 7 Œ¹# t        j                  $ r#}|j                  r|j                  cY d }~S ‚ d }~ww xY w7 Œ¸7 Œƒ­w)Né   r   r   é   r   éüÿÿÿ)	ÚreadexactlyÚasyncioÚIncompleteReadErrorÚpartialr   Úunpackr	   r   r   )	r   ÚreaderÚpacket_len_seqÚexcÚ
packet_lenÚseqÚbodyÚchecksumÚvalid_checksums	            r   Úread_packetzFullPacketCodec.read_packet   s  è ø€ ð	Ø#)×#5Ñ#5°aÓ#8×8ˆNô !Ÿ-™-¨¨~Ó>‰ˆ
�CØ˜Š>˜c Ašgð  ×+Ñ+¨AÓ.×.ˆDÜ$ TÓ*Ð*Ø˜!Š^ô % ^Ó4Ð4à×'Ñ'¨
°Q©Ó7×7ˆÜ—=‘=  t¨B¨C yÓ1°!Ñ4ˆØ�C�Rˆyˆä˜~°Ñ4Ó5ˆØ�~Ò%Ü& x°Ó@Ð@àˆð7 9ùÜ×*Ñ*ò 	Ø�{Š{Ø—{‘{Õ"àûð		úð /øð 8úsh   ‚D„C ˜C™C �7DÁDÁ6DÂDÂADÃC ÃD
Ã'DÃ>D
Ã?DÄDÄD
Ä
DÄD)Ú__name__Ú
__module__Ú__qualname__Útagr   r   r1   Ú__classcell__)r   s   @r   r   r   	   s   ø„ Ø
€Côòör   r   c                   ó   — e Zd ZdZeZy)ÚConnectionTcpFullzy
    Default Telegram mode. Sends 12 additional bytes and
    needs to calculate the CRC value of the packet itself.
    N)r2   r3   r4   Ú__doc__r   Úpacket_codec© r   r   r8   r8   9   s   „ ñð #�Lr   r8   )r%   r   Úzlibr   r   r   r   Úerrorsr   r	   r   r8   r;   r   r   ú<module>r>      s-   ðÛ Û Ý ç /ß >ô-�kô -ô`#˜
õ #r   