관리-도구
편집 파일: 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