File: //usr/lib/python3.9/site-packages/ansible/plugins/action/__pycache__/assemble.cpython-39.pyc
a
�)g� � @ s� d dl mZmZmZ eZd dlZd dlZd dlZd dl Z d dl
Z
d dl m Z
d dlmZmZmZmZ d dlmZmZ d dlmZ d dlmZ d dlmZ G d d
� d
e�Z dS ) � )�absolute_import�division�print_functionN)� constants)� AnsibleError�
AnsibleAction�_AnsibleActionDone�AnsibleActionFail)� to_native�to_text)�boolean)�
ActionBase)�
checksum_sc s, e Zd ZdZddd�Zd � fdd� Z� ZS )
� ActionModuleTNFc C s< t jtjd�\}}t�|d�}d} d}
dd� tt�|��D �D ]�} |rR|�| �sRq>d|| f } tj �
| �r>|r�tj � | �� d�r�q>t
| jj| |d�d ��}
|
�� }W d
� n1 s�0 Y |
r�|�d � | �r
|�r
t�|�d }|�|� |d
d k�r
|�d � |�|� d} |�d ��r*d}
q>d}
q>|�� |S )z/ assemble a file from a directory of fragments )�dir�wbFc s s | ]}t |d d�V qdS )Zsurrogate_or_strict)�errorsN)r )�.0�p� r �C/usr/lib/python3.9/site-packages/ansible/plugins/action/assemble.py� <genexpr>0 � z8ActionModule._assemble_from_fragments.<locals>.<genexpr>z%s/%s�.)�decrypt�rbN�
r ���T)�tempfileZmkstemp�CZDEFAULT_LOCAL_TMP�os�fdopen�sorted�listdir�search�path�isfile�basename�
startswith�openZ_loaderZ
get_real_file�read�write�codecs�
escape_decode�endswith�close)�selfZsrc_path� delimiterZcompiled_regexp�
ignore_hiddenr ZtmpfdZ temp_path�tmpZ
delimit_meZ add_newline�f�fragmentZ fragment_fhZfragment_contentr r r �_assemble_from_fragments( s6 "&
z%ActionModule._assemble_from_fragmentsc
s� d| _ tt| ��||�}~|d u r(t� }| jj�dd �}| jj�dd �}| jj�dd �}| jj�dd�}| jj�dd �}| jj�dd�} | jj�d d�}
| jj�d
d �} �z�z�|d u s�|d u r�t d ��t
|dd
�r�|� | j d|d�� t
� �nDz| �d|�}W n2 t�y2 } zt t| ���W Y d } ~ n
d } ~ 0 0 tj�|��sNt d| ��d }
|d u�rft�|�}
| �|||
|
| �}t|�}| �|�}| j||| d�}i }| jj�� }dD ]}||v �r�||= �q�||d< ||d k�rd| jj �r�| � |||�}| j j � | j j j!d�}| �"||�}| �#| j j j!|f� |� t|d�� | j d||d�}|�rX||d< |� |� n|� | j d||d�� W n2 t$�y� } z|� | j%� W Y d } ~ n
d } ~ 0 0 W | �&| j j j!� n| �&| j j j!� 0 |S )NF�src�destr1 �
remote_srcZyes�regexp�followr2 r Tzsrc and dest are required)�strictzansible.legacy.assemble)� module_name� task_vars�filesz Source (%s) is not a directory)Zall_varsr; )r9 r: r1 r2 r Zchecksum)r7 zansible.legacy.copy)r= Z module_argsr> �diffzansible.legacy.file)'Z_supports_check_mode�superr �run�dictZ_task�args�get�popr r �updateZ_execute_moduler Z _find_needler r
r r% �isdir�re�compiler6 r Z_remote_expand_userZ_execute_remote_stat�copyZ
_play_contextr@ Z_get_diff_dataZ _connectionZ_shellZ join_pathZtmpdirZ_transfer_fileZ
_fixup_perms2r �resultZ_remove_tmp_path)r0 r3 r> rL r7 r8 r1 r9 r: r; r2 r �e�_rer% Z
path_checksumZ dest_statr@ Znew_module_args�optZ remote_pathZxfered�res�� __class__r r rB S sl "
$$zActionModule.run)NNFT)NN)�__name__�
__module__� __qualname__ZTRANSFERS_FILESr6 rB �
__classcell__r r rQ r r $ s
+r ) Z
__future__r r r �typeZ
__metaclass__r, r Zos.pathrI r Zansibler r Zansible.errorsr r r r Zansible.module_utils._textr
r Z)ansible.module_utils.parsing.convert_boolr Zansible.plugins.actionr
Zansible.utils.hashingr r r r r r �<module> s