i-ddlZddlZddlZddlZddlZddlmZddlmZejdZ gZ dZ da GddZ dS) N)base_namespace)packetzsocketio.clientctddD]}|jttrt ||St j||S)zSIGINT handler. Notify any clients that are in a reconnect loop to abort. Other disconnection tasks are handled at the engine.io level. N)reconnecting_clients_reconnect_abortsetcallableoriginal_signal_handlersignaldefault_int_handler)sigframeclients ?/usr/local/lib/python3.11/dist-packages/socketio/base_client.pysignal_handlerrsj 'qqq)&&##%%%%'((6&sE222)#u555ceZdZgdZejjZ dd Zd Zdd Z d Z dZ ddZ dZ dZdZdZdZdZdZdZd S) BaseClient)connect connect_error disconnect__disconnect_finalTrr?FdefaultNc  @| rStLtjtjkr$t jtjt a||_||_||_ ||_ ||_ | |_ | } | | d<| dd} | | | d<|dkrtj|_n |dkrddlm} | j|_n||_|||j_|| d<|d i| |_|jd |j|jd |j|jd |jt7|t8s||_nt<|_|jjt@j!krv|r%|j"t@j#n$|j"t@j$|j%tAj&d|_'d|_(d|_)d|_*g|_+d|_,d|_-d |_.i|_/g|_0i|_1i|_2i|_3d|_4d|_5d|_6d|_7dS)N handle_sigintengineio_loggerloggerrmsgpackr)msgpack_packetjsonrmessagerF)8r threadingcurrent_thread main_threadr SIGINTr reconnectionreconnection_attemptsreconnection_delayreconnection_delay_maxrandomization_factorrpoprPacket packet_classr" MsgPackPacketr#_engineio_client_classeioon_handle_eio_connect_handle_eio_message_handle_eio_disconnect isinstanceboolr default_loggerlevelloggingNOTSETsetLevelINFOERROR addHandler StreamHandlerconnection_urlconnection_headersconnection_authconnection_transportsconnection_namespaces socketio_pathsid connected namespacesfailed_namespaceshandlersnamespace_handlers callbacks_binary_packet_connect_event_reconnect_taskr)selfr*r+r,r-r.r serializerr#rkwargsengineio_optionsrr"s r__init__zBaseClient.__init__&s  D4<(**i.C.E.EEE&,mFM4B'D'D #(%:""4&<#$8!*!,9)*../@$GG  &)8 X &  " " & D   9 $ $ ( ( ( ( ( ( . >>&$'' @ DKK(DK{ GN228K((6666K((777 &&w'<'>'>???""&#%)"%'"!!# "$""# $rcdS)NFr%rUs ris_asyncio_basedzBaseClient.is_asyncio_basedisurc@pdfd}||S||dS)aRegister 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') def connect_handler(): print('Connected!') # as a method: def message_handler(msg): print('Received message: ', msg) sio.send( 'response') sio.on('message', message_handler) The arguments passed to the handler function depend on the event type: - The ``'connect'`` event handler does not take arguments. - The ``'disconnect'`` event handler does not take arguments. - The ``'message'`` handler and handlers for custom event names receive the message payload as only argument. 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. /cNjvr ij<|j<|SN)rO)handlerevent namespacerUs r set_handlerz"BaseClient.on..set_handlers2 --+- i(.5DM) $U +NrNr%)rUrbrarcrds`` ` rr6z BaseClient.onlsXX$         ?  GrctdkrWtdkrDtdr/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|Sr`)r6__name__)raargsrWrUs rrdz%BaseClient.event..set_handlers2Awtww/A$AAA&AA'JJJr)lenr r6rg)rUrhrWrds``` rrbzBaseClient.events0 t99>>c&kkQ..8DG3D3D.-47747+,,T!W55 5 K K K K K K K rct|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 clientN)r:rBaseClientNamespace ValueErrorr\ _set_clientrPrc)rUnamespace_handlers rregister_namespacezBaseClient.register_namespaces+(<>> 9788 8  " "&7&H&H&J&J J JJKK K%%d+++   1 ;<<,>(?DN9 % $.+A. / /(0y!"% rctr`NotImplementedErrorr[s rr7zBaseClient._handle_eio_connect!###rctr`r)rUdatas rr8zBaseClient._handle_eio_message!rrctr`r)rUreasons rr9z!BaseClient._handle_eio_disconnect$rrctr`rr[s rr4z!BaseClient._engineio_client_class'rr) TrrrrFrNT)NNr`)rg __module__ __qualname__rxengineioClientrrYr\r6rbrorrrtryr{rr7r8r9r4r%rrrr!s#---O _ #F@A>?DM*.A%A%A%A%F6666p!!!F 5 5 5 5$$$4   $$$$$$$$$$$$$$rr)r}r>r r&rr2rr getLoggerr<rrr rr%rrrs ""#455 6 6 6G$G$G$G$G$G$G$G$G$G$r