je"UddlmZddlZddlmZddlZddlZddlm Z m Z ddl m Z m Z mZmZmZdZejdZded<dd ZGd d ZGddZGddeZddZddZdS)) annotationsN)NoReturn)HeadersMutableHeaders)ASGIAppMessageReceiveScopeSend) zapplication/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]returnanyio.CapacityLimiterc tS#t$r3tjd}t||cYSwxYw)zDReturn the capacity limiter used for worker-thread GZip compression.()r get LookupErroranyioCapacityLimitersetlimiters IC:\Projects\Muse2API\.venv\Lib\site-packages\starlette/middleware/gzip.py_get_gzip_capacity_limiterr sc%))+++ '++""7+++ s:AAc,eZdZ dedddZddZdS)GZipMiddleware exclude_content_typesappr minimum_sizeint compresslevelthread_minimum_sizer tuple[str, ...]r Nonecf||_||_||_||_t ||_dSN)r!r"r$r%_normalize_content_typesr )selfr!r"r$r%r s r__init__zGZipMiddleware.__init__-s:(*#6 %=>S%T%T"""scoper receiver sendr ctK|ddkr||||d{VdSt|}d|ddvr.t|j|j|j|j|j}n!t|j|j|j}||||d{VdS) Ntypehttp)r.gzipAccept-Encoding)r$r%r r) r!rr GZipResponderr"r$r%r IdentityResponder)r+r.r/r0headers responders r__call__zGZipMiddleware.__call__<s =F " "((5'400 0 0 0 0 0 0 0 F&&& W[[!2B77 7 7%!"0$($<&*&@ II*$(D4E]a]wxxxIiw-----------r-N)rrr r!rr"r#r$r#r%r#r r&r r'r.r r/r r0r r r')__name__ __module__ __qualname__DEFAULT_EXCLUDED_CONTENT_TYPESr,r;r-rrr,sc #- U2P U U U U U U......r-rc@eZdZUded<eddd ZddZddZd dZdS)!r8strcontent_encodingrr!rr"r#r r&r r'c||_||_t||_t|_i|_d|_d|_d|_ d|_ dS)NF) r!r"r*r unattached_sendr0initial_messagestartedcontent_encoding_setcontent_type_is_excludedpartial_response)r+r!r"r s rr,zIdentityResponder.__init__TsX(%=>S%T%T") (* $)!(-% %r-r.r r/r r0r c\K||_||||jd{VdSr))r0r!send_with_compression)r+r.r/r0s rr;zIdentityResponder.__call__es> hhugt'ABBBBBBBBBBBr-messagercK|d}|dkr||_t|jd}d|v|_|ddk|_|dd d d }||d d d zh}||j  |_ dS|dkr`|js|js|j rK|j s'd|_ | |jd{V| |d{VdS|dkr|j sd|_ |dd}|dd}t||jkr?|s=| |jd{V| |d{VdS|s||dd{V}t!|jd}|d||dkr.|j|d<t't||d<||d<| |jd{V| |d{VdS||dd{V}t!|jd}|d||dkr|j|d<|d=||d<| |jd{V| |d{VdS|dkri|dd}|dd}|||d{V|d<| |d{VdS|dkr=| |jd{V| |d{VdSdS)Nr2zhttp.response.startr9)rawzcontent-encodingstatusz content-typer6;r/z/*zhttp.response.bodyTbodyr- more_bodyF)rWr5zContent-EncodingzContent-Lengthzhttp.response.pathsend)rHrrJrLr partitionstriplower isdisjointr rKrIr0lenr"apply_compressionradd_vary_headerrErD)r+rO message_typer9 media_type media_typesrVrWs rrNz'IdentityResponder.send_with_compressionisv 0 0 0$+D $"6y"ABBBG(:g(ED %$+H$5$2BFB_2< 6# ii 4555555555))G$$ $ $ $ $ $ $ $ $ $ 1 1 1$, 1DL;;vs++D K77I4yy4,,,Y,ii 4555555555ii((((((((((( )!33DE3JJJJJJJJ(T-A)-LMMM''(9:::76?**262GG./03CIIG,-&*GFOii 4555555555ii((((((((((("33DD3IIIIIIII(T-A)-LMMM''(9:::76?**262GG./ 01&*GFOii 4555555555ii((((((((((( 1 1 1;;vs++D K77I$($:$:49$:$U$UUUUUUUGFO))G$$ $ $ $ $ $ $ $ $ $ 5 5 5))D011 1 1 1 1 1 1 1))G$$ $ $ $ $ $ $ $ $ $6 5r-rVbytesrWboolc K|S)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. rBr+rVrWs rr]z#IdentityResponder.apply_compressions  r-N)r!rr"r#r r&r r'r=)rOrr r'rVrbrWrcr rb) r>r?r@__annotations__rAr,r;rNr]rBr-rr8r8Qs2P &&&&&&"CCCC@%@%@%@%Dr-r8cXeZdZdZ ddeddfdZeddZddZddZ xZ S)r7r4rr)r%r r!rr"r#r$r%r r&r r'czt|||||_||_d|_dS)Nr)superr,r$r% _compressor)r+r!r"r$r%r __class__s rr,zGZipResponder.__init__sC lBWXXX*#6 26r-zlib._Compressc|j7tj|jtjdtjz|_|jS)N)rkzlib compressobjr$DEFLATED MAX_WBITS)r+s r compressorzGZipResponder.compressors:   ##/0BDMSUX\XfSfggD r-rVrbrWrccKt||jkrr?r@rErAr,propertyrtr]rx __classcell__)rls@rr7r7s  7 $.1O 7 7 7 7 7 7 7 7   X 4444HHHHHHHHr-r7rOrrc$Ktd)Nzsend awaitable not set) RuntimeError)rOs rrGrGs / 0 00r- content_typesr&c4td|DS)Nc3K|]C}|ddVDdS)rTrN)rXrYrZ).0 content_types r z+_normalize_content_types..sMbbL'',,Q/5577==??bbbbbbr-)tuple)rs rr*r*s bbTabbb b bbr-)r r)rOrr r)rr&r r&) __future__rrptypingranyio.lowlevelranyio.to_threadstarlette.datastructuresrrstarlette.typesrrr r r rAlowlevelRunVarr rgrrr8r7rGr*rBr-rrs""""""" <<<<<<<<BBBBBBBBBBBBBB" HM~G\G\]uGvGvvvvv    ".".".".".".".".J````````F"H"H"H"H"H%"H"H"HJ1111ccccccr-