#)fDUddlmZddlZddlZddlZddlZddlZddlZddlm Z m Z m Z m Z m Z mZmZddlZddlZddlmZmZe rddlZddlmZmZddlmZddlmZmZmZeej<ej>fZ de!d <d d Z"d!d Z#d!d Z$d"d Z%d#dZ&e ddZ'ejPGddZ)ejPGddZ*ejPGddZ+ejPGddejXjZZ.ejPGddejXj^Z0eGddZ1eGddej jdeZ3y)$) annotationsN) TYPE_CHECKINGAnyIterableNoReturnTypeVarUnionoverload)NoPublicConstructorfinal) AddressFamily SocketKind) TracebackType)BufferSelf TypeAliasr IPAddressct|tjrtjj St|tj rtjjStd)Nz!Unhandled IPAddress instance type) isinstance ipaddress IPv4AddresstriosocketAF_INET IPv6AddressAF_INET6NotImplementedError)ips S/var/www/html/flask-app/venv/lib/python3.12/site-packages/trio/testing/_fake_net.py _family_forr *sN"i++,{{""" B -- .{{### A BBc|tjjk(rtjdS|tjj k(rtjdSt d)N0.0.0.0::Unhandled ip address familyrrrr ip_addressrrfamilys r_wildcard_ip_forr*2sT $$$##I.. 4;;'' '##D)) ; <zUDPPacket.vs r!)reprbytespayloadcFt|j|j|S)Nr_r`rg)r^r`r_)rJrgs rreplyzUDPPacket.replyys ##g  r!N)rgrfrRr^)rTrUrVrWattrsfieldrgrjrYr!rr^r^rs)  U[[&78GU8 r!r^c eZdZUded<ddZy)FakeSocketFactoryFakeNetfake_netcFtj|j|||Sr0) FakeSocket_createrp)rJr)type_protos rrzFakeSocketFactory.sockets!!$--FFr!N)r)rErtrErurErRrr)rTrUrVrWrrYr!rrnrnsGr!rncXeZdZUded< d ddZ ddZy) FakeHostnameResolverrorpc KtdwNzFakeNet doesn't do fake DNS yetr)rJhostrFr)typeruflagss r getaddrinfoz FakeHostnameResolver.getaddrinfos"""CDD c Ktdwryrz)rJrKr}s r getnameinfoz FakeHostnameResolver.getnameinfos""CDDrN)rrrr)r{z bytes | NonerFzbytes | str | int | Noner)rEr|rErurEr}rErRz]list[tuple[AddressFamily, SocketKind, int, str, tuple[str, int] | tuple[str, int, int, int]]])rKrSr}rErRztuple[str, str])rTrUrVrWr~rrYr!rrwrws EE'E E  E  EE E&ECELOE Er!rwc4eZdZddZddZddZd dZd dZy) roctjdj|_tjdj|_t tdd|_i|_ d|_ y)Nz 1.0.0.0/8z1::/16iPi) r IPv4Networkhosts_auto_ipv4_iter IPv6Network_auto_ipv6_iteriterrange_auto_port_iter_bound route_packetrJs r__init__zFakeNet.__init__s](44[AGGI(44X>DDF#E%$7846  r!cp||jvrttj||j|<yr0)rr5errno EADDRINUSE)rJbindingrs r_bindz FakeNet._binds* dkk ! e&& '% Gr!ctjjt|tjj t |yr0)rrset_custom_socket_factoryrnset_custom_hostname_resolverrwrs renablezFakeNet.enables2 --.?.EF 001Ed1KLr!cb|j|j|y|j|yr0)rdeliver_packetrJpackets r send_packetzFakeNet.send_packets*    $    '   f %r!ct|j}||jvr|j|j|yy)Nr\)r[r`r_deliver_packet)rJrrs rrzFakeNet.deliver_packets:6#5#56 dkk ! KK 0 0 8 r!NrRNone)rr[rrrrRrrr^rRr)rTrUrVrrrrrrYr!rroros!& M& r!roceZdZ d)dZed*dZed+dZed,dZd-dZd-dZ d.dZ d/dZ d0d Z d1d Z d2 d3d Zej d k7seseej&dreZ d4 d5dZej d k7seseej&dreZd6dZd6dZed7dZed8dZ d9 d:dZed;dZe ddZ d?dZd@dAdZe dBdZe dCdZdDdZd@dEdZ d4dFdZ!d@dGd Z" d4 dHd!Z# d4 dId"Z$ej d k7seseej&dre$Z%d,d#Z&d,d$Z'dJd%Z(dKd&Z)ej d k(seseej&d'rdLd(Z*y y y )Mrrc ||_|stjj}|stjj}|tjjtjj fvrt d||tjjk7rt d|||_||_ ||_ d|_ tjttd\|_|_d|_y)Nz%FakeNet doesn't (yet) support family=z#FakeNet doesn't (yet) support type=Finf) _fake_netrrr SOCK_STREAMrr SOCK_DGRAM_family_type_proto_closedopen_memory_channelr^float_packet_sender_packet_receiver_binding)rJrpr)r|rus rrzFakeSocket.__init__s"[[((F;;**D $++--t{{/C/CD D%(MfX&VW W 4;;)) )%(KD6&RS S    595M5M 6 ,62T2 ,0 r!c|jSr0)rrs rr|zFakeSocket.types zzr!c|jSr0)rrs rr)zFakeSocket.familys ||r!c|jSr0)rrs rruzFakeSocket.protos {{r!cP|jrttjyyr0)rr5rEBADFrs r _check_closedzFakeSocket._check_closeds << ekk " r!c|jryd|_|j!|jj|j=|jj y)NT)rrrrrclosers rrzFakeSocket.closesE <<  == $%%dmm4 ##%r!cKtjj|j|j|j |d|d{S7w)NF)address ipv6_v6onlyr\)r_socket_resolve_address_nocpr|r)ru)rJrr\s rrz FakeSocket._resolve_address_nocpsL\\77 II KK JJ 8    sAA A Actjtj5|jj |dddy#1swYyxYwr0) contextlibsuppressrBrokenResourceErrorr send_nowaitrs rrzFakeSocket._deliver_packets?  !9!9 : 4    + +F 3 4 4 4s A  AcK|j|jttjt j jd{|j|dd{^}}}|gk(sJdtj|}t||jk(sJ|tjdk(rtjd}n-|tjdk(rtjd}|dk(rt|jj}t!t#||}|jj%||||_y77w) NTrzTODO: handle other values?r#r,r$r-r)rrr5rEINVALrlowlevel checkpointrrr'r r)nextrrr[rBr)rJaddrip_strrF_rrs rbindzFakeSocket.binds&  == $ ell #mm&&(((!%!;!;D!;!MMqBw444  ! !& )2$++-- %%i0 0%%k2B 9''- -%%e,B 19667D;r4#89 Wd+  )Ms%AE5E0E54E35C>73 S( ( .. .IG33 7sA)C+C,A0Cc&|j|j$|jjjS|jt j jk(ry|jt j jk(sJy)N)r#r)r$r) rrr\rLr)rrrrrs r getsocknamezFakeSocket.getsocknamesf  == $==&&99; ; [[DKK// /!;;$++"6"66 6r!cr|j|jt|jdsJd|jjOt |jjt sJd|jjj Sttjy)NremotezGThis method seems to assume that self._binding has a remote UDPEndpointz,Self._binding.remote should be a UDPEndpoint) rrhasattrrrrBrLr5rrrs r getpeernamezFakeSocket.getpeernames  == $ x YX Y}}##/!MM((+BAB}}++>>@@%..!r!cyr0rY)rJleveloptnames r getsockoptzFakeSocket.getsockopts>Ar!cyr0rYrJrrbuflens rrzFakeSocket.getsockoptsMPr!cF|jtd|d|d)Nz%FakeNet doesn't implement getsockopt(, ))rr1rs rrzFakeSocket.getsockopts+ =eWBwiqQRRr!cyr0rY)rJrrvalues r setsockoptzFakeSocket.setsockoptsTWr!cyr0rYrJrrroptlens rrzFakeSocket.setsockoptsr!c|j||ftjjtjjfk(r |s t dt d|d|d)Nz#FakeNet always has IPV6_V6ONLY=Truez%FakeNet doesn't implement setsockopt(rz, ...))rrr IPPROTO_IPV6 IPV6_V6ONLYrr1rs rrzFakeSocket.setsockoptsh  7  KK $ $ KK # #  %&KL L=eWBwivVWWr!c|Sr0rYrs r __enter__zFakeSocket.__enter__s r!c$|jyr0)r)rJexc_type exc_value tracebacks r__exit__zFakeSocket.__exit__s r!cDK|j||dd{S7wr0)sendto)rJr:r}s rsendzFakeSocket.sends[[ud3333s   c Kywr0rY)rJ_FakeSocket__data_FakeSocket__addresss rrzFakeSocket.sendtos c Kywr0rY)rJr_FakeSocket__flagsrs rrzFakeSocket.sendtos rcKt|dk(r|\}}d}n t|dk(r|\}}}n td|j|gg||d{S7w)NrNrzwrong number of arguments)r9 TypeErrorr)rJargsr:rr}s rrzFakeSocket.sendtosa t9> MD'E Y!^#' D%78 8]]D62ug>>>>sAAAAcLK|j||d{\}}|S7 wr0)recvfrom)rJbufsizer}r:rs rrecvzFakeSocket.recvs'"mmGU;; g  >8<8J8J E1e9 3 / GY7""3 sAAAAcKt|}|j|g||d{\}}}}t|d||||fS7wr0) bytearrayrrf) rJrrr}r=rrrrs rrzFakeSocket._recvmsgs[ 8<8J8J E:u9 3 / GYc+:&')WEE3 s#AAActd)Nz&can't get fileno() for FakeNet socketsrzrs rfilenozFakeSocket.filenos!"JKKr!ctd)Nzcan't detach() a FakeNet socketrzrs rdetachzFakeSocket.detachs!"CDDr!cy)NFrYrs rget_inheritablezFakeSocket.get_inheritablesr!c|r tdy)Nz&FakeNet can't make inheritable socketsrz)rJ inheritables rset_inheritablezFakeSocket.set_inheritables %&NO O r!sharectd)NzFakeNet can't share socketsrz)rJ process_ids rr#zFakeSocket.share"s%&CD Dr!)rpror)r r|rrurE)rRr)rRr )rRrEr)robjectr\boolrRztuple[str, int]r)rr&rRr)rr&rRr)rYrN) r;Iterable[Buffer]rz!Iterable[tuple[int, int, Buffer]]r}rErz Any | NonerRrErH)r;r(rrEr}rErRz2tuple[int, list[tuple[int, int, bytes]], int, Any]rQ)rrErrErRrE)rrErrErrErRrfr0)rrErrEr int | NonerRz int | bytes)rrErrErz int | BufferrRr) rrErrErrrrErRr) rrErrErzint | Buffer | Nonerr)rRr)rRr)rz#builtins.type[BaseException] | NonerzBaseException | NonerzTracebackType | NonerRr)r)r:rr}rErRrE)rrrz!tuple[object, ...] | str | BufferrRrE)rrrrErz(tuple[object, ...] | str | None | BufferrRrE)r rrRrE)rrEr}rErRrf)r=rr8rEr}rErRrE)rrEr}rErRztuple[bytes, Any])r=rr8rEr}rErRztuple[int, Any])rrErrEr}rErRz4tuple[bytes, list[tuple[int, int, bytes]], int, Any])rRr')r!r'rRr)r%rErRrf)+rTrUrVrpropertyr|r)rurrrrrrrsysplatformrrrrr recvmsg_intorrr rrrrrrrrr rrrecvmsgrrrr"r#rYr!rrrrrs000 0  0@#&    )-    4 *V 68" %!%3% %  % %N ||w gfmmY?  4!44 4 < 4> ||w gfmmY?$  "AA PPAESS&)S3=S S WW &)26@C " XX X # X  X X,5((   4)J <   ? :;###&#36# #?@FF(+F8;F =F ||w gfmmY?LEP ||w gfmmW= E>Mr!rr) metaclass)rrrRrE)r)rErRr)r4rErRr)r:rfr;r(rRrE)4 __future__rrrrr2rr+typingrrrrrr r rkr trio._utilr r builtinsr rtypesrtyping_extensionsrrrrrrrWr r*r.r5r@rAfrozenrBr[r^abc SocketFactoryrnHostnameResolverrwro SocketTyperrrYr!rr;s#   10#99Y22I4I4IIJ 9JC==+ }= ;;;*      G..GGE48844EE8   FZE''3FZEZEr!