:"ri<ddlmZddlZddlZddlZddlmZm Z m Z ddl m Z m Z ddlmZmZmZgdZ dd lmZdd lmZmZdddd  dd Z d dd ZGddZy#e$r&dddd  ddZ d ddZY5wxYw)) annotationsN)AnyCallableLiteral)RequestResponse)ServerServerConnectionserve)route unix_routeRouter)NotFound)MapRequestRedirect) server_namessl create_routerc |dnd}|dur|||d<|t}|||| |jdd j}n d fd }t jg|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/", 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. NwswssTrprocess_requestcB||}||Sj||SN) route_request) connectionrequestresponse_process_requestrouters ^/var/www/fortnox.pascalinesoft.com/venv/lib/python3.12/site-packages/websockets/sync/router.pyrzroute..process_requests/,J@'#O++J@@rr rrreturnzResponse | None)rpoprr handler) url_maprrrargskwargs url_schemerr!r"s @@r#rr(sJ![Te d?sF5M  "Mw Z@ JJ($ /   #$$   A, A7> A  AV^^VdVOVvVVr$c  t|fd|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)unixpath)rr)r/r+s r#rrs W=4d=f==r$ctd)Nzroute() requires werkzeug ImportError)r)rrrr*r+s r#rrs566r$c td)Nzunix_route() requires werkzeugr2r0s r#rrs :;;r$c`eZdZdZ d d dZd dZd dZd dZ ddZddZ y)rz*WebSocket router supporting :func:`route`.Ncz||_||_||_|jjD] }d|_ y)NT)r)rr, iter_rules websocket)selfr)rr,rules r#__init__zRouter.__init__s=  &$LL++- "D!DN "r$cP|j|jdS|jS)NHost)rheaders)r9rrs r#get_server_namezRouter.get_server_names)    #??6* *## #r$c~|jtjjd|}||jd<|S)Nz Found at Location)respondhttp HTTPStatusFOUNDr>)r9rurlr s r#redirectzRouter.redirects:%%doo&;&;y=NO'*$r$cV|jtjjdS)Nz Not Found)rBrCrD NOT_FOUNDr9rs r# not_foundzRouter.not_founds!!$//";";[IIr$c|jj|j|||j} tj j |j}|j|j|j\}}||c|_|_y#t$r&}|j||jcYd}~Sd}~wt$r|j|cYSwxYw)zRoute incoming request.)rr,) path_info query_argsN)r)bindr?r,urllibparseurlparser/matchqueryrrGnew_urlrrKr(handler_kwargs)r9rrurl_map_adapterparsedr(r+rGs r#rzRouter.route_requests,,++,,ZA,  .\\**7<<8F-33 ++!<<4OGV9@5 J5  ?==X-=-=> > .>>*- - .s$AB C&%CC&C&%C&c<|j|fi|jS)zHandle a connection.)r(rVrJs r#r(zRouter.handlers !z!!*J 0I0IJJr$)Nr)r)rr str | Noner,strr&None)rr rrr&r[)rr rFr[r&r )rr r&r r%)rr r&r\) __name__ __module__ __qualname____doc__r;r?rGrKrr(r$r#rrsk4 #' " "  " "  "$  J*5< *Kr$r)r)rr*rrrZrz,ssl_module.SSLContext | Literal[True] | Nonerztype[Router] | Noner+rr&r r)r)rr/rZr+rr&r ) __future__rrCr ssl_module urllib.parserPtypingrrrhttp11rr serverr r r __all__werkzeug.exceptionsrwerkzeug.routingrrrrr3rrar$r#rksb" ))&33 ,O>,54#'<@-1 dWdWdW dW: dW + dW  dW dWP >>>>  >&4K4K]< #'<@-1 777 7: 7 + 7  7 7 <<<<  <