/Jf(@ddlZddlZddlZddlmZddlmZmZddlm Z ddl m Z ddl m Z ddlmZdd lmZmZejeZGd d e jZee Gd d e jZdS)N)unquote)inlineCallbacks maybeDeferred)IProtocolNegotiationFactory)ProtocolWrapper)http) implementer)HEADER_NAME_REparse_x_forwarded_forceZdZdZdddddddddZd Zed Zd Z d Z d Z dZ dZ dZdZdZdZdZdS) 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 cHd|_d|_ tjj|g|Ri||jjj|_d|_d|_ |j |dS#t$r-t tjwxYw)NF) client_addr server_addrrRequest__init__channelfactoryserverapplication_queue_response_startedprotocol_connected Exceptionloggererror traceback format_exc)selfargskwargss W/home/alex/cs2snipeproduction/venv/lib/python3.11/site-packages/daphne/http_protocol.pyrzWebRequest.__init__4s  L !$ 8 8 8 8 8 8 8,.5DK%)D "%*D " K * *4 0 0 0 0 0    LL-// 0 0 0  s AA**7B!c#^ K tj|_|jD]3\}}t j|s|ddddS4d}|jdr |jdd}t|j drit|j drTt|j j |j j g|_t|j j |j j g|_|rdnd |_|jjrNt)|j|jj|jj|jj|j|j\|_|_ |jd n/#t2$r"d |_|ddd YdSwxYwd |_d|jvrj|jddd|_ |jd n(#t2$r|dddYdSwxYw|r|dkr|jj|j !}|sC|"dtF$d|%|j|_&|j dc}|_ tO|tPr||_)n||_*|+||j,dz|jzdz}|jD]/}||ddzd-|dzdzz }0|dz }||j./z }|0|tF1d|j|j2||j3j45dSg|_6|jj7|_7|jD]}\}}d|vr |D]p} |dkr(tq| d |_7B|j69|| fq~tF1d|j,|j|j.:ddtw|jj<|d |j=d dd |j,d tq|jd |j|j7|j|j|j6|j|jd V|_>|j> |j.j?rdS|jj@} |j./| } t| | k } d | | d!} |j>B| | sdSS#t$rFtFDtjF|dd"d#YdSwxYw)$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_stringheadersclientrTz http.request)r3body 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_headerr6decodeUnicodeDecodeErrorr:urisplitlower ws_factory buildProtocol transportgetPeersetResponseCoderwarnfinish_raw_query_string isinstancerwrappedProtocolprotocolmakeConnectionr5joincontentread dataReceiveddebugprotocol_disconnectedr_networkProducerresumeProducing clean_headersr8rappendseekrcreate_application clientprotorclosedrequest_buffer_sizelen put_nowaitrrr r!)r"name_upgrade_headerr^rVdatahvaluesvalue buffer_sizechunkr>payloads r%processzWebRequest.processDsM !%D  .??AA  a%/55$$S.:OPPPFF "N",,Z88 R!%!4!B!B:!N!Nq!Qt{F++ I V0L0L I%( (8$9$94;;K#L $' $7$7#H ,0MMOO!GD {9 7L'K>K;K<$& 884 $"4    ))))%       n6RSSS  !$D tx$(HNN4$;$;A$>!%,,W5555)$$S.:PQQQFFV ."6"6"8"8L"H"H;1??N**,, "((---KK CDDDKKMMM-1->*,0ND) 4>i99208I--)1I&'' 222{T)DH47KK,==??IIAAaD5L499QqT??:[HHDD # ))+++%%d+++ BDDTUUU 11$777 -==????? &("!%!6$($7$H$H$J$JMMLD&t|| !'MM::<<+>>>-4U\\'5J5J-K-KDNN .55tzz||U6KLLLL M  5t{DDTUUU !!!Q'''/<K2 &(,(8(>(>t(D(DR(H(O(O#))#'+"4"4W"="= ' (8(8(A(A B B$(I%)^"&"4(,(9#'#5"&"2"&"200**&*)1T\5H1F"k=   L--k::E%(ZZ+%= >I . %%.G *55g>>>$     LL-// 0 0 0   -/M       swA"Y(D2YF65Y6(G"Y!G""9YH76Y7!IYIGY8GYFzHTTP response complete for %sr*rcompletereplacez%s:%s)r6rr5r< time_takensizezHTTP response chunk for %szCannot handle message type %s!)"finishedr ValueErrorrrXgetresponseHeaders addRawHeaderr server_namerF setHeaderencoderrdrrrwriterZrQrOrPrepr log_actioncoder5tupleduration sentLengthrrr r!)r"messageheaderrwrQs r% handle_replyzWebRequest.handle_replysH = DL0 F  :;; ; 6?3 3 3% K !IJJJ%)D "w&& R  !2 3 3 3!(Y!;!; A A $11&%@@@@{& Lt/C/M/Mh/W/W Ly$+*A*H*H*J*JKKK LL1783DdFV     V_ 4 4 4)  Gfo& L  tW[[%=%= > > >;;{E22 M  NOOO)(//'22CC))))tx..CCC)9K**"$'&*i&*k&8&8)&L&L$(#3!*%0@*A*A A A%)*.--//$(O   !999LL!5!7!78888889 94;KLLLLL=OPP Ps% G;;HH A6J5KKc4|ddddS)zF Called by the server when our application tracebacks r.r?zException inside application.N)rE)r" exceptions r%handle_exceptionzWebRequest.handle_exception1s$ 68WXXXXXr,c|jjrr||jjkrR|jr0td|dS|ddddSdSdS)zK 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_timeoutrrrwarningrZrErs r%check_timeoutszWebRequest.check_timeouts7s ; #  $+:R(R(R% MNNN   *F  (R(Rr,cP|jr|jddidSdS)z_ Sends a http.disconnect message. Useful only really for long-polling. r3zhttp.disconnectN)r6rrprs r%r~zWebRequest.send_disconnectIs> 9 K  " - -v7H.I J J J J J K Kr,c\t|dsdStj|jz S)zB Returns the time since the start of the request. rAr)rHr@rArs r%rzWebRequest.durationRs/t_-- 1y{{T///r,c|d|dgd|d|jt|dz|dz|dzdd d S) zF Responds with a server-level error page (very basic) r)s Content-Typestext/html; charset=utf-8)r3rr;rrr*)titler=utf8)r3r=N)rerror_templaterIrOr)r"r status_textr=s r%rEzWebRequest.basic_errorZs - JK      ,'!$Vs!2[5G5G5P5P!P $ &..   r,c:tt|SN)hashidrs r%__hash__zWebRequest.__hash__rsBtHH~~r,cBt|t|kSr)r)r"others r%__eq__zWebRequest.__eq__us$xx2e99$$r,N)__name__ __module__ __qualname____doc__rrrrr{rrZrrrr~rrErrr,r%rrs> "  "         s  /4    NN_N`000000DQDQDQLYYY $KKK000   0%%%%%r,rc$eZdZdZdZdZdZdS) HTTPFactoryz 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. cRtj|||_dSr)rrrr)r"rs r%rzHTTPFactory.__init__s$ !!$''' r,c tj||}t|_|S#t $r0t dtj zwxYw)z Builds protocol instances. This override is used to ensure we use our own Request object instead of the default. zCannot build protocol: %s) rrrUrrequestFactoryrrrr r!)r"addrr^s r%rUzHTTPFactory.buildProtocolsk  '55dDAAH&0H #O    LL4y7K7M7MM N N N  s -0:A*cPdg}tjr|dd|S)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%acceptableProtocolszHTTPFactory.acceptableProtocolss1% ? +  E * * *r,N)rrrrrrUrrr,r%rrysK        r,r)loggingr@r urllib.parsertwisted.internet.deferrrtwisted.internet.interfacesrtwisted.protocols.policiesr twisted.webrzope.interfacer utilsr r getLoggerrrrrrrr,r%rsC  AAAAAAAACCCCCC666666&&&&&&88888888  8 $ $e%e%e%e%e%e%e%e%P   ())&&&&&$"&&*)&&&r,