i9SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKJr SSKJ r \R"S5r "SS5r g)N)packet)payloadzengineio.serverc\rSrSrSS/r/SQrSS/rSrSr"S S 5r S"S jr S r Sr S#Sjr SrSrSrSrSrSrSrSrS$SjrS#SjrSrS#SjrSrSrSrSrS rS!rg )% BaseServergzipdeflate)connect disconnectmessagepolling websocketTrc,\rSrSrSrSrSrSrSrSr Sr g ) BaseServer.reasonzDisconnection reasons.zserver disconnectzclient disconnectz ping timeoutztransport closeztransport errorN) __name__ __module__ __qualname____firstlineno____doc__SERVER_DISCONNECTCLIENT_DISCONNECT PING_TIMEOUTTRANSPORT_CLOSETRANSPORT_ERROR__static_attributes__rQ/home/admin/cozy_coffee/venv/lib/python3.13/site-packages/engineio/base_server.pyreasonrs $//% ++rr!Nc X0l[U[5(aUSUlUSUlO X lSUlX@lXPlX`lXplXl Xl Xl Xl 0Ul 0Ul[5UlUbUO UR"UlSUlSUlU bU [*R,l[U [05(dXlO[4UlUR2R6[8R::XaU (a*UR2R=[8R>5 O)UR2R=[8R@5 UR2RC[8RD"55 URG5nUb UU;aU/O/nSUl$SUl%UHjn[LRN"SU-5RHUl$SURH;aURHSOSnUURQ5:waMcUUl% O URJc [US5eURQ5(a/SURH;dURHS(d [US5eURQ5(d/SURH;aURHS(a [US5eUbN[U[V5(aU/nUVs/sHnUURX;dMUPM nnU(d [US 5eU=(d URXUl-UR2R]S URJ5 g![Ra GMf=fs snf) 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)selfrHr'r$r)r*r+r,r-r.r/r<r:r0monitor_clientsrPkwargsmodesmode asyncio_based transports r __init__BaseServer.__init__#s) mU + +!.q!1D .;A.>D +!. ./D +$8!, 0%:" $8! 0,  #*#2040M0M #' "&  !%FMM &$'' K(DK{{  GNN2KK((6KK((7 &&w'<'<'>?  "  !$.%$7ZLRE D '55-466? ?  !*c**(\ 5?AZ &$*?*??$ZJA !?@@$=(=(= 5tG+   As%AM,/M,9M>M>, M;:M;cg)NFrrRs r rKBaseServer.is_asyncio_basedrsrc /SQ$)N)eventlet gevent_uwsgigevent threadingrr\s r rFBaseServer.async_modesusBBrcf^^TTR;a [S5eUU4SjnUcU$U"U5 g)a9Register 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&>UTRT'U$N)r2)handlereventrRs r set_handler"BaseServer.on..set_handlers#*DMM% NrN) event_namesrM)rRrhrgris`` r on BaseServer.onxs8> (( (_- -  ? GrcJURU5R(aS$S$)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)rRsids r rXBaseServer.transports"#..s3<<{K)Krc,URS"U0UD6$)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. queuerGrRargsrTs r create_queueBaseServer.create_queue{{7#T4V44rc URS$)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_emptyrur\s r get_queue_empty_exception$BaseServer.get_queue_empty_exceptions{{=))rc,URS"U0UD6$)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. rhrurvs r create_eventBaseServer.create_eventrzrc [R"[R"S5URR SS5-5nURS-S-UlUR S5RSS5RS S 5$) zGenerate a unique session id. bigriutf-8/_+-)base64 b64encodesecrets token_bytessequence_numberto_bytesdecodereplace)rRids r generate_idBaseServer.generate_idsz       #d&:&:&C&CAu&M MO $ 4 4q 8HDyy!))#s3;;CEErcURSS5S-U-nUR5HAupEUS:XaM [U5(aU"5nUSLa USU-- nM3USU-S-U-- nMC U$)zGenerate the sid cookie.nameio=Tz; )getitemscallable)rRrq attributesr- attributevalues r _generate_sid_cookieBaseServer._generate_sid_cookies-3c9 * 0 0 2 IF"}$**$*S0588!3 rcUR(a&URU5R(dUS:Xa/$URScUR SS5 /$S/$)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*rorprG_log_error_once)rRrqrXs r _upgradesBaseServer._upgradessb""d&6&6s&;&D&D[(I ;;{ # +  @  I}rcURUnUR(aURU [S5eU$![a [S5ef=f)z-Return the socket object for a given session.zSession not foundzSession is disconnected)r1KeyErrorclosed)rRrqss r roBaseServer._get_socketsX 0 S!A 88 S!45 5  0./ / 0s <AcUb?Uc/nUS/- nSU[R"US9RUS9RS5S.$SS/SS.$) z$Generate a successful HTTP response.) Content-Typeztext/plain; charset=UTF-8z200 OK)packets) jsonp_indexrstatusheadersresponserz text/plainsOK)rPayloadencode)rRrrrs r _okBaseServer._okss   EF FG&& ' @ G G$/!H!117B B ' >? %' 'rcUcSn[RRRU5nSS/UR S5S.$)z+Generate a bad request HTTP error response.z Bad Requestz400 BAD REQUESTrrrrr9r:dumpsrrRr s r _bad_requestBaseServer._bad_requestsE ?#G--$$**73+:;#NN735 5rcSS/SS.$)z0Generate a method not found HTTP error response.z405 METHOD NOT FOUNDrsMethod Not Foundrrr\s r _method_not_foundBaseServer._method_not_found s0:;/1 1rcUcSn[RRRU5nSS/UR S5S.$)z,Generate a unauthorized HTTP error response. Unauthorizedz401 UNAUTHORIZED)rzapplication/jsonrrrrs r _unauthorizedBaseServer._unauthorizedsE ?$G--$$**73,@A#NN735 5rc NURc/nSU;aSU;aURSRUSUSS95 SU;dSU;aURSUS5R S5SR 5nURSRX1RSUS5R S5SR 5S95 U$URS :XaSnU$[ UR[5(aUR/nU$[UR5(a3URS 5nURXA5nU(aU/nU$/nU$S UR;aSnU$URnU$![a URU5nNOf=f) Nzwsgi.url_scheme HTTP_HOSTz{scheme}://{host})schemehostHTTP_X_FORWARDED_PROTOHTTP_X_FORWARDED_HOST,r* HTTP_ORIGIN) r.appendformatrsplitstripr%rNr TypeError)rRenvironallowed_originsrorigin is_alloweds r _cors_allowed_origins BaseServer._cors_allowed_originss  $ $ , O G+ w0F&&':'A'A"#45 -(B(/0,w6/7:$[[0 12449E#JqBBG%'$**+>+E+E%KK3#K0-227% #3%%&-(). ,F,12*! & &# -"O113 7 7#889Od// 0 0[[/F ?!66vG +5vhO  ;=O  d///"&#'";"; ?!66v>  ?sFF$#F$cUR/:Xa/$/nURU5nSU;aUb USU;aSUS4/nUSS:XaUS/- nSU;a USUS4/- nUR(aUS/- nU$) 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/)rRrrrs r _cors_headersBaseServer._cors_headers?s  $ $ *I44W= G # (GM,B -!5w}7MNOG # $ 1 NO OG 0G ; 7 EFHI IG  DE EGrc[R"5n[R"USS9nUR U5 SSS5 UR 5$!,(df  UR 5$=f)z%Apply gzip compression to a response.w)fileobjrVN)rBytesIOr GzipFilewritegetvalue)rRrbytesiogzs r _gzipBaseServer._gzipSsU**, ]]7 5 HHX 6!!6 5!!s A A2c.[R"U5$)z(Apply deflate compression to a response.)zlibcompress)rRrs r _deflateBaseServer._deflateZs}}X&&rcX R;a:URRUS-5 URRU5 gURR U5 g)zOLog 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)r4r<erroraddrQ)rRr message_keys r rBaseServer._log_error_once^sW 33 3 KK  g)@@ A  ! ! % %k 2 KK  W %r)rGr*r0rHr,r-r.r/r2r+r4r<r)r'r(r$rr8r7r1r6rP)Ni@BTTiNNTFNTNNrf)NNN) rrrrcompression_methodsrkrOr5rr!rYrKrFrlrXrxr}rrrrrorrrrrrrrrrrrr rrs!9-6K!;/#O , ,HJ>B>B37;?GK MH^C(TL5*5F    '51 5!F("'&rr) rr rIrr?rrrr getLoggerr=rrrr rs=   ""#45W&W&r