_1h ddlmZddlZddlmZmZmZddlZddlm Z edZ erddl m Z m Z ddlmZd de d  dd Zdd dd  dd Zdd ddej$d ddZy)) annotationsN) TYPE_CHECKINGNoReturnTypeVar) DEFAULT_DELAYT) AwaitableCallable) SocketStreamF)https_compatible ssl_contexthappy_eyeballs_delaycKtj|||d{}|Htj}t tdr$|xj tj zc_tj||||S7gw)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)hostportr rr tcp_streams Y/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/trio/_highlevel_ssl_helpers.pyopen_ssl_over_tcp_streamrsD++  1J 002 32 3   C$@$@#@ @  >>)  sBBA(Brr backlogcKtj|||d{}|Dcgc]}tj|||}}|S7+cc}ww)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 N)r )ropen_tcp_listeners SSLListener)rrrr r tcp_listeners tcp_listener ssl_listenerss ropen_ssl_over_tcp_listenersr'Psa(11$T7SSM*  {EUVM  Ts AA AA A A)rr r handler_nursery task_statuscKtj|||||d{}tj||||d{y7&7w)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'serve_listeners) handlerrrrr r r(r) listenerss rserve_ssl_over_tcpr.ls^x66  ) I   '  s!A A A A A  A ) rz str | bytesrintr boolrzssl.SSLContext | Nonerz float | Nonereturnztrio.SSLStream[SocketStream]) rr/rssl.SSLContextrstr | bytes | Noner r0r int | Noner1z$list[trio.SSLListener[SocketStream]])r,z;Callable[[trio.SSLStream[SocketStream]], Awaitable[object]]rr/rr2rr3r r0r r4r(ztrio.Nursery | Noner)z5trio.TaskStatus[list[trio.SSLListener[SocketStream]]]r1r) __future__rrtypingrrrr_highlevel_open_tcp_streamrr collections.abcr r _highlevel_socketr rr'TASK_STATUS_IGNOREDr.rr=s9" 33 5 CL3/ #)-)6 2 2 2 2 ' 2 ' 2"2r $"        *B $"+/   H HH H H  H  HH)HHHr<