wg)pddlZddlZddlmZddlmZddlmZej dZGddZy) N)manager)base_namespace)packetzsocketio.serverceZdZddgZej j Z ddZdZddZ dZ dZ dd Z dd Z dd Zd Zd ZdZdZdZdZy) BaseServerconnect disconnectNc |} | jdd} | | | d<|dk(rtj|_n$|dk(rddlm} | j |_n||_|||j_|| d<d| d <|jdi| |_ |jjd |j|jjd |j|jjd |ji|_i|_i|_t#|_i|_t)|t*s||_nt.|_|j,j0t2j4k(r|r*|j,j7t2j8n)|j,j7t2j:|j,j=t3j>|tAjB}||_ |j@jE|d|_#||_$||_%|xsd g|_&|jjN|_'y)Nengineio_loggerloggerdefaultmsgpackr)msgpack_packetjsonFasync_handlersr messager /)(poprPacket packet_classr MsgPackPacketr_engineio_server_classeioon_handle_eio_connect_handle_eio_message_handle_eio_disconnectenvironhandlersnamespace_handlersobject not_handled_binary_packet isinstanceboolr default_loggerlevelloggingNOTSETsetLevelINFOERROR addHandler StreamHandlerrManager set_servermanager_initializedralways_connect namespaces async_mode) selfclient_managerr serializerrrr5r6kwargsengineio_optionsr rs Y/home/mcse/projects/flask/flask-venv/lib/python3.12/site-packages/socketio/base_server.py__init__zBaseServer.__init__s"*../@$G  &)8 X &  " & D  9 $ ( . < ?  !$__.N%  %#( ,,$-((--cy)NFrr8s r=is_asyncio_basedzBaseServer.is_asyncio_basedEsr?c<xsdfd}||S||y)a Register an event handler. :param event: The event name. It can be any string. The event names ``'connect'``, ``'message'`` and ``'disconnect'`` are reserved and should not be used. The ``'*'`` event name can be used to define a catch-all event handler. :param handler: The function that should be invoked to handle the event. When this parameter is not given, the method acts as a decorator for the handler function. :param namespace: The Socket.IO namespace for the event. If this argument is omitted the handler is associated with the default namespace. A catch-all namespace can be defined by passing ``'*'`` as the namespace. Example usage:: # as a decorator: @sio.on('connect', namespace='/chat') def connect_handler(sid, environ): print('Connection request') if environ['REMOTE_ADDR'] in blacklisted: return False # reject # as a method: def message_handler(sid, msg): print('Received message: ', msg) sio.send(sid, 'response') socket_io.on('message', namespace='/chat', handler=message_handler) The arguments passed to the handler function depend on the event type: - The ``'connect'`` event handler receives the ``sid`` (session ID) for the client and the WSGI environment dictionary as arguments. - The ``'disconnect'`` handler receives the ``sid`` for the client as only argument. - The ``'message'`` handler and handlers for custom event names receive the ``sid`` for the client and the message payload as arguments. Any values returned from a message handler will be passed to the client's acknowledgement callback function if it exists. - A catch-all event handler receives the event name as first argument, followed by any arguments specific to the event. - A catch-all namespace event handler receives the namespace as first argument, followed by any arguments specific to the event. - A combined catch-all namespace and catch-all event handler receives the event name as first argument and the namespace as second argument, followed by any arguments specific to the event. rcfjvrij<|j<|SN)r")handlerevent namespacer8s r= set_handlerz"BaseServer.on..set_handlerzs5 -+- i(.5DMM) $U +Nr?Nr)r8rGrFrHrIs`` ` r=rz BaseServer.onHs*`$   ? Gr?ctdk(rCtdk(r5tdr'jdjdSfd}|S)aDecorator to register an event handler. This is a simplified version of the ``on()`` method that takes the event name from the decorated function. Example usage:: @sio.event def my_event(data): print('Received data: ', data) The above example is equivalent to:: @sio.on('my_event') def my_event(data): print('Received data: ', data) A custom namespace can be given as an argument to the decorator:: @sio.event(namespace='/test') def my_event(data): print('Received data: ', data) rrcPj|jgi|SrE)r__name__)rFargsr;r8s r=rIz%BaseServer.event..set_handlers+Awtwww//A$A&A'JJr?)lencallablerrL)r8rMr;rIs``` r=rGzBaseServer.eventsZ0 t9>c&kQ.8DG3D-47747++,T!W5 5 K r?ct|tjs td|j |j k7r td|j |||j |j<y)zRegister a namespace handler object. :param namespace_handler: An instance of a :class:`Namespace` subclass that handles all the event traffic for a namespace. zNot a namespace instancez+Not a valid namespace class for this serverN)r'rBaseServerNamespace ValueErrorrB _set_serverr#rH)r8namespace_handlers r=register_namespacezBaseServer.register_namespacess+(<<>78 8  "&7&H&H&J JJK K%%d+   1 ; ;rBrrGrUrYr\rarfrhrrr rrr?r=rr sn ,/O __ # #FEN@E 3.j:x!F 6 +)4 $$$Gr?r) r+rsrrrr getLoggerr)rrr?r=rws5"""#45~G~Gr?