wg~ddlZddlZddlZddlZddlZddlmZejdZgZ dZ da GddZ y)N)packetzengineio.clientctddD]#}|jr|j%ttr t ||St j ||S)zdSIGINT handler. Disconnect all active clients and then invoke the original signal handler. N)connected_clientsis_asyncio_based disconnectcallableoriginal_signal_handlersignaldefault_int_handler)sigframeclients Y/home/mcse/projects/flask/flask-venv/lib/python3.12/site-packages/engineio/base_client.pysignal_handlerr s] $A& &&(     '(&sE22))#u55c\eZdZgdZGddZ d dZdZd dZdZd Z d Z d Z y) BaseClient)connectrmessageceZdZdZdZdZdZy)BaseClient.reasonzDisconnection reasons.zclient disconnectzserver disconnectztransport errorN)__name__ __module__ __qualname____doc__CLIENT_DISCONNECTSERVER_DISCONNECTTRANSPORT_ERRORrrreasonr!s$//+rr!Nc |rWtQtjtjk(r(t jtj t ai|_d|_d|_ d|_ d|_ d|_ d|_ d|_||_|du|_||_d|_d|_d|_d|_d|_||_|xsi|_||_||t4j6_t;|t<s||_||_)yt@|_|j>jBtDjFk(r|r*|j>jItDjJn)|j>jItDjL|j>jOtEjP||_)yN disconnected)*r threadingcurrent_thread main_threadr SIGINTrhandlersbase_url transportscurrent_transportsidupgrades ping_interval ping_timeouthttp external_http handle_sigintwsread_loop_taskwrite_loop_taskqueuestate ssl_verifywebsocket_extra_optionstimestamp_requestsrPacketjson isinstanceboolloggerdefault_loggerlevelloggingNOTSETsetLevelINFOERROR addHandler StreamHandlerrequest_timeout) selfr@r=rJ http_sessionr9r3r:r;s r__init__zBaseClient.__init__*sv 4<((*i.C.C.EE&,mmFMM4B'D #  !% !   )5*"# # $'>'D"$"4  !%FMM &$' DK /)DK{{  GNN2KK((6KK((7 &&w'<'<'>?.rcy)NFr rKs rrzBaseClient.is_asyncio_basedUsrc^jvr tdfd}||S||y)aRegister an event handler. :param event: The event name. Can be ``'connect'``, ``'message'`` or ``'disconnect'``. :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. Example usage:: # as a decorator: @eio.on('connect') def connect_handler(): print('Connection request') # as a method: def message_handler(msg): print('Received message: ', msg) eio.send('response') eio.on('message', message_handler) z Invalid eventc&|j<|SN)r))handlereventrKs r set_handlerz"BaseClient.on..set_handlerqs#*DMM% NrN) event_names ValueError)rKrTrSrUs`` ronz BaseClient.onXs8, (( (_- -  ? Grc|jS)zReturn the name of the transport currently in use. The possible values returned by this function are ``'polling'`` and ``'websocket'``. )r,rOs r transportzBaseClient.transportys %%%rc d|_d|_yr#)r8r-rOs r_resetzBaseClient._resets# rc<|jd}tjj|}|dk(rd}n|dk(rd}n t d|j dvr|dz }d j ||j||j|jrd | Sd | S) z&Generate the Engine.IO connection URL./pollingr1 websocketr4zinvalid transport)httpswssszC{scheme}://{netloc}/{path}/?{query}{sep}transport={transport}&EIO=4&)schemenetlocpathqueryseprZ) stripurllibparseurlparserWrfformatrgri)rKurl engineio_pathrZ parsed_urlrfs r_get_engineio_urlzBaseClient._get_engineio_urls%++C0 \\**3/  !F + %F01 1    0 0 cMF34:F!**;*;&j.>.>)//' 5;5) )68' 5;5) )rc\|jsydttjzS)z.Generate the Engine.IO query string timestamp.rez&t=)r;strtimerOs r_get_url_timestampzBaseClient._get_url_timestamps$&&s499;'''r)FNNTTNTrR) rrrrVr!rMrrXrZr\rsrwr rrrrsC6K,,ABCGBF)/VB&)*(rr) rCr r%rvrlrer getLoggerrArrr rr rrrzsI  """#45 6@(@(r