o
    XzjÄ  ã                   @   s@   d dl Z ddlmZmZ dZG dd„ deƒZG dd„ deƒZdS )	é    Né   )Ú
ConnectionÚPacketCodeci»  c                   @   s$   e Zd ZdZdZdd„ Zdd„ ZdS )ÚHttpPacketCodecNc                 C   s$   d  | jj| jjt|ƒ¡ d¡| S )NzªPOST /api HTTP/1.1
Host: {}:{}
Content-Type: application/x-www-form-urlencoded
Connection: keep-alive
Keep-Alive: timeout=100000, max=10000000
Content-Length: {}

Úascii)ÚformatÚ_connÚ_ipÚ_portÚlenÚencode)ÚselfÚdata© r   ú[/var/www/kodo/tsheker/venv/lib/python3.10/site-packages/telethon/network/connection/http.pyÚencode_packet   s   ùzHttpPacketCodec.encode_packetc                 Ã   sn   �	 |  ¡ I d H }|r|d dkrt |d ¡‚| ¡  d¡r6| d¡I d H  t|dd… ƒ}| |¡I d H S q)NTéÿÿÿÿó   
s   content-length: é   é   éþÿÿÿ)ÚreadlineÚasyncioÚIncompleteReadErrorÚlowerÚ
startswithÚreadexactlyÚint)r   ÚreaderÚlineÚlengthr   r   r   Úread_packet   s   €øzHttpPacketCodec.read_packet)Ú__name__Ú
__module__Ú__qualname__ÚtagÚobfuscate_tagr   r!   r   r   r   r   r   	   s
    
r   c                       s"   e Zd ZeZd‡ fdd„	Z‡  ZS )ÚConnectionHttpNc                 ƒ   s"   �t ƒ j|| jtkd�I d H  d S )N)ÚtimeoutÚssl)ÚsuperÚconnectr
   ÚSSL_PORT)r   r(   r)   ©Ú	__class__r   r   r+   &   s   € zConnectionHttp.connect)NN)r"   r#   r$   r   Úpacket_codecr+   Ú__classcell__r   r   r-   r   r'   #   s    r'   )r   Ú
connectionr   r   r,   r   r'   r   r   r   r   Ú<module>   s
    