z g>ddlZddlZddlZddlmZddlmZmZddlm Z ddl m Z ddl m Z ddlmZdd lmZejeZGd d e jZee Gd d e jZdS)N)unquote)inlineCallbacks maybeDeferred)IProtocolNegotiationFactory)ProtocolWrapper)http) implementer)parse_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 c, tjj|g|Ri||jjj|_d|_d|_|j|dS#t$r-t tj wxYw)NF)rRequest__init__channelfactoryserverapplication_queue_response_startedprotocol_connected Exceptionloggererror traceback format_exc)selfargskwargss F/var/www/html/env/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 AA7Bc# K tj|_d}|jdr |jdd}t |jdrjt |jdrUt|jj|jj g|_ t|jj|jj g|_ nd|_ d|_ | rdnd|_ |jjrNt!|j|jj|jj|jj|j |j \|_ |_ |jdn/#t*$r"d|_|d d d YdSwxYwd |_d |jvrj|jd dd|_ |jdn(#t*$r|d d dYdSwxYw|r|dkr|jj|j}|sC|dt@!d|"|j|_#|jdc}|_tI|tJr||_&n||_'|(||j)dz|jzdz}|j*D]/}||ddzd+|dzdzz }0|dz }||j,-z }|.|t@/d|j |j0||j1j23dSg|_4|jj5|_5|j*D]}\}}d|vr |D]p}|dkr(tm|d|_5B|j47||fq~t@/d|j)|j |j,8ddts|jj:|d|j;ddd|j)dtm|jd|j|j5|j |j|j4|j |j d V|_<|j< |j,j=rdS|jj>} |j,-| } t| | k } d| | d } |j<@| | sdSS#t$rFt@BtjD|dd!d"YdSwxYw)#NsUpgraderhostporthttpsrascii/is Bad RequestzInvalid 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)r0body more_bodyInternal Server ErrorzDaphne HTTP processing error)Etime request_startrequestHeaders hasHeader getRawHeadershasattrr9strr$r% client_addr server_addrisSecure client_schemerproxy_forwarded_address_headerr proxy_forwarded_port_headerproxy_forwarded_proto_headerr3decodeUnicodeDecodeError basic_errorr7urisplitlower ws_factory buildProtocol transportgetPeersetResponseCoderwarnfinish_raw_query_string isinstancerwrappedProtocolprotocolmakeConnectionr2getAllRawHeadersjoincontentread dataReceiveddebugprotocol_disconnectedr_networkProducerresumeProducing clean_headersr5rappendseekrcreate_application clientprotorclosedrequest_buffer_sizelen put_nowaitrrrr) rupgrade_headerr[rSdatahnamevaluesvalue buffer_sizechunkr;payloads r"processzWebRequest.processBsI !%D !N",,Z88 R!%!4!B!B:!N!Nq!Qt{F++ ( V0L0L (%( (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       spEXE87X8(F$ X#F$$9XG98X9!HXHGX:GX>AXXA Y.-Y.c|jr|td|jt j|||j |dS)3 Cleans up reply channel on close. zHTTP disconnect for %sN) rsend_disconnectrrbrDrrconnectionLostrrc)rreasons r"r|zWebRequest.connectionLostsm  ! #  " " " -t/?@@@ ##D&111 ))$/////r)c|jr|td|jt j||j |dS)rzzHTTP close for %sN) rr{rrbrDrrrWrrcrs r"rWzWebRequest.finishsk  ! #  " " " ($*:;;; D!!! ))$/////r)c .|js|jdSd|vrtd|ddkr |jrtdd|_d|vrtd||d|d iD] \}}|j||!|jj rU|jj d kr3| d |jj d td |d|jdS|ddkr|jstd|dzt j||dd|dds)|td|j |jd}n$#t,$rt/|j}YnwxYw |jdd||j|jdd|jrdt7|jznd||jddS#t<$r/ttAj!YdSwxYwtd|jdStd|dz)z1 Handles a reply from the client Nr0zMessage has no type definedhttp.response.startz&HTTP response has already been startedTstatusz > >;;{E22 M  NOOO)(//'22CC))))tx..CCC)9K**"$'&*i&*k&8&8)&L&L#/'&gd6F0G0G&G&G!%*.--//$(O       !999LL!5!7!78888889 94;KLLLLL=OPP Ps%)HH%$H%)A6J!!5KKc4|ddddS)zF Called by the server when our application tracebacks r+r<zException inside application.N)rM)r exceptions r"handle_exceptionzWebRequest.handle_exception)s$ 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_timeoutrrrwarningrWrMrs r"check_timeoutszWebRequest.check_timeouts/s ; #  $+:R(R(R% MNNN   *F  (R(Rr)cP|jr|jddidSdS)z_ Sends a http.disconnect message. Useful only really for long-polling. r0zhttp.disconnectN)r3rrnrs r"r{zWebRequest.send_disconnectAs> 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. r>r)rBr=r>rs r"rzWebRequest.durationJs/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)r0rr8rrr')titler:utf8)r0r:N)rerror_templaterCrKr)rr status_textr:s r"rMzWebRequest.basic_errorRs - JK      ,'!$Vs!2[5G5G5P5P!P $ &..   r)c:tt|SN)hashidrs r"__hash__zWebRequest.__hash__jsBtHH~~r)cBt|t|kSr)r)rothers r"__eq__zWebRequest.__eq__ms$xx2e99$$r)N)__name__ __module__ __qualname____doc__rrrrrxr|rWrrrr{rrMrrr)r"r r s> "  "         s  /4   JJ_JX000000BQBQBQHYYY $KKK000   0%%%%%r)r c$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)rrs r"rzHTTPFactory.__init__zs$ !!$''' 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) rrrRr requestFactoryrrrrr)raddrr[s r"rRzHTTPFactory.buildProtocol~sk  '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)rrrrrrRrrr)r"rrqsK        r)r)loggingr=r urllib.parsertwisted.internet.deferrrtwisted.internet.interfacesrtwisted.protocols.policiesr twisted.webrzope.interfacer utilsr getLoggerrrrr rrr)r"rs=  AAAAAAAACCCCCC666666&&&&&&((((((  8 $ $]%]%]%]%]%]%]%]%@   ())&&&&&$"&&*)&&&r)