z gp4ddlZddlZddlZddlmZejZejddZ e ;e e ej s)ej de ejd=ejenejeddlZddlZddlmZddlmZmZddlmZddlmZmZdd lmZd d lmZd d lmZej e!Z"Gd de#Z$dS)N)asyncioreactorztwisted.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.)CancelledError)deferreactor)serverFromString)STDLibLogObserverglobalLogBeginner)http) HTTPFactory)WebSocketFactoryceZdZ dd Zd ZdZdZdZdZdZ dZ dZ e dZ dZdZdZdZdS)ServerNT Qr  Daphnec||_|pg|_g|_g|_||_||_||_| |_| |_||_ | |_ | |_ ||_ ||_ ||_||_||_| |_||_d|_||_||_|js0t,dt1jddSdS)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'r r!r*r#r$r%r+r(r)r-r. ws_protocolss ?/var/www/html/env/lib/python3.11/site-packages/daphne/server.py__init__zServer.__init__&s0'"b#% .*(*(#6 .L++F(,H)!2)B&+F()B&"" ,&~  LLQ R R R HQKKKKK  ci|_t||_t||j|_|j|jd|j|j dkrtj dgddn'tj ttgtjrt dnt d t%jd|jt%jd |j|jD]}t d |t/t$t1|}||j}||j||j|j|tAj!t$j"|j d kr&tAj#$dt%j%d d|j&|j's7|j(r|(t%j)|j*dSdS)N)serverT)autoPingTimeoutallowNullOriginopenHandshakeTimeoutr cdSN)_s r5zServer.run..gs4r7F)redirectStandardIO discardBufferzHTTP/2 support enabledzEHTTP/2 support not enabled (install the http2 and tls Twisted extras)zConfiguring endpoint %sbeforeshutdown)installSignalHandlers)+ connectionsr http_factoryr r. ws_factorysetProtocolOptionsr!r(r+r beginLoggingTor__name__r H2_ENABLEDr/infor callLaterapplication_checkertimeout_checkerrrstrlisten addCallbacklisten_success addErrback listen_errorrappendasyncioset_event_loop_asyncioEventloopget_event_loop set_debugaddSystemEventTriggerkill_all_applicationsr,r-runr)r3socket_descriptioneplisteners r5rbz Server.runYsg'--*48HIII ** - !%!A +   >Q    , U$       ,.?.I.I-J K K K ?  KK0 1 1 1 1 KKW    !T5666!T1222"&. , ,  KK13E F F F!'3/A+B+BCCByy!233H  !4 5 5 5    1 2 2 2 N ! !( + + + + w8999 >Q    " $ $ . .t 4 4 4%h D>DtV$$ v)>)> (//DI0FGGG 4LLNN'LLNN'       r7ctd||dS)NzListen failure: %s)r/criticalgetErrorMessagestop)r3failures r5rYzServer.listen_errors4,g.E.E.G.GHHH r7cVtjrtjdSd|_dS)z) Force-stops the server. TN)rrunningrnr,)r3s r5rnz Server.stops+ ? $ LNNNNN#D   r7cv||jvrtd|zdtji|j|<dS)z: Adds a protocol as a current connection. z)Protocol %r was added to main list twice! connectedN)rI RuntimeErrortimer3protocols r5protocol_connectedzServer.protocol_connectedsD t' ' 'JXUVV V&149;;%?"""r7cjd|j|vr#tj|j|d<dSdS)N disconnected)rIrurvs r5protocol_disconnectedzServer.protocol_disconnecteds= !1(!; ; ;9=D X &~ 6 6 6 < ;r7cDdjvsJtj}|dddi||jfd}jvrdStj|tjjd<|S) a Creates a new application instance that fronts a Protocol instance for one of our supported protocols. Pass it the protocol, and it will work out the type, supply appropriate callables, and return you the application's input queue application_instanceasgiversionz3.0c0|Sr>) handle_reply)messagerwr3s r5rAz+Server.create_application..s!2!28W!E!Er7)scopereceivesendN)loop)rIr[Queue setdefaultrget ensure_futurer^)r3rwr input_queuer}s`` r5create_applicationzServer.create_applications&T-=h-GGGGGmoo  )U!3444#//OEEEEE 0   4+ + +4=D=R '))> > > "#9:r7cK||jvs!|j|ddrdS ||n&#t$r|dddwxYw||dS)zP Coroutine that jumps the reply message from asyncio to Twisted rzNis Server Errorz Server Error)rIrcheck_headers_type ValueError basic_errorr)r3rwrs r5rzServer.handle_replys 4+ + +t/?/I/M/M D0 0 + F   # #G , , , ,     o~ F F F   g&&&&&s A#A)c n|ddksdS|dgD]\}}t|ts0td|t |t|ts0td|t |dS)Ntypezhttp.response.startheadersz5Header name '{}' expected to be `bytes`, but got `{}`z6Header value '{}' expected to be `bytes`, but got `{}`)r isinstancebytesrformatr)rkvs r5rzServer.check_headers_typesv"777 FKK 2..  DAqa''  KRR477 a''  LSS477   r7cFt|jD]^\}}|dd}|dd}|rrt j|z |jkrS|rQ|s=td|t|| |r|r | }|r^t|tr|nEtd|||s||n#t"$rYnwxYw|j|d=d}|s |r|j|=`t%jd|jdS)z Goes through the set of current application Futures and cleans up any that are done/prints exceptions for any that errored. rzNr}zTApplication instance %r for connection %s took too long to shut down and was killed.z Exception inside application: %s)exc_infor )listrIitemsrrur)doner/warningreprcancel exceptionrKeyboardInterruptrnr0handle_exceptionrrrQrR)r3rwdetailsrzr}rs r5rRzServer.application_checkers "&d&6&<&<&>&>!?!?( /( / Hg";;~t< > @ @I ! E%i1BCC E IIKKKK"LL B ))2) $0E ( 9 9) D D D&D $X./EF'+$' /L /$X.!T566666s$E E&%E&cg}|jD]G}|d}|s)|||Ht dt|tj tj |}| d|S)zG Kills all application coroutines before reactor exit. r}z'Killed %i pending application instancescdSr>r?)xs r5rAz.Server.kill_all_applications..=s4r7)rIvaluesrrrZr/rPlenrDeferred fromFuturer[gatherrX)r3wait_forrr} wait_deferreds r5razServer.kill_all_applications/s '..00 6 6G#*+A#B ',,.. 6$++--- 4555 =s8}}MMM11'.(2KLL   000r7ct|jD]}|t jd|jdS)z~ Called periodically to enforce timeout rules on all connections. Also checks pings at the same time. rDN)rrIkeyscheck_timeoutsrrQrSrvs r5rSzServer.timeout_checker@s[ T-224455 & &H  # # % % % %!T122222r7cF|jr||||dSdS)zN Dispatches to any registered action logger, if there is one. N)r)r3rwactionrs r5 log_actionzServer.log_actionIs7   :   x 9 9 9 9 9 : :r7)NTNNrrrrrrNNNr rrNrN)rN __module__ __qualname__r6rbrWrYrnrxr{rr staticmethodrrRrarSrr?r7r5rr%s> "$'+$(%)$%"$-1111f5D5D5Dn   $$$@@@EEE4'''$\&.7.7.7`"333:::::r7r)%r[r1warningstwisted.internetrnew_event_loop twisted_loopmodulesrcurrent_reactorrAsyncioSelectorReactorwarn UserWarninginstallloggingruconcurrent.futuresrrrtwisted.internet.endpointsrtwisted.loggerrr twisted.webr http_protocolr ws_protocolr getLoggerrNr/objectrr?r7r5rs ++++++%w%'' +//"