U &%e{@szddlmZddlZddlmZddlmZddlmZddl m Z m Z ddlm Z ddl mZmZmZmZmZmZmZd d lmZd d lmZmZmZd d lmZmZmZd dlm Z ee!e e fZ"ee!e#fZ$ee$e!fZ%ee&e$fZ'edZ(GdddeZ)GdddeZ*Gdddee*Z+Gddde+Z,Gdddee+e*Z-Gdddee'e*Z.Gdddee&e*Z/dS)) annotationsN)abstractmethod)AsyncExitStack)IOBase) IPv4Address IPv6Address) AddressFamily)AnyCallable CollectionMappingTupleTypeVarUnion)create_task_group)TypedAttributeProviderTypedAttributeSettyped_attribute) ByteStreamListenerUnreliableObjectStream) TaskGroupT_Retvalc@sbeZdZUeZded<eZded<eZded<eZded<eZ ded <eZ ded <d S) SocketAttributerfamily SockAddrType local_addressint local_port socket.socket raw_socketremote_address remote_portN) __name__ __module__ __qualname__rr__annotations__rr r"r#r$r)r)Q/var/www/html/Darija-Ai-API/env/lib/python3.8/site-packages/anyio/abc/_sockets.pyr#s rc@s4eZdZeddddZeeddddZdS) _SocketProviderzMapping[Any, Callable[[], Any]]returncsddlmtjfddtjfddtjfddi}zjWntk rfdYnXdk rfdd|tj <jjt j t j fkrʇfdd|tj <dk rʈd fd d|tj<|S) Nr)convert_ipv6_sockaddrcsjjSN) _raw_socketrr)selfr)r*8z2_SocketProvider.extra_attributes..csjSr/r0 getsocknamer))convertr2r)r*r39scsjSr/)r0r)r1r)r*r3<r4csSr/r)r))peernamer)r*r3Er4csjdS)Nrr5r)r1r)r*r3Kr4rcsSr/r)r))r$r)r*r3Nr4)Z_core._socketsr.rrrr"r0 getpeernameOSErrorr#rAF_INETAF_INET6r r$)r2 attributesr))r7r8r$r2r*extra_attributes3s.      z _SocketProvider.extra_attributesr!cCsdSr/r)r1r)r)r*r0Rsz_SocketProvider._raw_socketN)r%r&r'propertyr>rr0r)r)r)r*r+2s r+c@seZdZdZdS) SocketStreamzu Transports bytes over a socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. Nr%r&r'__doc__r)r)r)r*r@Xsr@c@s8eZdZeddddddZedddd d d Zd S) UNIXSocketStreambyteszCollection[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) Nr))r2rFrGr)r)r*send_fdsaszUNIXSocketStream.send_fdsrztuple[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) Nr))r2rIrJr)r)r* receive_fdskszUNIXSocketStream.receive_fdsN)r%r&r'rrHrKr)r)r)r*rC`s rCc@s6eZdZdZeddddZd ddd d d d ZdS)SocketListenerz} Listens to incoming socket connections. Supports all relevant extra attributes from :class:`~SocketAttribute`. r@r,csdS)zAccept an incoming connection.Nr)r1r)r)r*accept}szSocketListener.acceptNzCallable[[SocketStream], Any]zTaskGroup | NonerE)handler task_groupr-c sZt4IdH<}|dkr*|tIdH}|IdH}|||q*W5QIdHRXdSr/)renter_async_contextrrMZ start_soon)r2rNrOZ exit_stackstreamr)r)r*serves zSocketListener.serve)N)r%r&r'rBrrMrRr)r)r)r*rLvs rLc@s$eZdZdZdddddddZd S) UDPSocketz{ Represents an unconnected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. rDstrrrE)datahostportr-cs||||ffIdHS)zKAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))).N)send)r2rUrVrWr)r)r*sendtoszUDPSocket.sendtoN)r%r&r'rBrYr)r)r)r*rSsrSc@seZdZdZdS)ConnectedUDPSocketzy Represents an connected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. NrAr)r)r)r*rZsrZ)0 __future__rsocketabcr contextlibrior ipaddressrrrtypingr r r r r rrZ _core._tasksrZ_core._typedattrrrrZ_streamsrrr_tasksrrTZ IPAddressTyperZIPSockAddrTyperrDZ UDPPacketTyperrr+r@rCrLrSrZr)r)r)r*s.     $     &