o iA5@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)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@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)selfrrrr r!r$r(r)r"r#r,r%r&r'r-r*r+r/r0r6SC:\Users\psant\Downloads\PAF backend\school\venv\Lib\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)ZautoPingTimeoutZallowNullOriginZopenHandshakeTimeoutrcSdSNr6)_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_descriptioneplistenerr6r6r7rSasH           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)hasattrrVrrMrWrXr1rD)r5rXrWr6r6r7rJs zServer.listen_successcCstd||dS)NzListen failure: %s)r1criticalZgetErrorMessagestop)r5Zfailurer6r6r7rLs zServer.listen_errorcCstjr tdSd|_dS)z) Force-stops the server. TN)r runningr[r.)r5r6r6r7r[s  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)rB RuntimeErrortimer5protocolr6r6r7protocol_connecteds  zServer.protocol_connectedcCs(d|j|vrt|j|d<dSdS)N disconnected)rBr_r`r6r6r7protocol_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_instanceZasgiversionz3.0)scopeZreceivesendN)loop) rBrNQueue setdefaultrgetr handle_reply ensure_futurerP)r5rargZ input_queuerer6r6r7create_applications  zServer.create_applicationcs^||jvs|j|ddrdSz||Wnty'|dddw||dS)zP Coroutine that jumps the reply message from asyncio to Twisted rcNis Server Errorz Server Error)rBrlcheck_headers_type ValueErrorZ basic_errorrm)r5ramessager6r6r7rms 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 `{}`)rl isinstancebytesrqformatrs)rrkvr6r6r7rps"   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. rcNrezTApplication instance %r for connection %s took too long to shut down and was killed.z Exception inside application: %s)exc_infor)listrBitemsrlr_r+doner1warningreprcancel exceptionrrNruKeyboardInterruptr[r2Zhandle_exceptionr rErF)r5radetailsrcrerr6r6r7rFsH         zServer.application_checkercCsjg}|jD]}|d}|s|||qtdt|tj t j |}| dd|S)zG Kills all application coroutines before reactor exit. rez'Killed %i pending application instancescSr:r;r6)xr6r6r7r=Er>z.Server.kill_all_applications..N)rBvaluesr}rrMr1rDlenr ZDeferredZ fromFuturerNgatherrK)r5wait_forrreZ wait_deferredr6r6r7rR7s 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{rBkeysZcheck_timeoutsr rErGr`r6r6r7rGHs zServer.timeout_checkercCs|jr ||||dSdS)zN Dispatches to any registered action logger, if there is one. N)r )r5raactionrr6r6r7 log_actionQszServer.log_action)NTNNrrrrrrNNNrrrNr)rC __module__ __qualname__r8rSrJrLr[rbrdrorm staticmethodrprFrRrGrr6r6r6r7r/sD 17   0 r)+rNosr3warningsconcurrent.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 getLoggerrCr1rr6r6r6r7sF