obnFhdZddlmZmZddlZddlZddlmZddlm Z ddl m Z m Z m Z mZddlmZdd lmZej&rdd lmZmZmZmZdd lmZeeeeegefZ dd Z dd Z ddZ ddZ ddZ ddZ! ddZ" ddZ# ddZ$ ddZ% ddZ&dZ'dZ(y)z6Functions for copying resources *between* filesystem. )print_functionunicode_literalsN)ResourceNotFound) manage_fs)abspathcombinefrombasenormpath)is_thread_safe)Walker)CallableOptionalTextUnion)FSc &t||d||||S)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_copyworkersrs )/usr/lib/python3/dist-packages/fs/copy.pycopy_fsrs 4 &'7- c Ztjdtt||d||||S)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)warningswarnDeprecationWarningrrs rcopy_fs_if_newerr&7s4 MMACU ' r c *t|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 conditionrrrrs rrrNs-@   #  r c&t||||d|y)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_pathrs r copy_filer1{s*&(HMr cXtjdtt||||d|S)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.r"r)r#r$r%r-r.s rcopy_file_if_newerr3s2 MME &(G= r c t|d5}t|d5}t|||||}|rt|||||d|cdddcdddS#1swYnxYw dddy#1swYyxYw)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/rr0r+r_src_fs_dst_fsdo_copys rr-r-sZ 6U +w vd + w(7HiG""/      s"A)$A A)A A))A2c urjdyfd}|r:j5j5|ddddddy|y#1swYxYw#1swYyxYw)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) overwriterNc.jr.jd5}j|dddn,j5}j|dddrt yy#1swYxYw#1swY'xYw)Nw) hassyspathopenbindownloaduploadcopy_modified_time) write_file read_filerr0rrr/s r _copy_lockedz(copy_file_internal.._copy_locked s   X &#. 6**5 6 6) 3Y h 2 3  vx B   6 6 3 3sA?B ?B B)copyr9)rr/rr0rr9rJs````` rr;r;s4  Hh$m T C C [[] FKKM  N        s#A9 A-A9-A6 2A99Bc|xs t}t|5}t|d5}|j5|j5|j|d|j ||D])}|j t |t||d+ ddddddddddddy#1swY"xYw#1swY&xYw#1swY*xYw#1swYyxYw)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. Tr7)recreateN)r rr9makedirsdirsmakedirr r )rrrsrc_rootdst_rootr<r=dir_paths rcopy_structurerTs* vxF 6 g vd + w    D 9 & GX >HOO(8X*FGRV$         sRC"CC  AB> C %C-C">C C  C CC C""C+c ,t||||d|||| y)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/rr0rrrrs rcopy_dirrW<s'<# r c `tjdtt||||d|||| y)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.r"rN)r#r$r%r*rVs rcopy_dir_if_newerrYgs;" MMCEW# r c |xsd}|xs t}tt|} tt|} ddlm} t |||||t |d5} t |d5} | j5| j5t| | }| |r|nd| 5}|j| | D]G}t| t| |}t| || ||s)|j| || ||| || |I d d d d d d d d d d d d d d d y #1swY*xYw#1swY.xYw#1swY2xYw#1swY6xYw#1swYy xYw) 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. cy)N)argss rzcopy_dir_if..sr r)CopierFr5Tr7r) num_workersrN)r rr _bulkr_rTrr9r filesr r r:rK)rr/rr0r+rrrr _src_path _dst_pathr_r<r= _thread_safecopierrS copy_paths rr*r*sH-,G  vxF*+I*+I6668X> 6U +Gw t9G  \\^ GW\\^ G)'7;L'3G- G & Wi @GH ' 8Ix3P QI)7Iy GXw J7IF G G G GGGG G G G G G GGGGGsr E".E?E D> +;D2 '!D2 D> E E!E"2D;7D> >E E  E EE E""E+c|dk(ry|dk(r4 |j|}|j|}|duxs |duxs||kDS|dk(r4 |j|}|j|}|duxs |duxs||kS|dk(r|j|S|dk(r|j| Stdj |#t$rYywxYw#t$rYywxYw)NrTr"olderexists not_existsz!{} is not a valid copy condition.) getmodifiedrrj ValueErrorformat)rr/rr0r+ src_modified dst_modifieds rr:r:s0H g  !--h7L!--h7L $/4'/,.  g  !--h7L!--h7L $/4'/,.  h }}X&& l "==***<CCINOO;      s#"C"C C  C  CCc@d}t|d5}t|d5}|j||}|jjdi}i} dD]} | |vs|| | | <|j |d| iddddddy#1swYxYw#1swYyxYw) 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. )detailsFr5Tr7rr)metadata_changedmodifiedN)rgetinforawgetsetinfo) rr/rr0 namespacesr<r=src_meta src_details dst_detailsvalues rrGrGs J 6U +@w vd + @wx ? @@@ @ @@@s(B:BB7BB BB)NNrF)rNNrF)F)FF)Nr(r())__doc__ __future__rrtypingr#errorsropenerrpathrr r r toolsr walkr TYPE_CHECKINGrrrrbaserobject_OnCopyrr&rr1r3r-r;rTrWrYr*r:rGr\r rrs8 $66! 66D"d+V34G    D    4   *d > : ;F  /j    J   (`   N   ;G|-P`@r