hA5pddlZddlZddlZddlZddlmZddlmZejZ dejvr+e jee ejdejjddZeHeeej"sGej$ded ejd=ej(e nej(e ddlZddlZdd lmZdd lmZdd lmZmZdd lmZddlmZm Z ddl!m"Z"ddl#m$Z$ddl%m&Z&ejNe(Z)GddZ*y)N)ThreadPoolExecutor)asyncioreactor ASGI_THREADS) max_workersztwisted.internet.reactorzSomething has already installed a non-asyncio Twisted reactor. Attempting to uninstall it; you can fix this warning by importing daphne.server early in your codebase or finding the package that imports Twisted and importing it later on.) stacklevel)CancelledError)partial)deferreactor)serverFromString)STDLibLogObserverglobalLogBeginner)http) HTTPFactory)WebSocketFactoryceZdZ ddZdZdZdZdZdZdZ d Z d Z e d Z d Zd ZdZdZy)ServerNc||_|xsg|_g|_g|_||_||_||_| |_| |_||_ | |_ | |_ ||_ ||_ ||_||_||_| |_||_d|_||_||_|js+t,j/dt1j2dyy)NFz6No endpoints. This server will not listen on anything.r) application endpoints listenerslistening_addressessignal_handlers action_logger http_timeout ping_interval ping_timeoutrequest_buffer_sizeproxy_forwarded_address_headerproxy_forwarded_port_headerproxy_forwarded_proto_headerwebsocket_timeoutwebsocket_connect_timeoutwebsocket_handshake_timeoutapplication_close_timeout root_path verbosity abort_startready_callable server_nameloggererrorsysexit)selfrrrrrr r$r%rrr(r!r"r#r)r&r'r+r,s I/var/www/Befach/backend/env/lib/python3.12/site-packages/daphne/server.py__init__zServer.__init__0s,'"b#% .*(*(#6 .L++F(,H)!2)B&+F()B&"" ,&~~ LLQ R HHQKc4i|_t||_t||j|_|j j |jd|j|jdkrtjdgddn#tjttgtjrt j#dnt j#d t%j&d|j(t%j&d |j*|j,D]}t j#d |t/t$t1|}|j3|j}|j5|j6|j9|j:|j<j?|tAjBt$jD|jd k\r#tAjFjIdt%jJd d|jL|jNs=|jPr|jQt%jR|jTyy)N)serverT)autoPingTimeoutallowNullOriginopenHandshakeTimeoutrcyN)_s r2zServer.run..os4r4F)redirectStandardIO discardBufferzHTTP/2 support enabledzEHTTP/2 support not enabled (install the http2 and tls Twisted extras)rzConfiguring endpoint %sbeforeshutdown)installSignalHandlers)+ connectionsr http_factoryrr, ws_factorysetProtocolOptionsrr&r)rbeginLoggingTor__name__r H2_ENABLEDr-infor callLaterapplication_checkertimeout_checkerrr strlisten addCallbacklisten_success addErrback listen_errorrappendasyncioset_event_loop_asyncioEventloopget_event_loop set_debugaddSystemEventTriggerkill_all_applicationsr*r+runr)r1socket_descriptioneplisteners r2r^z Server.runas'-*48H8HI ** -- !%!A!A + >>Q   , , U$   , ,.?.I-J K ?? KK0 1 KKW  !T556!T112"&..  KK13E F!'3/A+BCByy!2!23H  !4!4 5    1 1 2 NN ! !( + #1 w889 >>Q   " " $ . .t 4%%h DDtV$v)>((//DII0FG 4LLN''LLN''*?$ $r4cltjd|j|jy)NzListen failure: %s)r-criticalgetErrorMessagestop)r1failures r2rUzServer.listen_errors#,g.E.E.GH r4c\tjrtjyd|_y)z) Force-stops the server. TN)r runningrjr*)r1s r2rjz Server.stops ?? LLN#D r4c||jvrtd|zdtji|j|<y)z: Adds a protocol as a current connection. z)Protocol %r was added to main list twice! connectedN)rE RuntimeErrortimer1protocols r2protocol_connectedzServer.protocol_connecteds> t'' 'JXUV V&1499;%?"r4cpd|j|vr%tj|j|d<yy)N disconnected)rErqrrs r2protocol_disconnectedzServer.protocol_disconnecteds7 !1!1(!; ;9=D  X &~ 6 "#9:r4cK||jvs|j|jddry |j||j |y#t$r|j dddwxYww)zP Coroutine that jumps the reply message from asyncio to Twisted rvNis Server Errorz Server Error)rErcheck_headers_type ValueError basic_errorr)r1rsmessages r2rzServer.handle_replys 4++ +t/?/?/I/M/M D0     # #G , g&    o~ F  s/A6AA6A33A6c |ddk(sy|jdgD]m\}}t|ts$tdj |t |t|trKtdj |t |y)Ntypezhttp.response.startheadersz5Header name '{}' expected to be `bytes`, but got `{}`z6Header value '{}' expected to be `bytes`, but got `{}`)r isinstancebytesrformatr)rkvs r2rzServer.check_headers_typesv"77 KK 2.DAqa' KRR47 a' LSS47/r4c&t|jjD]+\}}|jdd}|jdd}|rft j|z |j kDrB|r@|j s0tjd|t||j|r|j rr |j}|rMt|tr|jn,tjd|||s|j!| |j|d=d}|r|s|j|=.t'j(d|j*y#t"t$j"f$rYfwxYw)z Goes through the set of current application Futures and cleans up any that are done/prints exceptions for any that errored. rvNryzTApplication instance %r for connection %s took too long to shut down and was killed.z Exception inside application: %s)exc_infor)listrEitemsrrqr'doner-warningreprcancel exceptionrKeyboardInterruptrjr.handle_exceptionr rWr rMrN)r1rsdetailsrvryrs r2rNzServer.application_checkersm "&d&6&6&<&<&>!? Hg";;~t > @I !%i1BC IIK"LL B ))2) $0 ( 9 9) D$$X./EF'+$'L$$X.Q"@R !T556+'(>(>?s E44FFcvg}|jjD]9}|d}|jr|j|j |;t j dt|tjjtj|}|jd|S)zG Kills all application coroutines before reactor exit. ryz'Killed %i pending application instancescyr;r<)xs r2r>z.Server.kill_all_applications..Es4r4)rEvaluesrrrVr-rLlenr Deferred fromFuturerWgatherrT)r1wait_forrry wait_deferreds r2r]zServer.kill_all_applications7s ''..0G#*+A#B ',,.$++- 45 1  =s8}M11'..(2KL   0r4ct|jjD]}|jt j d|j y)z~ Called periodically to enforce timeout rules on all connections. Also checks pings at the same time. rN)rrEkeyscheck_timeoutsr rMrOrrs r2rOzServer.timeout_checkerHsD T--2245H  # # %6!T112r4cD|jr|j|||yy)zN Dispatches to any registered action logger, if there is one. N)r)r1rsactionrs r2 log_actionzServer.log_actionQs$      x 9 r4)NTNNi iQrNNNr Ndaphne)rJ __module__ __qualname__r3r^rSrUrjrtrwrr staticmethodrrNr]rOrr<r4r2rr/s "$'+$(%)$%"$)/b5Dn $@E4'$&.7`"3:r4r)+rWosr/warningsconcurrent.futuresrtwisted.internetrnew_event_loop twisted_loopenvironset_default_executorintmodulesrcurrent_reactorrAsyncioSelectorReactorwarn UserWarninginstallloggingrqr functoolsr r r twisted.internet.endpointsr twisted.loggerrr twisted.webr http_protocolr ws_protocolr getLoggerrJr-rr<r4r2rs  1+&w%%' RZZ%%s2::n+E'FG++//"