a h3 @s:UddlmZddlZddlZddlZddlmZddlmZm Z m Z ddl m Z ddl mZddlmZmZddlmZdd lmZmZmZd d lmZd d lmZmZmZd dlmZmZm Z d dl!m"Z"ej#dkrddlm$Z$n ddl%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<edZ0ej1fdddddddddd d!d"Z2Gd#d$d$eZ3Gd%d&d&eZ4Gd'd(d(ee4Z5Gd)d*d*e5Z6Gd+d,d,ee5e4Z7Gd-d.d.e e.e4Z8Gd/d0d0e e-e4Z9Gd1d2d2e e/e4Z:Gd3d4d4e e-e4Z;dS)5) 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_boundsocket.socket | intzsocket.SocketKindzsocket.AddressFamilybool socket.socket) sock_or_fd sock_type addr_familyr"r#returnc Cst|tr|ztj|d}Wqtyx}zF|jtjkrBtd|n"|rRtd|n|rbtd|nWYd}~qd}~00n(t|tjr|}ntdt|j dz|rz | Wn.ty}ztd|WYd}~n d}~00|rBz.|j tj tj fvr|d}n|}Wnty2d}Yn0|sBtd|tjkrt|j |krttd|jd |j j|j|krtd |jd |jjWn*tyt|tr|Yn0|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#sockexcZ bound_addrrBN/var/www/html/assistant/venv/lib/python3.9/site-packages/anyio/abc/_sockets.py_validate_socket$sf             rDc@sfeZdZUdZeZded<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 r7r local_addressr- local_portr& raw_socketremote_address remote_portN) __name__ __module__r5__doc__rr7__annotations__rFrGrHrIrJrBrBrBrCrEis  rEc@s4eZdZeddddZeeddddZdS) _SocketProviderzMapping[Any, Callable[[], Any]]r*csddlmtjfddtjfddtjfddi}zjWntyddYn0durfdd|tj <jjt j t j fvrȇfdd|tj <durȈd fd d|tj<|S) Nr)convert_ipv6_sockaddrcsjjSN) _raw_socketr7rBselfrBrCz2_SocketProvider.extra_attributes..csjSrRrSr:rB)convertrUrBrCrVscsjSrR)rSrBrTrBrCrVrWcsSrRrBrB)peernamerBrCrVrWcsjdS)NrrXrBrTrBrCrVrWrcsSrRrBrB)rJrBrCrVrW)Z_core._socketsrQrEr7rFrHrSr6r/rIr r8r9rGrJ)rU attributesrB)rYrZrJrUrCextra_attributess$    z _SocketProvider.extra_attributesr&cCsdSrRrBrTrBrBrCrSsz_SocketProvider._raw_socketN)rKrLr5propertyr\rrSrBrBrBrCrOs rOc@s$eZdZdZedddddZdS) SocketStreamzu Transports bytes over a socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r$r'r*cs"t|tjdd}t|IdHS)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)rDr. SOCK_STREAMrZwrap_stream_socketclsr'r@rBrBrC from_sockets zSocketStream.from_socketNrKrLr5rM classmethodrdrBrBrBrCr^sr^c@sLeZdZedddddZeddddd d Zed d d d ddZdS)UNIXSocketStreamr$r_cs&t|tjtjdd}t|IdHS)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 Tr`N)rDr.raAF_UNIXrZwrap_unix_stream_socketrbrBrBrCrds  zUNIXSocketStream.from_socketbyteszCollection[int | IOBase]None)messagefdsr*csdS)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) NrB)rUrkrlrBrBrCsend_fdsszUNIXSocketStream.send_fdsr-ztuple[bytes, list[int]])msglenmaxfdsr*csdS)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) NrB)rUrnrorBrBrC receive_fdsszUNIXSocketStream.receive_fdsN)rKrLr5rfrdrrmrprBrBrBrCrgs  rgc@sJeZdZdZedddddZedddd Zdd d d dddZd S)SocketListenerz} Listens to incoming socket connections. Supports all relevant extra attributes from :class:`~SocketAttribute`. r$r_cs"t|tjdd}t|IdHS)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)rDr.rarZwrap_listener_socketrbrBrBrCrdszSocketListener.from_socketr^rPcsdS)zAccept an incoming connection.NrBrTrBrBrCacceptszSocketListener.acceptNzCallable[[SocketStream], Any]zTaskGroup | Nonerj)handler task_groupr*c sddlm}t4IdHL}|dur6||IdH}|IdH}|||q6WdIdHq|1IdHsr0YdS)Nr)create_task_group)rvrenter_async_contextrsZ start_soon)rUrtrurvstackstreamrBrBrCserves  zSocketListener.serve)N) rKrLr5rMrfrdrrsr{rBrBrBrCrqsrqc@s8eZdZdZedddddZdddd d d d Zd S) UDPSocketz{ Represents an unconnected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r$r_cs"t|tjdd}t|IdHS)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 TrrN)rDr. SOCK_DGRAMrZwrap_udp_socketrbrBrBrCrd)s zUDPSocket.from_socketristrr-rj)datahostportr*cs||||ffIdHS)z^ Alias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))). Nsend)rUrrrrBrBrCsendto8szUDPSocket.sendtoNrKrLr5rMrfrdrrBrBrBrCr|"sr|c@s$eZdZdZedddddZdS)ConnectedUDPSocketzy Represents an connected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r$r_cs"t|tjdd}t|IdHS)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 Tr`N)rDr.r}rZwrap_connected_udp_socketrbrBrBrCrdGs zConnectedUDPSocket.from_socketNrerBrBrBrCr@src@s6eZdZdZedddddZdddd d d Zd S) UNIXDatagramSocketz Represents an unconnected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r$r_cs"t|tjtj}t|IdHS)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)rDr.r}rhrZwrap_unix_datagram_socketrbrBrBrCrddszUNIXDatagramSocket.from_socketrir~rj)rpathr*cs|||fIdHS)zCAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, path)).Nr)rUrrrBrBrCrvszUNIXDatagramSocket.sendtoNrrBrBrBrCr[src@s$eZdZdZedddddZdS)ConnectedUNIXDatagramSocketz Represents a connected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r$r_cs&t|tjtjdd}t|IdHS)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 Tr`N)rDr.r}rhrZ#wrap_connected_unix_datagram_socketrbrBrBrCrds z'ConnectedUNIXDatagramSocket.from_socketNrerBrBrBrCr{sr)< __future__rr0r.sysabcrcollections.abcrrr contextlibrior ipaddressr r r typingr r rZ_core._eventlooprZ_core._typedattrrrrZ_streamsrrrZ_tasksr version_inforZtyping_extensionsr~rrNtupler-rrrirr r!r;rDrErOr^rgrqr|rrrrBrBrBrCsN        E)&',