h(@SSKrSSKrSSKrSSKJr SSKJrJr SSKJ r SSK J r SSK J r SSKJr SS KJrJr \R&"\5r"S S \ R,5r\"\ 5"S S \ R055rg)N)unquote)inlineCallbacks maybeDeferred)IProtocolNegotiationFactory)ProtocolWrapper)http) implementer)HEADER_NAME_REparse_x_forwarded_forc\rSrSrSrSR SS5R SS5R SS5R S S5rS r\S 5r S r S r Sr Sr SrSrSrSrSrSrSrg) WebRequestz Request that either hands off information to channels, or offloads to a WebSocket class. Does some extra processing over the normal Twisted Web request to separate GET and POST out. a %(title)s

%(title)s

%(body)s

 z  z z ctSUlSUl[RR"U/UQ70UD6 UR R RUlSUlSUl URRU5 g![a* [R[R"55 ef=f)NF) client_addr server_addrrRequest__init__channelfactoryserverapplication_queue_response_startedprotocol_connected Exceptionloggererror traceback format_exc)selfargskwargss XC:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\daphne/http_protocol.pyrWebRequest.__init__4s  LL ! !$ 8 8 8,,..55DK%)D "%*D " KK * *4 0  LL--/ 0  s A2B4B7c## [R"5UlURR5H5up[R "U5(aM"UR SSS5 g SnURRS5(aURRS5Sn[URS5(a[URS5(at[URR5URR/Ul[URR5URR/UlUR!5(aSOS UlUR$R&(aw[)URUR$R&UR$R*UR$R,URUR"5uUlUlUR.R1S 5 S UlSUR6;a@UR6R9SS5SUlUR4R1S 5 U(GaUR;5S:XGaUR$R<R?UR@RC55nU(d6URES5 [FRIS5 URK5 UR4Ul&UR@SsoPl [OU[P5(aXEl)OXEl*URWU5 URXS-UR6-S-nURR5H%nXgSS-SR[US5-S-- nM' US- nX`R\R_5- nURaU5 [FRcSUR5 UR$ReU5 URfRhRk5 g/Ul6UR$RnUl7URR5HvupSU;aM UHcn UR;5S:Xa![qU R1S 55Ul7M8URlRsUR;5U 45 Me Mx [FRcSURXUR5 UR\RuSS5 [wUR$RxUS URzR9S 5SR1S 5URXR1S 5[qUR.R1S 55UR.URnUR"UR4URlURURS. 5vUl>UR|bUR\R~(agUR$Rn UR\R_U 5n [U 5U :+n SU U S .n UR|RU 5 U (dgMU![2a S UlUR SSS 5 gf=f![2a UR SSS5 gf=f![a> [FR[R"55 UR SS!S"5 gf=f7f)#Nis Bad RequestzInvalid header namesUpgraderhostporthttpsrascii/zInvalid characters in path?r zInvalid query strings websocketz!Could not make WebSocket protocol s HTTP/1.1 s: ,s z#Upgraded connection %s to WebSocket_sdaphne-root-pathzHTTP %s request for %s) type http_versionmethodpathraw_path root_pathscheme query_stringheadersclientrz http.request)r5body more_bodyInternal Server ErrorzDaphne HTTP processing error)Gtime request_startrequestHeadersgetAllRawHeadersr fullmatch basic_error hasHeader getRawHeadershasattrr>strr)r*rrisSecure client_schemerproxy_forwarded_address_headerr proxy_forwarded_port_headerproxy_forwarded_proto_headerr8decodeUnicodeDecodeErrorr<urisplitlower ws_factory buildProtocol transportgetPeersetResponseCoderwarnfinish_raw_query_string isinstancerwrappedProtocolprotocolmakeConnectionr7joincontentread dataReceiveddebugprotocol_disconnectedr_networkProducerresumeProducing clean_headersr:rappendseekrcreate_application clientprotorclosedrequest_buffer_sizelen put_nowaitrr r!r")r#name_upgrade_headerr`rXdatahvaluesvalue buffer_sizechunkr@payloads r&processWebRequest.processDsM !%D  ..??A%//55$$S.:OPB "N"",,Z88!%!4!4!B!B:!Nq!Qt{{F++ V0L0L%( (8(8$94;;;K;K#L $' $7#H ,0MMOOD {{997L''KK>>KK;;KK<<$$&& 84 $"4    ) !$D txx$(HHNN4$;A$>!%%,,W5 ."6"6"8L"H;;11??NN**, ((-KK CDKKM-1->->*,0NND) >i9908-)1&'' 2{{T)DHH47KK,,==?AaD5L499QqT?:[HHD@ # ))++%%d+ BDDTDTU 11$7 --==? &("!%!6!6$($7$7$H$H$JLDt| !'::<+>>-4U\\'5J-KDN ..55tzz|U6KL "( %K 5t{{DDTDTU !!!Q'/<KK22 &(,(8(8(>(>t(DR(H(O(O#)#'++"4"4W"= ' (8(8(A B$(II%)^^"&"4"4(,(9(9#'#5#5"&"2"2"&"2"20*&*))1T\\5H5H"kk==  LL--k:E%(Z+ >I . %%.G **55g>$u&     n6RS *$$S.:PQx  LL--/ 0   -/M  s]*A\\.]*/F\ [';\#[<>G!\]* H\%]*&A)\]*\$[96\7]*8[99\<\\]*\\A]'$]*&]'']*cUR(aUR5 [RSUR5 [ R RX5 URRU5 g)# Cleans up reply channel on close. zHTTP disconnect for %sN) rsend_disconnectrrfrrrconnectionLostrrg)r#reasons r&rWebRequest.connectionLostsR  ! !  " -t/?/?@ ##D1 ))$/r.cUR(aUR5 [RSUR5 [ R RU5 URRU5 g)rzHTTP close for %sN) rrrrfrrrr\rrgr#s r&r\WebRequest.finishsR  ! !  " ($*:*:; D! ))$/r.c JUR(d URcgSU;a [S5eUSS:XGaUR(a [S5eSUlSU;a [S5eUR US5 UR S 05H up#UR RX#5 M" URR(aTUR RS 5(d4URS URRR55 [RS USUR5 gUSS :XGa`UR(d[SUS-5e[ R"R%XR SS55 UR SS5(dUR'5 [RSUR5 UR(R+S5nURR1SSUUR2UR4R+SS5UR(aS[7UR5-OSUR95UR:S.5 g[RSUR5 g[SUS-5e![,a [/UR(5nNf=f![<a+ [R?[@RB"55 gf=f)z! Handles a reply from the client Nr5zMessage has no type definedhttp.response.startz&HTTP response has already been startedTstatusz time_takensizezHTTP response chunk for %szCannot handle message type %s!)"finishedr ValueErrorrrZgetresponseHeaders addRawHeaderr server_namerH setHeaderencoderrfrrrwriter\rSrQrRrepr log_actioncoder7tupleduration sentLengthrr r!r")r#messageheaderryrSs r& handle_replyWebRequest.handle_replys ==DLL0   :; ; 6?3 3%% !IJJ%)D "w& R  !2 3!(Y!; $$11&@"<{{&&t/C/C/M/Mh/W/Wy$++*A*A*H*H*JK LL1783DdFVFV V_ 4 4)) Gfo& LL  t[[%= >;;{E22  N>NO)((//'2C9KK**"$'&*ii&*kk&8&8)&L$(#3#3!(%0@0@*A A%)*.--/$(OO & 94;K;KL=OP P3*)txx.C)(!9LL!5!5!789s%0K B K-K*)K*-2L"!L"c*URSSS5 g)z6 Called by the server when our application tracebacks r0rAzException inside application.N)rG)r# exceptions r&handle_exceptionWebRequest.handle_exception1s 68WXr.c"URR(atUR5URR:aKUR(a&[R S5 UR 5 gURSSS5 ggg)z; Called periodically to see if we should timeout something z,Application timed out while sending responseisService Unavailablez0Application failed to respond within time limit.N)r http_timeoutrrrwarningr\rGrs r&check_timeoutsWebRequest.check_timeouts7sg ;; # # $++:R:R(R%%MN   *F )S #r.cbUR(aURRSS05 gg)zG Sends a http.disconnect message. Useful only really for long-polling. r5zhttp.disconnectN)r8rrrrs r&rWebRequest.send_disconnectIs* 99  " " - -v7H.I J r.cj[US5(dg[R"5UR- $)z2 Returns the time since the start of the request. rCr)rJrBrCrs r&rWebRequest.durationRs+t_--yy{T////r.cURSUS/S.5 URSUR[U5S-URS5-US.-R S5S .5 g ) z6 Responds with a server-level error page (very basic) r)s Content-Typestext/html; charset=utf-8)r5rr=rrr,)titler?utf8)r5r?N)rerror_templaterKrQr)r#r status_textr?s r&rGWebRequest.basic_errorZsx - JK   ,''!$Vs!2[5G5G5P!P $ &.  r.c*[[U55$N)hashidrs r&__hash__WebRequest.__hash__rsBtH~r.c0[U5[U5:H$r)r)r#others r&__eq__WebRequest.__eq__us$x2e9$$r.) rrrjrrMr8r<rCr:rrrXN)__name__ __module__ __qualname____firstlineno____doc__rrrrr}rr\rrrrrrGrr__static_attributes__r.r&rrs "  "      s /4  NN`00DQLY $K0 0%r.rc*\rSrSrSrSrSrSrSrg) HTTPFactoryiyz Factory which takes care of tracking which protocol instances or request instances are responsible for which named response channels, so incoming messages can be routed appropriately. cN[RRU5 Xlgr)rrrr)r#rs r&rHTTPFactory.__init__s !!$' r.c[RRX5n[UlU$![ a- [ RS[R"5-5 ef=f)zr Builds protocol instances. This override is used to ensure we use our own Request object instead of the default. zCannot build protocol: %s) rrrWrrequestFactoryrrr r!r")r#addrr`s r&rWHTTPFactory.buildProtocolsW  ''55dAH&0H #O  LL4y7K7K7MM N  s +.7A%cZS/n[R(aURSS5 U$)a Protocols this server can speak after ALPN negotiation. Currently that is HTTP/1.1 and optionally HTTP/2. Websockets cannot be negotiated using ALPN, so that doesn't go here: anyone wanting websockets will negotiate HTTP/1.1 and then do the upgrade dance. shttp/1.1rsh2)r H2_ENABLEDinsert)r# baseProtocolss r&acceptableProtocolsHTTPFactory.acceptableProtocolss(% ??  E *r.)rN) rrrrrrrWrrrr.r&rrys  r.r)loggingrBr! urllib.parsertwisted.internet.deferrrtwisted.internet.interfacesrtwisted.protocols.policiesr twisted.webrzope.interfacer utilsr r getLoggerrrrrrrr.r&rsm  AC6&8   8 $e%e%P  ()&$""&*&r.