9tjUddlmZddlZddlmZddlZddlmZmZddl m Z m Z m Z m Z mZdZejdZded<dd ZGd d ZGddZGddeZddZdS)) annotationsN)NoReturn)HeadersMutableHeaders)ASGIAppMessageReceiveScopeSend)ztext/event-stream_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 W/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/starlette/middleware/gzip.py_get_gzip_capacity_limiterrsc%))+++ '++""7+++ s:AAc&eZdZ ddd ZddZdS)GZipMiddleware appr minimum_sizeint compresslevelthread_minimum_sizer Nonec>||_||_||_||_dSN)rr r"r#)selfrr r"r#s r__init__zGZipMiddleware.__init__s)(*#6   scoper receiver sendr cZK|ddkr||||d{VdSt|}d|ddvr(t|j|j|j|j}nt|j|j}||||d{VdS)Ntypehttp)r*gzipAccept-Encoding)r"r#)rrr GZipResponderr r"r#IdentityResponder)r'r*r+r,headers responders r__call__zGZipMiddleware.__call__)s =F " "((5'400 0 0 0 0 0 0 0 F&&& W[[!2B77 7 7%!"0$($< II*$(D4EFFIiw-----------r)N)rrr rrr r!r"r!r#r!r r$r*r r+r r,r r r$)__name__ __module__ __qualname__r(r7r)rrrsL #- 7 7 7 7 7......r)rc:eZdZUded<dd ZddZddZddZdS)r4strcontent_encodingrrr r!r r$cr||_||_t|_i|_d|_d|_d|_dS)NF)rr unattached_sendr,initial_messagestartedcontent_encoding_setcontent_type_is_excluded)r'rr s rr(zIdentityResponder.__init__@s=() (* $)!(-%%%r)r*r r+r r,r c\K||_||||jd{VdSr&)r,rsend_with_compression)r'r*r+r,s rr7zIdentityResponder.__call__Is> hhugt'ABBBBBBBBBBBr)messagercK|d}|dkr`||_t|jd}d|v|_|ddt |_dS|dkrY|js|jrK|js'd |_||jd{V||d{VdS|dkr|jsd |_|d d }|d d }t||j kr?|s=||jd{V||d{VdS|s| |d d{V}t|jd}| d||d kr.|j|d<tt||d<||d <||jd{V||d{VdS| |d d{V}t|jd}| d||d kr|j|d<|d=||d <||jd{V||d{VdS|dkri|d d }|d d }| ||d{V|d <||d{VdS|dkr=||jd{V||d{VdSdS)Nr.zhttp.response.startr5)rawzcontent-encodingz content-typer2zhttp.response.bodyTbodyr) more_bodyF)rMr1zContent-EncodingzContent-Lengthzhttp.response.pathsend)rCrrEr startswithDEFAULT_EXCLUDED_CONTENT_TYPESrFrDr,lenr apply_compressionradd_vary_headerr@r?)r'rI message_typer5rLrMs rrHz'IdentityResponder.send_with_compressionMsSv 0 0 0$+D $"6y"ABBBG(:g(ED %,3KK,K,K,V,VWu,v,vD ) ) ) 1 1 1t7P 1TXTq 1< 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)rLbytesrMboolc 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. r=r'rLrMs rrQz#IdentityResponder.apply_compressions  r)N)rrr r!r r$r9)rIrr r$rLrTrMrUr rT)r:r;r<__annotations__r(r7rHrQr=r)rr4r4=sw....CCCC;%;%;%;%zr)r4cVeZdZdZ ddddfd ZeddZddZddZxZ S)r3r0rr)r#rrr r!r"r#r r$cvt||||_||_d|_dSr&)superr(r"r# _compressor)r'rr r"r# __class__s rr(zGZipResponder.__init__s= l+++*#6 26r)zlib._Compressc|j7tj|jtjdtjz|_|jS)N)r]zlib compressobjr"DEFLATED MAX_WBITS)r's r compressorzGZipResponder.compressors:   ##/0BDMSUX\XfSfggD r)rLrTrMrUcKt||jkrrxsi"""""""  <<<<<<<<BBBBBBBBBBBBBB!7GL~G\G\]uGvGvvvvv    ........BSSSSSSSSl!H!H!H!H!H%!H!H!HH111111r)