Ë
    ¸�©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
mZ d dlZddlmZmZ ddlmZmZmZ dd	gZ	 d d
lmZ d dlmZmZ dddej4                  dœ	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dd„Z G d„ d	«      Zy# e$ r& dddej4                  dœ	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dd„ZY Œ5w xY w)é    )ÚannotationsN)ÚAnyÚ	AwaitableÚCallableÚLiteralé   )ÚRequestÚResponseé   )ÚServerÚServerConnectionÚserveÚrouteÚRouter)ÚNotFound)ÚMapÚRequestRedirect)Úserver_nameÚsslÚcreate_routerÚtask_statusc             �  óü   ‡	‡
K  — |€dnd}|dur|�||d<   |€t         } || ||«      Š
|j                  dd«      Š	‰	€‰
j                  }n	 	 	 	 	 	 d	ˆ	ˆ
fd„}t        ‰
j                  g|¢­||dœ|¤Žƒ d{  –—† S 7 Œ­w)
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.trio.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.trio.router import route
            from werkzeug.routing import Map, Rule

            async def channel_handler(websocket, channel_id):
                ...

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

            # set this event to exit the server
            stop = trio.Event()

            with trio.open_nursery() as nursery:
                server = await nursery.start(route, url_map, ...)
                async with server:
                    await stop.wait()

        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.
            task_status: For compatibility with :meth:`nursery.start
                <trio.Nursery.start>`.

        NÚwsÚwssTr   Úprocess_requestc              “  ó‚   •K  —  ‰| |«      }t        |t        «      r
|ƒ d {  –—† }|�|S ‰j                  | |«      S 7 Œ­w)N)Ú
isinstancer   Úroute_request)Ú
connectionÚrequestÚresponseÚ_process_requestÚrouters      €€ú]/var/www/html/streamforge-license/venv/lib/python3.12/site-packages/websockets/trio/router.pyr   zroute.<locals>.process_request‡   sI   øè ø€ ñ ,¨J¸Ó@�Ü˜h¬	Ô2Ø%-Ÿ~�HØÐ'Ø#�OØ×+Ñ+¨J¸Ó@Ð@ð  .ús   ƒ?¢=£?)r   r   ©r   r   r    r	   ÚreturnzResponse | None)r   Úpopr   r   Úhandler)Úurl_mapr   r   r   r   ÚargsÚkwargsÚ
url_schemer   r"   r#   s            @@r$   r   r   $   sÒ   ùè ø€ ðX !˜[‘T¨eˆ
Ø�d‰?˜s˜ØˆF�5‰MàÐ Ü"ˆMá˜w¨°ZÓ@ˆð �J‰JÐ(¨$Ó/ð 	ð Ð#ð ×$Ñ$ñ ð	AØ,ð	Aà ð	Að !ö	Aô Ø�N‰Nð
àñ
ð ,Ø#ñ	
ð
 ñ
÷ 
ð 	
ð 
ús   „A1A<Á5A:Á6A<c             �  ó    K  — t        d«      ‚­w)Nzroute() requires werkzeug)ÚImportError)r)   r   r   r   r   r*   r+   s          r$   r   r      s   è ø€ ô Ð5Ó6Ð6ùs   ‚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ñ	"ó    c                óP   — | j                   €|j                  d   S | j                   S )NÚHost)r   Úheaders)r3   r   r    s      r$   Úget_server_namezRouter.get_server_nameª   s)   € Ø×ÑÐ#Ø—?‘? 6Ñ*Ð*à×#Ñ#Ð#r6   c                ó~   — |j                  t        j                  j                  d|› �«      }||j                  d<   |S )Nz	Found at ÚLocation)ÚrespondÚhttpÚ
HTTPStatusÚFOUNDr9   )r3   r   Úurlr!   s       r$   ÚredirectzRouter.redirect°   s:   € Ø×%Ñ%¤d§o¡o×&;Ñ&;¸yÈÈÐ=NÓOˆØ'*ˆ×Ñ˜Ñ$Øˆr6   c                óV   — |j                  t        j                  j                  d«      S )Nz	Not Found)r=   r>   r?   Ú	NOT_FOUND©r3   r   s     r$   Ú	not_foundzRouter.not_foundµ   s   € Ø×!Ñ!¤$§/¡/×";Ñ";¸[ÓIÐIr6   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ÚurlparseÚpathÚmatchÚqueryr   rB   Únew_urlr   rF   r(   Úhandler_kwargs)r3   r   r    Úurl_map_adapterÚparsedr(   r+   rB   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              ƒ  óX   K  —  |j                   |fi |j                  ¤Žƒ d{  –—† S 7 Œ­w)zHandle a connection.N)r(   rR   rE   s     r$   r(   zRouter.handlerÍ   s*   è ø€ à'�Z×'Ñ'¨
ÑP°j×6OÑ6OÑP×PÐPÐPús   ‚!*£(¤*)Nr   )r)   r   r   ú
str | Noner,   Ústrr&   ÚNone)r   r   r    r	   r&   rW   )r   r   rA   rW   r&   r
   )r   r   r&   r
   r%   )r   r   r&   rX   )
Ú__name__Ú
__module__Ú__qualname__Ú__doc__r5   r:   rB   rF   r   r(   © r6   r$   r   r   ›   sk   „ Ù4ð
 #'Øð	
"àð
"ð  ð
"ð ð	
"ð
 
ó
"ó$óó
JðØ*ðØ5<ðà	óô*Qr6   )r)   r   r*   r   r   rV   r   z,ssl_module.SSLContext | Literal[True] | Noner   ztype[Router] | Noner   ztrio.TaskStatus[Server]r+   r   r&   rX   )Ú
__future__r   r>   r   Ú
ssl_moduleÚurllib.parserK   Útypingr   r   r   r   ÚtrioÚhttp11r	   r
   Úserverr   r   r   Ú__all__Úwerkzeug.exceptionsr   Úwerkzeug.routingr   r   ÚTASK_STATUS_IGNOREDr   r.   r   r]   r6   r$   ú<module>ri      s-  ðÝ "ã Û Û ß 4Ó 4ã ç &ß 3Ñ 3ð �HÐ
€ðG
Ý,ß5ð( #'Ø<@Ø-1Ø/3×/GÑ/Gñt
Øðt
àðt
ð  ðt
ð :ð	t
ð
 +ðt
ð -ðt
ð ðt
ð 
ót
÷n4Qò 4QøðM ò 7ð
 #'Ø<@Ø-1Ø/3×/GÑ/Gñ	7Øð	7àð	7ð  ð	7ð :ð		7ð
 +ð	7ð -ð	7ð ð	7ð 
õ	7ð7ús   ºA6 Á6(B!Â B!