U -eP@sddlmZmZmZddlmZddlmZmZm Z m Z m Z m Z m Z ddlZddlmZddlmZddlmZddlmZddlmZee e e e e Zed ejege ejZeed Zed d ejfd d Z GdddeZ!dS))absolute_importdivisionprint_function)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)readintor rr ) archive_pcontextZptrptrlengthbufZbuf_pfileb/var/www/html/Darija-Ai-Train/env/lib/python3.8/site-packages/fsspec/implementations/libarchive.py read_func,s z custom_reader..read_funccs||S)N)seektell)rroffsetwhence)rrr seek_func5s z custom_reader..seek_funcN)r r r ffiZ READ_CALLBACK SEEK_CALLBACKnew_apirZ NO_CLOSE_CB libarchivereadZ OPEN_CALLBACKZVOID_CBZCLOSE_CALLBACKZnew_archive_readrZ read_openZ ArchiveRead) r format_nameZ filter_name block_sizerr"Zread_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|trft|fd|i|prrrCsz$LibArchiveFileSystem._strip_protocolc sdddddddd|jdk r"dSi|_g}|}|D]tjsLjsLq:|jd d |tjDfd d D}jrd nd |d<|j||j|d<q:W5QRX|jdd ||DdS)Npathnamesizectimer;uidgidmtime)namerHcreatedr;rJrKrLcSs"i|]}|d|ddddqSrBr directory)rMrHtyper.0dirnamerrr s z2LibArchiveFileSystem._get_dirs..csi|]}|t|qSr)getattr)rSkeyentryfieldsrrrUsrPrrQrMcSs"i|]}|d|ddddqSrOrrRrrrrUs) r9rAisdirisfileupdateZ _all_dirnamessetrMappend)r:Z list_namesr@frrXr _get_dirss<    zLibArchiveFileSystem._get_dirsrbTc Ks||}|dkrtt}|H}|D]<} | j|kr:q*| jdkrHqh| | jD] } | }q*qTtq*W5QRXt|||dS)Nrbr)fsrFdata) rCNotImplementedErrorbytesrArGrHZ get_blocksr2r) r:rFr;r)Z autocommitZ cache_optionsr<rdr@rYblockrrr_opens    zLibArchiveFileSystem._open)rbNTN)__name__ __module__ __qualname____doc__Z root_markerr.Zcachablerr1rrA classmethodrCrarh __classcell__rrr>rr+Js(( -r+)" __future__rrr contextlibrctypesrrrr r r r r&Zlibarchive.ffir#Zfsspecr Zfsspec.archiverZfsspec.implementations.memoryrZ fsspec.utilsrr$Z c_archive_pZ check_intrhasattrr%Z page_sizer*r+rrrrs& $       &