wgu-ddlZddlZddlZddlZddlZddlmZddlmZejdZ gZ dZ da GddZ y) N)base_namespace)packetzsocketio.clientctddD]}|jjttr t ||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 Y/home/mcse/projects/flask/flask-venv/lib/python3.12/site-packages/socketio/base_client.pysignal_handlerrsU 'q)&##%&'(&sE22))#u55ceZdZgdZej j Z ddZdZddZ dZ dZ ddZ d Z d Zd Zd Zd ZdZdZdZy) BaseClient)connect connect_error disconnect__disconnect_finalNc  | rWtQtjtjk(r(t jtj t a||_||_||_ ||_ ||_ | |_ | } | | d<| jdd} | | | d<|dk(rtj|_n$|dk(rddlm} | j&|_n||_|||j _|| d<|j+d i| |_|j,j/d |j0|j,j/d |j2|j,j/d |j4t7|t8s||_nt<|_|j:j>t@jBk(r|r*|j:jEt@jFn)|j:jEt@jH|j:jKtAjLd|_'d|_(d|_)d|_*g|_+d|_,d|_-d |_.i|_/i|_0i|_1i|_2d|_3d|_4d|_5d|_6y)N handle_sigintengineio_loggerloggerdefaultmsgpackr)msgpack_packetjsonrmessagerF)7r 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 isinstanceboolrdefault_loggerlevelloggingNOTSETsetLevelINFOERROR addHandler StreamHandlerconnection_urlconnection_headersconnection_authconnection_transportsconnection_namespaces socketio_pathsid connected namespaceshandlersnamespace_handlers callbacks_binary_packet_connect_event_reconnect_taskr)selfr(r)r*r+r,r serializerr!rkwargsengineio_optionsrr s r__init__zBaseClient.__init__&sO 4<((*i.C.C.EE&,mmFMM4B'D #(%:""4&<#$8!*!,9)*../@$G  &)8 X &  " & D  9 $ ( . < .set_handlers5 -+- i(.5DMM) $U +NrNr#)rRr_r^r`ras`` ` rr4z BaseClient.onks*X$   ? Grctdk(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|Sr])r4__name__)r^argsrTrRs rraz%BaseClient.event..set_handlers+Awtwww//A$A&A'JJr)lenr r4rd)rRrerTras``` rr_zBaseClient.eventsZ0 t9>c&kQ.8DG3D-47747++,T!W5 5 K rct|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 clientN)r8rBaseClientNamespace ValueErrorrY _set_clientrMr`)rRnamespace_handlers rregister_namespacezBaseClient.register_namespacess+(<<>78 8  "&7&H&H&J JJK K%%d+   1 ; ;(?DNN9 % $..+A. /(0y!"% rctr]NotImplementedErrorrXs rr5zBaseClient._handle_eio_connect !##rctr]r)rRdatas rr6zBaseClient._handle_eio_message rrctr]r)rRreasons rr7z!BaseClient._handle_eio_disconnect#rrctr]rrXs rr2z!BaseClient._engineio_client_class&rr) Trrg?FrNT)NNr])rd __module__ __qualname__ruengineioClientrrVrYr4r_rlrorqrvrxrr5r6r7r2r#rrrr!sn-O __ # #F@A>?DM*.@%D6p!F 5$4 $$$$rr)rzr<r r$rr0rr getLoggerr:rrr rr#rrrsL """#45 6F$F$r