
    $Sh	                     x    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  ej	        e
          Z G d d          ZdS )	    N)Optional   )TCPTCPAbridged   )
DataCenterc                   `    e Zd ZdZddededededef
dZd	 Zd
 Z	de
fdZdee
         fdZdS )
Connection   Fdc_id	test_modeipv6proxymediac                     || _         || _        || _        || _        || _        t          ||||          | _        d | _        d S N)r   r   r   r   r   r   addressprotocol)selfr   r   r   r   r   s         d/var/www/html/movieo_spanner_bot/venv/lib/python3.11/site-packages/pyrogram/connection/connection.py__init__zConnection.__init__    sE    
"	

!%D%@@!    c                   K   t          t          j                  D ]}t          | j        | j                  | _        	 t                              d           | j        	                    | j
                   d {V  t                              d| j        rdnd| j        | j        rdnd| j        rdnd            d S # t          $ r_}t                              d	|           | j                                         d {V  t#          j        d
           d {V  Y d }~d }~ww xY wt                              d           t&          )NzConnecting...zConnected! %s DC%s%s - IPv%sTest
Productionz (media) 64z+Unable to connect due to network issues: %sr   z"Connection failed! Trying again...)ranger
   MAX_CONNECTION_ATTEMPTSr   r   r   r   loginfoconnectr   r   r   r   OSErrorwarningcloseasynciosleepConnectionError)r   ies      r   r#   zConnection.connect*   sq     z9:: 	" 	"A'	4:>>DM)))m++DL999999999 7#'>C|'+z9r $	2s	4 4 4
   ' ' 'I1MMMm))+++++++++mA&&&&&&&&&&&&&&' KK<===!!s   ?B??
D(	AD##D(c                 |   K   | j                                          d {V  t                              d           d S )NDisconnected)r   r&   r!   r"   r   s    r   r&   zConnection.close@   sD      m!!#########     r   datac                 J   K   | j                             |           d {V  d S r   )r   send)r   r/   s     r   r1   zConnection.sendD   s4      m  &&&&&&&&&&&r   returnc                 D   K   | j                                          d {V S r   )r   recvr.   s    r   r4   zConnection.recvG   s,      ]'')))))))))r   N)F)__name__
__module____qualname__r    intbooldictr   r#   r&   bytesr1   r   r4    r   r   r
   r
      s        " "c "d "$ "t "TX " " " "" " ",! ! !'u ' ' ' '*HUO * * * * * *r   r
   )r'   loggingtypingr   	transportr   r   session.internalsr   	getLoggerr5   r!   r
   r<   r   r   <module>rB      s   &         ' ' ' ' ' ' ' ' * * * * * *g!!+* +* +* +* +* +* +* +* +* +*r   