bQjg$UddlmZddlZddlmZddlZddlZddlm Z m Z ddl m Z m Z mZmZmZdZej$j'dZded<dd ZGd d ZGd d ZGddeZddZddZy)) annotationsN)NoReturn)HeadersMutableHeaders)ASGIAppMessageReceiveScopeSend)application/grpczapplication/gzipzapplication/x-gzipzapplication/zipzaudio/*z font/woffz font/woff2z image/avifz image/gifz image/jpegz image/pngz image/webpztext/event-streamzvideo/*_gzip_capacity_limiterz,anyio.lowlevel.RunVar[anyio.CapacityLimiter]c tjS#t$r/tjd}tj ||cYSwxYw)zDReturn the capacity limiter used for worker-thread GZip compression.()r get LookupErroranyioCapacityLimitersetlimiters ^/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/starlette/middleware/gzip.py_get_gzip_capacity_limiterr!sJ%))++ ''+""7+ s5A Ac@eZdZ ded ddZddZy)GZipMiddlewareexclude_content_typesc\||_||_||_||_t ||_yN)app minimum_size compresslevelthread_minimum_size_normalize_content_typesr)selfrr r!r"rs r__init__zGZipMiddleware.__init__.s1(*#6 %=>S%T"cK|ddk7r|j|||d{yt|}d|jddvrCt|j|j|j |j |j}n,t|j|j|j}||||d{y77w) Ntypehttp)scopegzipAccept-Encoding)r!r"rr) rrr GZipResponderr r!r"rIdentityResponder)r$r*receivesendheaders responders r__call__zGZipMiddleware.__call__=s =F "((5'40 0 0 & W[[!2B7 7%!!"00$($<$<&*&@&@ I*$((D4E4E]a]w]wxIw---! 1 .s"C C B!C C C  C N)i  rrr intr!r8r"r8rtuple[str, ...]returnNoner*r r0r r1r r:r;)__name__ __module__ __qualname__DEFAULT_EXCLUDED_CONTENT_TYPESr%r4r&rrr-sd #- U2P U  U U U ! U / U  U.r&rcLeZdZUded<ed d dZd dZd dZd dZy) r/strcontent_encodingrc||_||_t||_t|_i|_d|_d|_d|_ d|_ y)NF) rr r#runattached_sendr1initial_messagestartedcontent_encoding_setcontent_type_is_excludedpartial_response)r$rr rs rr%zIdentityResponder.__init__UsO(%=>S%T") (* $)!(-% %r&chK||_|j|||jd{y7wr)r1rsend_with_compression)r$r*r0r1s rr4zIdentityResponder.__call__fs) hhugt'A'ABBBs (202cK|d}|dk(r-||_|jdgt|jd}d|v|_|ddk(|_|j dd j d d jj}||j d d d zh}|jdr|jd|j|j |_ |js|js |jr$|j|jd{yy|dvr>|js|js |jr|j|d{y|dk(r|jsd|_|j dd}|j dd}t!||j"kr?|s=|j|jd{|j|d{y|s|j%|dd{}t'|jd}|j)d||dk7rK|j*|d<|jj ddr|d=nt-t!||d<||d<|j|jd{|j|d{y|j%|dd{}t'|jd}|j)d||dk7r|j*|d<|d=||d<|j|jd{|j|d{y|dk(r\|j dd}|j dd}|j%||d{|d<|j|d{y|dvr|j|d{y|dk(r=|j|jd{|j|d{yy777_7I7.77{7b77777h7A7*w)Nr(zhttp.response.startr2)rawzcontent-encodingstatusz content-typer-;r/z/*zapplication/grpc+r )http.response.bodyhttp.response.pathsendrTTbodyr& more_bodyF)rWr,zContent-EncodingtrailerszContent-Length)zhttp.response.early_hintzhttp.response.trailersrU)rG setdefaultrrIrKr partitionstriplower startswithadd isdisjointrrJr1rHlenr apply_compressionradd_vary_headerrDrC)r$message message_typer2 media_type media_typesrVrWs rrMz'IdentityResponder.send_with_compressionjs"v 0 0$+D   y" -$"6"6y"ABG(:g(ED %$+H$5$)>$B_B_))G$ $ $ 1 1$,,DL;;vs+D K7I4y4,,,Yii 4 4555ii(((!33DE3JJ(T-A-A)-LM''(9:76?*262G2GG./++// EB#$4547D N 01&*GFOii 4 4555ii((("33DD3II(T-A-A)-LM''(9:76?*262G2GG./ 01&*GFOii 4 4555ii((( 1 1;;vs+D K7I$($:$:49$:$UUGFO))G$ $ $ S S))G$ $ $ 5 5))D001 1 1))G$ $ $6i6 %6(K6(J6( V $ $ 2 $sD2Q24Q 5AQ27Q8A;Q23Q4Q2 Q Q2*Q+BQ2 Q Q2#Q$Q2?Q!A+Q2+Q$,Q2Q&AQ2 Q( Q2%Q*&Q2Q,(Q2,Q.-Q2Q0Q2Q2Q2Q2Q2Q2Q2!Q2$Q2&Q2(Q2*Q2,Q2.Q20Q2cK|Sw)zApply compression on the response body. If more_body is False, the compression stream is finalized. Compression resources are only allocated once a body is actually compressed. rAr$rVrWs rraz#IdentityResponder.apply_compressions  sN)rrr r8rr9r:r;r<)rcrr:r;rVbytesrWboolr:rj) r=r>r?__annotations__r@r%r4rMrarAr&rr/r/RsK2P & && / &  &"CG%Rr&r/cheZdZdZ dded d fdZed dZd dZd dZ xZ S) r.r+r6)r"rcTt||||||_||_d|_y)Nr)superr%r!r" _compressor)r$rr r!r"r __class__s rr%zGZipResponder.__init__s2 lBWX*#6 26r&c|jEtj|jtjdtj z|_|jS)N)rpzlib compressobjr!DEFLATED MAX_WBITS)r$s r compressorzGZipResponder.compressorsH    ##//0B0BDMMSUX\XfXfSfgD r&cKt||jk\r?t}tjj |j |||d{S|j ||S7w)Nr)r`r"rr to_threadrun_sync_compress_body)r$rVrWrs rrazGZipResponder.apply_compressionsa t900 002G11$2E2EtY`g1hh h""433isAA.A,A.c|rE|jj||jjtjzS|jj||jjzSr)rxcompressflushrt Z_SYNC_FLUSHrhs rr|zGZipResponder._compress_bodys[ ??++D1DOO4I4I$J[J[4\\ \''-0E0E0GGGr&)r5r7)r:zzlib._Compressri) r=r>r?rDr@r%propertyrxrar| __classcell__)rqs@rr.r.sy  7 $.1O 7  7 7 7 ! 7 / 7  7  4Hr&r.c Ktdw)Nzsend awaitable not set) RuntimeError)rcs rrFrFs / 00s c&td|DS)Nc3|K|]4}|jddjj6yw)rRrN)rZr[r\).0 content_types r z+_normalize_content_types..s2bL'',Q/557==?bs:<)tuple) content_typess rr#r#s bTab bbr&)r:zanyio.CapacityLimiter)rcrr:r)rr9r:r9) __future__rrttypingranyio.lowlevelranyio.to_threadstarlette.datastructuresrrstarlette.typesrrr r r r@lowlevelRunVarr rlrrr/r.rFr#rAr&rrs}" <BB""HM~~G\G\]uGvDv ".".JggT"H%"HJ1cr&