o %= jD3@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 sockexcZ bound_addrrA\C:\Users\psant\Downloads\Anu Raj Backend\school\venv\Lib\site-packages\anyio/abc/_sockets.py_validate_socketsv             rCc@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__rErFrGrHrIrArArArBrDcs  rDc@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_socketr6rAselfrArBsz2_SocketProvider.extra_attributes..csjSrQrRr9rA)convertrTrArBrUscsjSrQ)rRrArSrArBrUcSrQrArA)peernamerArBrUcsjdS)NrrVrArSrArBrUsrcrYrQrArA)rIrArBrUr[)Z_core._socketsrPrDr6rErGrRr5r.rHr r7r8rFrI)rT attributesrA)rWrZrIrTrBextra_attributess$  z _SocketProvider.extra_attributesr)cCsdSrQrArSrArArBrRsz_SocketProvider._raw_socketN)r(rO)r(r))rJrKr4propertyr]rrRrArArArBrNs  rNc@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)rCr- SOCK_STREAMrZwrap_stream_socketclsr!r?rArArB from_socket zSocketStream.from_socketN)r!r"r(r`rJrKr4rL classmethodrfrArArArBr`r`c@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 TrbN)rCr-rcAF_UNIXrZwrap_unix_stream_socketrdrArArBrfs  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) NrA)rTrnrprArArBsend_fdsrXzUNIXSocketStream.send_fdsmsglenr,maxfdstuple[bytes, list[int]]crs)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) NrA)rTrurvrArArB receive_fdsrXzUNIXSocketStream.receive_fdsN)r!r"r(rk)rnrorprqr(rr)rur,rvr,r(rw)rJrKr4rirfrrtrxrArArArBrks   rkc@s:eZdZdZedddZeddd Z ddddZd S)SocketListenerz} Listens to incoming socket connections. Supports all relevant extra attributes from :class:`~SocketAttribute`. r!r"r(cra)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)rCr-rcrZwrap_listener_socketrdrArArBrfszSocketListener.from_socketr`crs)zAccept an incoming connection.NrArSrArArBacceptrXzSocketListener.acceptNhandlerCallable[[SocketStream], Any] task_groupTaskGroup | Nonerrc spddlm}t4IdH}|dur||IdH} |IdH}|||q1IdHs1wYdS)Nr)create_task_groupT)rrenter_async_contextr{Z start_soon)rTr|r~rstackstreamrArArBserve s  zSocketListener.serve)r!r"r(ry)r(r`rQ)r|r}r~rr(rr) rJrKr4rLrirfrr{rrArArArBrys  ryc@s(eZdZdZedddZdddZdS) UDPSocketz{ Represents an unconnected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r!r"r(cra)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 TrzN)rCr- SOCK_DGRAMrZwrap_udp_socketrdrArArBrf#rgzUDPSocket.from_socketdatarohoststrportr,rrcs||||ffIdHS)z^ Alias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))). Nsend)rTrrrrArArBsendto2szUDPSocket.sendtoN)r!r"r(r)rrorrrr,r(rrrJrKr4rLrirfrrArArArBrs  rc@r_) ConnectedUDPSocketzy Represents an connected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r!r"r(cra)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 TrbN)rCr-rrZwrap_connected_udp_socketrdrArArBrfAs zConnectedUDPSocket.from_socketN)r!r"r(rrhrArArArBr:rjrc@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)rCr-rrmrZwrap_unix_datagram_socketrdrArArBrf^szUNIXDatagramSocket.from_socketrropathrrrcs|||fIdHS)zCAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, path)).Nr)rTrrrArArBrpszUNIXDatagramSocket.sendtoN)r!r"r(r)rrorrr(rrrrArArArBrUs  rc@r_) ConnectedUNIXDatagramSocketz Represents a connected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r!r"r(crl)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 TrbN)rCr-rrmrZ#wrap_connected_unix_datagram_socketrdrArArBrf|s  z'ConnectedUNIXDatagramSocket.from_socketN)r!r"r(rrhrArArArBrurjr) r!r"r#r$r%r&rr'r r'r(r))8 __future__rr/r-abcrcollections.abcrrr contextlibrior ipaddressr r r typingr r rZ_core._eventlooprZ_core._typedattrrrrZ_streamsrrrZ_tasksrrrrMtupler,rrrorrrr:rCrDrNr`rkryrrrrrArArArBsH      E)&',