o >hA5@sHddlZddlZddlZddlZddlmZddlmZeZ dej vr2e ee ej ddej ddZedurUeeejsTejdedd ej d=ee nee ddlZddlZdd lmZdd lmZdd lmZmZdd lmZddlmZm Z ddl!m"Z"ddl#m$Z$ddl%m&Z&e'e(Z)GdddZ*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)WebSocketFactoryc@seZdZ                d(d d ZddZddZddZddZddZddZ ddZ ddZ e ddZ d d!Zd"d#Zd$d%Zd&d'ZdS))ServerNT Qr daphnecCs||_|pg|_g|_g|_||_||_||_| |_| |_||_ | |_ | |_ ||_ ||_ ||_||_||_| |_||_d|_||_||_|jsStdtddSdS)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)selfrrr r!r"r%r)r*r#r$r-r&r'r(r.r+r,r0r1r7m/var/www/vedio/testing/chatpythonscript.ninositsolution.com/env/lib/python3.10/site-packages/daphne/server.py__init__0s4  zServer.__init__cCsTi|_t||_t||jd|_|jj|jd|jd|j dkr,t j ddgdddnt t t gtjr=td ntd td|jtd |j|jD]'}td |ttt|}||j}||j||j|j|qSt !tj"|j d krt #$dt%dd|j&|j's|j(r|(tj)|j*ddSdS)N)serverT)autoPingTimeoutallowNullOriginopenHandshakeTimeoutrcSdSNr7)_r7r7r8ozServer.run..F)redirectStandardIO discardBufferzHTTP/2 support enabledzEHTTP/2 support not enabled (install the http2 and tls Twisted extras)rzConfiguring endpoint %sbeforeshutdown)installSignalHandlers)+ connectionsr http_factoryrr1 ws_factorysetProtocolOptionsr$r+r.rbeginLoggingTor __name__r H2_ENABLEDr2infor callLaterapplication_checkertimeout_checkerrr strlisten addCallbacklisten_success addErrback listen_errorrappendasyncioset_event_loop_asyncioEventloopget_event_loop set_debugaddSystemEventTriggerkill_all_applicationsr/r0runr )r6socket_descriptioneplistenerr7r7r8rbasH           z Server.runcCsdt|dr,|}t|dr.t|dr0|j|j|jftd|j|jdSdSdSdS)z_ Called when a listen succeeds so we can store port details (if there are any) getHosthostportzListening on TCP address %s:%sN)hasattrrfrrZrgrhr2rP)r6rhrgr7r7r8rWs zServer.listen_successcCstd||dS)NzListen failure: %s)r2criticalgetErrorMessagestop)r6failurer7r7r8rYs zServer.listen_errorcCstjr tdSd|_dS)z) Force-stops the server. TN)r runningrlr/)r6r7r7r8rls  z Server.stopcCs,||jvr td|dti|j|<dS)z: Adds a protocol as a current connection. z)Protocol %r was added to main list twice! connectedN)rI RuntimeErrortimer6protocolr7r7r8protocol_connecteds  zServer.protocol_connectedcCs(d|j|vrt|j|d<dSdS)N disconnected)rIrqrrr7r7r8protocol_disconnectedszServer.protocol_disconnectedcCsrd|j|vs Jt}|dddi|j||jt|j|d}||jvr)dStj|t d|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) rIr[Queue setdefaultrgetr handle_reply ensure_futurer^)r6rsrz input_queuerwr7r7r8create_applications  zServer.create_applicationcs^||jvs|j|ddrdSz||Wnty'|dddw||dS)zP Coroutine that jumps the reply message from asyncio to Twisted ruNis Server Errorz Server Error)rIrcheck_headers_type ValueError basic_errorr)r6rsmessager7r7r8rs zServer.handle_replycCsf|ddksdS|dgD]"\}}t|ts!td|t|t|ts0td|t|qdS)Ntypezhttp.response.startheadersz5Header name '{}' expected to be `bytes`, but got `{}`z6Header value '{}' expected to be `bytes`, but got `{}`)r isinstancebytesrformatr)rkvr7r7r8rs"   zServer.check_headers_typec Cst|jD]r\}}|dd}|dd}|r5t||jkr5|r5|s5td|t || |rq|rqz| }Wn t t j fyMYnw|rit|trZ|ntjd||d|si|||j|d=d}|sy|ry|j|=qtd|jdS)z Goes through the set of current application Futures and cleans up any that are done/prints exceptions for any that errored. ruNrwzTApplication instance %r for connection %s took too long to shut down and was killed.z Exception inside application: %s)exc_infor)listrIitemsrrqr,doner2warningreprcancel exceptionrr[rKeyboardInterruptrlr3handle_exceptionr rQrR)r6rsdetailsrurwrr7r7r8rRsF         zServer.application_checkercCsjg}|jD]}|d}|s|||qtdt|tj t j |}| dd|S)zG Kills all application coroutines before reactor exit. rwz'Killed %i pending application instancescSr>r?r7)xr7r7r8rAErBz.Server.kill_all_applications..)rIvaluesrrrZr2rPlenr Deferred fromFuturer[gatherrX)r6wait_forrrw wait_deferredr7r7r8ra7s zServer.kill_all_applicationscCs.t|jD]}|qtd|jdS)z~ Called periodically to enforce timeout rules on all connections. Also checks pings at the same time. rN)rrIkeyscheck_timeoutsr rQrSrrr7r7r8rSHs zServer.timeout_checkercCs|jr ||||dSdS)zN Dispatches to any registered action logger, if there is one. N)r!)r6rsactionrr7r7r8 log_actionQszServer.log_action)NTNNrrrrrrNNNrrrNr)rN __module__ __qualname__r9rbrWrYrlrtrvrr staticmethodrrRrarSrr7r7r7r8r/sD 17   0 r)+r[osr4warningsconcurrent.futuresrtwisted.internetrnew_event_loop twisted_loopenvironset_default_executorintmodulesrcurrent_reactorrAsyncioSelectorReactorwarn UserWarninginstallloggingrqr functoolsr r r twisted.internet.endpointsr twisted.loggerr r twisted.webr http_protocolr ws_protocolr getLoggerrNr2rr7r7r7r8sF