o <^öh„ã@sxddlZddlZddlZddlmZmZddlmZmZm Z m Z m Z Gdd„dƒZ Gdd„dƒZ ded ejfd d „ZdS) éN)ÚHeadersÚMutableHeaders)ÚASGIAppÚMessageÚReceiveÚScopeÚSendc @sBeZdZddedededdfdd „Zd ed ed eddfd d„Z dS)ÚGZipMiddlewareéôé ÚappÚ minimum_sizeÚ compresslevelÚreturnNcCs||_||_||_dS©N)r r r©Úselfr r r©rúY/home/air/websocket/korean/venv/lib/python3.10/site-packages/starlette/middleware/gzip.pyÚ__init__ s zGZipMiddleware.__init__ÚscopeÚreceiveÚsendcÃsj|ddkr)t|d}d| dd¡vr)t|j|j|jd}||||ƒIdHdS| |||¡IdHdS)NÚtypeÚhttp)rÚgzipúAccept-EncodingÚ)r)rÚgetÚ GZipResponderr r r)rrrrÚheadersÚ responderrrrÚ__call__s€  zGZipMiddleware.__call__)r r ) Ú__name__Ú __module__Ú __qualname__rÚintrrrrr"rrrrr sr c @sTeZdZddedededdfdd„Zd ed ed eddfd d „Z de ddfdd„Z dS)rr r r rrNcCsF||_||_t|_i|_d|_d|_t ¡|_ t j d|j |d|_ dS)NFÚwb)ÚmodeÚfileobjr) r r Úunattached_sendrÚinitial_messageÚstartedÚcontent_encoding_setÚioÚBytesIOÚ gzip_bufferrÚGzipFileÚ gzip_filerrrrrs zGZipResponder.__init__rrrc Ãs€||_|j/|j| |||j¡IdHWdƒn1s!wYWdƒdSWdƒdS1s9wYdSr)rr0r2r Úsend_with_gzip)rrrrrrrr"$s €PÿzGZipResponder.__call__ÚmessagecÃsV|d}|dkr||_t|jdd}d|v|_dS|dkr;|jr;|js1d|_| |j¡IdH| |¡IdHdS|dkrî|jsîd|_| dd ¡}| d d ¡}t|ƒ|jkrm|sm| |j¡IdH| |¡IdHdS|s¯|j  |¡|j  ¡|j   ¡}t |jdd}d |d <tt|ƒƒ|d<| d¡||d<| |j¡IdH| |¡IdHdSt |jdd}d |d <| d¡|d=|j  |¡|j   ¡|d<|j  d¡|j  ¡| |j¡IdH| |¡IdHdS|dkr)| dd ¡}| d d ¡}|j  |¡|s |j  ¡|j   ¡|d<|j  d¡|j  ¡| |¡IdHdSdS)Nrzhttp.response.startr )Úrawzcontent-encodingzhttp.response.bodyTÚbodyóÚ more_bodyFrzContent-EncodingzContent-Lengthrr)r+rr-r,rrÚlenr r2ÚwriteÚcloser0ÚgetvaluerÚstrÚadd_vary_headerÚseekÚtruncate)rr4Ú message_typer r6r8rrrr3)sd€                 ózGZipResponder.send_with_gzip)r ) r#r$r%rr&rrrrr"rr3rrrrrs rr4rcÃs tdƒ‚)Nzsend awaitable not set)Ú RuntimeError)r4rrrr*ks€r*)rr.ÚtypingÚstarlette.datastructuresrrÚstarlette.typesrrrrrr rÚNoReturnr*rrrrÚsR