o 4@Hh@sddlmZddlZddlmZmZmZddlZddlm Z edZ er2ddl m Z m Z ddlmZd de d d+ddZdd ddd,dd Zdd ddejd!d-d)d*ZdS).) annotationsN) TYPE_CHECKINGNoReturnTypeVar) DEFAULT_DELAYT) AwaitableCallable) SocketStreamF)https_compatible ssl_contexthappy_eyeballs_delayhost str | bytesportintr boolr ssl.SSLContext | Noner float | Nonereturntrio.SSLStream[SocketStream]csVtj|||dIdH}|dur"t}ttdr"|jtjM_tj||||dS)aTMake a TLS-encrypted Connection to the given host and port over TCP. This is a convenience wrapper that calls :func:`open_tcp_stream` and wraps the result in an :class:`~trio.SSLStream`. This function does not perform the TLS handshake; you can do it manually by calling :meth:`~trio.SSLStream.do_handshake`, or else it will be performed automatically the first time you send or receive data. Args: host (bytes or str): The host to connect to. We require the server to have a TLS certificate valid for this hostname. port (int): The port to connect to. https_compatible (bool): Set this to True if you're connecting to a web server. See :class:`~trio.SSLStream` for details. Default: False. ssl_context (:class:`~ssl.SSLContext` or None): The SSL context to use. If None (the default), :func:`ssl.create_default_context` will be called to create a context. happy_eyeballs_delay (float): See :func:`open_tcp_stream`. Returns: trio.SSLStream: the encrypted connection to the server. )rNOP_IGNORE_UNEXPECTED_EOF)server_hostnamer )trioopen_tcp_streamsslcreate_default_contexthasattroptionsr SSLStream)rrr r r tcp_streamr"[/home/air/sanwanet/gpt-api/venv/lib/python3.10/site-packages/trio/_highlevel_ssl_helpers.pyopen_ssl_over_tcp_streams "  r$rr backlogssl.SSLContextstr | bytes | Noner& int | None$list[trio.SSLListener[SocketStream]]cs0tj|||dIdH}fdd|D}|S)a*Start listening for SSL/TLS-encrypted TCP connections to the given port. Args: port (int): The port to listen on. See :func:`open_tcp_listeners`. ssl_context (~ssl.SSLContext): The SSL context to use for all incoming connections. host (str, bytes, or None): The address to bind to; use ``None`` to bind to the wildcard address. See :func:`open_tcp_listeners`. https_compatible (bool): See :class:`~trio.SSLStream` for details. backlog (int or None): See :func:`open_tcp_listeners` for details. )rr&Ncsg|] }tj|dqS))r )r SSLListener).0 tcp_listenerr r r"r# esz/open_ssl_over_tcp_listeners..)ropen_tcp_listeners)rr rr r& tcp_listeners ssl_listenersr"r.r#open_ssl_over_tcp_listenersPs  r3)rr r&handler_nursery task_statushandler;Callable[[trio.SSLStream[SocketStream]], Awaitable[object]]r4trio.Nursery | Noner55trio.TaskStatus[list[trio.SSLListener[SocketStream]]]rc s8tj|||||dIdH}tj||||dIdHdS)uOListen for incoming TCP connections, and for each one start a task running ``handler(stream)``. This is a thin convenience wrapper around :func:`open_ssl_over_tcp_listeners` and :func:`serve_listeners` – see them for full details. .. warning:: If ``handler`` raises an exception, then this function doesn't do anything special to catch it – so by default the exception will propagate out and crash your server. If you don't want this, then catch exceptions inside your ``handler``, or use a ``handler_nursery`` object that responds to exceptions in some other way. When used with ``nursery.start`` you get back the newly opened listeners. See the documentation for :func:`serve_tcp` for an example where this is useful. Args: handler: The handler to start for each incoming connection. Passed to :func:`serve_listeners`. port (int): The port to listen on. Use 0 to let the kernel pick an open port. Ultimately passed to :func:`open_tcp_listeners`. ssl_context (~ssl.SSLContext): The SSL context to use for all incoming connections. Passed to :func:`open_ssl_over_tcp_listeners`. host (str, bytes, or None): The address to bind to; use ``None`` to bind to the wildcard address. Ultimately passed to :func:`open_tcp_listeners`. https_compatible (bool): Set this to True if you want to use "HTTPS-style" TLS. See :class:`~trio.SSLStream` for details. backlog (int or None): See :class:`~trio.SSLStream` for details. handler_nursery: The nursery to start handlers in, or None to use an internal nursery. Passed to :func:`serve_listeners`. task_status: This function can be used with ``nursery.start``. Returns: This function only returns when cancelled. r%N)r4r5)rr3serve_listeners) r6rr rr r&r4r5 listenersr"r"r#serve_ssl_over_tcpls< r<) rrrrr rr rrrrr) rrr r'rr(r rr&r)rr*)r6r7rrr r'rr(r rr&r)r4r8r5r9rr) __future__rrtypingrrrr_highlevel_open_tcp_streamrrcollections.abcr r _highlevel_socketr r$r3TASK_STATUS_IGNOREDr<r"r"r"r#s.   9!