File: //lib/python3.9/site-packages/ansible/plugins/action/__pycache__/copy.cpython-39.pyc
a
�)g�j � @ s� d dl mZmZmZ eZd dlZd dlZd dlZd dl Z d dl
Z
d dl Z d dl m
Z d dlmZmZ d dlmZ d dlmZmZmZ d dlmZ d dlmZ d d l m Z e e� � �� d
�Z!d d � Z"d
d� Z#ddd�Z$G dd� de�Z%dS )� )�absolute_import�division�print_functionN)� constants)� AnsibleError�AnsibleFileNotFound)�FILE_COMMON_ARGUMENTS)�to_bytes� to_native�to_text)�boolean)�
ActionBase)�checksum)�state�path�_original_basename�recurse�forceZ
_diff_peek�srcc C s t dd� | �� D ��S )z)remove keys that are not relevant to filec s s" | ]\}}|t v r||fV qd S �N)�REAL_FILE_ARGS��.0�k�v� r �?/usr/lib/python3.9/site-packages/ansible/plugins/action/copy.py� <genexpr>/ � z+_create_remote_file_args.<locals>.<genexpr>��dict�items�� module_argsr r r �_create_remote_file_args- s r$ c C s t dd� | �� D ��S )z remove action plugin only keysc s s" | ]\}}|d vr||fV qdS ))�content�decryptNr r r r r r 4 r z+_create_remote_copy_args.<locals>.<genexpr>r r" r r r �_create_remote_copy_args2 s r' Fc s� g g g d��d � ��fdd� � d}|r0|| �}n| � tjj�}|du rJ| }|sZtj�|�}| �|�rlt|�}|r�||�s�|d7 }n|� tjj�s�|d7 }tj�| �rƈs�t�| �tj� | �f�d< �S t�
| �}t |j |j
ff�}� | ||� �S )
aD
Walk a filesystem tree returning enough information to copy the files
:arg topdir: The directory that the filesystem tree is rooted at
:kwarg base_path: The initial directory structure to strip off of the
files for the destination directory. If this is None (the default),
the base_path is set to ``top_dir``.
:kwarg local_follow: Whether to follow symlinks on the source. When set
to False, no symlinks are dereferenced. When set to True (the
default), the code will dereference most symlinks. However, symlinks
can still be present if needed to break a circular link.
:kwarg trailing_slash_detector: Function to determine if a path has
a trailing directory separator. Only needed when dealing with paths on
a remote machine (in which case, pass in a function that is aware of the
directory separator conventions on the remote machine).
:returns: dictionary of tuples. All of the path elements in the structure are text strings.
This separates all the files, directories, and symlinks along with
important information about each::
{ 'files': [('/absolute/path/to/copy/from', 'relative/path/to/copy/to'), ...],
'directories': [('/absolute/path/to/copy/from', 'relative/path/to/copy/to'), ...],
'symlinks': [('/symlink/target/path', 'relative/path/to/copy/to'), ...],
}
The ``symlinks`` field is only populated if ``local_follow`` is set to False
*or* a circular symlink cannot be dereferenced.
��files� directories�symlinks� c
s< t �| �D �]*\}}}|D ]�}t j�||�}t j�|||d� �} t j�|�r�t j�|�}
�r~t j�|
�r~�d �|
| f� q��d �t �|�| f� q�d �|| f� q|D �]�} t j�|| �} t j�|| |d� �}
t j�| �}t � |�}t j�| ��r"��r|j
|j f|v �r0�d �t �| �|
f� n�t � }t j�
| ��t jj�}tt|�dd�D ]H}t � d�|d|� ��}|j
|j f|v �r� �q�|�|j
|j f� �q\|j
|j f|v �r҈d �t �| �|
f� n4�d �||
f� t|�d }� |||�|�|
d � n�d �t �| �|
f� q��d �| |
f� q�q
dS )
a�
This is a closure (function utilizing variables from it's parent
function's scope) so that we only need one copy of all the containers.
Note that this function uses side effects (See the Variables used from
outer scope).
:arg topdir: The directory we are walking for files
:arg rel_offset: Integer defining how many characters to strip off of
the beginning of a path
:arg parent_dirs: Directories that we're copying that this directory is in.
:kwarg rel_base: String to prepend to the path after ``rel_offset`` is
applied to form the relative path.
Variables used from the outer scope
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
:r_files: Dictionary of files in the hierarchy. See the return value
for :func:`walk` for the structure of this dictionary.
:local_follow: Read-only inside of :func:`_recurse`. Whether to follow symlinks
Nr) r+ r ����/r* � )�rel_base)�os�walkr �join�islink�realpath�isfile�append�readlink�stat�st_dev�st_ino�set�dirname�split�sep�range�len�add�union)�topdirZ
rel_offsetZ parent_dirsr0 � base_pathZ sub_foldersr) �filename�filepathZ
dest_filepathZ real_filer= �dirpathZ dest_dirpathZreal_dir� dir_statsZ new_parentsZparent_dir_list�parentZ parent_stat�offset��_recurse� local_followZr_filesr r rM X sB
z _walk_dirs.<locals>._recurseFNr/ r+ )r, )�endswithr1 r r? r= �
startswithrA r4 r8 �basenamer9 � frozensetr: r; )rD rE rN �trailing_slash_detectorZsource_trailing_slashrK rI �parentsr rL r �
_walk_dirs7 s. S
rU c sB e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
� fd d � Z� Z S )� ActionModuleTc C s� d|vr>| j jrd|d< n$| jj�� |d< | jj�� |d d< t|d t�r�d|d v rdd|d d< |d �di ��d�d ur�d|d d d< |S )NZ
invocationzCENSORED: no_log is setr# r% z'CENSORED: content is a no_log parameterZ#VALUE_SPECIFIED_IN_NO_LOG_PARAMETER)�
_play_contextZno_log�_task�args�copy�
isinstancer �get)�self�resultr r r �_ensure_invocation� s
z ActionModule._ensure_invocationc
C s� t | jj�dd�dd�}t | jj�dd�dd�} t | jj�dd�dd�}
i } g | d < z| jj||d
�}W nD ty� } z,d| d < d |t| �f | d
< | W Y d } ~ S d } ~ 0 0 d }
| jj�dd �dkr�dt� t
�|�j � }
| j j
�|�� r�| j j
�||�}n|}| j|||| d�}|d �rt|d �rt|d u�rR| �||� d| d < d| d
< | S | j j
�||�}| j|||| d�}|d �r�| �s�d S t|�}||d k�r�| jj�r�|
�s�| d �| �|||�� | jj�r�| �||� d| d< | S | j j
�| j j
jd�}d }|
�s| �||�}n | �||� | �||� | j�|� |�rT| �| j j
j|f� |
�r^d S t | jj�}|� t ||||d�� | jj�d��s�||d< |
�r�|
|d< | j d||d�}n�| �||� | j�|� |
�r�d S |�r| j||dd�}|d �rd |� � v �r|d }t!| jj�}|� t ||dd d �� z
|d = W n t"�yP Y n0 |
�r`|
|d< | j d!||d�}|�d��s�||d< | � |� | S )"Nr& TF��strictr Zyes�raw�no�diff)r& �failedzcould not find src=%s, %s�msg�mode�preservez0%03o)�all_vars�followr �exists�isdir�&can not use content with a dir as destr �changed�source)r �destr rj �ansible.legacy.copy�� module_namer# � task_vars)ri rj ZislnkZ
lnk_source�file)rp r r r r �ansible.legacy.file)#r rX rY r\ Z_loaderZ
get_real_filer r r9 �S_IMODEr1 �st_mode� _connection�_shell�path_has_trailing_slash� join_pathZ_execute_remote_stat�#_remove_tempfile_if_content_definedr rW rd r7 Z_get_diff_dataZ
check_mode�tmpdirZ_transfer_fileZcleanup_tmp_fileZ
_fixup_perms2r' �updater �_execute_module�keysr$ �KeyError)r] � source_full�
source_relr% �content_tempfilerp rt rj r& r rb r^ �eZlmodeZ dest_fileZ dest_statusZlocal_checksumZtmp_srcZ remote_path�new_module_args�
module_returnZdest_status_nofollowr r r �
_copy_file� s�
�� ��
zActionModule._copy_filec
C s� t jtjd�\}}t�|d�}t|�}zRz|�|� W n6 tyl } z t� |� t|��W Y d}~n
d}~0 0 W |�
� n
|�
� 0 |S )z. Create a tempfile containing defined content )�dir�wbN) �tempfileZmkstemp�CZDEFAULT_LOCAL_TMPr1 �fdopenr �write� Exception�remove�close)r] r% �fdr� �f�errr r r �_create_content_tempfile� s
z%ActionModule._create_content_tempfilec C s |d urt �|� d S r )r1 r� )r] r% r� r r r r} � s z0ActionModule._remove_tempfile_if_content_definedNc
s� |du rt � }tt| ��||�}~| jj�dd�}| jj�dd�}| jj�dd�}t| jj�dd�dd�}t| jj�dd �dd�}d |d
< |s�|du r�d |d < nN|s�d
|d < n@|r�|dur�d|d < n*|dur�|dur�|�d�r�d|d < n|d
= |�d
��r| � |�S d} |du�r�z<t
|t ��s,t
|t ��r>| � t
�|��} n
| � |�} | }W nH t�y� }
z.d |d
< dt|
� |d < | � |�W Y d}
~
S d}
~
0 0 n�|�r�|�| jd|d�� | � |�S |�tjj�} z| �d|�}W nP t�y, } z6d |d
< t| �|d < t�� |d< | � |�W Y d} ~ S d} ~ 0 0 | |�tjj�k�rn|d tjjk�rb|dd� }n |tjj }g g g d�}
tj�t |dd���r�t ||| j j j d�}
| j j � |��s�| j j �!|d�}n|tj�"|�fg|
d< d}t dd �}d}| �#|�}t$� }|
d D ]�\}}|
d �r d}nt| jj�d d�dd�}| �%|||| |||�}|du �rZ�q|�d
��r~|�|� | � |� S tj�&|�}d}|D ] }tj�'||� |�(|� �q�d |v �r�|d �s�|d = d }|�p�|�d d�}�q|
d D ]�\}}||v �r�q�t)| jj�}tj�'||�|d!< d"|d#< | jj�d$d�|d%< d|d&< |d= | jd'||d(�}|�d
��r�|�|� | � |� S d }|�p�|�d d�}�q�|
d) D ]�\}}t)| jj�}tj�'||�|d!< ||d< d*|d#< d |d+< |
d �r�d|d < |�d%d�d,k�r|�*d%� | jd'||d(�}d }|�d
��rF|�|� | � |� S |�pV|�d d�}�q�|�r�t+|
d �d-k�r�|�|� d!|v �r�d|v�r�|d! |d< n|�t |||d.�� | �,| j j j-� | � |�S )/z& handler for file transfer operations Nr r% rp �
remote_srcFr` rN Tre z src (or content) is requiredrf zdest is requiredz&src and content are mutually exclusiver. rm z%could not write content temp file: %srq )rs rt r) � exceptionr- r( Zsurrogate_or_strict)�errors)rN rS r, )rn r* rj rd rn r Z directoryr Zdirectory_moderg r rv rr r+ �linkr rh r/ )rp r rn ).r �superrV �runrX rY r\ r rO r_ r[ �listr� �json�dumpsr� r
r r� r1 r r? Z _find_needler r � traceback�
format_excrl r rU ry rz r{ r| rQ Z_remote_expand_userr< r� r> r3 rB r$ �poprA Z_remove_tmp_pathr~ ) r] �tmprt r^ ro r% rp r� rN r� r� Ztrailing_slashr� Z source_filesrn r� Zmodule_executedZimplicit_directoriesr� r� rj �pathsZdir_pathZ
dir_componentr Z dest_pathr� Z target_path�� __class__r r r� � s�
"
�
zActionModule.run)NN)
�__name__�
__module__� __qualname__ZTRANSFERS_FILESr_ r� r� r} r� �
__classcell__r r r� r rV � s rV )NFN)&Z
__future__r r r �typeZ
__metaclass__r� r1 Zos.pathr9 r� r� Zansibler r� Zansible.errorsr r Zansible.module_utils.basicr Zansible.module_utils._textr r
r Z)ansible.module_utils.parsing.convert_boolr Zansible.plugins.actionr
Zansible.utils.hashingr rR r� rC r r$ r' rU rV r r r r �<module> s, �