o pfnF@sndZddlmZmZddlZddlZddlmZddlm Z ddl m Z m Z m Z mZddlmZdd lmZejrUdd lmZmZmZmZdd lmZeeeeegefZ    d)d dZ    d)ddZ     d*ddZ d+ddZ d+ddZ d+ddZ! d,ddZ"   d-ddZ#    d)dd Z$    d)d!d"Z%    d)d#d$Z&d%d&Z'd'd(Z(dS).z6Functions for copying resources *between* filesystem. )print_functionunicode_literalsN)ResourceNotFound) manage_fs)abspathcombinefrombasenormpath)is_thread_safe)Walker)CallableOptionalTextUnion)FSFc Cst||d||||dS)a@Copy the contents of one filesystem to another. Arguments: src_fs (FS or str): Source filesystem (URL or instance). dst_fs (FS or str): Destination filesystem (URL or instance). walker (~fs.walk.Walker, optional): A walker object that will be used to scan for files in ``src_fs``. Set this if you only want to consider a sub-set of the resources in ``src_fs``. on_copy (callable): A function callback called after a single file copy is executed. Expected signature is ``(src_fs, src_path, dst_fs, dst_path)``. workers (int): Use `worker` threads to copy data, or ``0`` (default) for a single-threaded copy. preserve_time (bool): If `True`, try to preserve mtime of the resources (defaults to `False`). always preserve_time) copy_fs_ifsrc_fsdst_fswalkeron_copyworkersrr@/home/ertert/spirit/venv/lib/python3.10/site-packages/fs/copy.pycopy_fssrc Cs"tdtt||d||||dS)zCopy the contents of one filesystem to another, checking times. .. deprecated:: 2.5.0 Use `~fs.copy.copy_fs_if` with ``condition="newer"`` instead. z7copy_fs_if_newer is deprecated. Use copy_fs_if instead.newerr)warningswarnDeprecationWarningrrrrrcopy_fs_if_newer7s r#rc Cst|d|d|||||d S)aCopy the contents of one filesystem to another, depending on a condition. Arguments: src_fs (FS or str): Source filesystem (URL or instance). dst_fs (FS or str): Destination filesystem (URL or instance). condition (str): Name of the condition to check for each file. walker (~fs.walk.Walker, optional): A walker object that will be used to scan for files in ``src_fs``. Set this if you only want to consider a sub-set of the resources in ``src_fs``. on_copy (callable):A function callback called after a single file copy is executed. Expected signature is ``(src_fs, src_path, dst_fs, dst_path)``. workers (int): Use ``worker`` threads to copy data, or ``0`` (default) for a single-threaded copy. preserve_time (bool): If `True`, try to preserve mtime of the resources (defaults to `False`). See Also: `~fs.copy.copy_file_if` for the full list of supported values for the ``condition`` argument. /)rrrr copy_dir_if)rr conditionrrrrrrrrNs rcCst||||d|ddS)a Copy a file from one filesystem to another. If the destination exists, and is a file, it will be first truncated. Arguments: src_fs (FS or str): Source filesystem (instance or URL). src_path (str): Path to a file on the source filesystem. dst_fs (FS or str): Destination filesystem (instance or URL). dst_path (str): Path to a file on the destination filesystem. preserve_time (bool): If `True`, try to preserve mtime of the resource (defaults to `False`). rrN) copy_file_ifrsrc_pathrdst_pathrrrr copy_file{s  r,cCs tdtt||||d|dS)zCopy a file from one filesystem to another, checking times. .. deprecated:: 2.5.0 Use `~fs.copy.copy_file_if` with ``condition="newer"`` instead. z;copy_file_if_newer is deprecated. Use copy_file_if instead.rr)r r!r"r(r)rrrcopy_file_if_newers r-c Cst|dd<}t|dd%}t|||||}|r"t|||||dd|WdWdS1s5wYWddS1sEwYdS)aCopy a file from one filesystem to another, depending on a condition. Depending on the value of ``condition``, certain requirements must be fulfilled for a file to be copied to ``dst_fs``. The following values are supported: ``"always"`` The source file is always copied. ``"newer"`` The last modification time of the source file must be newer than that of the destination file. If either file has no modification time, the copy is performed always. ``"older"`` The last modification time of the source file must be older than that of the destination file. If either file has no modification time, the copy is performed always. ``"exists"`` The source file is only copied if a file of the same path already exists in ``dst_fs``. ``"not_exists"`` The source file is only copied if no file of the same path already exists in ``dst_fs``. Arguments: src_fs (FS or str): Source filesystem (instance or URL). src_path (str): Path to a file on the source filesystem. dst_fs (FS or str): Destination filesystem (instance or URL). dst_path (str): Path to a file on the destination filesystem. condition (str): Name of the condition to check for each file. preserve_time (bool): If `True`, try to preserve mtime of the resource (defaults to `False`). Returns: bool: `True` if the file copy was executed, `False` otherwise. F writeableTcreate)rlockN)r_copy_is_necessarycopy_file_internal) rr*rr+r'r_src_fs_dst_fsdo_copyrrrr(s&- "r(c surjdddSfdd}|rQ( |Wdn1s2wYWddSWddS1sJwYdS|dS)aCopy a file at low level, without calling `manage_fs` or locking. If the destination exists, and is a file, it will be first truncated. This method exists to optimize copying in loops. In general you should prefer `copy_file`. Arguments: src_fs (FS): Source filesystem. src_path (str): Path to a file on the source filesystem. dst_fs (FS): Destination filesystem. dst_path (str): Path to a file on the destination filesystem. preserve_time (bool): If `True`, try to preserve mtime of the resource (defaults to `False`). lock (bool): Lock both filesystems before copying. T) overwriterNcsr"d}|Wdn1swYn}|Wdn1s8wYrHtdSdS)Nw) hassyspathopenbindownloaduploadcopy_modified_time) write_file read_filerr+rrr*rr _copy_locked s  z(copy_file_internal.._copy_locked)copyr2)rr*rr+rr2rBrrArr4s P r4r$c Cs|pt}t|l}t|ddM}|9|%|j|dd|||D]}|jt|t||ddq(Wdn1sBwYWdn1sQwYWdn1s`wYWddSWddS1sxwYdS)apCopy directories (but not files) from ``src_fs`` to ``dst_fs``. Arguments: src_fs (FS or str): Source filesystem (instance or URL). dst_fs (FS or str): Destination filesystem (instance or URL). walker (~fs.walk.Walker, optional): A walker object that will be used to scan for files in ``src_fs``. Set this if you only want to consider a sub-set of the resources in ``src_fs``. src_root (str): Path of the base directory to consider as the root of the tree structure to copy. dst_root (str): Path to the target root of the tree structure. Tr0)recreateN)r rr2makedirsdirsmakedirrr )rrrsrc_rootdst_rootr5r6dir_pathrrrcopy_structures$  "rKc Cst||||d||||d dS)aCopy a directory from one filesystem to another. Arguments: src_fs (FS or str): Source filesystem (instance or URL). src_path (str): Path to a directory on the source filesystem. dst_fs (FS or str): Destination filesystem (instance or URL). dst_path (str): Path to a directory on the destination filesystem. walker (~fs.walk.Walker, optional): A walker object that will be used to scan for files in ``src_fs``. Set this if you only want to consider a sub-set of the resources in ``src_fs``. on_copy (callable, optional): A function callback called after a single file copy is executed. Expected signature is ``(src_fs, src_path, dst_fs, dst_path)``. workers (int): Use ``worker`` threads to copy data, or ``0`` (default) for a single-threaded copy. preserve_time (bool): If `True`, try to preserve mtime of the resources (defaults to `False`). rrNr%rr*rr+rrrrrrrcopy_dir<s rMc Cs*tdtt||||d||||d dS)zCopy a directory from one filesystem to another, checking times. .. deprecated:: 2.5.0 Use `~fs.copy.copy_dir_if` with ``condition="newer"`` instead. z9copy_dir_if_newer is deprecated. Use copy_dir_if instead.rrN)r r!r"r&rLrrrcopy_dir_if_newergs rNc  Cs|pdd}|p t}tt|} tt|} ddlm} t|||||t|dd} t|ddw} | c| Ot| | }| |rG|nd |d 0}| | | D]!}t | t | |}t | || ||rt| | || ||| || |qSWd n1swYWd n1swYWd n1swYWd n1swYWd d SWd d S1swYd S) aCopy a directory from one filesystem to another, depending on a condition. Arguments: src_fs (FS or str): Source filesystem (instance or URL). src_path (str): Path to a directory on the source filesystem. dst_fs (FS or str): Destination filesystem (instance or URL). dst_path (str): Path to a directory on the destination filesystem. condition (str): Name of the condition to check for each file. walker (~fs.walk.Walker, optional): A walker object that will be used to scan for files in ``src_fs``. Set this if you only want to consider a sub-set of the resources in ``src_fs``. on_copy (callable):A function callback called after a single file copy is executed. Expected signature is ``(src_fs, src_path, dst_fs, dst_path)``. workers (int): Use ``worker`` threads to copy data, or ``0`` (default) for a single-threaded copy. preserve_time (bool): If `True`, try to preserve mtime of the resources (defaults to `False`). See Also: `~fs.copy.copy_file_if` for the full list of supported values for the ``condition`` argument. cWsdS)Nr)argsrrrszcopy_dir_if..r)CopierFr.Tr0r) num_workersrN)r rr _bulkrQrKrr2r filesrr r3rC)rr*rr+r'rrrr _src_path _dst_pathrQr5r6 _thread_safecopierrJ copy_pathrrrr&s@ $       Pr&cCs|dkrdS|dkr-z ||}||}Wn ty YdSw|dup,|dup,||kS|dkrTz ||}||}Wn tyGYdSw|dupS|dupS||kS|dkr]||S|dkrg|| Std|)NrTrolderexists not_existsz!{} is not a valid copy condition.) getmodifiedrr[ ValueErrorformat)rr*rr+r' src_modified dst_modifiedrrrr3s>       r3c Csd}t|ddM}t|dd.}|||}|jdi}i} dD] } | |vr-|| | | <q!||d| iWdn1s@wYWddSWddS1sXwYdS) acCopy modified time metadata from one file to another. Arguments: src_fs (FS or str): Source filesystem (instance or URL). src_path (str): Path to a directory on the source filesystem. dst_fs (FS or str): Destination filesystem (instance or URL). dst_path (str): Path to a directory on the destination filesystem. )detailsFr.Tr0rb)metadata_changedmodifiedN)rgetinforawgetsetinfo) rr*rr+ namespacesr5r6src_meta src_details dst_detailsvaluerrrr>s  "r>)NNrF)rNNrF)F)FF)Nr$r$))__doc__ __future__rrtypingr errorsropenerrpathrrr r toolsr walkr TYPE_CHECKINGr rrrbaserobject_OnCopyrr#rr,r-r(r4rKrMrNr&r3r>rrrrsv      "  2   C 5 % 0 ' > 0