
    N[i                     n    d dl Z d dlmZmZ d dlmZ ddlmZ  e j                  e	      Z
 G d de      Zy)    N)packunpack)Optional   )TCPc                   d     e Zd Zdedef fdZdef fdZdef fdZ	dde
d	ee   f fd
Z xZS )TCPIntermediateipv6proxyc                 &    t         |   ||       y )N)super__init__)selfr
   r   	__class__s      e/var/www/files/kim/lib/python3.12/site-packages/pyrogram/connection/transport/tcp/tcp_intermediate.pyr   zTCPIntermediate.__init__   s    u%    addressc                 r   K   t         |   |       d {    t         | 	  d       d {    y 7 7 w)Ns   )r   connectsend)r   r   r   s     r   r   zTCPIntermediate.connect    s4     gog&&&gl;''' 	''s   737577datac                 l   K   t         |   t        dt        |            |z          d {    y 7 w)N<i)r   r   r   len)r   r   argsr   s      r   r   zTCPIntermediate.send$   s)     gl4c$i047888s   )424lengthreturnc                    K   t         |   d       d {   }|y t         |   t        d|      d          d {   S 7 +7 w)N   r   r   )r   recvr   )r   r   r   s     r   r    zTCPIntermediate.recv'   sH     w|A&>W\&v"6q"9::: '
 ;s   AA&AAAA)r   )__name__
__module____qualname__booldictr   tupler   bytesr   intr   r    __classcell__)r   s   @r   r	   r	      sJ    &T &$ &(U (9u 9; ;Xe_ ; ;r   r	   )loggingstructr   r   typingr   tcpr   	getLoggerr!   logr	    r   r   <module>r1      s1   &    g!;c ;r   