dtj'ddlZddlZddlZddlZddlZddlZddlmZmZddl m Z m Z m Z m Z ddlmZddlmZejdZGdde Zd d d efd Zd Zed krddlZeejdddSdS)N)EIOENOENT)FUSE FuseOSError LoggingMixIn Operations) __version__) url_to_fs fsspec.fusecdeZdZddZddZdZdZdZdZd Z dd Z d Z dd Z d Z dZdZdS)FUSErFc||_i|_|ddz|_d|_t d|||_dS)N/rzStarting FUSE at %s)fscacherstriprootcounterloggerinfo _ready_file)selfrpath ready_files I/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/fsspec/fuse.py__init__zFUSEr.__init__sR KK$$s*   )4000%NcXtd||jr |dvrdddSd|j|dgd} |j|}n'#t$r}tt|d}~wwxYw| dd | d d d }| d d }|ddkrtj|z|d<d|d<d|d<n'tj|z|d<|d|d<d|d<d|d<d|vr|dnt!j|d<d|vr|dnt!j|d<d|vr|dnt!j|d<|S)Nz getattr %sz /.fuse_readyz .fuse_readyfile)typest_sizeruidigid)st_uidst_gidmodeir"st_moderr# st_blksizesizeiPst_nlinkatimest_atimectimest_ctimemtimest_mtime)rdebugrjoinrlstriprrrFileNotFoundErrorrrgetstatS_IFDIRS_IFREGtime)rrfhrexcdataperms rgetattrz FUSEr.getattrs \4(((   2(G G G"q11 1ww 4;;s#3#3455<z!FUSEr.readdir..:s2@@@Q!!!((3--00@@@r.z..)rr5r6rr7rls)rrr>filess rreaddirz FUSEr.readdir6sq \4(((ww 4;;s#3#3455 4''@@%@@@T{U""rcd|j|dg}|j|dSNr$rr)r6rr7rmkdirrrr)s rrPz FUSEr.mkdir=?ww 4;;s#3#3455  dqrcd|j|dg}|j|dSrO)r6rr7rrmdir)rrs rrTz FUSEr.rmdirBrRrctd|||f|jr|dvrdS|j|}||||}|S)Nzread %srsready)rr5rrseekread)rrr,offsetr>rHouts rrWz FUSEr.readGsf YtV 4555   (G G G8 JrN vffTll rctd||f|j|}||||t |S)Nzwrite %s)rr5rrVwritelen)rrr@rXr>rHs rr[z FUSEr.writeRsO Z$000 JrN v  4yyrcVtd||fd|j|dg}|j||j|d}||j|j <|xj dz c_ |j dz S)Nz create %sr$rwbr-) rr5r6rr7rtouchopenrr)rrflagsfifnrHs rcreatez FUSEr.createYs [4-000 WWdiS!1!12 3 3  b GLLT " "#$ 4<   |arc:td||fd|j|dg}|dzdkrd}nd}|j|||j|j<|xjdz c_|jdz S) Nzopen %sr$rrrbr^r-) rr5r6rr7rr`rr)rrrarcr)s rr`z FUSEr.openbs Yu ... WWdiS!1!12 3 3 19>>DDD#'7<<D#9#9 4<   |arcd|j|dg}|dkrt|j|dSrO)r6rr7NotImplementedErrorrr_)rrlengthr>rcs rtruncatezFUSEr.truncateosO WWdiS!1!12 3 3 Q;;% %  brcd|j|dg} |j|ddS#t t f$r}tt|d}~wwxYw)Nr$rF) r6rr7rrmOSErrorr8rr)rrrcr?s runlinkz FUSEr.unlinkvs| WWdiS!1!12 3 3 , GJJr5 ! ! ! ! !*+ , , ,c"" + ,sAA9A44A9c ||jvr;|j|}||j|n&#t$r}t |Yd}~nd}~wwxYwdS)Nr)rclosepop Exceptionprint)rrr>rHes rreleasez FUSEr.release}sz TZJrN  r"""    !HHHHHHHH qsAA A*A%%A*ct|jdrJd|j|dg}|j||St )Nchmodr$r)hasattrrr6rr7rxrirQs rrxz FUSEr.chmodsV 47G $ $ -77DIt{{3'7'7899D7==t,, ,!!r)F)N)__name__ __module__ __qualname__rrBrMrPrTrWr[rdr`rkrorvrxrrr r s&&&&8###            ,,,"""""rr TFcfd}s2tj|}d|_||S |dS#t$rYdSwxYw)amMount stuff in a local directory This uses fusepy to make it appear as if a given path on an fsspec instance is in fact resident within the local file-system. This requires that fusepy by installed, and that FUSE be available on the system (typically requiring a package to be installed with apt, yum, brew, etc.). Parameters ---------- fs: file-system instance From one of the compatible implementations path: str Location on that file-system to regard as the root directory to mount. Note that you typically should include the terminating "/" character. mount_point: str An empty directory on the local file-system where the contents of the remote path will appear. foreground: bool Whether or not calling this function will block. Operation will typically be more stable if True. threads: bool Whether or not to create threads when responding to file operations within the mounter directory. Operation will typically be more stable if False. ready_file: bool Whether the FUSE process is ready. The ``.fuse_ready`` file will exist in the ``mount_point`` directory if True. Debugging purpose. ops_class: FUSEr or Subclass of FUSEr To override the default behavior of FUSEr. For Example, logging to file. cDt S)N)r) nothreads foreground)r)rr mount_point ops_classrrthreadssrzrun..s54 "dz222+ r)targetTN) threadingThreaddaemonstartKeyboardInterrupt) rrrrrrrfuncths ``````` rrunrsX          D    T * * *      DFFFFF     DD s A A"!A"c Gddtj}|dtj}|ddt |dt d |d t d |d t d |dddd|ddt d |dddd|dddd|dddd ||}i}|jpgD]}| d!\}}}|s| d"|#| }| d$r&t|d%td$ }n/| d&r|d%td& d'v}d(|vr1|d(d)\} } | |vr ||| | <| |i|| <|||<|jrBt#jt"j|jd*+Gd,d-t(t*} | } nt(} t-|jfi|\} }t0d.|t |jt7| |j|j|j|j|j| /d%S)0aMount filesystem from chained URL to MOUNT_POINT. Examples: python3 -m fsspec.fuse memory /usr/share /tmp/mem python3 -m fsspec.fuse local /tmp/source /tmp/local \ -l /tmp/fsspecfuse.log You can also mount chained-URLs and use special settings: python3 -m fsspec.fuse 'filecache::zip::file://data.zip' \ / /tmp/zip \ -o 'filecache-cache_storage=/tmp/simplecache' You can specify the type of the setting by using `[int]` or `[bool]`, (`true`, `yes`, `1` represents the Boolean value `True`): python3 -m fsspec.fuse 'simplecache::ftp://ftp1.at.proftpd.org' \ /historic/packages/RPMS /tmp/ftp \ -o 'simplecache-cache_storage=/tmp/simplecache' \ -o 'simplecache-check_files=false[bool]' \ -o 'ftp-listings_expiry_time=60[int]' \ -o 'ftp-username=anonymous' \ -o 'ftp-password=xieyanbo' ceZdZfdZxZS)*main..RawDescriptionArgumentParserct}|d}|j|d<d|S)Nz r-)super format_helpsplit descriptionrr6)rusageparts __class__s rrz6main..RawDescriptionArgumentParser.format_helpsSGG''))EKK''E'..00E!H;;u%% %r)rzr{r|r __classcell__)rs@rRawDescriptionArgumentParserrs8 & & & & & & & & &rrr )progrz --versionversion)actionrurlzfs url)r"help source_pathzsource directory in fsrzlocal directoryz-oz--optionappendz3Any options of protocol included in the chained URL)rrz-lz --log-filez%Logging FUSE debug info (Default: '')z-fz --foreground store_falsez-Running in foreground or not (Default: False)z-tz --threadsz-Running with threads support (Default: False)z-rz --ready-filezZThe `.fuse_ready` file will exist after FUSE is ready. (Debugging purpose, Default: False)=zWrong option: )messagez[int]Nz[bool])1yestrue-r-z%(asctime)s %(message)s)levelfilenameformatceZdZdS)main..LoggingFUSErN)rzr{r|r}rr LoggingFUSErr-s DrrzMounting %s to %s)rrrr) argparseArgumentParsermain__doc__ add_argumentr str parse_argsoption partitionerrorlowerendswithintr\rlog_filelogging basicConfigDEBUGr rr rrr5rrrrrr)argsrparserkwargsitemkeysepvaluevalfs_name setting_namerfuserrurl_paths rrrs8&&&&&x'>&&&* )}$, W W WF  I{KKK Ch777  C6NOOO  C6GHHH   B    l+R   <     <    .    T " "D F !r  ..--S% < LL!:$!:!:L ; ; ;kkmm <<  BoW o.//EE \\( # # B(3x==.()-AAE #::$'IIc1$5$5 !G\&  05w --#/"7wF3KK } -],         5,   TX0000LB LL$hD4D0E0EFFF   ? ?r__main__r-)rrrEr:rr=errnorrfuserrrrfsspecr fsspec.corer getLoggerrr rrrzsysargvr}rrrsW  <<<<<<<<<<<<!!!!!!  = ) )z"z"z"z"z"Jz"z"z"B ;;;;|rrrj zJJJD!""r