:ɄjUddlZddlZddlZddlZddlmZmZmZmZddl Z eje Z e je je jdZeeefed<GddeZGddZy) N)TupleDict TypedDictOptional)SOCKS4SOCKS5HTTPproxy_type_by_schemecLeZdZUeed<eed<eed<eeed<eeed<y)ProxyschemehostnameportusernamepasswordN)__name__ __module__ __qualname__str__annotations__intr\/var/www/html/GAP/venv/lib/python3.12/site-packages/pyrogram/connection/transport/tcp/tcp.pyr r %s% KM Ismsmrr ceZdZdZdededdfdZdeee fddfdZ deee fddfd Z deee fddfd Z d eee fddfd Z dd ZdeddfdZdde deefdZy)TCP ipv6proxyreturnNc||_||_d|_d|_t j |_t j|_yN) rrreaderwriterasyncioLocklockget_event_looploop)selfrrs r__init__z TCP.__init__0s;  6: 6: LLN **, r destinationcK|jjd}| tdtj|j }|td||jjd}|jjd}|jjd}|jjd} t j |}t|t j} | rtjntj} tj| } | j||||| | jt j"|j$j'| | d{| j)dt+j,| d{\|_|_y#t$rd} YwxYw7R7%w) Nr zNo scheme specifiedzUnknown proxy type rrrrF) proxy_typeaddrrrr)sockaddress)r0)rget ValueErrorr upper ipaddress ip_address isinstance IPv6AddresssocketAF_INET6AF_INETsocks socksocket set_proxy settimeoutrTIMEOUTr) sock_connect setblockingr%open_connectionr#r$) r*r,r r.rrrrr6 is_proxy_ipv6 proxy_familyr0s r_connect_via_proxyzTCP._connect_via_proxy:s) >23 3)--flln=  26(;< <::>>*-zz~~f%::>>*-::>>*- J"--h7J'z93H3HIM*7vV^^  - !    $ii$$%   )0)@)@* $   T[1 "!M "" $ sICG G B&GG.G5G6G GGGGGcK|\}}|jrtjntj}t j |||d{\|_|_y7w)N)hostrfamily)rr9r:r;r%rCr#r$)r*r,rHrrIs r_connect_via_directzTCP._connect_via_directisR! d$(II6>>)0)@)@* $   T[$ sA A$A"A$cK|jr|j|d{y|j|d{y77wr")rrFrJ)r*r,s r_connectz TCP._connectus> ::))+6 6 6**;7 7 7 7 7s!AAAAAAr1cK tj|j|tjd{y7#tj $r t dwxYww)NzConnection timed out)r%wait_forrLrr@ TimeoutError)r*r1s rconnectz TCP.connect{sN 7""4==#93;;G G G## 756 6 7s+A$6AAAA$AA!!A$chK|jy |jjtj|jj t j d{y7#t$r4}tjdt|j|Yd}~yd}~wwxYww)NzClose exception: %s %s) r$closer%rN wait_closedrr@ Exceptionloginfotyper)r*es rrRz TCP.closes ;;  D KK   ""4;;#:#:#/C6A88 B;5B66B;;C>CCC CClengthcDKd}t||krj tj|jj |t|z t j d{}|r||z }nyt||krj|S7#ttjf$rYywxYww)Nr) lenr%rNr#readrr@r]rO)r*r_rYchunks rrecvzTCP.recvs$i&  %..KK$$Vc$i%78KKEMD$i&  W112  sAB A B A?!B%B =B ?BBB BB )r N)r)rrrr@boolr r+rrrrFrJrLrPrRbytesr^rrdrrrrr-sG-T-%-D-- 38_-  - ^  38_     8%S/8d8 7U38_77 D !u ! !Xe_rr)r%r5loggingr9typingrrrrr< getLoggerrrUrrr r rrrr rrrrrjst( 33 g!llll JJ(d38nI{{r