U u]jA5@sHddlZddlZddlZddlZddlmZddlmZeZ dej krde ee ej ddej ddZedk reeejsejdedd ej d=ee n ee ddlZddlZdd lmZdd lmZdd lmZmZdd lmZddlmZm Z ddl!m"Z"ddl#m$Z$ddl%m&Z&e'e(Z)GdddZ*dS)N)ThreadPoolExecutor)asyncioreactorZ 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@seZdZd(d d ZddZddZddZddZddZddZ ddZ ddZ e ddZ d d!Zd"d#Zd$d%Zd&d'ZdS))ServerNT Qr daphnecCs||_|p g|_g|_g|_||_||_||_| |_| |_||_ | |_ | |_ ||_ ||_ ||_||_||_| |_||_d|_||_||_|jstdtddS)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)selfrrrr r!r$r(r)r"r#r,r%r&r'r-r*r+r/r0r6Vc:\users\psant\downloads\hotstarbackend\school\venv\Lib\site-packages\daphne/server.py__init__0s2  zServer.__init__cCsVi|_t||_t||jd|_|jj|jd|jd|j dkrXt j ddgdddnt t t gtjrztd n td td|jtd |j|jD]N}td |ttt|}||j}||j||j|j|qt !tj"|j d krt #$dt%dd|j&|j'sR|j(rD|(tj)|j*ddS)N)serverT)ZautoPingTimeoutZallowNullOriginZopenHandshakeTimeoutrcSsdSNr6)_r6r6r7ozServer.run..F)ZredirectStandardIOZ discardBufferzHTTP/2 support enabledzEHTTP/2 support not enabled (install the http2 and tls Twisted extras)rzConfiguring endpoint %sbeforeshutdown)ZinstallSignalHandlers)+ connectionsrZ http_factoryrr0Z ws_factoryZsetProtocolOptionsr#r*r-r ZbeginLoggingTor __name__rZ H2_ENABLEDr1infor callLaterapplication_checkertimeout_checkerrr strlistenZ addCallbacklisten_success addErrback listen_errorrappendasyncioset_event_loopZ_asyncioEventloopget_event_loop set_debugZaddSystemEventTriggerkill_all_applicationsr.r/runr)r5Zsocket_descriptioneplistenerr6r6r7rRasJ          z Server.runcCsXt|drT|}t|drTt|drT|j|j|jftd|j|jdS)z_ Called when a listen succeeds so we can store port details (if there are any) getHosthostportzListening on TCP address %s:%sN)hasattrrUrrLrVrWr1rC)r5rWrVr6r6r7rIs zServer.listen_successcCstd||dS)NzListen failure: %s)r1criticalZgetErrorMessagestop)r5Zfailurer6r6r7rKszServer.listen_errorcCstjrtnd|_dS)z) Force-stops the server. TN)r runningrZr.)r5r6r6r7rZs z Server.stopcCs,||jkrtd|dti|j|<dS)z: Adds a protocol as a current connection. z)Protocol %r was added to main list twice! connectedN)rA RuntimeErrortimer5protocolr6r6r7protocol_connecteds  zServer.protocol_connectedcCs$d|j|kr t|j|d<dS)N disconnected)rAr^r_r6r6r7protocol_disconnectedszServer.protocol_disconnectedcCsrd|j|kstt}|dddi|j||jt|j|d}||jkrRdStj |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_instanceZasgiversionz3.0)scopeZreceivesendN)loop) rAAssertionErrorrMQueue setdefaultrgetr handle_reply ensure_futurerO)r5r`rfZ input_queuerdr6r6r7create_applications  zServer.create_applicationcsb||jks|j|ddr dSz||Wn$tk rR|dddYnX||dS)zP Coroutine that jumps the reply message from asyncio to Twisted rbNis Server Errorz Server Error)rArlcheck_headers_type ValueErrorZ basic_errorrm)r5r`messager6r6r7rmszServer.handle_replycCsf|ddksdS|dgD]D\}}t|tsBtd|t|t|tstd|t|qdS)Ntypezhttp.response.startheadersz5Header name '{}' expected to be `bytes`, but got `{}`z6Header value '{}' expected to be `bytes`, but got `{}`)rl isinstancebytesrqformatrs)rrkvr6r6r7rps"   zServer.check_headers_typec Cst|jD]\}}|dd}|dd}|rjt||jkrj|rj|sjtd|t || |r|rz | }Wnt t j fk rYn8X|rt|tr|ntjd||d|s|||j|d=d}|s|r|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. rbNrdzTApplication instance %r for connection %s took too long to shut down and was killed.z Exception inside application: %s)exc_infor)listrAitemsrlr^r+doner1warningreprcancel exceptionrrMruKeyboardInterruptrZr2Zhandle_exceptionr rDrE)r5r`detailsrbrdrr6r6r7rEsD          zServer.application_checkercCsjg}|jD]&}|d}|s|||qtdt|tj t j |}| dd|S)zG Kills all application coroutines before reactor exit. rdz'Killed %i pending application instancescSsdSr:r6)xr6r6r7r<Er=z.Server.kill_all_applications..)rAvaluesr}rrLr1rClenr ZDeferredZ fromFuturerMgatherrJ)r5wait_forrrdZ wait_deferredr6r6r7rQ7s 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)r{rAkeysZcheck_timeoutsr rDrFr_r6r6r7rFHs zServer.timeout_checkercCs|jr||||dS)zN Dispatches to any registered action logger, if there is one. N)r )r5r`actionrr6r6r7 log_actionQszServer.log_action)NTNNrrrrrrNNNrrrNr)rB __module__ __qualname__r8rRrIrKrZrarcrorm staticmethodrprErQrFrr6r6r6r7r/sB 17   0 r)+rMosr3warningsconcurrent.futuresrZtwisted.internetrnew_event_loopZ twisted_loopenvironset_default_executorintmodulesrlZcurrent_reactorruZAsyncioSelectorReactorwarn UserWarninginstallloggingr^r functoolsrr r Ztwisted.internet.endpointsr Ztwisted.loggerr r Z twisted.webrZ http_protocolrZ ws_protocolr getLoggerrBr1rr6r6r6r7sB