Ë
    ¸�©j,  ã                  óH  — 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 G d„ d«      Zy# e$ r& ddddœ	 	 	 	 	 	 	 	 	 	 	 	 	 dd„Z	 d	 	 	 	 	 	 	 dd„ZY Œ5w xY w)é    )ÚannotationsN)ÚAnyÚCallableÚLiteralé   )ÚRequestÚResponse)ÚPathLikeé   )ÚServerÚServerConnectionÚserve)ÚrouteÚ
unix_routeÚRouter)ÚNotFound)ÚMapÚRequestRedirect)Úserver_nameÚsslÚcreate_routerc               óÞ   ‡‡	— |€dnd}|dur|�||d<   |€t         } || ||«      Š	|j                  dd«      Š‰€‰	j                  }n	 	 	 	 	 	 dˆˆ	fd„}t        ‰	j                  g|¢­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_requestc                óB   •—  ‰| |«      }|�|S ‰j                  | |«      S ©N)Úroute_request)Ú
connectionÚrequestÚresponseÚ_process_requestÚrouters      €€ú]/var/www/html/streamforge-license/venv/lib/python3.12/site-packages/websockets/sync/router.pyr   zroute.<locals>.process_request…   s/   ø€ ñ ,¨J¸Ó@�ØÐ'Ø#�OØ×+Ñ+¨J¸Ó@Ð@ó    ©r   r   r    r   ÚreturnzResponse | None)r   Úpopr   r   Úhandler)
Úurl_mapr   r   r   ÚargsÚkwargsÚ
url_schemer   r"   r#   s
           @@r$   r   r   )   s­   ù€ ðJ !˜[‘T¨eˆ
Ø�d‰?˜s˜ØˆF�5‰MàÐ Ü"ˆMá˜w¨°ZÓ@ˆð �J‰JÐ(¨$Ó/ð 	ð Ð#ð ×$Ñ$ñ ðAØ,ðAØ7>ðAà öAô �V—^‘^ÐV dÒV¸OÐVÈvÑVÐVr%   c                ó    — 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)ÚunixÚpath)r   ©r*   r0   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Ð6r%   c                ó   — t        d«      ‚)Nzunix_route() requires werkzeugr3   r1   s      r$   r   r       s   € ô
 Ð:Ó;Ð;r%   c                  ó`   — 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	y)r   z*WebSocket router supporting :func:`route`.Nc                óz   — || _         || _        || _        | j                   j                  «       D ]	  }d|_        Œ y )NT)r*   r   r-   Ú
iter_rulesÚ	websocket)Úselfr*   r   r-   Úrules        r$   Ú__init__zRouter.__init__¥   s=   € ð ˆŒØ&ˆÔØ$ˆŒØ—L‘L×+Ñ+Ó-ò 	"ˆDØ!ˆD�Nñ	"r%   c                óP   — | j                   €|j                  d   S | j                   S )NÚHost)r   Úheaders)r:   r   r    s      r$   Úget_server_namezRouter.get_server_name±   s)   € Ø×ÑÐ#Ø—?‘? 6Ñ*Ð*à×#Ñ#Ð#r%   c                ó~   — |j                  t        j                  j                  d|› �«      }||j                  d<   |S )Nz	Found at ÚLocation)ÚrespondÚhttpÚ
HTTPStatusÚFOUNDr?   )r:   r   Úurlr!   s       r$   ÚredirectzRouter.redirect·   s:   € Ø×%Ñ%¤d§o¡o×&;Ñ&;¸yÈÈÐ=NÓOˆØ'*ˆ×Ñ˜Ñ$Øˆr%   c                óV   — |j                  t        j                  j                  d«      S )Nz	Not Found)rC   rD   rE   Ú	NOT_FOUND©r:   r   s     r$   Ú	not_foundzRouter.not_found¼   s   € Ø×!Ñ!¤$§/¡/×";Ñ";¸[ÓIÐIr%   c                óÒ  — | j                   j                  | j                  ||«      | j                  ¬«      }	 t        j
                  j                  |j                  «      }|j                  |j                  |j                  ¬«      \  }}||c|_        |_        y# t        $ r&}| j                  ||j                  «      cY d}~S d}~wt        $ r | j                  |«      cY S w xY w)zRoute incoming request.)r   r-   )Ú	path_infoÚ
query_argsN)r*   Úbindr@   r-   ÚurllibÚparseÚurlparser0   ÚmatchÚqueryr   rH   Únew_urlr   rL   r)   Úhandler_kwargs)r:   r   r    Úurl_map_adapterÚparsedr)   r,   rH   s           r$   r   zRouter.route_request¿   sÐ   € ð Ÿ,™,×+Ñ+Ø×,Ñ,¨Z¸ÓAØ—‘ð ,ó 
ˆð		.Ü—\‘\×*Ñ*¨7¯<©<Ó8ˆFØ-×3Ñ3Ø Ÿ+™+Ø!Ÿ<™<ð 4ó ‰OˆG�Vð 9@ÀÐ5ˆ
Ô˜JÔ5Øøô ò 	?Ø—=‘= ¨X×-=Ñ-=Ó>Õ>ûÜò 	.Ø—>‘> *Ó-Ò-ð	.ús$   ¹AB Â	C&Â%CÃ C&ÃC&Ã%C&c                ó<   —  |j                   |fi |j                  ¤ŽS )zHandle a connection.)r)   rW   rK   s     r$   r)   zRouter.handlerÔ   s    € à!ˆz×!Ñ! *ÑJ°
×0IÑ0IÑJÐJr%   )Nr   )r*   r   r   ú
str | Noner-   Ústrr'   ÚNone)r   r   r    r   r'   r\   )r   r   rG   r\   r'   r	   )r   r   r'   r	   r&   )r   r   r'   r]   )
Ú__name__Ú
__module__Ú__qualname__Ú__doc__r<   r@   rH   rL   r   r)   © r%   r$   r   r   ¢   sk   „ Ù4ð
 #'Øð	
"àð
"ð  ð
"ð ð	
"ð
 
ó
"ó$óó
JðØ*ðØ5<ðà	óô*Kr%   r   )r*   r   r+   r   r   r[   r   z,ssl_module.SSLContext | Literal[True] | Noner   ztype[Router] | Noner,   r   r'   r   r   )r*   r   r0   zPathLike | Noner,   r   r'   r   )Ú
__future__r   rD   r   Ú
ssl_moduleÚurllib.parserQ   Útypingr   r   r   Úhttp11r   r	   r
   Úserverr   r   r   Ú__all__Úwerkzeug.exceptionsr   Úwerkzeug.routingr   r   r   r   r4   r   rb   r%   r$   ú<module>rl      se  ðÝ "ã Û Û ß )Ñ )ç &Ý ß 3Ñ 3ò ,€ðO>Ý,ß5ð4 #'Ø<@Ø-1ñdWØðdWàðdWð  ðdWð :ð	dWð
 +ðdWð ðdWð 
ódWðP !%ð>Øð>àð>ð ð>ð 
ó	>÷&4Kò 4Køð] ò <ð
 #'Ø<@Ø-1ñ7Øð7àð7ð  ð7ð :ð	7ð
 +ð7ð ð7ð 
ó7ð !%ð<Øð<àð<ð ð<ð 
õ	<ð<ús   ºA6 Á6(B!Â B!