codekingpro/portable-devtools
115k
1�
2 �j � �Z � S r SSKrSSKJr SSKrSSKJr S rS\0r S!S jr3S"S jr \4" S\ S5 SS K J
r
\5" S6\
S75 SS KJr S#S jr\8" S
\S5 SSKJr \9" S\S5 \10" S\S5 SSKr\11" S\R( SSS9 \12" S\R( SSS9 " S S\5 r SSKr\R0 " S5 \13" S\/ 5 SSKr \14" S\ R: R< S5 \R> S:� a SS K J!r! OSS K"J!r! \15" S \!RF S 5 S r&g! \ a N�f = f! \ a SSKJr \16" S
S S5 N�f = f! \ a N�f = f! \ a N�f = f! \\\4 a N�f = f! \ a N�f = f! \ a$ SSK$r!S#S jr%\17" S \%S 5 O ! \ a Of = f N�f = f)$z9Helper functions for a standard streaming compression API� N)�ZipFile)�AbstractBufferedFilec � � U $ �N� )�file�mode�kwargss �XD:\code\apps\devtools\python\user_packages\Python313\site-packages\fsspec/compression.py� noop_filer 18 s � � �K� c �T � [ U[ 5 ( a U/nU [ ; a U( d [ SU 35 eU H< nU[ R19 R ; d M# U( a M, [ SU SU S35 e U[ U ' U H nU [ R20 R U' M" g)a Register an "inferable" file compression type.21 22Registers transparent file compression type for use with fsspec.open.23Compression can be specified by name in open, or "infer"-ed for any files24ending with the given extensions.25 26Args:27 name: (str) The compression type name. Eg. "gzip".28 callback: A callable of form (infile, mode, **kwargs) -> file-like.29 Accepts an input file-like object, the target mode and kwargs.30 Returns a wrapped file-like object.31 extensions: (str, Iterable[str]) A file extension, or list of file32 extensions for which to infer this compression scheme. Eg. "gz".33 force: (bool) Force re-registration of compression type or extensions.34 35Raises:36 ValueError: If name or extensions already registered, and not force.37 38z$Duplicate compression registration: z&Duplicate compression file extension: z (�)N)�39isinstance�str�compr�40ValueError�fsspec�utils� compressions)�name�callback�41extensions�force�exts r �register_compressionr s� � �( �*�c�"�"� �\�42� �u�}�U��?��v�F�G�G��� �&�,�,�+�+� +�E�E� � E�c�U�"�T�F�RS� T�U� U� � �E�$�K���)-�� � �!�!�#�&� r
c � ^� SU; aC U=( d Sn[ U 4SS0UD6mTR USS9nUR 4U4S jjUl U$ [ U 5 mUc TR 5 S nTR " U4SS0UD6$ )N�rr r �w)r c �@ >� U " 5 =( d TR 5 $ r )�close)�closer�zs �r �<lambda>�unzip.<locals>.<lambda>= s �� �6�8�+@�q�w�w�y�+@r
r )r �openr! �namelist)�infiler �filenamer43 �for# s @r �unzipr+ 8 s� �� �44�$���%�v�� �F� /�� /�� /��
�V�V�H�3�V�
'��!#���@���� ����A����:�:�<��?�� �6�6�(� /�� /�� /�/r
�zip)�BZ2File�bz2)�igzipc �2 � [ R " SXS.UD6$ )N)�fileobjr r )r/ � IGzipFile)r( r r45 s r �isalr3 Q s � ����C�v�C�F�C�Cr
�gzip�gz��GzipFilec � � [ SSU 0UD6$ )Nr1 r r6 )�fr46 s r r$ r$ Y s � �H�$A�Q�$A�&�$Ar
)�LZMAFile�lzma�xzT)r c �H ^ � \ rS rSrU 4S jrSS jrS S jrS rS rSr U =r47$ )48�49SnappyFile�m c �� >� SS K n[ TU ] " SS SUR S5 S- SS.UD6 Xl SU; a UR50 " 5 U l g UR " 5 U l g )Nr �snappy�bi�ɚ;)�fs�pathr �sizer r )rA �super�__init__�stripr( �StreamDecompressor�codec�StreamCompressor)�selfr( r r51 rA � __class__s �r rG �SnappyFile.__init__n sd �� ��
��� 52��(����C� �3�)>�Y� 53�RX� 54� � � �$�;� �2�2�4�D�J� �0�0�2�D�Jr
c �� � U R R S5 U R R U R R 5 5 nU R55 R
U5 g)Nr T)�buffer�seekrJ � add_chunk�readr( �write)rL �final�outs r �
_upload_chunk�SnappyFile._upload_chunkz sJ � � � � ������j�j�"�"�4�;�;�#3�#3�#5�6�� � � ���#� �r
c � � [ S5 e)NzSnappyFile is not seekable)�NotImplementedError)rL �loc�whences r rQ �SnappyFile.seek� s � �!�">�?�?r
c � � g)NFr )rL s r �seekable�SnappyFile.seekable� s � �r
c �r � U R R X!-56 5 nU R R U5 $ )z*Get the specified set of bytes from remote)r( rS rJ �57decompress)rL �start�end�datas r � _fetch_range�SnappyFile._fetch_range� s- � ��{�{� � �� �,���z�z�$�$�T�*�*r
)rJ r( �F)r ) �__name__�58__module__� __qualname__�__firstlineno__rG rW rQ r_ rf �__static_attributes__�
__classcell__)rM s @r r> r> m s" �� �593�� @��+� +r
r> r
rA �lz4)� � )�zstdrr �zstc � � SU; a& [ R " 5 nUR U 5 $ [ R " SS9nUR U 5 $ )Nr �60 )�level)rr �ZstdDecompressor�
stream_reader�ZstdCompressor�
stream_writer)r( r �cctxs r �zstandard_filer| � sI � ��d�{��,�,�.���)�)�&�1�1��*�*��4���)�)�&�1�1r
c � � [ [ 5 $ )z.Return a list of the implemented compressions.)�listr r r
r �available_compressionsr � s � � ��;�r
rh )�rbN)r� )'�__doc__�sys�zipfiler � fsspec.utilsr � fsspec.specr r r r r+ r. r- � ImportErrorr3 r/ r4 r7 r; r: �lzmaffir> rA �compress� NameError�AttributeError� lz4.framero �framer& � version_info� compressionrr � backports�ZstdFile� zstandardr| r r r
r �<module>r� s �� ?� 61� � � ,�� 62�y���".�J630� �U�E�5� )�0�� ����/� ��D� ���t�,� � ����6�2���x��.� �����!1�!1�6��F���w� /� /��T�B�64 +�%� +�> ��65�O�O�C�� ��:�r�2�66 ����� � ����6� �67���7�"�$�"���� � ��6�&��] � �� �� � � ���A�4���� � �� �� � �� ��V �Y��/� �� �� � �� �� � �
� � 2� �V�^�U�;�� �
� �
��� �s� �D$ �D0 �E
�5*E �+ E% � "E4 �/1F �$D-�,D-�0E68� E69�
E�E�E"�!E"�% E1�0E1�4E=�<E=� F*�F�F*�F$�!F*�#F$�$F*�)F*