h3UddlmZddlZddlZddlZddlmZddlmZm Z m Z ddl m Z ddl mZddlmZmZddlmZdd lmZmZmZd d lmZd d lmZmZmZd dlmZmZm Z d dl!m"Z"ej#dkrddlm$Z$nddl%m$Z$ee&eefZ'de(d<e)e&e*fZ+de(d<ee+e&fZ,de(d<e)e-e+fZ.de(d<e)e-e&fZ/de(d<edZ0ej1fdddd9d&Z2Gd'd(eZ3Gd)d*eZ4Gd+d,ee4Z5Gd-d.e5Z6Gd/d0ee5e4Z7Gd1d2e e.e4Z8Gd3d4e e-e4Z9Gd5d6e e/e4Z:Gd7d8e e-e4Z;dS):) annotationsN)abstractmethod)Callable CollectionMapping)AsyncExitStack)IOBase) IPv4Address IPv6Address) AddressFamily)AnyTypeVarUnion)get_async_backend)TypedAttributeProviderTypedAttributeSettyped_attribute) ByteStreamListenerUnreliableObjectStream) TaskGroup) ) TypeAliasr IPAddressTypeIPSockAddrType SockAddrType UDPPacketTypeUNIXDatagramPacketTypeT_RetvalF)require_connected require_bound sock_or_fdsocket.socket | int sock_typesocket.SocketKind addr_familysocket.AddressFamilyr#boolr$return socket.socketcrt|trs tj|}n#t$rO}|jtjkrt d||rt d||rt d|d}~wwxYwt|tjr|}n%tdt|j d |r8 | n"#t$r}t d|d}~wwxYw|rs |j tj tj fvr|d}n|}n#t$rd}YnwxYw|st d|tjkr/|j |kr$t d|jd |j j|j|kr$t d |jd |jjn8#t"$r+t|tr|wxYw|d |S) N)filenoz.the file descriptor does not refer to a socketzthe socket must be connectedz+the socket must be bound to a local addresszexpected an int or socket, got z insteadrz"address family mismatch: expected z, got zsocket type mismatch: expected F) isinstanceintsocketOSErrorerrnoENOTSOCK ValueError TypeErrortype __qualname__ getpeernamefamilyAF_INETAF_INET6 getsockname AF_UNSPECname BaseExceptiondetach setblocking)r%r'r)r#r$sockexc bound_addrs _/var/www/html/web-builder-api.evdpl.com/venv/lib/python3.11/site-packages/anyio/abc/_sockets.py_validate_socketrH$s*c""  = 333DD   yEN** D#  !?@@cI  !NOOUXX  J . .  Ud:.>.>.K U U U   "  J J  """" J J J !?@@cI J  P ";6>6?"CCC!%!1!1!3!3A!6JJ!%!1!1!3!3J " " "!  " P !NOOO &* * *t{k/I/I&[5E&&;#&&  9 ! !X).XX XX  "  j# & &  KKMMM  U Ksk- BA BB G*C$#G*$ D.C>>DG* AEG* E'$G*&E''BG**5HceZdZUdZeZded<eZded<eZded<eZ ded <eZ ded <eZ ded <d S) SocketAttributea .. attribute:: family :type: socket.AddressFamily the address family of the underlying socket .. attribute:: local_address :type: tuple[str, int] | str the local address the underlying socket is connected to .. attribute:: local_port :type: int for IP based sockets, the local port the underlying socket is bound to .. attribute:: raw_socket :type: socket.socket the underlying stdlib socket object .. attribute:: remote_address :type: tuple[str, int] | str the remote address the underlying socket is connected to .. attribute:: remote_port :type: int for IP based sockets, the remote port the underlying socket is connected to r r;r local_addressr1 local_portr- raw_socketremote_address remote_portN) __name__ __module__r9__doc__rr;__annotations__rKrLrMrNrOrGrJrJis@,O--F----"1/"3"3M3333%o''J'''' / 1 1J1111#2?#4#4N4444&((K((((((rUrJcNeZdZeddZeeddZdS) _SocketProviderr,Mapping[Any, Callable[[], Any]]cddlmtjfdtjfdtjfdi} jn#t$rdYnwxYwfd|tj <jjtj tj fvr.fd|tj <dfd |tj<|S) Nr)convert_ipv6_sockaddrcjjSN) _raw_socketr;selfsrGz2_SocketProvider.extra_attributes..s D,<,CrUcHjSr\r]r>)convertr_srGr`z2_SocketProvider.extra_attributes..s%77 ,,..44rUcjSr\)r]r^srGr`z2_SocketProvider.extra_attributes..s 0@rUcSr\rT)peernamesrGr`z2_SocketProvider.extra_attributes..srUcBjdS)Nrrbr^srGr`z2_SocketProvider.extra_attributes..s(4466q9rUrcSr\rT)rOsrGr`z2_SocketProvider.extra_attributes..s+rU)_core._socketsrZrJr;rKrMr]r:r3rNr r<r=rLrO)r_ attributesrcrfrOs` @@@rGextra_attributesz _SocketProvider.extra_attributess1EEEEEE  "$C$C$C$C  ),,,,,  &(@(@(@(@ 4  /6wt7G7S7S7U7U/V/VHH   HHH   9I9I9I9IJ5 6   "}'T&U U U9999 1 2#&qk :M:M:M:M ?67s"A A.-A.r-cdSr\rTr^s rGr]z_SocketProvider._raw_sockets  rUN)r,rX)r,r-)rPrQr9propertyrkrr]rTrUrGrWrWs\ X<   ^X   rUrWc*eZdZdZeddZdS) SocketStreamzu Transports bytes over a socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r%r&r,cKt|tjd}t|d{VS)aH Wrap an existing socket object or file descriptor as a socket stream. The newly created socket wrapper takes ownership of the socket being passed in. The existing socket must already be connected. :param sock_or_fd: a socket object or file descriptor :return: a socket stream Tr#N)rHr2 SOCK_STREAMrwrap_stream_socketclsr%rDs rG from_socketzSocketStream.from_socketsL F,>RVWWW&((;;DAAAAAAAAArUN)r%r&r,rorPrQr9rR classmethodrvrTrUrGrorosD  B B B[ B B BrUrocVeZdZeddZedd ZeddZdS)UNIXSocketStreamr%r&r,cKt|tjtjd}t |d{VS)aR Wrap an existing socket object or file descriptor as a UNIX socket stream. The newly created socket wrapper takes ownership of the socket being passed in. The existing socket must already be connected. :param sock_or_fd: a socket object or file descriptor :return: a UNIX socket stream TrqN)rHr2rrAF_UNIXrwrap_unix_stream_socketrts rGrvzUNIXSocketStream.from_socketsX *FNd   '((@@FFFFFFFFFrUmessagebytesfdsCollection[int | IOBase]Nonec KdS)z Send file descriptors along with a message to the peer. :param message: a non-empty bytestring :param fds: a collection of files (either numeric file descriptors or open file or socket objects) NrT)r_r~rs rGsend_fdszUNIXSocketStream.send_fds rUmsglenr1maxfdstuple[bytes, list[int]]c KdS)a Receive file descriptors along with a message from the peer. :param msglen: length of the message to expect from the peer :param maxfds: maximum number of file descriptors to expect from the peer :return: a tuple of (message, file descriptors) NrT)r_rrs rG receive_fdszUNIXSocketStream.receive_fdsrrUN)r%r&r,rz)r~rrrr,r)rr1rr1r,r)rPrQr9rxrvrrrrTrUrGrzrzsvGGG[G    ^    ^   rUrzcNeZdZdZeddZeddZ dddZdS)SocketListenerz} Listens to incoming socket connections. Supports all relevant extra attributes from :class:`~SocketAttribute`. r%r&r,cKt|tjd}t|d{VS)a Wrap an existing socket object or file descriptor as a socket listener. The newly created listener takes ownership of the socket being passed in. :param sock_or_fd: a socket object or file descriptor :return: a socket listener Tr$N)rHr2rrrwrap_listener_socketrts rGrvzSocketListener.from_socketsK F,>dSSS&((==dCCCCCCCCCrUroc KdS)zAccept an incoming connection.NrTr^s rGacceptzSocketListener.acceptrrUNhandlerCallable[[SocketStream], Any] task_groupTaskGroup | NonercKddlm}t4d{V}|#||d{V} |d{V}|||1#1d{VswxYwYdS)Nr)create_task_group)rrenter_async_contextr start_soon)r_rrrstackstreams rGservezSocketListener.serves )(((((!## 7 7 7 7 7 7 7u!#(#<#<=N=N=P=P#Q#QQQQQQQ  7#{{}},,,,,,%%gv666 7  7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7sAA55 A?A?)r%r&r,r)r,ror\)rrrrr,r) rPrQr9rRrxrvrrrrTrUrGrrs DDD[D ---^- (, 7 7 7 7 7 7 7rUrc2eZdZdZeddZdd ZdS) UDPSocketz{ Represents an unconnected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r%r&r,cKt|tjd}t|d{VS)aI Wrap an existing socket object or file descriptor as a UDP socket. The newly created socket wrapper takes ownership of the socket being passed in. The existing socket must be bound to a local address. :param sock_or_fd: a socket object or file descriptor :return: a UDP socket TrN)rHr2 SOCK_DGRAMrwrap_udp_socketrts rGrvzUDPSocket.from_socket)sK F,=TRRR&((88>>>>>>>>>rUdatarhoststrportr1rcDK||||ffd{VS)z^ Alias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))). Nsend)r_rrrs rGsendtozUDPSocket.sendto8s5 YYtTl3444444444rUN)r%r&r,r)rrrrrr1r,rrPrQr9rRrxrvrrTrUrGrr"sR  ? ? ?[ ?555555rUrc*eZdZdZeddZdS)ConnectedUDPSocketzy Represents an connected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r%r&r,cKt|tjd}t|d{VS)aV Wrap an existing socket object or file descriptor as a connected UDP socket. The newly created socket wrapper takes ownership of the socket being passed in. The existing socket must already be connected. :param sock_or_fd: a socket object or file descriptor :return: a connected UDP socket TrqN)rHr2rrwrap_connected_udp_socketrts rGrvzConnectedUDPSocket.from_socketGsV   "    '((BB4HHHHHHHHHrUN)r%r&r,rrwrTrUrGrr@sD III[IIIrUrc2eZdZdZed dZdd Zd S)UNIXDatagramSocketz Represents an unconnected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r%r&r,cKt|tjtj}t |d{VS)a' Wrap an existing socket object or file descriptor as a UNIX datagram socket. The newly created socket wrapper takes ownership of the socket being passed in. :param sock_or_fd: a socket object or file descriptor :return: a UNIX datagram socket N)rHr2rr|rwrap_unix_datagram_socketrts rGrvzUNIXDatagramSocket.from_socketdsJ F,=v~NN&((BB4HHHHHHHHHrUrrpathrrc@K|||fd{VS)zCAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, path)).Nr)r_rrs rGrzUNIXDatagramSocket.sendtovs.YYd|,,,,,,,,,rUN)r%r&r,r)rrrrr,rrrTrUrGrr[sV III[I"------rUrc*eZdZdZeddZdS)ConnectedUNIXDatagramSocketz Represents a connected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r%r&r,cKt|tjtjd}t |d{VS)ar Wrap an existing socket object or file descriptor as a connected UNIX datagram socket. The newly created socket wrapper takes ownership of the socket being passed in. The existing socket must already be connected. :param sock_or_fd: a socket object or file descriptor :return: a connected UNIX datagram socket TrqN)rHr2rr|r#wrap_connected_unix_datagram_socketrts rGrvz'ConnectedUNIXDatagramSocket.from_socketsX  )6>T   '((LLTRRRRRRRRRrUN)r%r&r,rrwrTrUrGrr{sD SSS[SSSrUr) r%r&r'r(r)r*r#r+r$r+r,r-)< __future__rr4r2sysabcrcollections.abcrrr contextlibrior ipaddressr r r typingr rr_core._eventloopr_core._typedattrrrr_streamsrrr_tasksr version_infortyping_extensionsrrrStupler1rrrr r!r"r?rHrJrWrorzrrrrrrTrUrGrs""""""" 9999999999%%%%%%........ &&&&&&&&&&000000 CBBBBBBBBBw       ++++++ k;!>? ????!#s(O++++ 34 4444 !67 7777$)%*$55555 7:   )/(8B $ BBBBBBJ&)&)&)&)&)'&)&)&)R# # # # # ,# # # LBBBBB:BBB.$ $ $ $ $ |$ $ $ N)7)7)7)7)7Xl+_)7)7)7X55555&}5555<IIIII/6III6-----12O---@SSSSS"8"?SSSSSrU