U g @sddlmZddlZddlmZmZmZddlZddlm Z edZ erdddl m Z m Z ddlmZd de d d d d ddddddZdd ddd ddd dddddZdd ddejddd ddd dddd d! d"d#ZdS)$) annotationsN) TYPE_CHECKINGNoReturnTypeVar) DEFAULT_DELAYT) AwaitableCallable) SocketStreamF)https_compatible ssl_contexthappy_eyeballs_delayz str | bytesintboolzssl.SSLContext | Nonez float | Noneztrio.SSLStream[SocketStream])hostportr r rreturncsTtj|||dIdH}|dkrBt}ttdrB|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 )trioZopen_tcp_streamsslcreate_default_contexthasattroptionsrZ SSLStream)rrr r rZ tcp_streamr?/tmp/pip-unpacked-wheel-ks04xdmi/trio/_highlevel_ssl_helpers.pyopen_ssl_over_tcp_streams"  rrr backlogzssl.SSLContextzstr | bytes | Nonez int | Nonez$list[trio.SSLListener[SocketStream]])rr rr rrcs.tj|||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. )rrNcsg|]}tj|dqS))r )rZ SSLListener).0Z tcp_listenerr r rr esz/open_ssl_over_tcp_listeners..)rZopen_tcp_listeners)rr rr rZ tcp_listenersZ ssl_listenersrr!ropen_ssl_over_tcp_listenersPs  r#)rr rhandler_nursery task_statusz;Callable[[trio.SSLStream[SocketStream]], Awaitable[object]]ztrio.Nursery | Nonez5trio.TaskStatus[list[trio.SSLListener[SocketStream]]]r) handlerrr rr rr$r%rc s6tj|||||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 rr$r%Z listenersrrrserve_ssl_over_tcpls< r') __future__rrtypingrrrrZ_highlevel_open_tcp_streamrrcollections.abcr r Z_highlevel_socketr rr#ZTASK_STATUS_IGNOREDr'rrrrs,   9!