9hSSKJr SSKrSSKrSSKrSSKJrJ r J r J r SSK J r SSKJrJr SSKJrJr SS KJrJrJr /S Qr"S S 5rSSSS .SSjjrSSSjjrg)) annotationsN)Any AwaitableCallableLiteral)NotFound)MapRequestRedirect)RequestResponse)ServerServerConnectionserve)route unix_routeRoutercv\rSrSrSrS S SjjrS SjrSSjrSSjrSSjr SS jr S r g)rz*WebSocket router supporting :func:`route`.NcxXlX lX0lURR5H nSUlM g)NT)url_map server_name url_scheme iter_rules websocket)selfrrrrules ^C:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\websockets/asyncio/router.py__init__Router.__init__s2  &$LL++-D!DN.cRURcURS$UR$)NHost)rheaders)r connectionrequests rget_server_nameRouter.get_server_name!s)    #??6* *## #r"c|UR[RRSU35nX#RS'U$)Nz Found at Location)respondhttp HTTPStatusFOUNDr%)rr&urlresponses rredirectRouter.redirect's8%%doo&;&;y=NO'*$r"cVUR[RRS5$)Nz Not Found)r,r-r. NOT_FOUNDrr&s r not_foundRouter.not_found,s!!$//";";[IIr"cURRURX5URS9n[R R UR5nURURURS9upVXVsUlUlg![a%nURXR5sSnA$SnAf[a URU5s$f=f)zRoute incoming request.)rr) path_info query_argsN)rbindr(rurllibparseurlparsepathmatchqueryr r2new_urlrr7handlerhandler_kwargs)rr&r'url_map_adapterparsedrDkwargsr2s r route_requestRouter.route_request/s,,++,,ZA,  .\\**7<<8F-33 ++!<<4OG9@5 J5  ?==-=-=> > .>>*- - .s$AB CB=7C=CCcX# UR"U40URD6IShvN $N7f)zHandle a connection.N)rDrEr6s rrDRouter.handlerDs''' Pj6O6OPPPPs !*(*)rrr)Nws)rr r str | NonerstrreturnNone)r&rr'r rPrO)r&rr0rOrPr )r&rrPr r&rr'r rPzResponse | None)r&rrPrQ) __name__ __module__ __qualname____firstlineno____doc__r r(r2r7rIrD__static_attributes__r"rrrsk4 #' " "  " "  "$  J*5< *Qr"r)rssl create_routerc^^ UcSOSnUSLaUbX%S'Uc[nU"XU5m URSS5mTc T RnOSUU 4Sjjn[T R/UQ7SU0UD6$) 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.asyncio.router import route from werkzeug.routing import Map, Rule async def channel_handler(websocket, channel_id): ... url_map = Map([ Rule("/channel/", endpoint=channel_handler), ... ]) # set this future to exit the server stop = asyncio.get_running_loop().create_future() async with route(url_map, ...) as server: await stop 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 actually 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. NrMwssTrZprocess_requestc># T"X5n[U[5(a UIShvN nUbU$TRX5$N7fN) isinstancerrI)r&r'r1_process_requestrouters rr^route..process_requestsG( #'' < <*s#AAArR)rpoprIrrD) rrrZr[argsrHrr^rbrcs @@rrrIsR%J $3?u  7 rss" 44(1&33 ,4Q4Qt#8<)- jS jS jSjS 6 jS ' jS  jSjS^: : :: :r"