=2gdZddlmZddlZddlmZddlmZddlmZejr ddl m Z dd l m Z ndxZ Z dd lmZd d gZGd dZGddZdZddZy)z Adapt s3 to package_streaming ) annotationsN)closing)Any)package_streaming)Client)GetObjectOutputTypeDef)conda_reader_for_urlstream_conda_infoconda_reader_for_s3cBeZdZddZdZedZedZddZy) ResponseFacadec&||_|d|_y)NBody)responseraw)selfrs :lib/python3.12/site-packages/conda_package_streaming/s3.py__init__zResponseFacade.__init__s   (cyNrs rraise_for_statuszResponseFacade.raise_for_statuss rc&|jddS)NResponseMetadataHTTPStatusCoderrs r status_codezResponseFacade.status_code!s}}/01ABBrc&|jddS)Nr HTTPHeadersrrs rheaderszResponseFacade.headers%s}}/0??rc&tfddS)Nc:jjSr)rread)nrsrz-ResponseFacade.iter_content..+sDHHMM!,rr)iter)rr's``r iter_contentzResponseFacade.iter_content*s,c22rN)rr )r'int) __name__ __module__ __qualname__rrpropertyr r#r*rrrrrs=) CC@@3rrc(eZdZdZddZdddddZy) SessionFacadezU Make s3 client look just enough like a requests.session for LazyZipOverHTTP c.||_||_||_yr)clientbucketkey)rr3r4r5s rrzSessionFacade.__init__3s  rNT)r#streamc|rDd|vr@|jj|j|j|d}t |S|jj|j|j}t |S)NRange)BucketKeyr8)r9r:)r3 get_objectr4r5r)rurlr#r6rs rgetzSessionFacade.get8st w'){{--{{8H.H h''{{--T[[dhh-OHh''rr3rr4strr5r?)r#z dict | None)r,r-r.__doc__rr=rrrr1r1.s 26d(rr1c#Kt|||\}}t|5tj||Ed{dddy7 #1swYyxYww)zc Yield (tar, member) for conda package. Just "info/" for .conda, all members for tar. N)r rrr )r3r4r5filenamecondas rr r BsI *&&#>OHe $66xGGG G s+AAAA AAA Ac4t|||}t||S)zF Return (name, file_like) suitable for package_streaming APIs )r1r )r3r4r5sessions rr r Ns!5G W --rr>)r@ __future__rtyping contextlibrrr TYPE_CHECKING mypy_boto3_s3rmypy_boto3_s3.type_defsr r<r __all__rr1r r rrrrNsb#  $>&**F #%  5 633,((( H.r