o 6WjD3@sUddlmZddlZddlZddlmZddlmZmZm Z ddl m Z ddl m Z ddlmZmZddlmZdd lmZmZmZd d lmZd d lmZmZmZd dlmZmZmZd dl m!Z!e"eBeBZ#de$d<e%e"e&fZ'de$d<e'e"BZ(de$d<e%e)e'fZ*de$d<e%e)e"fZ+de$d<edZ,ej-fdddd8d$d%Z.Gd&d'd'eZ/Gd(d)d)eZ0Gd*d+d+ee0Z1Gd,d-d-e1Z2Gd.d/d/ee1e0Z3Gd0d1d1ee*e0Z4Gd2d3d3ee)e0Z5Gd4d5d5ee+e0Z6Gd6d7d7ee)e0Z7dS)9) annotationsN)abstractmethod)Callable CollectionMapping)AsyncExitStack)IOBase) IPv4Address IPv6Address) AddressFamily)Any TypeAliasTypeVar)get_async_backend)TypedAttributeProviderTypedAttributeSettyped_attribute) ByteStreamListenerUnreliableObjectStream) TaskGroupr IPAddressTypeIPSockAddrType SockAddrType UDPPacketTypeUNIXDatagramPacketTypeT_RetvalF)require_connected require_bound sock_or_fdsocket.socket | int sock_typesocket.SocketKind addr_familysocket.AddressFamilyrboolr return socket.socketc Cst|tr4ztj|d}Wn:ty3}z|jtjkr td||r'td||r.td|d}~wwt|tjr=|}n tdt|j dzo|rcz| Wntyb}ztd|d}~ww|rz|j tj tj fvrv|d}n|}Wn tyd}Ynw|std|tjkr|j |krtd|jd |j j|j|krtd |jd |jjWntyt|tr|w|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%rr sockexc bound_addrrBa/home/esfera/Documents/content_generation/venv/lib/python3.10/site-packages/anyio/abc/_sockets.py_validate_socketsv             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 r6r local_addressr, local_portr) raw_socketremote_address remote_portN) __name__ __module__r4__doc__rr6__annotations__rFrGrHrIrJrBrBrBrCrEcs  rEc@s,eZdZed ddZeed ddZdS) _SocketProviderr(Mapping[Any, Callable[[], Any]]csddlmtjfddtjfddtjfddi}z jWn ty2dYnwdur@fdd|tj <jjt j t j fvrdfdd|tj <durdd fd d|tj<|S) Nr)convert_ipv6_sockaddrcsjjSN) _raw_socketr6rBselfrBrCsz2_SocketProvider.extra_attributes..csjSrRrSr9rB)convertrUrBrCrVscsjSrR)rSrBrTrBrCrVcSrRrBrB)peernamerBrCrVcsjdS)NrrWrBrTrBrCrVsrcrZrRrBrB)rJrBrCrVr\)_core._socketsrQrEr6rFrHrSr5r.rIr r7r8rGrJ)rU attributesrB)rXr[rJrUrCextra_attributess$  z _SocketProvider.extra_attributesr)cCsdSrRrBrTrBrBrCrSsz_SocketProvider._raw_socketN)r(rP)r(r))rKrLr4propertyr_rrSrBrBrBrCrOs  rOc@eZdZdZedddZdS) SocketStreamzu Transports bytes over a socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r!r"r(c$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 TrN)rDr- SOCK_STREAMrwrap_stream_socketclsr!r?rBrBrC from_socket zSocketStream.from_socketN)r!r"r(rbrKrLr4rM classmethodrirBrBrBrCrbrbc@s6eZdZedddZedd d ZedddZdS)UNIXSocketStreamr!r"r(c(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 TrdN)rDr-reAF_UNIXrwrap_unix_stream_socketrgrBrBrCris  zUNIXSocketStream.from_socketmessagebytesfdsCollection[int | IOBase]NonecdS)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)rUrrrtrBrBrCsend_fdsrYzUNIXSocketStream.send_fdsmsglenr,maxfdstuple[bytes, list[int]]crw)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)rUryrzrBrBrC receive_fdsrYzUNIXSocketStream.receive_fdsN)r!r"r(rn)rrrsrtrur(rv)ryr,rzr,r(r{)rKrLr4rlrirrxr|rBrBrBrCrns   rnc@s:eZdZdZedddZeddd Z ddddZd S)SocketListenerz} Listens to incoming socket connections. Supports all relevant extra attributes from :class:`~SocketAttribute`. r!r"r(crc)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-rerwrap_listener_socketrgrBrBrCriszSocketListener.from_socketrbcrw)zAccept an incoming connection.NrBrTrBrBrCacceptrYzSocketListener.acceptNhandlerCallable[[SocketStream], Any] task_groupTaskGroup | Nonervc spddlm}t4IdH}|dur||IdH} |IdH}|||q1IdHs1wYdS)Nr)create_task_group)rrenter_async_contextr start_soon)rUrrrstackstreamrBrBrCserve s  zSocketListener.serve)r!r"r(r})r(rbrR)rrrrr(rv) rKrLr4rMrlrirrrrBrBrBrCr}s  r}c@s(eZdZdZedddZdddZdS) UDPSocketz{ Represents an unconnected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r!r"r(crc)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 Tr~N)rDr- SOCK_DGRAMrwrap_udp_socketrgrBrBrCri#rjzUDPSocket.from_socketdatarshoststrportr,rvcs||||ffIdHS)z^ Alias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))). Nsend)rUrrrrBrBrCsendto2szUDPSocket.sendtoN)r!r"r(r)rrsrrrr,r(rvrKrLr4rMrlrirrBrBrBrCrs  rc@ra) ConnectedUDPSocketzy Represents an connected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r!r"r(crc)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 TrdN)rDr-rrwrap_connected_udp_socketrgrBrBrCriAs zConnectedUDPSocket.from_socketN)r!r"r(rrkrBrBrBrCr:rmrc@s(eZdZdZedddZdd d ZdS)UNIXDatagramSocketz Represents an unconnected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r!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-rrprwrap_unix_datagram_socketrgrBrBrCri^szUNIXDatagramSocket.from_socketrrspathrrvcs|||fIdHS)zCAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, path)).Nr)rUrrrBrBrCrpszUNIXDatagramSocket.sendtoN)r!r"r(r)rrsrrr(rvrrBrBrBrCrUs  rc@ra) ConnectedUNIXDatagramSocketz Represents a connected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r!r"r(cro)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 TrdN)rDr-rrpr#wrap_connected_unix_datagram_socketrgrBrBrCri|s  z'ConnectedUNIXDatagramSocket.from_socketN)r!r"r(rrkrBrBrBrCrurmr) r!r"r#r$r%r&rr'r r'r(r))8 __future__rr/r-abcrcollections.abcrrr contextlibrior ipaddressr r r typingr r r_core._eventloopr_core._typedattrrrr_streamsrrr_tasksrrrrNtupler,rrrsrrrr:rDrErOrbrnr}rrrrrBrBrBrCsH      E)&',