
     fD                        d dl mZ d dlZd dlmZmZmZ d dlZddlm	Z	  ed          Z
erd dlmZmZ ddlmZ d	de	d
d(dZdd	ddd)dZdd	ddej        dd*d'ZdS )+    )annotationsN)TYPE_CHECKINGNoReturnTypeVar   )DEFAULT_DELAYT)	AwaitableCallable)SocketStreamF)https_compatiblessl_contexthappy_eyeballs_delayhoststr | bytesportintr   boolr   ssl.SSLContext | Noner   float | Nonereturntrio.SSLStream[SocketStream]c                  K   t          j        | ||           d{V }|Ct          j                    }t	          t          d          r|xj        t          j         z  c_        t          j        ||| |          S )aT  Make 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   NOP_IGNORE_UNEXPECTED_EOF)server_hostnamer   )trioopen_tcp_streamsslcreate_default_contexthasattroptionsr   	SSLStream)r   r   r   r   r   
tcp_streams         ^/var/www/api.educacionweb.es/myenv/lib/python3.11/site-packages/trio/_highlevel_ssl_helpers.pyopen_ssl_over_tcp_streamr%      s      D +d)=        J 0223233 	AC$@#@@>KHX       r   r   backlogssl.SSLContextstr | bytes | Noner(   
int | None$list[trio.SSLListener[SocketStream]]c               f   K   t          j        | ||           d{V }fd|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.

    )r   r(   Nc                >    g | ]}t          j        |           S ))r   )r   SSLListener).0tcp_listenerr   r   s     r$   
<listcomp>z/open_ssl_over_tcp_listeners.<locals>.<listcomp>`   s<        	{EUVVV  r&   )r   open_tcp_listeners)r   r   r   r   r(   tcp_listenersssl_listenerss    ` `   r$   open_ssl_over_tcp_listenersr6   K   sh      ( 1$T7SSSSSSSSSM    )  M r&   )r   r   r(   handler_nurserytask_statushandler;Callable[[trio.SSLStream[SocketStream]], Awaitable[object]]r7   trio.Nursery | Noner8   5trio.TaskStatus[list[trio.SSLListener[SocketStream]]]r   c                  K   t          j        |||||           d{V }t          j        | |||           d{V  dS )uO  Listen 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)r7   r8   )r   r6   serve_listeners)	r9   r   r   r   r   r(   r7   r8   	listenerss	            r$   serve_ssl_over_tcpr@   g   s      x 6)        I 
O           r&   )r   r   r   r   r   r   r   r   r   r   r   r   )r   r   r   r)   r   r*   r   r   r(   r+   r   r,   )r9   r:   r   r   r   r)   r   r*   r   r   r(   r+   r7   r;   r8   r<   r   r   )
__future__r   r   typingr   r   r   r   _highlevel_open_tcp_streamr   r	   collections.abcr
   r   _highlevel_socketr   r%   r6   TASK_STATUS_IGNOREDr@    r&   r$   <module>rH      s2   " " " " " " 



 3 3 3 3 3 3 3 3 3 3  5 5 5 5 5 5GCLL 033333333//////  #)-)6- - - - - -h  $"     B  $"+/ 	 E E E E E E E Er&   