i)tddlZddlZddlmZddlmZddlmZejdZGddZdS) N)manager)base_namespace)packetzsocketio.serverceZdZddgZejjZ ddZdZdd Z d Z d Z dd Z dd Z ddZdZdZdZdZdZdZdS) BaseServerconnect disconnectNFdefaultTc ~|} | dd} | | | d<|dkrtj|_n |dkrddlm} | j|_n||_|||j_|| d<d| d <|di| |_ |j d |j |j d |j |j d |j i|_i|_i|_t#|_i|_t)|t*s||_nt.|_|jjt2jkrv|r%|jt2jn$|jt2j|jt3j|tAj!}||_ |j "|d|_#||_$||_%|pd g|_&|j j'|_'dS)Nengineio_loggerloggerr msgpackr)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 isinstanceboolrdefault_loggerlevelloggingNOTSETsetLevelINFOERROR addHandler StreamHandlerrManager set_servermanager_initializedralways_connect namespaces async_mode) selfclient_managerr serializerrrr5r6kwargsengineio_optionsr rs ?/usr/local/lib/python3.11/dist-packages/socketio/base_server.py__init__zBaseServer.__init__s2"*../@$GG  &)8 X &  " " & D   9 $ $ ( ( ( ( ( ( . >>  "$!88 &$'' @ DKK(DK{ GN228K((6666K((777 &&w'<'>'>???  !$_..N%  %%%#( ,,$-(-cdS)NFrr8s r=is_asyncio_basedzBaseServer.is_asyncio_basedEsur?c@pdfd}||S||dS)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. rcNjvr ij<|j<|SN)r")handlerevent namespacer8s r= set_handlerz"BaseServer.on..set_handlerzs2 --+- i(.5DM) $U +Nr?Nr)r8rGrFrHrIs`` ` r=rz BaseServer.onHsX`$         ?  Gr?ctdkrWtdkrDtdr/djdSfd}|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) rrcBj|jgRi|SrE)r__name__)rFargsr;r8s r=rIz%BaseServer.event..set_handlers2Awtww/A$AAA&AA'JJJr?)lencallablerrL)r8rMr;rIs``` r=rGzBaseServer.events0 t99>>c&kkQ..8DG3D3D.-47747+,,T!W55 5 K K K K K K K r?ct|tjstd||krtd||||j|j<dS)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_namespaces+(<>> 9788 8  " "&7&H&H&J&J J JJKK K%%d+++   1 ;<<rBrrGrUrYr\rarfrhrrr rrr?r=rr s$ ,/O _ #FEN@E 3.3.3.3.j::::x!!!F 6666 + + + +))))4   $$$$$$$$$GGGGGr?r) r+rsrrrr getLoggerr)rrr?r=rws""#455~G~G~G~G~G~G~G~G~G~Gr?