o ACe@sddlmZddlZddlmZmZddlmZmZddl Z ddl m Z ddl m Z edZd de d d+ddZdd ddd,dd Zdd dde jd!d-d)d*ZdS).) annotationsN) AwaitableCallable)NoReturnTypeVar) DEFAULT_DELAY) SocketStreamTF)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. )r NOP_IGNORE_UNEXPECTED_EOF)Zserver_hostnamer )trioZopen_tcp_streamsslZcreate_default_contexthasattroptionsrZ SSLStream)rrr r r Z tcp_streamr?usr/lib/python3.10/site-packages/trio/_highlevel_ssl_helpers.pyopen_ssl_over_tcp_streams"  rrr 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 )rZ SSLListener).0Z tcp_listenerr r rr ]sz/open_ssl_over_tcp_listeners..)rZopen_tcp_listeners)rr rr r Z tcp_listenersZ ssl_listenersrr&ropen_ssl_over_tcp_listenersHs  r()rr r handler_nursery task_statushandler;Callable[[trio.SSLStream[SocketStream]], Awaitable[object]]r)trio.Nursery | Noner*5trio.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. rN)r)r*)rr(Zserve_listeners) r+rr rr r r)r*Z listenersrrrserve_ssl_over_tcpds< r/) rrrrr rr rr rrr) rrr r!rr"r rr r#rr$)r+r,rrr r!rr"r rr r#r)r-r*r.rr) __future__rrcollections.abcrrtypingrrrZ_highlevel_open_tcp_streamrZ_highlevel_socketr r rr(ZTASK_STATUS_IGNOREDr/rrrrs,   4!