h(@ddlZddlZddlZddlmZddlmZmZddlm Z ddl m Z ddl m Z ddlmZdd lmZmZej&eZGd d e j,Zee Gd d e j0Zy)N)unquote)inlineCallbacks maybeDeferred)IProtocolNegotiationFactory)ProtocolWrapper)http) implementer)HEADER_NAME_REparse_x_forwarded_forceZdZdZdj ddj ddj ddj ddZd Zed Zd Z d Z d Z dZ dZ dZdZdZdZdZy) 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 cnd|_d|_ tjj|g|i||j j j|_d|_d|_ |jj|y#t$r)tjtjwxYw)NF) client_addr server_addrrRequest__init__channelfactoryserverapplication_queue_response_startedprotocol_connected Exceptionloggererror traceback format_exc)selfargskwargss P/var/www/Befach/backend/env/lib/python3.12/site-packages/daphne/http_protocol.pyrzWebRequest.__init__4s  LL ! !$ 8 8 8,,..55DK%)D "%*D " KK * *4 0  LL--/ 0  s A1B2B4c#HK tj|_|jjD]/\}}t j |r|j dddyd}|jjdr|jjdd}t|jdrt|jdrtt|jj|jjg|_t|jj|jjg|_|j!rdnd |_|j$j&rwt)|j|j$j&|j$j*|j$j,|j|j"\|_|_ |j.j1d d |_d|j6vr@|j6j9ddd|_ |j4j1d |r|j;dk(r|j$j<j?|j@jC}|s6|jEdtFjId|jK|j4|_&|j@dc}|_ tO|tPr||_)n||_*|jW||jXdz|j6zdz}|jjD]%}||ddzdj[|dzdzz }'|dz }||j\j_z }|ja|tFjcd|j|j$je||jfjhjkyg|_6|j$jn|_7|jjD]o\}}d|vr |D]`} |j;dk(r tq| j1d |_76|jljs|j;| fbqtFjcd|jX|j|j\juddtw|j$jx|d |jzj9d dj1d |jXj1d tq|j.j1d |j.|jn|j"|j4|jl|j|jd |_>|j||j\j~ry|j$j} |j\j_| } t| | k } d| | d } |j|j| | syO#t2$rd |_|j ddd YywxYw#t2$r|j dddYywxYw#t$r=tFjtj|j dd!d"YywxYww)#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)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%//5$$S.:OPB "N"",,Z8!%!4!4!B!B:!Nq!Qt{{F+ V0L%( (8(8$94;;;K;K#L $' $7#H ,0MMOD {{997L''KK>>KK;;KK<<$$&& 84 $"4    ) !$D txx$(HHNN4$;A$>!%%,,W5 ."6"6"8L"H;;11??NN**, ((-KK CDKKM-1->->*,0NND) 4>i908I-)1I&'' 2{{T)DHH47KK,,==?AAaD5L499QqT?:[HHD@ # ))++%%d+ BDDTDTU 11$7 --==? &("!%!6!6$($7$7$H$H$JLD&t| !'::<+>>-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[+Z9[Z7G[/\"0G7['\"(A$[ \" [#Z41[2\"3Z44[7[[\"[[A\\"\\"c|jr|jtjd|jt j j|||jj|y)3 Cleans up reply channel on close. zHTTP disconnect for %sN) rsend_disconnectrrdrrrconnectionLostrre)r"reasons r%rzWebRequest.connectionLostsT  ! !  " -t/?/?@ ##D&1 ))$/r,c|jr|jtjd|jt j j||jj|y)r}zHTTP close for %sN) rr~rrdrrrrZrrer"s r%rZzWebRequest.finishsR  ! !  " ($*:*:; D! ))$/r,c |js |jyd|vr td|ddk(r|jr tdd|_d|vr td|j |d|j d iD]!\}}|j j||#|jjrO|j jd s4|jd |jjjtjd |d|jy|dd k(rR|jstd|dzt j"j%||j dd|j dds|j'tjd|j |j(j+d} |jj1dd||j2|j4j+dd|jrdt7|jznd|j9|j:dytjd|jytd|dz#t,$rt/|j(}YwxYw#t<$r*tj?tAjBYywxYw)z1 Handles a reply from the client Nr3zMessage has no type definedhttp.response.startz&HTTP response has already been startedTstatuszFzHTTP 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_replys ==DLL0   :; ; 6?3 3%% !IJJ%)D "w& R  !2 3!(Y!; $$11&%@"<{{&&t/C/C/M/Mh/Wy$++*A*A*H*H*JK LL1783DdFVFV V_ 4 4)) Gfo& LL  tW[[%= >;;{E2  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% J(BKK?K0K65K6c*|jdddy)zF Called by the server when our application tracebacks r.r?zException inside application.N)rE)r" exceptions r%handle_exceptionzWebRequest.handle_exception1s 68WXr,c |jjrn|j|jjkDrF|jr&tj d|j y|jdddyyy)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_timeouts7sg ;; # # $++:R:R(R%%MN   *F )S #r,cX|jr|jjddiyy)z_ Sends a http.disconnect message. Useful only really for long-polling. r3zhttp.disconnectN)r6rrprs r%r~zWebRequest.send_disconnectIs* 99  " " - -v7H.I J r,c^t|dsytj|jz S)zB Returns the time since the start of the request. rAr)rHr@rArs r%rzWebRequest.durationRs(t_-yy{T////r,c|jd|dgd|jd|jt|dz|jdz|dzj dd y ) 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_errorZsx - JK   ,''!$Vs!2[5G5G5P!P $ &.  r,c*tt|SN)hashidrs r%__hash__zWebRequest.__hash__rsBtH~r,c0t|t|k(Sr)r)r"others r%__eq__zWebRequest.__eq__us$x2e9$$r,N)__name__ __module__ __qualname____doc__rrrrr{rrZrrrr~rrErrr,r%rrs "  "      s /4  NN`00DQLY $K0 0%r,rc"eZdZdZdZdZdZy) 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. cPtjj|||_yr)rrrr)r"rs r%rzHTTPFactory.__init__s !!$' r,c tjj||}t|_|S#t $r,t jdtjzwxYw)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.buildProtocolsY  ''55dDAH&0H #O  LL4y7K7K7MM N  s ,/5A$cPdg}tjr|jdd|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.acceptableProtocolss(% ??  E *r,N)rrrrrrUrrr,r%rrys  r,r)loggingr@r urllib.parsertwisted.internet.deferrrtwisted.internet.interfacesrtwisted.protocols.policiesr twisted.webrzope.interfacer utilsr r getLoggerrrrrrrr,r%rso  AC6&8   8 $e%e%P  ()&$""&*&r,