Gi7SrSSKrSSKrSSKJr SSKJr SSKJr SSKJ r SSK J r SSK J r S r"S S 5r"S S \R 5rg)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)UWSGIParseExceptionc0U(a[USS5$S$)zNormalize socket address to ASGI-compatible (host, port) tuple. ASGI spec requires server/client to be (host, port) tuples. IPv6 sockets return 4-tuples (host, port, flowinfo, scope_id), so we extract just the first two elements. N)tuple)sockaddrs `/var/www/fortnox.synktek.com/backend/venv/lib/python3.13/site-packages/gunicorn/asgi/protocol.py_normalize_sockaddrrs#+5"1 44c\rSrSrSrSrSrg)ASGIResponseInfo!z;Simple container for ASGI response info for access logging.cXlX0l/UlUHmupE[U[5(aUR S5n[U[5(aUR S5nURR XE45 Mo g)Nlatin-1)statussentheaders isinstancebytesdecodeappend)selfrrrnamevalues r __init__ASGIResponseInfo.__init__$si   "KD$&&{{9-%'' Y/ LL   . #r)rrrN)__name__ __module__ __qualname____firstlineno____doc__r__static_attributes__rr rr!s E /rrc\rSrSrSrSrSrSrSrSr Sr S r S r S r S rS rSrSrSrSrSrSSjrSrSrSrSrSrSrSrSrg) ASGIProtocol1zzHTTP/1.1 protocol handler for ASGI applications. Handles connection lifecycle, request parsing, and ASGI app invocation. cXlURUlURUlURUlSUlSUlSUlSUlSUl SUl SUl g)NrF) workercfglogasgiapp transportreaderwriter_task req_count_closed_receive_queue)rr,s r rASGIProtocol.__init__7s\ ::::;;    "rc$XlUR=RS- slURS5nU(a{[ US5(ajUR 5nUS:XaT[ R"5UlURRRURX55Ul g[ R"5UlXl URRRUR55Ul g)z(Called when a connection is established. ssl_objectselected_alpn_protocolh2N)r1r,nr_connsget_extra_infohasattrr<asyncio StreamReaderr2loop create_task_handle_http2_connectionr4r3_handle_connection)rr1r;alpns r connection_madeASGIProtocol.connection_madeGs" !--l; '*.FGG446Dt|&224 ![[--9911)H **,  [[%%11$2I2I2KL rc^UR(aURRU5 gg)z/Called when data is received on the connection.N)r2 feed_data)rdatas r data_receivedASGIProtocol.data_receivedas ;; KK ! !$ ' rcRUR(agSUlUR=RS-slUR(aURR 5 UR bUR R SS05 UR(aURR5(di[URSS5nUS:a1URRRUUR5 gURR5 ggg) a\Called when the connection is lost or closed. Instead of immediately cancelling the task, we signal a disconnect event and send an http.disconnect message to the receive queue. This allows the ASGI app to clean up resources (like database connections) gracefully before the task is cancelled. See: https://github.com/benoitc/gunicorn/issues/3484 NTr:typehttp.disconnectasgi_disconnect_grace_periodr)r6r,r>r2feed_eofr7 put_nowaitr4donegetattrr-rC call_later_cancel_task_if_pendingcancel)rexc grace_periods r connection_lostASGIProtocol.connection_lostfs <<   ! ;; KK "    *    * *F4E+F G ::djjoo//"488-KQOLa   ++ 00  !!#0:rcUR(a;URR5(dURR5 ggg)z9Cancel the task if it's still pending after grace period.N)r4rVrZrs r rY$ASGIProtocol._cancel_task_if_pendings0 ::djjoo// JJ   0:rcFURRU5 g![agnUR[R[R [R 4;a URRS5 SnAgSnAgSnAf[[4a gf=f)aHWrite data to transport, handling connection errors gracefully. Catches exceptions that occur when the client has disconnected: - OSError with errno EPIPE, ECONNRESET, ENOTCONN - RuntimeError when transport is closing/closed - AttributeError when transport is None These are silently ignored since the client is already gone. zSocket error writing response.N) r1writeOSErrorerrnoEPIPE ECONNRESETENOTCONNr. exception RuntimeErrorAttributeError)rrLes r _safe_writeASGIProtocol._safe_writesw  NN  & Ewwu{{E,<,>T[[%=%==HHMM"PQ(-DKK% %I  (9(9xx))((***mlllz  ! ! #m## "*HHNN#:A> N*+%%   C HH  > B B C  ! ! #sK.AJ7A I II J 0I :I;I ?,J+J ,J0K2JJ B!J)K*JKJJJ2K.I I JJK JJ;J?KJJ JJK%K' K0K KKKK++K.cURS:wagSnSnURH5upEUS:XaUR5nMUS:XdM%UR5nM7 US:H=(a U=(a SU;$)zCheck 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)rrr connectionrrs r rx"ASGIProtocol._is_websocket_upgradeso >>U " "??KDy ++-%"[[] + +%P*Pj9PPrc# SSKJn URXU5nU"URURXPR UR 5nUR5IShvN gN7f)z!Handle WebSocket upgrade request.r)WebSocketProtocolN)gunicorn.asgi.websocketr_build_websocket_scoper1r2r0r.run)rrrqrprscope ws_protocols r ryASGIProtocol._handle_websocketsO=++GxH' NNDKK$(( oosAA)!A'"A)c D ^^^ ^ ^ ^^^^^^# TRTX#5nSmSmSm SmSm/mSm[R"5m T TlSm TRS:Xa1TR (d T R SSSS.5IShvN Sm O&[R"TRTT 55 U U U4S jnU UUUUUUUU4 S jnTRTX#5nSn[R"5n TRRTRT5 TRXEU5IShvN T bT eT(dTR!SS 5IShvN SmSTl[R"5U - n [)TTT5nTR$R+UTXz5 TRR-TRTXx5 TR35(agTRR4=(a TRR6$GNNN![R"a TR$R'S 5 STl[R"5W - n [)TTT5nTR$R+UTXz5 TRR-TRTXx5 g![.a TR$R1S 5 gf=f[.a TR$R1S5 T(dTR!SS 5IShvN SmSTl[R"5W - n [)TTT5nTR$R+UTXz5 TRR-TRTXx5 g![.a TR$R1S 5 gf=ff=f![.a TR$R1S 5 GN/f=f!STl[R"5W - n [)TTT5nTR$R+UTXz5 TRR-TRTXx5 f![.a TR$R1S 5 ff=f=f7f)zHandle a single HTTP request.FNr http.requestrrPbody more_bodyTc># TR(a T(aSS0$TR5IShvN nURS5S:XaURSS5(dSmU$N47f)NrPrQrrT)r6get)msg body_complete receive_queuers r receive2ASGIProtocol._handle_http_request..receive%s_||  122%))++Cwwv.0d9S9S $ J ,s0A*A(5A*c"> # TR(agUSnUS:Xa>URS5nURS/5nTRX#T5IShvN gUS:XaT (a [S5mgSm USm URS/5m [ ST 55nU(d!TR S :aSm[ T 5S /-m TRT T T5IShvN gUS :XaT (d [S 5mgT (a [S 5mgURSS5nURSS5nU(a&TRUTS9IShvN T [U5- m U(dT(aTRS5 Sm gggGN/NN;7f)NrPhttp.response.informationalrrhttp.response.startResponse already startedTc3# UH~up[U[5(aUR5OUR5S:H=(d8 [U[5(aUR5OUR5S:Hv M g7f)scontent-lengthzcontent-lengthN)rstrr).0r_s r BASGIProtocol._handle_http_request..send..Nsj)$4&0c%:%:TZZ\ Qbbe(24(=(= 4::.send3s ||vH88%kk(3 &{{9b9 ..{'RRR00##/0J#KL#' ")("3#*;;y"#= &))$4)&"*goo.G"&K'+,<'=Ac@d'd$//AQSZ[[[11'#/0F#GL$#/0K#LL{{63/#KK U; //$ /DDD!SY.M "((6(,% !23S.\Es8AFFBF!F "A/FF 7F F FInternal Server Errorz'Request cancelled (client disconnected)Exception in post_request hookError in ASGI application)_build_http_scoperAQueuer7content_lengthrputrD_read_body_to_queue_build_environrnowr- pre_requestr,r0_send_error_responserr.rwraccess post_requestrri should_closer~r)rrrqrprrrenvironresp request_start request_timerrrrrrrrrs`` @@@@@@@@@r rz!ASGIProtocol._handle_http_requests&&wC !     +   ! !Q &w##&"%   !M    8 8- P Q ; -; -|%%gxB# E$LLNM HH g 6((540 0 0'""$//5LMMM"%#'D  E'||~ = '9I=YgwE%%dkk7GJ    ! !{{  7TXX%7%77E z 1N%%  HHNND E#'D  E'||~ = '9I=YgwE%%dkk7GJ E""#CD E!  HH  : ;#//5LMMM"%#'D  E'||~ = '9I=YgwE%%dkk7GJ E""#CD E!   E""#CD E#'D  E'||~ = '9I=YgwE%%dkk7GJ E""#CD Es"A8R HAR AH.H/%HHHR #A)O A R HH/O O? R A)J>=R >%K&#R %K&&R )AO)L,*O1O?2R :A)N$#R $%O  R  O  R OO?%O<8R ;O<<R ?RA)Q21R2%RRRRR cx# URS5IShvN nU(aURSUSS.5IShvN OURSSSS.5IShvN gM^NIN'N ![aDnURR SU5 URSSSS.5IShvN SnAgSnAff=f7f) z.Read request body and put chunks on the queue.TiNrrrFzError reading body: %s) read_bodyrrr.rw)rrqueuechunkrls r r ASGIProtocol._read_body_to_queues %//66)) . %%)%  )) . #%*% 6    HHNN3Q 7))&"   slB:A)A##A)A%A)A'A) B:!A)%A)'A)) B734B2'B*(B2-B:2B77B:c ,/nURHDupVURUR5RS5URS545 MF [ U5n[ U5nSSSS.UR SSUR S3UR URURUR(aURRS5OS UR(aURRS5OS URR=(d S UUUS . n [URS 5(aURRU S '[US 5(aSURUR S.0U S'U $)z*Build ASGI HTTP scope from parsed request.rrs3.02.4r spec_versionr.r:r rPr/ http_versionrschemepathraw_path query_string root_pathrserverclientstatepriority_weighthttp.response.priorityweight depends_on extensions)rrrencoderrrrrqueryr-rr@r,rrpriority_depends_on) rrrqrprrrrrrs r rASGIProtocol._build_http_scopesX"??KD NNDJJL// :ELLEO  '  & sAAc# URS5nSUSUS[U5S3nURURS55 URU5 g7f)zSend an error response.zutf-8z HTTP/1.1 rz, Content-Type: text/plain Content-Length: z Connection: close rN)rrrm)rrrrrs r r!ASGIProtocol._send_error_responseUsd~~g&xq *"4yk*   34 sAAc0SS_SS_SS_SS_S S _S S _S S_SS_SS_SS_SS_SS_SS_SS_SS_SS _S!S"_0S#S$_S%S&_S'S(_S)S*_S+S,_S-S._S/S0_S1S2_S3S4_S5S6_S7S8_S9S:_S;S<_S=S>_S?S@_SASB_EnURUSC5$)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 RequestsrrizNot Implementediz Bad GatewayizService UnavailableizGateway TimeoutUnknown)r)rrreasonss r rASGIProtocol._get_reason_phrasebs" " &"  "   "  "  "  "  ""  $"  "  "  "  %"  %"  " !" " #" $ %" & %'" ( ")" * +" , -" . "/" 0 $1" 2 3" 4 )5" 6 '7" 8 $9" : (;" < "=" > ?" @ &A" B "C" F{{69--rc"UR(anUR(d\URR5(aURR5 URR 5 SUlggg![ a Nf=f)zClose the transport safely. Calls write_eof() first if supported to signal end of writing, which helps ensure buffered data is flushed before closing. TN)r1r6 can_write_eof write_eofcloserr`s r rASGIProtocol._close_transportsm >>$,, >>//11NN,,.$$& DL#/>   sAB B Bc # SSKJn URS5nURS5nURn[R "U5n[R "XX`RR5nU"URXhU5n U R5IShvN Xl U R(Gd/URR(GaU RSS9IShvN n U HCn UR'XXT5IShvN U R3U R,R.5 ME UR=R4[7U 5- slURR4URR8:a-UR"R;S 5 S URl O/U R(dURR(aGM[?US5(a#URRA5IShvN URC5 gGNGNH![Ra GM[ a'n UR"R%SU 5 Sn A MSn A ff=fGNv![ aun UR"R)S 5 U R+U R,R.S [1U 55IShvN Sn A GN![ a Sn A GNf=fSn A ff=f!U R3U R,R.5 f=f![R<a GN\[ a'n UR"R)S U 5 Sn A GNSn A ff=fGN`![ a GNkf=f![?US5(a5URRA5IShvN O![ a Of=fURC5 f=f7f)zHandle an HTTP/2 connection.r)AsyncHTTP2ConnectionrprqNg?)timeoutzHTTP/2 receive error: %szError handling HTTP/2 requestrruFzHTTP/2 connection error: %s_h2_conn)"gunicorn.http2.async_connectionrEr?r2rAStreamReaderProtocol StreamWriterr,rCr-initiate_connectionrG is_closedr~ receive_data TimeoutErrorrr.rw_handle_http2_requestri send_errorstream stream_idrcleanup_streamr{rr|r}rr@rBr) rr1r;rErprqr2rrr3h2_connrequestsrlreqs r rE%ASGIProtocol._handle_http2_connections)C $ L // ;H // ;H[[F33F;H))V[[-=-=F +&(G--/ / /#M'''DKK,=,=,=%,%9%9#%9%FFH$C E"88( ..szz/C/CD$" #h-/;;>>T[[%=%==HHMM"PQ(-DKK%A''DKK,=,=,=NtZ((----///  ! ! #c 0 G++ HHNN#=qA %!**+JK!")"4"4 # 4 4c3q6# )! ! ! ..szz/C/CD%%   A HH  M>M;M> O*1L14H77I? L1 I?I:4L18N:I??L1J LK?+3K*K!K*$L* K<4K?5L;K<<K??LL'L..L11M8N M8M3-N3M88N;M>> N O* N  O*O'"O?OOO' OO'OO''O*c .^^^^^^^^^^# TRRmURTX45nSmSmSmSm/mSm/mU4SjnUUUUUUUUU4 SjnURTX45n[R "5n UR RURT5 URXVU5IShvN TbTeT(Ga/n THcup[U [5(aU RS5n [U [5(aU RS5n U RX45 Me T(aS[T54/n U H/upU RU R5[U 545 M1 TR R#TU SS 9 TR$TnUR#U SS 9 TR'5IShvN T(aCTR R)TTSS 9 UR)TSS 9 TR'5IShvN TR+TT5IShvN O;TR-TTU T5IShvN OTR/TSS 5IShvN Sm[R "5U - n[7TT[9T55nUR2R;UTX5 UR R=URTUU5 gGN.GNNNNN![0aC UR2R5S 5 T(dTR/TSS 5IShvN SmNf=f![0a UR2R5S 5 gf=f![R "5U - n[7TT[9T55nUR2R;UTX5 UR R=URTUU5 f![0a UR2R5S 5 ff=f=f7f) zHandle a single HTTP/2 request.FNrrcL># TRR5nSUSS.$7f)NrFr)rread)rrs r r3ASGIProtocol._handle_http2_request..receives+<<$$&D&" s!$c> # USnUS:XaURS5nURS/5n/nUHcupV[U[5(aURS5n[U[5(aURS5nUR XV45 Me T R TX$5IShvN gUS:Xa-T(a [ S5m gSmUSmURS/5mgUS :XaaT(d [ S 5m gT(a [ S 5m gURS S 5nURSS5nU(aT U- m U(dSmggUS:XaT(d [ S5m gURS/5n /n U HcupV[U[5(aURS5n[U[5(aURS5nU R XV45 Me TRU 5 ggGNI7f)NrPrrrrrrTrrrrrrFhttp.response.trailersz)Cannot send trailers before body complete)rrrrrsend_informationalrjextend)rrrrrrrrrtrailer_headerstrailersrrT response_bodyrrrrresponse_trailersrRs r r0ASGIProtocol._handle_http2_request..sendsvH88%kk(3 &{{9b9 #/KD!$..#{{95!%// % Y 7NND=1 $0 00KQQQ00##/0J#KL#' ")("3#*;;y"#= 11'#/0F#GL$#/0K#LL{{63/#KK U; !T)M (,%!55(#/0[#\L")++i"<#2KD!$..#{{95!%// % Y 7OOTM2 $3 "((269RsB/G>2G;3E G>rz:status) end_streamrrr)rQrR_build_http2_scope_build_http2_environrrr-rr,r0rrrrrrrT send_headersstreams_send_pending_data send_data send_trailers send_responserPrr.rirrrr)rrrTrqrprrrrrrrr response_hdrsrQrrrrbrrrrrcrRs `` @@@@@@@@r rO"ASGIProtocol._handle_http2_requestsNN,, ''D !   ; 3; 3|++GXH  < E HH g 6((540 0 0'"" #3KD!$..#{{95!%// % Y 7NND=1 $4%&/_1E%F$GM'. %,,djjlCJ-GH(/OO00MV[0\$__Y7F'' %'H!44666%11)]W\1]((5(I%88:::"// ;LMMM!//!?G]((C9PQQQ"% E'||~ = '#%5s=7IgwE%%dkk7GTJq 147 ;NR & HH  : ;#((C9PQQQ"%  & E""#CD E E'||~ = '#%5s=7IgwE%%dkk7GTJ E""#CD EsA2P?;K6:K(;DK6K+A K6K.K62K03K67M18K6K2K6M1K6+K4,K62M14A3M'P(K6+K6.K60K62K64K66AM8L;9MM1MM1%M.+P-M..P1P3A3O'&P'%P PPPPc /nURHDupVURUR5RS5URS545 MF [ U5n[ U5nSSSS.SUR UR URUR(aURRS5OSUR(aURRS5OSURR=(d SUUUS . n [URS 5(aURRU S '0n [US 5(aURURS .U S '0U S'XS'U $)z*Build ASGI HTTP scope from HTTP/2 request.rrsrrr2rrrrrrrr]r)rrrrrrrrrr-rr@r,rrr) rrrqrprrrrrrrs r rfASGIProtocol._build_http2_scopevsN"??KD NN ##I. Y' + %X.$X. %u=nnnnLL:A,, ++I6C?F}}GMM00;RU++1r   4;; ( (![[..E'N 7- . .!11%994J/ 0 02 +,(l rcURURURUR=(d SSU(aUSOSS.nURHupVSUR SS5-nXdU'M U$)z.Build minimal environ dict for access logging.rzHTTP/2rrrrr)rr rrrr r s r rg!ASGIProtocol._build_http2_environso&nn{{ #MM/R'*28A;  #??KDDLLc22C CL+r) r6rGr7r4r0r-r.r2r5r1r,r3N)F)r!r"r#r$r%rrHrMr]rYrmrFrxryrzrrrrrrrrrrrErOrfrgr&r'rr r)r)1s # M4( !$F &E$NQ* V8p4&P$$L585,' %.N E$NTEl)Vrr))r%rArergunicorn.asgi.unreaderrgunicorn.asgi.messagergunicorn.asgi.uwsgirgunicorn.http.errorsrgunicorn.uwsgi.errorsrrrProtocolr)r'rr r{sG  0.1+55 / /  7## r