\ei|dZddlZddlmZddlmZddlmZddlmZddl m Z ddl m Z Gd d Z Gd d ejZy) z ASGI protocol handler for gunicorn. Implements asyncio.Protocol to handle HTTP/1.x and HTTP/2 connections and dispatch to ASGI applications. N)datetime) AsyncUnreader) AsyncRequest)AsyncUWSGIRequest) NoMoreData)UWSGIParseExceptionceZdZdZdZy)ASGIResponseInfoz;Simple container for ASGI response info for access logging.c||_||_g|_|D]d\}}t|tr|j d}t|tr|j d}|jj ||ffy)Nlatin-1)statussentheaders isinstancebytesdecodeappend)selfr rrnamevalues L/var/www/ceduoda/envi/lib/python3.12/site-packages/gunicorn/asgi/protocol.py__init__zASGIResponseInfo.__init__sp   " /KD%$&{{9-%' Y/ LL  u .  /N)__name__ __module__ __qualname____doc__rrrr r s E /rr ceZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZddZdZdZdZdZdZdZdZy) ASGIProtocolzHTTP/1.1 protocol handler for ASGI applications. Handles connection lifecycle, request parsing, and ASGI app invocation. c||_|j|_|j|_|j|_d|_d|_d|_d|_d|_ d|_ y)NrF) workercfglogasgiapp transportreaderwriter_task req_count_closed)rr"s rrzASGIProtocol.__init__,sV ::::;;    rc||_|jxjdz c_|jd}|rut |dri|j }|dk(rTt j|_|jjj|j|||_ yt j|_||_ |jjj|j|_ y)z(Called when a connection is established. ssl_objectselected_alpn_protocolh2N)r'r"nr_connsget_extra_infohasattrr0asyncio StreamReaderr(loop create_task_handle_http2_connectionr*r)_handle_connection)rr'r/alpns rconnection_madezASGIProtocol.connection_made;s" !--l; '*.FG446Dt|&224 ![[--9911)ZH **,  [[%%11$2I2I2KL rcT|jr|jj|yy)z/Called when data is received on the connection.N)r( feed_data)rdatas r data_receivedzASGIProtocol.data_receivedUs ;; KK ! !$ ' rc d|_|jxjdzc_|jr|jj |j r6|j j s|j jyyy)z-Called when the connection is lost or closed.Tr.N)r,r"r2r(feed_eofr*donecancel)rexcs rconnection_lostzASGIProtocol.connection_lostZs`  ! ;; KK " ::djjoo/ JJ   0:rcKt|j} |jjd}|jjd}|js|xj dz c_ t |jdd}|dk(r5tj|j|||j d{}n4tj|j|||j d{}|j!|r|j#|||d{n|j%|||d{}|j&xj(dz c_|j&j(|j&j*k\r.|jj-d d |j&_d }|r|j&j.sn=|jj0sn&|j3d{|js|j=y7c71#t$rY"t$rY,t$r&}|jjd|Yd}~Ud}~wwxYw7N757u#t4j6$rYzt8$r&}|jj;d |Yd}~d}~wwxYw#|j=wxYww) z/Main request handling loop for this connection.peernamesocknamer.protocolhttpuwsgiNzuWSGI parse error: %s,Autorestarting worker after current request.FzError handling connection: %s)rr(r'r3r,r+getattrr#rparser StopIterationrrr$debug_is_websocket_upgrade_handle_websocket_handle_http_requestr"nr max_requestsinfoalive keepalive drain_bodyr5CancelledError Exception exception_close_transport)runreaderrHrIrJrequesterYs rr:zASGIProtocol._handle_connectioncs[ -D $~~44Z@H~~44Z@Hll!#&txxVDH7*(9(?(? HH$$ NN )#)5(:(: HH$$ NN )#"--g600(HMMM#'";";Xx#  !#;;>>T[[%=%==HHMM"PQ(-DKK% %I  (9(9xx))((***sll@  ! ! #s## %!*HHNN#:A> N*+%%   C HH  > B B C  ! ! #sKAI42A H&=H >4H&2H#3H&7'I4I,I4:I/;CI4<I2=I4K H&#H&& I)/I41I)9I4;I)I$I4$I))I4/I42I44J7J: J7J2-J:2J77J::K  Kc|jdk7ryd}d}|jD]1\}}|dk(r|j}|dk(s"|j}3|dk(xr|xrd|vS)a Check if request is a WebSocket upgrade. Per RFC 6455 Section 4.1, the opening handshake requires: - HTTP method MUST be GET - Upgrade header MUST be "websocket" (case-insensitive) - Connection header MUST contain "Upgrade" GETFNUPGRADE CONNECTION websocketupgrade)methodrlower)rr`rg connectionrrs rrRz"ASGIProtocol._is_websocket_upgradesv >>U " "?? +KD%y ++-%"[[]  + +%P*Pj9PPrcKddlm}|j|||}||j|j||j |j }|jd{y7w)z!Handle WebSocket upgrade request.r)WebSocketProtocolN)gunicorn.asgi.websocketrl_build_websocket_scoper'r(r&r$run)rr`rIrHrlscope ws_protocols rrSzASGIProtocol._handle_websocketsT=++GXxH' NNDKK$(( oosA!A+#A)$A+c * Kj||}dd d ddgdtj jdk(r*js j ddddd{n%tj j  fd}  f d }j||}d} tj} jjjj|||d{  sjdd d{d tj| z } t'}j"j)||| jj+j||j-ryjj.xrjj0S7t77#t $rj"j%d sjdd d{7dY tj z } t'}j"j)||| jj+j||y#t $rj"j%d YywxYwwxYw#t $rj"j%d YKwxYw# tj z } t'}j"j)||| jj+j||w#t $rj"j%d YwwxYwxYww) zHandle a single HTTP request.FNr http.requestrtypebody more_bodyc@Kjd{S7w)Nget) receive_queuesrreceivez2ASGIProtocol._handle_http_request..receives&**,, ,,s c K|d}|dk(r?|jd}|jdg}j||d{y|dk(rw r tdyd |d |jdg td D}|s jd k\rdt d gz j d{y|d k(r s td y r td y|jdd}|jdd}|r)j|d{ t|z |s rjjdd yyy777;w)Nrvhttp.response.informationalr rhttp.response.startResponse already startedTc3K|]o\}}t|tr|jn|jdk(xs3t|tr|jn|jdk(qyw)scontent-lengthzcontent-lengthN)rstrri).0r_s r zBASGIProtocol._handle_http_request..send..sg) a&0c%:TZZ\ Qbbe(24(= 4::.sendsvH88%kk(3 &{{9b9 ..{L'RRR00##/0J#KL#' ")("3#*;;y"#= &))$4)&"*goo.G"&K'+,<'=Ac@d'd$//AQSZ[[[11'#/0F#GL$#/0K#LL{{63/#KK U; //$ /DDD!SY.M ",,\:(,% !23S.\Es8AE$EA;E$E A"E$&E"'7E$ E$"E$Internal Server ErrorError in ASGI applicationException in post_request hook)_build_http_scoper5Queuecontent_lengthrputr8_read_body_to_queue_build_environrnowr# pre_requestr"r&_send_error_responser\r$r]r access post_request should_closerXrY)rr`rIrHrpr}renvironresp request_start request_timerr|rrrrrrs`` @@@@@@@@rrTz!ASGIProtocol._handle_http_requests<&&w(C !       ! !Q &w##&"%      8 8- P Q -6 -6 -r%%gxB E$LLNM HH g 6((5'40 0 0'""$//5LMMM"% E'||~ = '9I=Ygw E%%dkk7GTJ    !{{  7TXX%7%77U X 1N  HH  : ;#//5LMMM"% E'||~ = '9I=Ygw E%%dkk7GTJ E""#CD E  E""#CD E  E'||~ = '9I=Ygw E%%dkk7GTJ E""#CD EsA)N5G)6ANAG0G,G08G.9G0A*K*AN,G0.G00;K +H.,K 3K95A*J N $KNKN K  K9$K62N5K66N9N;A*M&%N&$N  N N  NNcjK |jdd{}|r|jd|ddd{n|jddddd{yX7C7&7 #t$rD}|jj d||jddddd{7Yd}~yd}~wwxYww) z.Read request body and put chunks on the queue.TiNrtrurFzError reading body: %s) read_bodyrr\r$rQ)rr`queuechunkras rrz ASGIProtocol._read_body_to_queueJs %//66)) . %%)%  )) . #%*% 6    HHNN3Q 7))&"   slB3A#AA#AA#A!A#B3A#A#!A## B0,4B+ B#!B+&B3+B00B3c g}|jD]D\}}|j|jjd|jdfFdddd|jdd|jd|j |j |j|jr|jjdnd |jr|jjdnd |jjxsd ||r|nd |r|nd d }t|jd r|jj|d <t|drd|j|jdi|d<|S)z*Build ASGI HTTP scope from parsed request.r rK3.02.4r spec_versionr.r.rN rvr% http_versionrhschemepathraw_path query_string root_pathrserverclientstatepriority_weighthttp.response.priorityweight depends_on extensions)rrriencoderrhrrqueryr#rr4r"rrpriority_depends_on)rr`rIrHrrrrps rrzASGIProtocol._build_http_scopedsM"?? VKD% NNDJJL// :ELLEO$$U+$$T* sA"A$cK|jd}d|d|dt|d}|jj|jd|jj|yw)zSend an error response.zutf-8z HTTP/1.1 rz, Content-Type: text/plain Content-Length: z Connection: close r N)rrr'r)rr rrwrs rrz!ASGIProtocol._send_error_responsesm~~g&xq *"4yk*   X__Y78 T"sA-A/ciddddddddd d d d d ddddddddddddddddddd d!d"id#d$d%d&d'd(d)d*d+d,d-d.d/d0d1d2d3d4d5d6d7d8d9d:d;d<d=d>d?d@dAdB}|j|dCS)Dz'Get HTTP reason phrase for status code.dContinueezSwitching Protocolsgz Early HintsOKCreatedAcceptedz No ContentzPartial Contenti-zMoved Permanentlyi.Foundi/z See Otheri0z Not Modifiedi3zTemporary Redirecti4zPermanent Redirectiz Bad Requesti Unauthorizedi Forbiddeniz Not FoundizMethod Not AllowedizRequest TimeoutiConflictiGoneizLength RequiredizPayload Too Largeiz URI Too LongizUnsupported Media TypeizUnprocessable EntityizToo Many RequestsrsrizNot Implementediz Bad GatewayizService UnavailableizGateway TimeoutUnknownrz)rr reasonss rrzASGIProtocol._get_reason_phrases" " &"  "   "  "  "  "  ""  $"  "  "  "  %"  %"  " !" " #" $ %" & %'" ( ")" * +" , -" . "/" 0 $1" 2 3" 4 )5" 6 '7" 8 $9" : (;" < "=" > ?" @ &A" B "C" F{{69--rc|jr0|js# |jjd|_yyy#t$rYwxYw)zClose the transport safely.TN)r'r,closer\)rs rr^zASGIProtocol._close_transport.sH >>$,, $$& DL #/>  s> A  A c K ddlm}|jd}|jd}|j}t j |}t j ||||jj}||j|||} | jd{| |_ | js!|jjr | jdd{} | D]D} |j'| | ||d{| j3| j,j.F|jxj4t7| z c_|jj4|jj8k\r-|j"j;d d |j_ n$| js|jjr t?|dr# |jjAd{|jCy7z77#tj$rYt $r&} |j"j%d| Yd} ~ d} ~ wwxYw7_#t $rp} |j"j)d  | j+| j,j.d t1| d{7n#t $rYnwxYwYd} ~ d} ~ wwxYw#| j3| j,j.wxYw#tj<$rYLt $r'} |j"j)d | Yd} ~ vd} ~ wwxYw7T#t $rY^wxYw#t?|dr4 |jjAd{7n#t $rYnwxYw|jCwxYww)zHandle an HTTP/2 connection.r)AsyncHTTP2ConnectionrHrINg?)timeoutzHTTP/2 receive error: %szError handling HTTP/2 requestrsrMFzHTTP/2 connection error: %s_h2_conn)"gunicorn.http2.async_connectionrr3r(r5StreamReaderProtocol StreamWriterr"r7r#initiate_connectionr is_closedrX receive_data TimeoutErrorr\r$rQ_handle_http2_requestr] send_errorstream stream_idrcleanup_streamrUrrVrWr[r4rr^) rr'r/rrHrIr(rJr)h2_connrequestsrareqs rr9z%ASGIProtocol._handle_http2_connection7s0C $ L // ;H // ;H[[F33F;H))8VT[[-=-=F +&&(G--/ / /#DM''DKK,=,=%,%9%9#%9%FFH$EC E"88(H ..szz/C/CDE" #h-/;;>>T[[%=%==HHMM"PQ(-DKK%A''DKK,=,=NtZ(----///  ! ! #c 0 G++ HHNN#=qA %!**+JK!")"4"4 # 4 4c3q6# )! ! ! ..szz/C/CD%%   A HH  :NNNN> N*'N>)N**N>>Oc Kjj|j||}ddddgdgfd}f d}|j||}t j } |j j|j|j|||d{rg} D]Z\} } t| tr| jd} t| tr| jd} | j| | f\rdtfg} | D]/\} } | j| jt| f1j j#| d j$}|j#| d j'd{rIj j)d |j)d j'd{j+d{n:j-| d{nj/dd d{d t j | z }t7t9}|j2j;||||j j=|j||y777777#t0$r>|j2j5d sj/dd d{7dYwxYw#t0$r|j2j5d YywxYw# t j | z }t7t9}|j2j;||||j j=|j||w#t0$r|j2j5d YwwxYwxYww) zHandle a single HTTP/2 request.FNrsrcLKjj}d|ddSw)NrtFru)rwread)rwr`s rr}z3ASGIProtocol._handle_http2_request..receives,<<$$&D&" s!$c K|d}|dk(r|jd}|jdg}g}|D]Z\}}t|tr|jd}t|tr|jd}|j ||f\ j ||d{y|dk(r(r t d yd|d|jdgy|d k(rMs t d  yr t d  y|jd d }|jdd}|r |z |sdyy|dk(rs t d y|jdg} g} | D]Z\}}t|tr|jd}t|tr|jd}| j ||f\j| yy7w)Nrvrr rr rrTrrrrwrrxFhttp.response.trailersz)Cannot send trailers before body complete)r{rrrrsend_informationalrextend)rrrrrrrrwrxtrailer_headerstrailersrr response_bodyrrrrresponse_trailersrs rrz0ASGIProtocol._handle_http2_request..sendsvH88%kk(3 &{{9b9 #/2KD%!$.#{{95!%/ % Y 7NND%=1 2 00KQQQ00##/0J#KL#' ")("3#*;;y"#= 11'#/0F#GL$#/0K#LL{{63/#KK U; !T)M (,%!55(#/0[#\L")++i"<#23KD%!$.#{{95!%/ % Y 7OOT5M2 3 "((269RsB%G (G)DG r z:status) end_streamrrr)rr_build_http2_scope_build_http2_environrrr#rr"r&rrrrrrir send_headersstreams_send_pending_data send_data send_trailers send_responserr\r$r]r rrr)rr`rrIrHrpr}rrrrrr response_hdrsrrrrr+rrrrr,rs `` @@@@@@@@rrz"ASGIProtocol._handle_http2_request~sNN,, ''8D !   ; 3; 3|++GXxH  < E HH g 6((5'40 0 0'"" #32KD%!$.#{{95!%/ % Y 7NND%=1 2%&/_1E%F$GM'.I e%,,djjlCJ-GHIOO00MV[0\$__Y7F'' %'H!44666%11)]W\1]((5(I%88:::"// ;LMMM!//!?G]((C9PQQQ"% E'||~ = '#%5s=7Igw E%%dkk7GTJq 147 ;NR & HH  : ;#((C9PQQQ"%  & E""#CD E E'||~ = '#%5s=7Igw E%%dkk7GTJ E""#CD EsA1O>>K'K'K'!K'#K'%K''MO>O;A3OO;$O85O;7O88O;;O>c g}|jD]D\}}|j|jjd|jdfFddddd|j|j |j |j r|j jdnd|jr|jjdnd|jjxsd||r|nd |r|nd d }t|jd r|jj|d <i}t|d r|j|jd |d<i|d<||d<|S)z*Build ASGI HTTP scope from HTTP/2 request.r rKrrr2rrNrrrrrr&r)rrrirrhrrrr#rr4r"rrr) rr`rIrHrrrrprs rr.zASGIProtocol._build_http2_scopesC"?? KD% NN ##I. Y'   %u=nnnnLL:A,, ++I6C?F}}GMM00;RU++1r"*h"*h   4;; (![[..E'N 7- .!11%994J/ 0 02 +,(l rc|j|j|j|jxsdd|r|dndd}|jD]\}}d|j ddz}|||<!|S)z.Build minimal environ dict for access logging.rzHTTP/2rrrrr)rhrrrrrrs rr/z!ASGIProtocol._build_http2_environ<sx&nn{{ #MM/R'*28A;  #?? !KD%DLLc22C GCL !rN)F)rrrrrr<r@rFr:rRrSrTrrrrnrrrrrr^r9rr.r/rrrr r &s M4(  H$TQ* |8|4#J$!F989,+ #%.N E$NTEl&Prr )rr5rgunicorn.asgi.unreaderrgunicorn.asgi.messagergunicorn.asgi.uwsgirgunicorn.http.errorsrgunicorn.uwsgi.errorsrr Protocolr rrrr@s? 0.1+5 / / e 7##e r