i9ddlZddlZddlZddlZddlZddlZddlZddlmZddlm Z ej dZ GddZ dS)N)packet)payloadzengineio.serverceZdZddgZgdZddgZdZdZGdd Z d%dZ dZ dZ d&dZ dZ dZdZdZdZdZdZdZd'dZd&dZdZd&dZd Zd!Zd"Zd#Zd$Zd S)( BaseServergzipdeflate)connect disconnectmessagepolling websocketTrc&eZdZdZdZdZdZdZdZdS)BaseServer.reasonzDisconnection reasons.zserver disconnectzclient disconnectz ping timeoutztransport closeztransport errorN) __name__ __module__ __qualname____doc__SERVER_DISCONNECTCLIENT_DISCONNECT PING_TIMEOUTTRANSPORT_CLOSETRANSPORT_ERROR?/usr/local/lib/python3.11/dist-packages/engineio/base_server.pyreasonrs/$$//% ++rrN@BFc 0|_t|tr|d_|d_n|_d_|_|_|_|_|_ | _ | _ | _ i_ i_t_||nj_d_d_| | t*j_t| t0s| _nt4_jjt8jkrv| r%jt8jn$jt8j j!t9j"#}| ||vr|gng}d_$d_%|D]m} tMj'd|zj$_$dj$vr j$dnd}|(krU|_%n#tR$rYjwxYwj%tUd(r%dj$vs j$dstUd(s%dj$vrj$drtUd|7t|tVr|g}fd |D}|stUd |pj,_-j.d j%dS) Nrrzengineio.async_drivers.asyncioFzInvalid async_mode specifiedz1The selected async_mode is not asyncio compatiblezKThe selected async_mode requires asyncio and must use the AsyncServer classc&g|] }|jv |Sr)valid_transports).0 transportselfs r z'BaseServer.__init__..ks3AAA &$*???$???rzNo valid transports providedzServer initialized for %s.)/ ping_timeout isinstancetuple ping_intervalping_interval_grace_periodmax_http_buffer_sizeallow_upgradeshttp_compressioncompression_thresholdcookiecors_allowed_originscors_credentialsasync_handlerssocketshandlerssetlog_message_keys_default_monitor_clientsstart_service_taskservice_task_handleservice_task_eventrPacketjsonboolloggerdefault_loggerlevelloggingNOTSETsetLevelINFOERROR addHandler StreamHandler async_modes_async async_mode importlib import_moduleis_asyncio_based ImportError ValueErrorstrr% transportsinfo)r(rNr-r*r/r0r1r2r3r4r5rBr@r6monitor_clientsrUkwargsmodesmode asyncio_baseds` r__init__zBaseServer.__init__#s) mU + + 0!.q!1D .;A.>D + +!.D ./D +$8!, 0%:" $8! 0,  #*#2/040M #' "&  !%FM &$'' @ DKK(DK{ GN228K((6666K((777 &&w'<'>'>???  ""  !$.%$7$7ZLLRE   D '5-4666< !DK//!% I 6 65: D$9$9$;$;;;"&     ? ";<< <  " " +$+--Y'.*++ +$$&& ?9 +C+C I&,D>?? ?  !*c** *(\ AAAAZAAAJ A !?@@@$=(= 5tGGGGGs.set_handlers#*DM% NrN) event_namesrS)r(rhrgris`` ronz BaseServer.onxsc> ( ( (_-- -       ?  Grc>||jrdndS)zReturn the name of the transport used by the client. The two possible values returned by this function are ``'polling'`` and ``'websocket'``. :param sid: The session of the client. rr ) _get_socketupgraded)r(sids rr'zBaseServer.transports$#..s33<K{{)Krc(|jd|i|S)zCreate a queue object using the appropriate async model. This is a utility function that applications can use to create a queue without having to worry about using the correct call for the selected async mode. queuerMr(argsrXs r create_queuezBaseServer.create_queue $t{7#T4V444rc|jdS)zReturn the queue empty exception for the appropriate async model. This is a utility function that applications can use to work with a queue without having to worry about using the correct call for the selected async mode. queue_emptyrrr^s rget_queue_empty_exceptionz$BaseServer.get_queue_empty_exceptions{=))rc(|jd|i|S)zCreate an event object using the appropriate async model. This is a utility function that applications can use to create an event without having to worry about using the correct call for the selected async mode. rhrrrss r create_eventzBaseServer.create_eventrvrc$tjtjd|jddz}|jdzdz|_|dddd d S) zGenerate a unique session id. bigriutf-8/_+-)base64 b64encodesecrets token_bytessequence_numberto_bytesdecodereplace)r(ids r generate_idzBaseServer.generate_ids     # #d&:&C&CAu&M&M MOO $ 4q 8HDyy!!))#s33;;CEEErc|dddz|z}|D]@\}}|dkr t|r |}|dur |d|zz }2|d|zdz|zz }A|S)zGenerate the sid cookie.nameio=Tz; )getitemscallable)r(ro attributesr3 attributevalues r_generate_sid_cookiezBaseServer._generate_sid_cookies--3c9 * 0 0 2 2 9 9 IuF"" }}$**$*S0588 rc|jr ||js|dkrgS|jd|ddgSdgS)z=Return the list of possible upgrades for a client connection.rNzThe WebSocket transport is not available, you must install a WebSocket server that is compatible with your async mode to enable it. See the documentation for details.z no-websocket)r0rmrnrM_log_error_once)r(ror's r _upgradeszBaseServer._upgradesst" d&6&6s&;&;&D [((I ;{ # +  @    I}rc |j|}n#t$rtdwxYw|jr|j|=td|S)z-Return the socket object for a given session.zSession not foundzSession is disconnected)r7KeyErrorclosed)r(ross rrmzBaseServer._get_socketsg 0 S!AA 0 0 0.// / 0 8 6 S!455 5s *c|J|g}|dgz }d|tj||ddSddgd dS) z$Generate a successful HTTP response.N) Content-Typeztext/plain; charset=UTF-8z200 OK)packets) jsonp_indexrstatusheadersresponserz text/plainsOK)rPayloadencode)r(rrrs r_okzBaseServer._oks   EF FG&& ' @ @ @ G G$/!H!1!117BB B ' >? %'' 'rc|d}tjj|}ddg|ddS)z+Generate a bad request HTTP error response.Nz Bad Requestz400 BAD REQUESTrrrrr?r@dumpsrr(r s r _bad_requestzBaseServer._bad_requestsK ?#G-$**733+:;#NN73355 5rcddgddS)z0Generate a method not found HTTP error response.z405 METHOD NOT FOUNDrsMethod Not Foundrrr^s r_method_not_foundzBaseServer._method_not_found s0:;/11 1rc|d}tjj|}ddg|ddS)z,Generate a unauthorized HTTP error response.N Unauthorizedz401 UNAUTHORIZED)rzapplication/jsonrrrrs r _unauthorizedzBaseServer._unauthorizedsK ?$G-$**733,@A#NN73355 5rc v|jg}d|vrd|vr|d|d|dd|vsd|vr|d|ddd}|d||d|dddn|jd krd}nt |jtr |jg}nt|jrZ|d } |||}n%#t$r||}YnwxYw|r|gng}nd |jvrd}n|j}|S) Nzwsgi.url_scheme HTTP_HOSTz{scheme}://{host})schemehostHTTP_X_FORWARDED_PROTOHTTP_X_FORWARDED_HOST,r* HTTP_ORIGIN) r4appendformatrsplitstripr+rTr TypeError)r(environallowed_originsrorigin is_alloweds r_cors_allowed_originsz BaseServer._cors_allowed_originss  $ , O G++ w0F0F&&':'A'A"#45 -(B(/(/000,w66/7::$[[0 124449E#JJqBBG%''$**+>+E+E%GKK3#K0-2-227% #3%3%%&-(). ,F,1,1222  &# - -"OO 13 7 7 <#89OO d/ 0 0 <[[//F ?!66vwGG  ? ? ?!66v>>  ?*4B>B37;?GK MHMHMHMH^CCC((((TLLL555***555FFF          ' ' ' '5555111 5555!!!F("""'''&&&&&rr) rrrOrrErrrr getLoggerrCrrrrrs   ""#455W&W&W&W&W&W&W&W&W&W&r