wgz8ddlZddlZddlZddlZddlZddlZddlZddlmZddlm Z ejdZ GddZ y)N)packet)payloadzengineio.serverceZdZddgZgdZddgZdZdZGdd Z d d Z d Z d Z d!dZ dZ dZdZdZdZdZdZdZd"dZd!dZdZd!dZdZdZdZdZdZy )# BaseServergzipdeflate)connect disconnectmessagepolling websocketTrc$eZdZdZdZdZdZdZdZy)BaseServer.reasonzDisconnection reasons.zserver disconnectzclient disconnectz ping timeoutztransport closeztransport errorN) __name__ __module__ __qualname____doc__SERVER_DISCONNECTCLIENT_DISCONNECT PING_TIMEOUTTRANSPORT_CLOSETRANSPORT_ERRORY/home/mcse/projects/flask/flask-venv/lib/python3.12/site-packages/engineio/base_server.pyreasonrs $//% ++rrNc ||_t|tr|d|_|d|_n||_d|_||_||_||_||_||_ | |_ | |_ | |_ i|_ i|_t|_||n |j"|_d|_d|_| | t*j,_t| t0s| |_nt4|_|j2j6t8j:k(r| r*|j2j=t8j>n)|j2j=t8j@|j2jCt9jD|jG}| ||vr|gng}d|_$d|_%|D]e} tMjNd|zjH|_$d|jHvr|jHdnd}||jQk7r^||_%n|jJ tUd|jQr(d|jHvs|jHds tUd|jQs(d|jHvr|jHdr tUd|=t|tVr|g}|Dcgc]}||jXvr|}}|s tUd |xs |jX|_-|j2j]d |jJy#tR$rYvwxYwcc}w) Nrrzengineio.async_drivers.asyncioFzInvalid async_mode specifiedz1The selected async_mode is not asyncio compatiblezKThe selected async_mode requires asyncio and must use the AsyncServer classzNo 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 ValueErrorstrvalid_transports transportsinfo)selfrDr#r r%r&r'r(r)r*r+r8r6r,monitor_clientsrLkwargsmodesmode asyncio_based transports r__init__zBaseServer.__init__#s) mU +!.q!1D .;A.>D +!.D ./D +$8!, 0%:" $8! 0,  #*#2040M0M #' "&  !%FMM &$' DK(DK{{  GNN2KK((6KK((7 &&w'<'<'>?  "  !$.%$7ZLRE  D '55-466? ?  !*c*(\ 5?A &$*?*??$AJA !?@@$=(=(= 5tG+   AsAL+L+ L;+ L87L8cy)NFrrNs rrGzBaseServer.is_asyncio_basedrsrc gdS)N)eventlet gevent_uwsgigevent threadingrrWs rrBzBaseServer.async_modesusBBrc^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(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) eio.send(sid, 'response') eio.on('message', message_handler) The handler function receives the ``sid`` (session ID) for the client as first argument. The ``'connect'`` event handler receives the WSGI environment as a second argument, and can return ``False`` to reject the connection. The ``'message'`` handler receives the message payload as a second argument. The ``'disconnect'`` handler does not take a second argument. z Invalid eventc&|j<|SN)r.)handlereventrNs r set_handlerz"BaseServer.on..set_handlers#*DMM% NrN) event_namesrI)rNrar`rbs`` ronz BaseServer.onxs8> (( (_- -  ? Grc@|j|jrdSdS)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)rNsids rrTzBaseServer.transports"#..s3<<{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. queuerCrNargsrPs r create_queuezBaseServer.create_queue$t{{7#T4V44rc |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_emptyrkrWs 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. rarkrls r create_eventzBaseServer.create_eventrorctjtjd|jj ddz}|jdzdz|_|j djddjd d S) zGenerate a unique session id. bigriutf-8/_+-)base64 b64encodesecrets token_bytessequence_numberto_bytesdecodereplace)rNids r generate_idzBaseServer.generate_idsz       #d&:&:&C&CAu&M MO $ 4 4q 8HDyy!))#s3;;CEErc|jdddz|z}|jD]8\}}|dk(r t|r|}|dur |d|zz }+|d|zdz|zz }:|S)zGenerate the sid cookie.nameio=Tz; )getitemscallable)rNrh attributesr) attributevalues r_generate_sid_cookiezBaseServer._generate_sid_cookies-3c9 * 0 0 2 9 IuF"}$**$*S0588 9 rc|jr |j|js|dk(rgS|jd|j ddgSdgS)z=Return the list of possible upgrades for a client connection.rzThe 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)r&rfrgrC_log_error_once)rNrhrTs r _upgradeszBaseServer._upgradessb""d&6&6s&;&D&D[(I ;;{ # +  @  I}rc |j|}|jr|j|=td|S#t$r tdwxYw)z-Return the socket object for a given session.zSession not foundzSession is disconnected)r-KeyErrorclosed)rNrhss rrfzBaseServer._get_socketsX 0 S!A 88 S!45 5  0./ / 0s 7A c|C|g}|dgz }d|tj|j|jddSddgddS) z$Generate a successful HTTP response.) Content-Typeztext/plain; charset=UTF-8z200 OK)packets) jsonp_indexrystatusheadersresponserz text/plainsOK)rPayloadencode)rNrrrs r_okzBaseServer._okss   EF FG&& ' @ G G$/!H!117B B ' >? %' 'rc|d}tjjj|}ddg|j ddS)z+Generate a bad request HTTP error response.z Bad Requestz400 BAD REQUESTrryrrr5r6dumpsrrNr s r _bad_requestzBaseServer._bad_requestsE ?#G--$$**73+:;#NN735 5rcddgddS)z0Generate a method not found HTTP error response.z405 METHOD NOT FOUNDrsMethod Not FoundrrrWs r_method_not_foundzBaseServer._method_not_found s0:;/1 1rc|d}tjjj|}ddg|j ddS)z,Generate a unauthorized HTTP error response. Unauthorizedz401 UNAUTHORIZED)rzapplication/jsonryrrrs r _unauthorizedzBaseServer._unauthorizedsE ?$G--$$**73,@A#NN735 5rc g}d|vrd|vr|jdj|d|dd|vsd|vr|jd|djddj }|jdj||jd|djddj |j |}|S|j d k(rd}|St |j tr|j g}|St|j r+|jd }|j |r|g}|Sg}|S|j }|S) Nzwsgi.url_scheme HTTP_HOSTz{scheme}://{host})schemehostHTTP_X_FORWARDED_PROTOHTTP_X_FORWARDED_HOST,r* HTTP_ORIGIN) appendformatrsplitstripr*r!rJr)rNenvirondefault_originsrallowed_originsorigins r_cors_allowed_originsz BaseServer._cors_allowed_originss  'K7,B  " "#6#=#=01 8L$>$N O'72+w6 ,-.005c 1>>Ceg &&':'A'A! /1E)GGLuH!!")$$)EG(B(-.  $ $ ,-O & &# -"O113 7#889O d// 0[[/F,,V4 &hO;= #77Orc|jgk(rgSg}|j|}d|vr||d|vrd|dfg}|ddk(r|dgz }d|vr |d|dfgz }|jr|dgz }|S) z1Return the cross-origin-resource-sharing headers.rzAccess-Control-Allow-OriginREQUEST_METHODOPTIONS)zAccess-Control-Allow-MethodszOPTIONS, GET, POST#HTTP_ACCESS_CONTROL_REQUEST_HEADERSzAccess-Control-Allow-Headers)z Access-Control-Allow-Credentialstrue)r*rr+)rNrrrs r _cors_headerszBaseServer._cors_headers8s  $ $ *I44W= G # (GM,B -!5w}7MNOG # $ 1 NO OG 0G ; 7 EFHI IG  DE EGrctj}tj|d5}|j |ddd|j S#1swY|j SxYw)z%Apply gzip compression to a response.w)fileobjrRN)rBytesIOrGzipFilewritegetvalue)rNrbytesiogzs r_gzipzBaseServer._gzipLsW**, ]]7 5  HHX  !! !!s AA.c,tj|S)z(Apply deflate compression to a response.)zlibcompress)rNrs r_deflatezBaseServer._deflateSs}}X&&rc||jvr:|jj|dz|jj|y|jj |y)zWLog message with logging.ERROR level the first time, then log with given level.zC (further occurrences of this error will be logged with level INFO)N)r0r8erroraddrM)rNr message_keys rrzBaseServer._log_error_onceWsY d33 3 KK  g)@@ A  ! ! % %k 2 KK  W %r)Ni@BTTiNNTFNTNNr_)NNN)rrrcompression_methodsrcrKr1rrrUrGrBrdrTrnrrrtrrrrfrrrrrrrrrrrrrrs!9-6K!;/#O , ,HJ>B>B37;?GK MH^C(TL5*5F    '51 58("'&rr) r~rrErr;rrrr getLoggerr9rrrrrs?   """#45P&P&r