/JfA5ZddlZddlZddlZddlZddlmZddlmZejZ dej vr3e ee ej dej ddZe=eeejs+ejded ej d=eje neje ddlZddlZdd lmZdd lmZdd lmZmZdd lmZddlmZm Z ddl!m"Z"ddl#m$Z$ddl%m&Z&ej'e(Z)GddZ*dS)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 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)selfrr r#r$r%r(r,r-r&r'r0r)r*r+r1r.r/r3r4s P/home/alex/cs2snipeproduction/venv/lib/python3.11/site-packages/daphne/server.py__init__zServer.__init__0s,'"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)autoPingTimeoutallowNullOriginopenHandshakeTimeoutrcdSN)_s r:zServer.run..os4r<F)redirectStandardIO discardBufferzHTTP/2 support enabledzEHTTP/2 support not enabled (install the http2 and tls Twisted extras)rzConfiguring endpoint %sbeforeshutdown)installSignalHandlers)+ connectionsr http_factoryrr4 ws_factorysetProtocolOptionsr'r.r1rbeginLoggingTor__name__r H2_ENABLEDr5infor callLaterapplication_checkertimeout_checkerr r strlisten addCallbacklisten_success addErrback listen_errorr!appendasyncioset_event_loop_asyncioEventloopget_event_loop set_debugaddSystemEventTriggerkill_all_applicationsr2r3runr#)r9socket_descriptioneplisteners r:rfz Server.runasg'--*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'       r<ctd||dS)NzListen failure: %s)r5criticalgetErrorMessagestop)r9failures r:r]zServer.listen_errors4,g.E.E.G.GHHH r<cVtjrtjdSd|_dS)z) Force-stops the server. TN)r runningrrr2)r9s r:rrz Server.stops+ ? $ LNNNNN#D   r<cv||jvrtd|zdtji|j|<dS)z: Adds a protocol as a current connection. z)Protocol %r was added to main list twice! connectedN)rM RuntimeErrortimer9protocols r:protocol_connectedzServer.protocol_connectedsD t' ' 'JXUVV V&149;;%?"""r<cjd|j|vr#tj|j|d<dSdS)N disconnected)rMryrzs r:protocol_disconnectedzServer.protocol_disconnecteds= !1(!; ; ;9=D X &~ 6 6 6 < ;r<c^d|j|vsJtj}|dddi|||jt |j|}||jvrdStj|tj |j|d<|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.0)scopereceivesendN)loop) rMr_Queue setdefaultrgetr handle_reply ensure_futurerb)r9r{r input_queuers r:create_applicationzServer.create_applications&T-=h-GGGGGmoo  )U!3444#//O*H55 0   4+ + +4=D=R '))> > > "#9:r<cK||jvs!|j|ddrdS ||n&#t$r|dddwxYw||dS)zP Coroutine that jumps the reply message from asyncio to Twisted r~Nis Server Errorz Server Error)rMrcheck_headers_type ValueError basic_errorr)r9r{messages r:rzServer.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 r:rzServer.check_headers_typesv"777 FKK 2..  DAqa''  KRR477 a''  LSS477   r<c^t|jD]j\}}|dd}|dd}|rrt j|z |jkrS|rQ|s=td|t|| |r|r | }|r^t|tr|nQtd|||s||n#t"t$jf$rYnwxYw|j|d=d}|s |r|j|=lt'jd|jdS)z Goes through the set of current application Futures and cleans up any that are done/prints exceptions for any that errored. r~NrzTApplication instance %r for connection %s took too long to shut down and was killed.z Exception inside application: %s)exc_infor)listrMitemsrryr/doner5warningreprcancel exceptionrKeyboardInterruptrrr6handle_exceptionr r_r rUrV)r9r{detailsr~rrs r:rVzServer.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$EE21E2cg}|jD]G}|d}|s)|||Ht dt|tj tj |}| d|S)zG Kills all application coroutines before reactor exit. rz'Killed %i pending application instancescdSrCrD)xs r:rFz.Server.kill_all_applications..Es4r<)rMvaluesrrr^r5rTlenr Deferred fromFuturer_gatherr\)r9wait_forrr wait_deferreds r:rezServer.kill_all_applications7s '..00 6 6G#*+A#B ',,.. 6$++--- 4555 =s8}}MMM11'.(2KLL   000r<ct|jD]}|t jd|jdS)z~ Called periodically to enforce timeout rules on all connections. Also checks pings at the same time. rN)rrMkeyscheck_timeoutsr rUrWrzs r:rWzServer.timeout_checkerHs[ T-224455 & &H  # # % % % %!T122222r<cF|jr||||dSdS)zN Dispatches to any registered action logger, if there is one. N)r$)r9r{actionrs r: log_actionzServer.log_actionQs7   :   x 9 9 9 9 9 : :r<)NTNNrrrrrrNNNrrrNr)rR __module__ __qualname__r;rfr[r]rrr|rrr staticmethodrrVrerWrrDr<r:rr/s; "$'+$(%)$%"$)////b5D5D5Dn   $$$@@@EEE4'''$\&.7.7.7`"333:::::r<r)+r_osr7warningsconcurrent.futuresrtwisted.internetrnew_event_loop twisted_loopenvironset_default_executorintmodulesrcurrent_reactorrAsyncioSelectorReactorwarn UserWarninginstallloggingryr functoolsr r r twisted.internet.endpointsr twisted.loggerrr twisted.webr http_protocolr ws_protocolr getLoggerrRr5rrDr<r:rs4 111111++++++&w%'' RZ%%ss2:n+E'F'FGGG+//"