U xʹj@sddlmZddlmZmZmZmZmZmZm Z ddl Z ddl m Z ddl mZddlmZddlmZddlmZeeeeeeZe de jegee jZee d Zed d e jfd d ZGd ddeZdS))contextmanager) CFUNCTYPEPOINTERc_int c_longlongc_void_pcastcreate_string_bufferN) open_files)AbstractArchiveFileSystem) MemoryFile)DEFAULT_BLOCK_SIZEread_set_seek_callback NO_OPEN_CBallc #st|ttfdd}fdd}t|}t|}trRtj}tj} nt j tj }t j tj } t j ||0} t| |t| d||| t j | VW5QRXdS)zRead an archive from a seekable file-like object. The `file` object must support the standard `readinto` and 'seek' methods. cs$}t|tt}|d<|S)Nr)readintorrr) archive_pcontextZptrptrlengthbufZbuf_pfile`/var/www/html/bwave/python/venv/lib/python3.8/site-packages/fsspec/implementations/libarchive.py read_func*s z custom_reader..read_funccs||S)N)seektell)rroffsetwhence)rrr seek_func3s z custom_reader..seek_funcN)r rrffiZ READ_CALLBACK SEEK_CALLBACKnew_apirZ NO_CLOSE_CB libarchivereadZ OPEN_CALLBACKZVOID_CBZCLOSE_CALLBACKZnew_archive_readrZ read_openZ ArchiveRead) r format_nameZ filter_name block_sizerrZread_cbZseek_cbZopen_cbZclose_cbrrrr custom_reader!s    r'csfeZdZdZdZdZdZddddeffdd Ze d d Z e fd d Z d dZ dddZZS)LibArchiveFileSystemayCompressed archives as a file-system (read-only) Supports the following formats: tar, pax , cpio, ISO9660, zip, mtree, shar, ar, raw, xar, lha/lzh, rar Microsoft CAB, 7-Zip, WARC See the libarchive documentation for further restrictions. https://www.libarchive.org/ Keeps file object open while instance lives. It only works in seekable file-like objects. In case the filesystem does not support this kind of file object, it is recommended to cache locally. This class is pickleable, but not necessarily thread-safe (depends on the platform). See libarchive documentation for details. r#FrNc stj|f||dkr tdt|trlt|fd|i|psz2LibArchiveFileSystem._get_dirs..csi|]}|t|qSr)getattr)rPkeyentryfieldsrrrRsrMrrNrJcSsi|]}||dddqSrLrrOrrrrRs) r6r>isdirisfileupdateZ _all_dirnamessetrJappend)r7Z list_namesr=frrUr _get_dirss<    zLibArchiveFileSystem._get_dirsrbTc Ks||}|dkrtt}|H}|D]<} | j|kr:q*| jdkrHqh| | jD] } | }q*qTtq*W5QRXt|||dS)Nr_r)fsrCdata) r@NotImplementedErrorbytesr>rDrEZ get_blocksr0r ) r7rCr8r&Z autocommitZ cache_optionsr9rar=rVblockrrr_opens    zLibArchiveFileSystem._open)r_NTN)__name__ __module__ __qualname____doc__Z root_markerr+Zcachabler r/rr> classmethodr@r^re __classcell__rrr;rr(Hs(' ,r() contextlibrctypesrrrrrrr r#Zlibarchive.ffir Zfsspecr Zfsspec.archiver Zfsspec.implementations.memoryr Z fsspec.utilsr r!Z c_archive_pZ check_intrhasattrr"Z page_sizer'r(rrrrs$ $       &