§
    xÅj  ã                  ó  — d dl mZ d dlZd dlZd dlZd dlmZm	Z	m
Z
 ddlmZmZ ddlmZ ddlmZmZmZ g d	¢Z	 d d
lmZ d dlmZmZ ddddœd"d„Z	 d#d$d„Zn# e$ r ddddœd"d„Z	 d#d$d„ZY nw xY w G d „ d!¦  «        ZdS )%é    )ÚannotationsN)ÚAnyÚCallableÚLiteralé   )ÚRequestÚResponse)ÚPathLikeé   )ÚServerÚServerConnectionÚserve)ÚrouteÚ
unix_routeÚRouter)ÚNotFound)ÚMapÚRequestRedirect)Úserver_nameÚsslÚcreate_routerÚurl_mapr   Úargsr   r   ú
str | Noner   ú,ssl_module.SSLContext | Literal[True] | Noner   útype[Router] | NoneÚkwargsÚreturnr   c               óÐ   ‡‡	— |€dnd}|dur|�||d<   |€t           } || ||¦  «        Š	|                     dd¦  «        Š‰€‰	j        }ndˆˆ	fd„}t          ‰	j        g|¢R d|i|¤ŽS )a\	  
        Create a WebSocket server dispatching connections to different handlers.

        This feature requires the third-party library `werkzeug`_:

        .. code-block:: console

            $ pip install werkzeug

        .. _werkzeug: https://werkzeug.palletsprojects.com/

        :func:`route` accepts the same arguments as
        :func:`~websockets.sync.server.serve`, except as described below.

        The first argument is a :class:`werkzeug.routing.Map` that maps URL patterns
        to connection handlers. In addition to the connection, handlers receive
        parameters captured in the URL as keyword arguments.

        Here's an example::


            from websockets.sync.router import route
            from werkzeug.routing import Map, Rule

            def channel_handler(websocket, channel_id):
                ...

            url_map = Map([
                Rule("/channel/<uuid:channel_id>", endpoint=channel_handler),
                ...
            ])

            with route(url_map, ...) as server:
                server.serve_forever()

        Refer to the documentation of :mod:`werkzeug.routing` for details.

        If you define redirects with ``Rule(..., redirect_to=...)`` in the URL map,
        when the server runs behind a reverse proxy that modifies the ``Host``
        header or terminates TLS, you need additional configuration:

        * Set ``server_name`` to the name of the server as seen by clients. When
          not provided, websockets uses the value of the ``Host`` header.

        * Set ``ssl=True`` to generate ``wss://`` URIs without enabling TLS.
          Under the hood, this bind the URL map with a ``url_scheme`` of
          ``wss://`` instead of ``ws://``.

        There is no need to specify ``websocket=True`` in each rule. It is added
        automatically.

        Args:
            url_map: Mapping of URL patterns to connection handlers.
            server_name: Name of the server as seen by clients. If :obj:`None`,
                websockets uses the value of the ``Host`` header.
            ssl: Configuration for enabling TLS on the connection. Set it to
                :obj:`True` if a reverse proxy terminates TLS connections.
            create_router: Factory for the :class:`Router` dispatching requests to
                handlers. Set it to a wrapper or a subclass to customize routing.

        NÚwsÚwssTr   Úprocess_requestÚ
connectionr   Úrequestr   r   úResponse | Nonec                óP   •—  ‰| |¦  «        }|�|S ‰                      | |¦  «        S ©N)Úroute_request)r#   r$   ÚresponseÚ_process_requestÚrouters      €€úGC:\Projects\Historical\venv\Lib\site-packages\websockets/sync/router.pyr"   zroute.<locals>.process_request…   s8   ø€ ð ,Ð+¨J¸Ñ@Ô@�ØÐ'Ø#�OØ×+Ò+¨J¸Ñ@Ô@Ð@ó    ©r#   r   r$   r   r   r%   )r   Úpopr(   r   Úhandler)
r   r   r   r   r   r   Ú
url_schemer"   r*   r+   s
           @@r,   r   r   )   sÉ   øø€ ðJ !˜[�T�T¨eˆ
Ø�dˆ?ˆ?˜s˜ØˆF�5‰MàÐ Ý"ˆMà�˜w¨°ZÑ@Ô@ˆð �JŠJÐ(¨$Ñ/Ô/ð 	ð Ð#ð Ô$ð ˆOðAð Að Að Að Að Að Aõ �V”^ÐV dÐVÐVÐV¸OÐVÈvÐVÐVÐVr-   ÚpathúPathLike | Nonec                ó"   — t          | fd|dœ|¤ŽS )ag  
        Create a WebSocket Unix server dispatching connections to different handlers.

        :func:`unix_route` combines the behaviors of :func:`route` and
        :func:`~websockets.sync.server.unix_serve`.

        Args:
            url_map: Mapping of URL patterns to connection handlers.
            path: File system path to the Unix socket.

        T)Úunixr2   )r   ©r   r2   r   s      r,   r   r   �   s!   € õ  �WÐ= 4¨dÐ=Ð=°fÐ=Ð=Ð=r-   c               ó    — t          d¦  «        ‚)Nzroute() requires werkzeug©ÚImportError)r   r   r   r   r   r   s         r,   r   r      s   € õ Ð5Ñ6Ô6Ð6r-   c                ó    — t          d¦  «        ‚)Nzunix_route() requires werkzeugr8   r6   s      r,   r   r       s   € õ
 Ð:Ñ;Ô;Ð;r-   c                  óH   — e Zd ZdZ	 	 ddd„Zdd„Zdd„Zdd„Zdd„Zdd„Z	dS ) r   z*WebSocket router supporting :func:`route`.Nr    r   r   r   r   r1   Ústrr   ÚNonec                óv   — || _         || _        || _        | j                              ¦   «         D ]	}d|_        Œ
d S )NT)r   r   r1   Ú
iter_rulesÚ	websocket)Úselfr   r   r1   Úrules        r,   Ú__init__zRouter.__init__¥   sJ   € ð ˆŒØ&ˆÔØ$ˆŒØ”L×+Ò+Ñ-Ô-ð 	"ð 	"ˆDØ!ˆDŒNˆNð	"ð 	"r-   r#   r   r$   r   c                ó8   — | j         €|j        d         S | j         S )NÚHost)r   Úheaders)rA   r#   r$   s      r,   Úget_server_namezRouter.get_server_name±   s!   € ØÔÐ#Ø”? 6Ô*Ð*àÔ#Ð#r-   Úurlr	   c                ój   — |                      t          j        j        d|› �¦  «        }||j        d<   |S )Nz	Found at ÚLocation)ÚrespondÚhttpÚ
HTTPStatusÚFOUNDrF   )rA   r#   rH   r)   s       r,   ÚredirectzRouter.redirect·   s7   € Ø×%Ò%¥d¤oÔ&;Ð=NÈÐ=NÐ=NÑOÔOˆØ'*ˆÔ˜Ñ$Øˆr-   c                óL   — |                      t          j        j        d¦  «        S )Nz	Not Found)rK   rL   rM   Ú	NOT_FOUND©rA   r#   s     r,   Ú	not_foundzRouter.not_found¼   s   € Ø×!Ò!¥$¤/Ô";¸[ÑIÔIÐIr-   r%   c                óÆ  — | j                              |                      ||¦  «        | j        ¬¦  «        }	 t          j                             |j        ¦  «        }|                     |j        |j	        ¬¦  «        \  }}nR# t          $ r%}|                      ||j        ¦  «        cY d}~S d}~wt          $ r |                      |¦  «        cY S w xY w||c|_        |_        dS )zRoute incoming request.)r   r1   )Ú	path_infoÚ
query_argsN)r   ÚbindrG   r1   ÚurllibÚparseÚurlparser2   ÚmatchÚqueryr   rO   Únew_urlr   rS   r0   Úhandler_kwargs)rA   r#   r$   Úurl_map_adapterÚparsedr0   r   rO   s           r,   r(   zRouter.route_request¿   s  € ð œ,×+Ò+Ø×,Ò,¨Z¸ÑAÔAØ”ð ,ñ 
ô 
ˆð		.Ý”\×*Ò*¨7¬<Ñ8Ô8ˆFØ-×3Ò3Ø œ+Ø!œ<ð 4ñ ô ‰OˆG�V�Vøõ ð 	?ð 	?ð 	?Ø—=’= ¨XÔ-=Ñ>Ô>Ð>Ð>Ð>Ð>Ð>Ð>øøøøÝð 	.ð 	.ð 	.Ø—>’> *Ñ-Ô-Ð-Ð-Ð-ð	.øøøà8?ÀÐ5ˆ
Ô˜JÔ5Øˆts$   ·AB  Â 
CÂ
B*Â$CÂ*"CÃCc                ó(   —  |j         |fi |j        ¤ŽS )zHandle a connection.)r0   r^   rR   s     r,   r0   zRouter.handlerÔ   s    € à!ˆzÔ! *ÐJÐJ°
Ô0IÐJÐJÐJr-   )Nr    )r   r   r   r   r1   r<   r   r=   )r#   r   r$   r   r   r<   )r#   r   rH   r<   r   r	   )r#   r   r   r	   r.   )r#   r   r   r=   )
Ú__name__Ú
__module__Ú__qualname__Ú__doc__rC   rG   rO   rS   r(   r0   © r-   r,   r   r   ¢   s©   € € € € € Ø4Ð4ð
 #'Øð	
"ð 
"ð 
"ð 
"ð 
"ð$ð $ð $ð $ðð ð ð ð
Jð Jð Jð Jðð ð ð ð*Kð Kð Kð Kð Kð Kr-   r   )r   r   r   r   r   r   r   r   r   r   r   r   r   r   r'   )r   r   r2   r3   r   r   r   r   )Ú
__future__r   rL   r   Ú
ssl_moduleÚurllib.parserX   Útypingr   r   r   Úhttp11r   r	   r
   Úserverr   r   r   Ú__all__Úwerkzeug.exceptionsr   Úwerkzeug.routingr   r   r   r   r9   r   rf   r-   r,   ú<module>rp      sà  ðØ "Ð "Ð "Ð "Ð "Ð "à €€€Ø Ð Ð Ð Ø Ð Ð Ð Ø )Ð )Ð )Ð )Ð )Ð )Ð )Ð )Ð )Ð )à &Ð &Ð &Ð &Ð &Ð &Ð &Ð &Ø Ð Ð Ð Ð Ð Ø 3Ð 3Ð 3Ð 3Ð 3Ð 3Ð 3Ð 3Ð 3Ð 3ð ,Ð
+Ð
+€ðO>Ø,Ð,Ð,Ð,Ð,Ð,Ø5Ð5Ð5Ð5Ð5Ð5Ð5Ð5ð4 #'Ø<@Ø-1ðdWð dWð dWð dWð dWð dWðP !%ð>ð >ð >ð >ð >ð >øðw ð <ð <ð <ð
 #'Ø<@Ø-1ð7ð 7ð 7ð 7ð 7ð 7ð !%ð<ð <ð <ð <ð <ð <ð <ð<øøøð\4Kð 4Kð 4Kð 4Kð 4Kñ 4Kô 4Kð 4Kð 4Kð 4Ks   ºA ÁA/Á.A/