#tjD3UddlmZddlZddlZddlmZddlmZmZm Z ddl m Z ddl m Z ddlmZmZddlmZdd lmZmZmZd d lmZd d lmZmZmZd dlmZmZmZd dl m!Z!e"ezezZ#de$d<e%e"e&fZ'de$d<e'e"zZ(de$d<e%e)e'fZ*de$d<e%e)e"fZ+de$d<edZ,ej-fdddd7d$Z.Gd%d&eZ/Gd'd(eZ0Gd)d*ee0Z1Gd+d,e1Z2Gd-d.ee1e0Z3Gd/d0ee*e0Z4Gd1d2ee)e0Z5Gd3d4ee+e0Z6Gd5d6ee)e0Z7dS)8) 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.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 P/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/anyio/abc/_sockets.py_validate_socketrEs*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 r8r local_addressr. local_portr* raw_socketremote_address remote_portN) __name__ __module__r6__doc__rr8__annotations__rHrIrJrKrLrDrGrGcs@,O--F----"1/"3"3M3333%o''J'''' / 1 1J1111#2?#4#4N4444&((K((((((rRrGcNeZdZeddZeeddZdS) _SocketProviderr)Mapping[Any, Callable[[], Any]]cddlmtjfdtjfdtjfdi} jn#t$rdYnwxYwfd|tj <jjtj tj fvr.fd|tj <dfd |tj<|S) Nr)convert_ipv6_sockaddrcjjSN) _raw_socketr8selfsrDz2_SocketProvider.extra_attributes..s D,<,CrRcHjSrYrZr;)convertr\srDr]z2_SocketProvider.extra_attributes..s%77 ,,..44rRcjSrY)rZr[srDr]z2_SocketProvider.extra_attributes..s 0@rRcSrYrQ)peernamesrDr]z2_SocketProvider.extra_attributes..srRcBjdS)Nrr_r[srDr]z2_SocketProvider.extra_attributes..s ,,..q1rRrcSrYrQ)rLsrDr]z2_SocketProvider.extra_attributes..s+rR)_core._socketsrWrGr8rHrJrZr7r0rKr r9r:rIrL)r\ attributesr`rcrLs` @@@rDextra_attributesz _SocketProvider.extra_attributess6EEEEEE  "$C$C$C$C  ),,,,,  &(@(@(@(@ 4  /6wt7G7S7S7U7U/V/VHH   HHH   9I9I9I9IJ5 6   "}'T&U U U6666J1 2#&qk :M:M:M:M ?67s"A A.-A.r*cdSrYrQr[s rDrZz_SocketProvider._raw_sockets  rRN)r)rU)r)r*)rMrNr6propertyrhrrZrQrRrDrTrTs\ X<   ^X   rRrTc*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)rEr/ SOCK_STREAMrwrap_stream_socketclsr"rAs rD from_socketzSocketStream.from_socketsL F,>RVWWW&((;;DAAAAAAAAArRN)r"r#r)rlrMrNr6rO classmethodrsrQrRrDrlrlsD  B B B[ B B BrRrlcVeZdZeddZedd 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 TrnN)rEr/roAF_UNIXrwrap_unix_stream_socketrqs rDrszUNIXSocketStream.from_socketsX *FNd   '((@@FFFFFFFFFrRmessagebytesfdsCollection[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) NrQ)r\r{r}s rDsend_fdszUNIXSocketStream.send_fds rRmsglenr.maxfdstuple[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) NrQ)r\rrs rD receive_fdszUNIXSocketStream.receive_fdsrrRN)r"r#r)rw)r{r|r}r~r)r)rr.rr.r)r)rMrNr6rursrrrrQrRrDrwrwsvGGG[G    ^    ^   rRrwcNeZdZdZeddZeddZ 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)rEr/rorwrap_listener_socketrqs rDrszSocketListener.from_socketsK F,>dSSS&((==dCCCCCCCCCrRrlc KdS)zAccept an incoming connection.NrQr[s rDacceptzSocketListener.acceptrrRNhandlerCallable[[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 rDservezSocketListener.serve s )(((((!## 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)rlrY)rrrrr)r) rMrNr6rOrursrrrrQrRrDrrs DDD[D ---^- (, 7 7 7 7 7 7 7rRrc2eZdZdZeddZdd 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)rEr/ SOCK_DGRAMrwrap_udp_socketrqs rDrszUDPSocket.from_socket#sK F,=TRRR&((88>>>>>>>>>rRdatar|hoststrportr.rcDK||||ffd{VS)z^ Alias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))). Nsend)r\rrrs rDsendtozUDPSocket.sendto2s5 YYtTl3444444444rRN)r"r#r)r)rr|rrrr.r)rrMrNr6rOrursrrQrRrDrrsR  ? ? ?[ ?555555rRrc*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 TrnN)rEr/rrwrap_connected_udp_socketrqs rDrszConnectedUDPSocket.from_socketAsV   "    '((BB4HHHHHHHHHrRN)r"r#r)rrtrQrRrDrr:sD III[IIIrRrc2eZdZdZed 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)rEr/rryrwrap_unix_datagram_socketrqs rDrszUNIXDatagramSocket.from_socket^sJ F,=v~NN&((BB4HHHHHHHHHrRrr|pathrrc@K|||fd{VS)zCAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, path)).Nr)r\rrs rDrzUNIXDatagramSocket.sendtops.YYd|,,,,,,,,,rRN)r"r#r)r)rr|rrr)rrrQrRrDrrUsV III[I"------rRrc*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 TrnN)rEr/rryr#wrap_connected_unix_datagram_socketrqs rDrsz'ConnectedUNIXDatagramSocket.from_socket|sX  )6>T   '((LLTRRRRRRRRRrRN)r"r#r)rrtrQrRrDrrusD SSS[SSSrRr) r"r#r$r%r&r'r r(r!r(r)r*)8 __future__rr1r/abcrcollections.abcrrr contextlibrior ipaddressr r r typingr rr_core._eventloopr_core._typedattrrrr_streamsrrr_tasksrrrrPtupler.rrr|rrrr<rErGrTrlrwrrrrrrQrRrDrs""""""" 9999999999%%%%%%........ **********000000 CBBBBBBBBB,{: ::::!#s(O++++(3. .... !67 7777$)%*$55555 7:   )/(8B $ BBBBBBJ&)&)&)&)&)'&)&)&)R# # # # # ,# # # LBBBBB:BBB.$ $ $ $ $ |$ $ $ N)7)7)7)7)7Xl+_)7)7)7X55555&}5555<IIIII/6III6-----12O---@SSSSS"8"?SSSSSrR