a
�)g]R � @ s
d dl mZmZmZ eZdddddddd d
d d d
ddddddddd�Zd dlZd dlZd dl Z d dl
Z
d dl Z d dl Z d dl
Z
d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl m Z m Z zd dl Z dZ!W n e"�y. dZ!Y n0 z(d dl#m$Z$m%Z& e'e$d ��oTe&�(� Z)W n e"e*f�yt dZ)Y n0 dZ+zd d l,m-Z- dZ+W n e"�y� Y n0 ed�Z.d d l,m/Z/ d d l0m1Z1m2Z2m3Z3 d d!l4m5Z5m6Z7m8Z9 d d"l:m;Z; d d#l<m=Z=m>Z>m?Z?m@Z@ zd d$lAmBZB W nB e"�yV ZC z(eDd%�Ee1eC��� e�Fd � W Y dZC[Cn
dZC[C0 0 eG� ZHz�d dlIZId&D ] ZJeKeIeJd�ZLeL�rl �q��qleLdu �r�d'ZLeLD ]ZMeKeIeM�eHeM< �q�z eI�N� W n eO�y� eH�Pd(d� Y n0 W nR eQ�y6 d dlRZRd)eRjRiZHzd dlNZNeNjNeHd(< W n eQ�y0 Y n0 Y n0 d d*lSmTZTmUZUmVZVmWZWmXZXmYZYmZZZ d d+l[m\Z\ d d,l]m^Z^ d d-l_m`ZambZcmdZemfZfmgZgmhZh d d.limjZjmkZkmlZl d d/lmmnZnmoZo d d0lpmqZqmrZrmsZsmtZtmuZumvZv d d1lwmxZxmyZymzZz d d2l{m|Z|m}Z}m~Z~mZm�Z�m�Z�m�Z�m�Z� d d3l�m�Z�m�Z�m�Z� d d4l�m�Z�m�Z� d d5l�m�Z� d d6l�m�Z�m�Z�m�Z�m�Z� d d7l�m�Z�m�Z�m�Z�m�Z� e�eTeWfZ�e��d8ej��Z�e�Z�ze� W n e��y� e�Z�Y n0 ze� W n e��y� e�Z�Y n0 eoZ�da�eGeGd9d:�eGd;d:�eGd;d:�eGd;d:�eGd;d:�eGd;d:�eGd;d:�eGd;d<gd=�eGd>deqd?gfd@�dA� Z�e��dB�Z�e��dC�Z�e��dD�Z�e��dE�Z�ej�dFkZ�dGej� k�o�dHk n Z�e��p�e�Z�e��s�eDdIdJ��ej���� � � e�Fd � dKdL� Z�dMdN� Z�dOdP� Z�d[dQdR�Z�dSdT� Z�d\dUdV�Z�G dWdX� dXe��Z�dYdZ� Z�dS )]� )�absolute_import�division�print_functionZnoatime�append�
compressedZnocowZnodumpZdirsyncZextentsZ encrypted� blocksizeZ immutableZindexedZ
journalledZinlineZzeroZ synchronousZnotailZ blockrootZundeleteZ
compressedrawZcompresseddirty)�A�a�c�C�d�D�e�E�h�i�I�j�N�s�S�t�T�u�X�ZN)�chain�repeatTF)�journal�daemonZsendv)�selinux)� selectors� )� to_native�to_bytes�to_text)�jsonify�container_to_bytes�container_to_text)�ModuleArgumentSpecValidator)�lenient_lowercase�bytes_to_human�human_to_bytes� SIZE_RANGES)�jsonzJ
{{"msg": "Error: ansible requires the stdlib json: {0}", "failed": true}})Zavailable_algorithms�
algorithms)�md5�sha1Zsha224�sha256Zsha384Zsha512r0 r1 )�KeysView�Mapping�MutableMapping�Sequence�MutableSequence�Set�
MutableSet)�get_best_parsable_locale)� get_bin_path)�
_PERM_BITS�_EXEC_PERM_BITS�
_DEFAULT_PERM�
is_executable�format_attributes�get_flags_from_attributes)�get_distribution�get_distribution_version�get_platform_subclass)�
get_exception� literal_eval)� env_fallback�
remove_values�
sanitize_keys�DEFAULT_TYPE_VALIDATORS� PASS_VARS�
PASS_BOOLS)�AnsibleFallbackNotFound� AnsibleValidationErrorMultiple�UnsupportedError)�PY2�PY3�b� binary_type�
integer_types� iteritems� string_types� text_type)�map�reduce� shlex_quote)�check_missing_parameters� safe_eval)�get_all_subclasses)�BOOLEANS�BOOLEANS_FALSE�
BOOLEANS_TRUE�boolean)� deprecate�get_deprecation_messages�get_warning_messages�warnzB^(?:.+[-_\s])?pass(?:[-_\s]?(?:word|phrase|wrd|wd)?)(?:[-_\s].+)?$�raw)�type�str�attr)rg �aliases�boolZANSIBLE_UNSAFE_WRITES)rg �default�fallback) �mode�owner�group�seuser�serole�selevel�setype�
attributes�
unsafe_writesz^[-]{0,2}pass[-]?(word|wd)?z[+=-]z[^ugo]z [^rwxXstugo])� � )� � )rw z~
{"failed": true, "msg": "ansible-core requires a minimum of Python2 version 2.7 or Python3 version 3.5. Current version: %s"}� c C s t �� S )a+
**Deprecated** Use :py:func:`platform.system` directly.
:returns: Name of the platform the module is running on in a native string
Returns a native string that labels the platform ("Linux", "Solaris", etc). Currently, this is
the result of calling :py:func:`platform.system`.
)�platform�system� r~ r~ �>/usr/lib/python3.9/site-packages/ansible/module_utils/basic.py� get_platform s r� c O s t | �}t| |��|�S )zV**Deprecated**: Use ansible.module_utils.common.sys_info.get_platform_subclass instead)rD �super�__new__)�cls�args�kwargsZ platform_clsr~ r~ r �load_platform_subclass s r� c C s t t| ��S )zQ**Deprecated**: Use ansible.module_utils.common._utils.get_all_subclasses instead)�list�_get_all_subclasses)r� r~ r~ r r] $ s r] c C sL t | �} g }t| �}|}d}|�r.z| �dd|�}W n, ty` |�d| d|� � Y �q.Y n0 d}|}|s�z| �dd|�}W n ty� d}Y n0 z| �d|d |�}W qj ty� |dkr�|�d| d|� � Y q�|}Y qjY qj0 qj|r |�d| ||� � |�dd� |�d| ||d � � |}q d �|�}|�rHt||�}|S )
z; Remove strings that look like passwords from log messages r" �@r Nz://�:rw �********r{ )r# �len�rindex�
ValueError�insert�index�joinrH )�data�
no_log_values�outputZbeginZ
prev_begin�sep�endZsep_search_endr~ r~ r �heuristic_log_sanitize, sF
r� c C s
t durt } n�ttj�dkrntj�tjd �rPttjd d�}|�� } |� � q�tjd } t
r�| j ddd�} n t r~tj
�� } n tj
j�� } | a zt�| �d��}W n$ ty� td� t�d� Y n0 t r�t|�}z
|d W S t�y td � t�d� Y n0 dS )
a1 read the modules parameters and store them globally.
This function may be needed for certain very dynamic custom modules which
want to process the parameters that are being handed the module. Since
this is so closely tied to the implementation of modules we cannot
guarantee API stability for it (it may change between versions) however we
will try not to break it gratuitously. It is certainly more future-proof
to call this function and consume its outputs than to implement the logic
inside it as a copy in your own code.
Nr" �rb�utf-8�surrogateescape��errorsz�
{"msg": "Error: Module unable to decode valid JSON on stdin. Unable to figure out what parameters were passed", "failed": true}ZANSIBLE_MODULE_ARGSz�
{"msg": "Error: Module unable to locate ANSIBLE_MODULE_ARGS in json data from stdin. Unable to figure out what parameters were passed", "failed": true})�
_ANSIBLE_ARGSr� �sys�argv�os�path�isfile�open�read�closerQ �encoderP �stdin�bufferr. �loads�decoder� �print�exit�json_dict_unicode_to_bytes�KeyError)r� �fd�paramsr~ r~ r � _load_paramsm s4
r� c C sD t �� }d| |tjf }|r(|d| 7 }|r8|d| 7 }|d7 }|S )NzDFailed to import the required Python library (%s) on %s's Python %s.z This is required %s.z See %s for more info.z� Please read the module documentation and install it in the appropriate location. If the required library is installed, but Ansible is using the wrong Python interpreter, please consult the documentation on ansible_python_interpreter)r| Znoder� �
executable)Zlibrary�reason�url�hostname�msgr~ r~ r �missing_required_lib� s r� c @ sL e Zd Zd�dd�Zedd� �Zdd� Zd�d d
�Zd�d d �Zd
d� Z dd� Z
dd� Z d�dd�Z dd� Z
d�dd�Zdd � Zd d � Zd d � Zd�d!d"�Zd�d#d$�Zd�d%d&�Zd�d'd(�Zd�d)d*�Zd�d+d,�Zed-d.� �Zed/d0� �Zed1d2� �Z d�d3d4�Z d5d6� Z d�d7d8�Z d�d9d:�Z d;d<� Z!d=d>� Z"d�d?d@�Z#d�dAdB�Z$dCdD� Z%dEdF� Z&dGdH� Z'd�dIdJ�Z(dKdL� Z)dMdN� Z*d�dOdP�Z+dQdR� Z,dSdT� Z-dUdV� Z.dWdX� Z/dYdZ� Z0d[d\� Z1d]d^� Z2d_d`� Z3d�dadb�Z4dcdd� Z5dedf� Z6dgdh� Z7didj� Z8dkdl� Z9dmdn� Z:dodp� Z;d�dqdr�Z<dsdt� Z=dudv� Z>dwdx� Z?d�d{d|�Z@d}d~� ZAdd�� ZBeBZCd�d�d��ZDeEZEed�d�� �ZFdS )��
AnsibleModuleFNc C s t j�t�| _|| _|| _d| _|| _|| _ || _
|| _ || _ | | _
|
| _g | _d| _d| _d| _d| _d| _d| _i | _i | _d| _i | _g | _t� | _ d| _ |r�t � � D ] \} } | | jvr�| | j| < q�t � | _!| �"� | �#� | �$� t%| j| j
| j | j | j
| j�| _&| j&�'| j(�| _)| j(�*| j)j+� | j!�*| j)j,� | j�*| j)j-� z| j)j.d }
W n t/�yr d}
Y n0 |
�r�| j)j.j0}t1|
t2��r�dj3| jd|d�}| j4|d � | j�r�| j�s�| j5d
d | j d � t6| _7| j �s�| �8� d| _9d| _:d| _;| �<� dS )
a7
Common code for quickly building an ansible module in Python
(although you can write modules with anything that can return JSON).
See :ref:`developing_modules_general` for a general introduction
and :ref:`developing_program_flow_modules` for more detailed explanation.
FN�LOG_USERr r{ z1Unsupported parameters for ({name}) {kind}: {msg}�module)�name�kindr� �r� Tz.remote module (%s) does not support check mode)Zskippedr� )=r� r� �basename�__file__�_name�
argument_spec�supports_check_mode�
check_mode�
bypass_checks�no_log�mutually_exclusive�required_together�required_one_of� required_if� required_by�
cleanup_files�_debugZ_diffZ _socket_path�_shell�_syslog_facility�
_verbosity�run_command_environ_update�_cleanZ_string_conversion_actionrj Z
_legal_inputsr� Z_options_context�_tmpdir�FILE_COMMON_ARGUMENTS�items�setr� �
_check_localer� �_set_internal_propertiesr) Z validatorZvalidater� Zvalidation_result�updateZvalidated_parametersZ_no_log_values�_aliasesr� �
IndexErrorr� �
isinstancerO �format� fail_json� exit_jsonrJ Z _CHECK_ARGUMENT_TYPES_DISPATCHER�_log_invocation�_selinux_enabled�_selinux_mls_enabled�_selinux_initial_context�_set_cwd)�selfr� r� r� r� r� r� Zadd_file_common_argsr� r� r� �k�v�errorr� r~ r~ r �__init__� s|
�
zAnsibleModule.__init__c
C s. | j d u �r(d }| jd ur0tj�tj�| j��}|d ur�tj�|�s�ztj|dd� W nB tt fy� } z&| �
d|t |�f � d }W Y d }~nd }~0 0 | �
d| � dt � � }zt
j||d�}W nD tt f�y
} z&| jd||t |�f d� W Y d }~n
d }~0 0 | j�s"t�tj|� || _ | j S ) Ni� )rn zCUnable to use %s as temporary directory, failing back to system: %sz�Module remote_tmp %s did not exist and was created with a mode of 0700, this may cause issues when running as another user. To avoid this, create the remote_tmp dir with the correct permissions manuallyzansible-moduletmp-%s-)�prefix�dirzDFailed to create remote module tmp path at dir %s with prefix %s: %sr� )r� Z _remote_tmpr� r� �
expanduser�
expandvars�exists�makedirs�OSError�IOErrorre r# �time�tempfileZmkdtempr� Z_keep_remote_files�atexit�register�shutil�rmtree)r� Zbasedirr Zbasefile�tmpdirr~ r~ r r� s8
�� �� zAnsibleModule.tmpdirc C s t |� | �d| � d S )Nz [WARNING] %s)re �log)r� Zwarningr~ r~ r re @ s zAnsibleModule.warnc C sZ |d ur|d urt d��t||||d� |d urD| �d||f � n| �d||f � d S )Nz=implementation error -- version and date must not both be set��version�date�collection_namez[DEPRECATION WARNING] %s %s)�AssertionErrorrb r� )r� r� r� r� r� r~ r~ r rb D s zAnsibleModule.deprecatec C sH |du r |� d|� dd��}|du r(i S tj�tj�|��}t|dd�}|� dd�rttj�|�rttj�|�}t|�}|� dd�}|� d d�}|� d
d�}|� d d�}|� d d�}|� d
d�} |� dd�}
||| g} | � � r�| �
|
� | � |�} t t
| ��D ]$}
|
dur�| |
dkr�| |
| |
< q�|� dd�}t||||||| |
| |d�
S )a
many modules deal with files, this encapsulates common
options that the file module accepts such that it is directly
available to all modules and they can share code.
Allows to overwrite the path/dest module argument by providing path.
Nr� �dest�surrogate_or_strictr� �followFrn ro rp rq rr rt rs Z_defaultru )
r� rn ro rp rq rr rt rs � secontextru )�getr� r� r� r� r$ �islink�realpathr# �selinux_mls_enabledr �selinux_default_context�ranger� �dict)r� r� r� �b_pathrn ro rp rq rr rt rs r Zdefault_secontextr ru r~ r~ r �load_file_common_argumentsO s:
�z(AnsibleModule.load_file_common_argumentsc C s" | j d u r tot�� dk| _ | j S �Nr" )r� � HAVE_SELINUXr Zis_selinux_mls_enabled�r� r~ r~ r r � s
z!AnsibleModule.selinux_mls_enabledc C s" | j d u r tot�� dk| _ | j S r )r� r r Zis_selinux_enabledr
r~ r~ r �selinux_enabled� s
z AnsibleModule.selinux_enabledc C s. | j d u r(g d�| _ | �� r(| j �d � | j S )N)NNN)r� r r r
r~ r~ r �selinux_initial_context� s
z%AnsibleModule.selinux_initial_contextr c C sh | � � }| �� s|S zt�t|dd�|�}W n tyB | Y S 0 |d dkrT|S |d �dd�}|S )Nr� r� r ���r" r� rw )r r r Z matchpathconr# r� �split)r� r� rn �context�retr~ r~ r r � s
z%AnsibleModule.selinux_default_contextc
C s� | � � }| �� s|S zt�t|dd��}W nR ty| } z:|jtjkrZ| j|d| d� n| j|dd� W Y d }~n
d }~0 0 |d dkr�|S |d � d d
�}|S ) Nr� r� zpath %s does not exist�r� r� z"failed to retrieve selinux contextr r r" r� rw )
r r r Zlgetfilecon_rawr# r� �errno�ENOENTr� r )r� r� r r r r~ r~ r �selinux_context� s $ z AnsibleModule.selinux_contextTc C sB t |dd�}|r$tj�tj�|��}t�|�}|j}|j}||fS �Nr� r� )r$ r� r� r� r� �lstat�st_uid�st_gid)r� r� �expandr �st�uid�gidr~ r~ r �user_and_group� s
z AnsibleModule.user_and_groupc C sJ t j�tt j�t j�|��dd��}t j�|�s>t j�|�}q$t|dd�S )z�
Takes a path and returns it's mount point
:param path: a string type with a filesystem path
:returns: the path to the mount point as a text type
r� r� ) r� r� r r$ r� r� �ismount�dirnamer% )r� r� r r~ r~ r �find_mount_point� s $ z AnsibleModule.find_mount_pointc
C s� z t dd�}|�� }|�� W n ty2 Y dS 0 | �|�}|D ]X}|�dd�\}}}} }
t|�t|�krB| jD ]&} | |v rr| �|�} d| f S qrqBdS )z�
Returns a tuple containing (True, selinux_context) if the given path is on a
NFS or other 'special' fs mount point, otherwise the return will be (False, None).
z /proc/mounts�r)FN� � T) r� � readlinesr� � Exceptionr# r r$ Z_selinux_special_fsr )
r� r� �fZ
mount_dataZpath_mount_point�lineZdeviceZ mount_pointZfstype�options�restZfsZspecial_contextr~ r~ r �is_special_selinux_path� s
z%AnsibleModule.is_special_selinux_pathc C s$ | � � s |S | �|�}| �||d�S )NF)r r �set_context_if_different)r� r� �changedr r~ r~ r �set_default_selinux_context� s
z)AnsibleModule.set_default_selinux_contextc
C sx | � � s |S | �|�rdS | �|�}t|�}| �|�\}}|rD|}n`tt|��D ]R} t|�| krP|| d ur�|| || kr�|| || < qP|| d u rP|| || < qP||k�rt|d ur�d|vr�i |d< ||d d< d|vr�i |d< ||d d< z&| jr�W dS t� t
|�d� |��}
W nB t �yV } z(| j
|dt
| � |||d� W Y d } ~ n
d } ~ 0 0 |
dk�rp| j
|d d
� d}|S ) NT�beforer �afterr� zinvalid selinux context: %s)r� r� � new_context� cur_contextZ input_wasr zset selinux context failedr )r � check_file_absent_if_check_moder r� r- r r� r� r Z lsetfileconr# r� r� r� ) r� r� r r/ �diffr4 r3 Z
is_special_seZ
sp_contextr �rcr r~ r~ r r. � sF
�
z&AnsibleModule.set_context_if_differentc C sf |d u r |S t |dd�}|r0tj�tj�|��}| �|�r>dS | �||�\}}z t|�} W nP ty� zt �
|�j } W n, t y� t
|�}| j|d| d� Y n0 Y n0 || k�rb|d ur�d|vr�i |d< ||d d< d|vr�i |d< | |d d< | j�rdS zt�|| d � W nH ttf�y\ }
z*t
|�}| j|d
t
|
� d� W Y d }
~
n
d }
~
0 0 d}|S ) Nr� r� Tz'chown failed: failed to look up user %sr r1 ro r2 r zchown failed: %s)r$ r� r� r� r� r5 r �intr� �pwd�getpwnam�pw_uidr� r% r� r� �lchownr� r� ) r� r� ro r/ r6 r r �orig_uid�orig_gidr r r~ r~ r �set_owner_if_different sB
,z$AnsibleModule.set_owner_if_differentc
C sH |d u r |S t |dd�}|r0tj�tj�|��}| �|�r>dS | �||�\}}z t|�} W nP ty� zt �
|�j } W n, t y� t
|�}| j|d| d� Y n0 Y n0 || k�rD|d ur�d|vr�i |d< ||d d< d|vr�i |d< | |d d< | j�rdS zt�|d | � W n* t�y> t
|�}| j|d
d� Y n0 d}|S ) Nr� r� Tz(chgrp failed: failed to look up group %sr r1 rp r2 r z chgrp failed)r$ r� r� r� r� r5 r r8 r� �grp�getgrnam�gr_gidr� r% r� r� r< r� )
r� r� rp r/ r6 r r r= r> r r~ r~ r �set_group_if_differentH sB
z$AnsibleModule.set_group_if_differentc
C s� |d u r |S t |dd�}|r0tj�tj�|��}| �|�r>dS t�|�}t|t�s�zt|d�}W n� t y� z| �
||�}W n@ t y� } z(t |�}| j |dt
|�d� W Y d }~n
d }~0 0 |t�|�kr�t |�}| j |d|d� Y n0 t�|j�} | |k�r�|d u�rPd|v�r i |d< d | |d d
< d |v�r@i |d < d | |d d
< | j�r\dS z|ttd ��rxt�||� n^tj�|��s�t�||� nBt�|�}
t�||� t�|�} |
j| jk�r�t�|t�|
j�� W n� t�y> } zLtj�|��r|jtjtjtjfv �rn|jtjtj fv �r(n� W Y d }~nPd }~0 t �y� } z.t |�}| j |d
t
|�t � � d� W Y d }~n
d }~0 0 t�|�}t�|j�} | | k�r�d}|S )Nr� r� T� z&mode must be in octal or symbolic form)r� r� �detailsz6Invalid mode supplied, only permission info is allowedr1 �0%03orn r2 �lchmodz chmod failed�r� r� rE � exception) r$ r� r� r� r� r5 r r� r8 r( �_symbolic_mode_to_octalr% r� r# �stat�S_IMODE�st_moder� �hasattrrG r �chmodr� r �EACCES�EPERMZEROFSr �ELOOP� traceback�
format_exc)
r� r� rn r/ r6 r r � path_statr � prev_modeZunderlying_statZnew_underlying_stat�new_moder~ r~ r �set_mode_if_differentq s�
�
��
z#AnsibleModule.set_mode_if_differentc
C s� |d u r |S t |dd�}|r0tj�tj�|��}| �|�r>dS | j|dd�}d}|�d�rn|d }|d d � }|�d
d �|ks�|d k�r~| � d
�} | �r~| d||f |g} d}|d ur�d|vr�i |d< |�d
�|d d< d|vr�i |d< d||f |d d< | j
�s~z4| � | �\}
} } |
dk�s&| �r6t d| | ��W nD t �y| }
z*| j
t|�dt|
�t�� d� W Y d }
~
n
d }
~
0 0 |S )Nr� r� TF��include_version�=)�-�+r r" �
attr_flagsr{ r\ Zchattrz%s%sr1 ru r2 z"Error while setting attributes: %sz
chattr failedrH )r$ r� r� r� r� r5 �get_file_attributes�
startswithr r; r� � run_commandr( r� r% r# rS rT )r� r� ru r/ r6 r r �existingZattr_mod�attrcmdr7 �out�errr r~ r~ r �set_attributes_if_different� sD
� z)AnsibleModule.set_attributes_if_differentc C s� i }| � dd�}|r�|r dnd}|||g}zh| �|�\}}}|dkr�|�� } d}
|rhd}
| d �� |d< | |
�dd ��� |d
< t|d
�|d < W n ty� Y n0 |S ) NZlsattrFz-vdz-dr r" r� r\ r{ r^ ru )r; ra r �strip�replacer@ r( ) r� r� rZ r� rc �flagsr7 rd re �resZattr_flags_idxr~ r~ r r_ � s$
z!AnsibleModule.get_file_attributesc
C s� t �|j�}|�d�D ]�}t�|�}t�|�}|�d�}|dk}|dksP|dkrTd}t�|�rjt d| ��t
|�D ]L\} }
t �|
�r�t d| ��|D ](} | � || |
|�} | �
| || | |�}q�qrq|S )z�
This enables symbolic chmod string parsing as stated in the chmod man-page
This includes things like: "u=rw-x+X,g=r-x+X,o=r-x+X"
�,r r{ r Zugoz$bad symbolic permission for mode: %s)rK rL rM r �MODE_OPERATOR_RE�findall�pop�USERS_RE�matchr� � enumerate�PERMS_RE�#_get_octal_mode_from_symbolic_perms�_apply_operation_to_mode)
r� rU Z
symbolic_moderW rn ZpermlistZopersZusers� use_umask�idx�perms�user�
mode_to_applyr~ r~ r rJ s"
z%AnsibleModule._symbolic_mode_to_octalc C s� |dkr^| dkr t jt jB }n*| dkr4t jt jB }n| dkrHt jt jB }|tA }||@ |B }n&|dkrp||B }n|dkr�|||@ }|S )Nr[ r �g�or] r\ )rK �S_IRWXU�S_ISUID�S_IRWXG�S_ISGID�S_IRWXO�S_ISVTX� PERM_BITS)rx �operatorry Z current_mode�maskZ inverse_maskrW r~ r~ r rt 2 s
z&AnsibleModule._apply_operation_to_modec s� t �| j�}t �| j�}|t@ dk}|p*|}t�d�}t�|� |tA } |rldt jidt j idt j
id�}
nddiddiddid�}
|r�| t j @ nt j |r�| t j @ nt j |r�| t j@ nt jt j
d|t j@ |t j@ d> |t j@ d> d�|r�| t j@ nt j|�r| t j@ nt j|�r| t j @ nt j t jd|t j@ d? |t j@ |t j@ d> d�|�rX| t j@ nt j|�rl| t j@ nt j|�r�| t j
@ nt j
dt j|t j@ d? |t j@ d? |t j@ d�d��|
�� D ]\} } �| �| � �q�� �fdd�}
t|
|d�S ) Nr r )r rz r{ rw � )r$ �w�xr r r rz r{ c s | �� | B S �Nr~ )rn Zperm�rx Zuser_perms_to_modesr~ r � or_reduce� s zDAnsibleModule._get_octal_mode_from_symbolic_perms.<locals>.or_reduce)rK rL rM �S_ISDIR�EXEC_PERM_BITSr� �umaskr� �S_IXUSR�S_IXGRP�S_IXOTH�S_IRUSR�S_IWUSRr} r| r~ r� �S_IRGRP�S_IWGRPr �S_IROTH�S_IWOTHr� r� r� rY )rU rx rw ru rV Z is_directoryZhas_x_permissionsZapply_X_permissionr� Z rev_umaskZX_perms�key�valuer� r~ r� r rs E s`
�� �
�
�� z1AnsibleModule._get_octal_mode_from_symbolic_permsc C s� | � |d |d ||�}| �|d |d |||�}| �|d |d |||�}| �|d |d |||�}| �|d |d |||�}|S )Nr� r ro rp rn ru )r. r? rC rX rf �r� Z file_argsr/ r6 r r~ r~ r � set_fs_attributes_if_different� s �����z,AnsibleModule.set_fs_attributes_if_differentc C s | j otj�|� S r� )r� r� r� r� )r� Z file_pathr~ r~ r r5 � s z-AnsibleModule.check_file_absent_if_check_modec C s | � ||||�S r� �r� r� r~ r~ r �%set_directory_attributes_if_different� s z3AnsibleModule.set_directory_attributes_if_differentc C s | � ||||�S r� r� r� r~ r~ r � set_file_attributes_if_different� s z.AnsibleModule.set_file_attributes_if_differentc C sh |� d|� dd��}|du r |S t|dd�}tj�|��rd| �|�\}}||d< ||d< zt�|�d }W n ty� t |�}Y n0 zt
� |�d }W n ty� t |�}Y n0 ||d < ||d
< t� |�}d t
�|t
j � |d < tj�|�r�d
|d< n<tj�|��rd|d< n$t�
|�jdk�r0d|d< nd|d< | �� �rVd�| �|��|d< |t
j |d< |S )z�
for results that are files, supplement the info about the file
in the return path with stats about the file path.
r� r� Nr� r� r r r ro rp rF rn �link�stateZ directoryr" Zhard�filer� r �size)r r$ r� r� r� r r9 �getpwuidr� rh r@ �getgrgidr rK rL �ST_MODEr �isdir�st_nlinkr r� r �ST_SIZE) r� r� r� r r r rx rp r r~ r~ r �
add_path_info� s>
zAnsibleModule.add_path_infoc
C s� zt �t jd� W n� t jyZ t| �}t �t j|� |tjd< |tjd< |tjd< Y n> ty� } z&| jdt |� t
� � d� W Y d}~n
d}~0 0 dS )z�
Uses the locale module to test the currently set locale
(per the LANG and LC_CTYPE environment settings)
r{ �LANG�LC_ALL� LC_MESSAGESzLAn unknown error was encountered while attempting to validate the locale: %s�r� rI N) �locale� setlocaler� �Errorr: r� �environr( r� r# rS rT )r� Z best_localer r~ r~ r r� � s
��zAnsibleModule._check_localec C s� |d u r| j }|d u r | j}tD ]�}d| }||v r�|tv r\t| t| d | �|| �� nt| t| d || � || jv r�| j|= q t| t| d �s t| t| d t| d � q d S )Nz _ansible_%sr r" )r� r� rK rL �setattrra rN )r� r� Zmodule_parametersr� Z param_keyr~ r~ r r� � s
z&AnsibleModule._set_internal_propertiesc C s t |||�S r� )r\ )r� r� �localsZinclude_exceptionsr~ r~ r r\ � s zAnsibleModule.safe_evalc C s t � | _dS )z� read the input and set the params attribute.
This method is for backwards compatibility. The guts of the function
were moved out in 2.1 so that custom modules could read the parameters.
N)r� r� r
r~ r~ r r� s zAnsibleModule._load_paramsc
C s� t r�z>d| j }tt| jtj�}t�t|�d|� t�tj|� W n@ t y� } z(| j
dt |� t �
� |d� W Y d }~n
d }~0 0 d S )N�
ansible-%sr z�Failed to log to syslog (%s). To proceed anyway, disable syslog logging by setting no_target_syslog to True in your Ansible config.)r� rI Z
msg_to_log)�
HAS_SYSLOGr� �getattr�syslogr� r� Zopenlogrh ZLOG_INFO� TypeErrorr� r# rS rT )r� r� r� �facilityr r~ r~ r �_log_to_syslog s
��z AnsibleModule._log_to_syslogc C s | j r| �d| � d S )Nz
[debug] %s)r� r� )r� r� r~ r~ r �debug s zAnsibleModule.debugc C s~ | j �sz|d u rt� }d| j }t|t�r6|�dd�}t|ttf�sTtdt|� ��t|t�rtt |�dd�| j
�}n t || j
�}t r�|}n |� dd�}t
�rpdtj�t�fg}|D ]8}|�� t|| � }} |dv r�d| }|�|| f� q�zbt�r,tt| jtj�d? }
tjf d ||f |
d
�t|��� n tjf d d ||f it|��� W n t �yl | � |� Y n0 n
| � |� d S ) Nr� r� rh z msg should be a string (got %s)ZMODULE) ZPRIORITY�MESSAGEZ
MESSAGE_IDZ CODE_FILEZ CODE_LINEZ CODE_FUNC�SYSLOG_FACILITYZSYSLOG_IDENTIFIERZ
SYSLOG_PIDz_%srw z%s %s)r� r� r� ) r� r r� r� rS r� rW r� rg rH r� rQ r� � has_journalr� r� r� r� �upperrh r r� r� r� r� r� r �sendr� r� ) r� r� �log_argsr� Z journal_msgZ
syslog_msgZ journal_args�argr� r� r� r~ r~ r r� sP
�����
zAnsibleModule.logc C s� t � }| jD ]�}| j�||�}| j�|i �}|�dd�}|du rbt�|�rbd||< | �d| � q | �|�rvd||< q | j| }t |t
t f�s�t |�}nt |t
�r�|�
d�}t|| j�||< q dd� |�� D �}|r�d d
�|� }nd }| j||d � dS )
z! log that ansible ran the module r� NZNOT_LOGGING_PASSWORDz Module did not set no_log for %sZNOT_LOGGING_PARAMETERr� c S s$ g | ] \}}d t |�t |�f �qS )z%s=%s�r# )�.0r� �valr~ r~ r �
<listcomp>s � z1AnsibleModule._log_invocation.<locals>.<listcomp>zInvoked with %sr% ZInvoked)r� )r r� rj r r� �PASSWORD_MATCH�searchre ra r� rW rS rh r� r� r� r� r� r� )r� r� ZparamZcanonZarg_optsr� Z param_valr� r~ r~ r r� Z s*
z AnsibleModule._log_invocationc C s� z(t �� }t �|t jt jB �s$t� �|W S ty� | jt j�d�t �
� fD ]H}z0t �|t jt jB �r�t � |� |W Y S W qN ty� Y qN0 qNY n0 d S )Nz$HOME) r� �getcwd�access�F_OK�R_OKr( r� r� r� r� Z
gettempdir�chdir)r� �cwdr~ r~ r r� { s
zAnsibleModule._set_cwdc
C sd d}zt ||d�}W nJ ty^ } z2|r:| jt|�d� n|W Y d}~S W Y d}~n
d}~0 0 |S )aQ
Find system executable in PATH.
:param arg: The executable to find.
:param required: if executable is not found and required is ``True``, fail_json
:param opt_dirs: optional list of directories to search in addition to ``PATH``
:returns: if found return full path; otherwise return None
N)r� �opt_dirsr� )r; r� r� r% )r� r� �requiredr� Zbin_pathr r~ r~ r r; � s
&zAnsibleModule.get_bin_pathc
C sP |du r |S z
t |�W S tyJ } z | jt|�d� W Y d}~n
d}~0 0 dS )z!Convert the argument to a booleanNr� )ra r� r� r# )r� r� r r~ r~ r ra � s
zAnsibleModule.booleanc
C sD z
t |�W S ty> } z | jt|�d� W Y d }~n
d }~0 0 d S �Nr� )r& � UnicodeErrorr� r% )r� r� r r~ r~ r r& � s
zAnsibleModule.jsonifyc C s
t �|�S r� )r. r� )r� r� r~ r~ r � from_json� s zAnsibleModule.from_jsonc C s || j vr| j �|� d S r� )r� r �r� r� r~ r~ r �add_cleanup_file� s
z AnsibleModule.add_cleanup_filec C s | j D ]}| �|� qd S r� )r� �cleanupr� r~ r~ r �do_cleanup_files� s
z AnsibleModule.do_cleanup_filesc C sJ | � |� d|vr d| ji|d< d|v r^t|d t�rP|d D ]}| �|� q>n| �|d � t� }|rp||d< d|v �rt|d t��r|d D ]p}t|t�r�t|�dkr�| j|d |d d� q�t|t �r�| j|d |�
d
�|�
d �|�
d �d
� q�| �|� q�n| �|d � t � }|�r(||d< t || j
�}td| �|� � d S )NZ
invocationZ module_args�warnings� deprecationsry r r" )r� r� r� r� r� r� z
%s)r� r� r� r� re rd � SEQUENCETYPEr� rb r4 r rc rH r� r� r& )r� r� r� r� r r� r~ r~ r �_return_formatted� s6
� z AnsibleModule._return_formattedc K s | � � | �|� t�d� dS )z' return from the module, without error r N)r� r� r� r� )r� r� r~ r~ r r� � s
zAnsibleModule.exit_jsonc K s� d|d< ||d< d|vrvt �� d rv| js4| jdkrvtrZdd�t�t �� d �� |d< n d�t�t �� d ��|d< | �� | � |� t �
d � d
S ) z/ return from the module, with an error message TZfailedr� rI ry rw zIWARNING: The below traceback may *not* be related to the actual failure.
r{ r" N) r� �exc_infor� r� rP r� rS � format_tbr� r� r� )r� r� r� r~ r~ r r� � s $�
zAnsibleModule.fail_jsonc
C sR |sd S zt | j|� W n4 tyL } z | jt|�d� W Y d }~n
d }~0 0 d S r� )r[ r� r� r� r# )r� Zrequired_paramsr r~ r~ r �fail_on_missing_params s z$AnsibleModule.fail_on_missing_paramsc
C s� t |dd�}tj�|�s dS tj�|�r8| jd| d� t|d�rH|}n>zt| � }W n. ty� | jd||d� t�f d� Y n0 d }t
tj� |�d
�}|� |�}|r�|�
|� |� |�}q�|�� |�� S ) zh Return hex digest of local file for a digest_method specified by name, or None if file is not present. r� r� Nz+attempted to take checksum of directory: %sr� � hexdigestzFCould not hash file '%s' with algorithm '%s'. Available algorithms: %sz, i r� )r$ r� r� r� r� r� rN �AVAILABLE_HASH_ALGORITHMSr� r� r� r r� r� r� r� )r� �filename� algorithmZ
b_filenameZ
digest_methodr Zinfile�blockr~ r~ r �digest_from_file s*
�
z AnsibleModule.digest_from_filec C s dt vrtd��| �|d�S )a� Return MD5 hex digest of local file using digest_from_file().
Do not use this function unless you have no other choice for:
1) Optional backwards compatibility
2) Compatibility with a third party protocol
This function will not work on systems complying with FIPS-140-2.
Most uses of this function can use the module.sha1 function instead.
r0 z1MD5 not available. Possibly running in FIPS mode)r� r� r� �r� r� r~ r~ r r0 $ s zAnsibleModule.md5c C s | � |d�S )z@ Return SHA1 hex digest of local file using digest_from_file(). r1 �r� r� r~ r~ r r1 3 s zAnsibleModule.sha1c C s | � |d�S )zC Return SHA-256 hex digest of local file using digest_from_file(). r2 r� r� r~ r~ r r2 7 s zAnsibleModule.sha256c
C s� d}t j�|�r�t�dt�t�� ��}d|t �� |f }z| �||� W nD tj t
fy� } z&| j d||t |�f d� W Y d}~n
d}~0 0 |S )z[make a date-marked backup of the specified file, return True or False on success or failurer{ z%Y-%m-%d@%H:%M:%S~z%s.%s.%sz%Could not make backup of %s to %s: %sr� N)
r� r� r� r� �strftime� localtime�getpid�preserved_copyr� r� r� r� r# )r� �fnZ
backupdest�extr r~ r~ r � backup_local; s 0zAnsibleModule.backup_localc
C s\ t j�|�rXzt �|� W n< tyV } z$tj�d|t|�f � W Y d }~n
d }~0 0 d S )Nzcould not cleanup %s: %s) r� r� r� �unlinkr� r� �stderr�writer# )r� Ztmpfiler r~ r~ r r� K s
zAnsibleModule.cleanupc
C s� t �||� | �� r,| �|�}| �||d� zFt�|�}t�|�}|rp|j|jks^|j|jkrpt� ||j|j� W n2 t
y� } z|j t j kr�� W Y d}~n
d}~0 0 | j
|dd�}|�dd�}| �||d� dS )z=Copy a file with preserved ownership, permissions and contextFNrY r^ r{ T)r� �copy2r r r. r� rK r r �chownr� r rQ r_ r rf )r� �srcr� r � dest_stat�tmp_statr Zcurrent_attribsr~ r~ r r� R s
z AnsibleModule.preserved_copyc
C s d}d}t |dd�}t |dd�}tj�|��r"z�t�|�}t�||jt@ � t�||j |j
� t td�r�t |d�r�zt� ||j
� W nN ty� } z6dD ]"} t t| �r�|jtt| �kr� q�q�� W Y d}~n
d}~0 0 W n4 t�y
} z|jtjkr�� W Y d}~n
d}~0 0 | �� �r6| �|�}n| �� �r6| �|�}tj�|� }
zt�||� W �nN ttf�y� } �z.|jtjtjtjtjtjfv�r�| jd||t |�f t � � d� �n�tj� |�} tj� |�} d}
d}z�zt!j"d | | d
�\}}W nX ttf�y. } z$d tj� |�t |�f }
W Y d}~n d}~0 t#�yD d }
Y n0 W |
�r�|�rb| �$||� n| j|
t � � d� n.|
�r�|�r�| �$||� n| j|
t � � d� 0 |�r�t |dd�}�zʐzVt�%|� zt&�'||� W n t�y� t&�(||� Y n0 | �� �r| �)||d
� zBt�|�}|�rR|j |j k�s@|j
|j
k�rRt�||j |j
� W n6 t�y� } z |jtjk�rv� W Y d}~n
d}~0 0 zt�||� W nr t&j*ttf�y } zP|�r�|jtjk�r�| �$||� n"| jd|||t |�f t � � d� W Y d}~n
d}~0 0 W nb t&j*ttf�yt } z@|�r@| �$||� n | jd||t |�f t � � d� W Y d}~n
d}~0 0 W | �+|� n | �+|� 0 W Y d}~n
d}~0 0 |
�rt�,d�}t�,|� t�|t-| @ � zt�|t�.� t�/� � W n t�y Y n0 | �� �r| �)||d
� dS )a atomically move src to dest, copying attributes from dest, returns true on success
it uses os.rename to ensure this as it is an atomic operation, rest of the function is
to work around limitations, corner cases and ensure selinux context is saved if possibleNr� r� �chflags�st_flags)�
EOPNOTSUPP�ENOTSUPz$Could not replace file: %s to %s: %sr� s .ansible_tmp)r� r� �suffixzQThe destination directory (%s) is not writable by the current user. Error was: %sz�Failed creating tmp file for atomic move. This usually happens when using Python3 less than Python3.5. Please use Python2.x or Python3.5 or greater.Fz=Unable to make %s into to %s, failed final rename from %s: %sz$Failed to replace file: %s to %s: %sr )0r$ r� r� r� rK rO rM r� r� r r rN r� r� r� r r� rQ r r r �renamer� ZEXDEVrP ZETXTBSYZEBUSYr� r# rS rT r" r� r� Zmkstempr� �_unsafe_writesr� r� �mover� r. r� r� r� � DEFAULT_PERM�geteuid�getegid)r� r� r� rv r r� Zb_srcZb_destr re ZcreatingZ
b_dest_dirZb_suffixZ error_msgZ
tmp_dest_nameZ tmp_dest_fdZb_tmp_dest_namer� r� r~ r~ r � atomic_moveu s�
$ , �
�
"�� 8.
zAnsibleModule.atomic_movec
C s� zdd }}z<t |d�}t |d�}t�||� W |r:|�� |rb|�� n|rT|�� |r`|�� 0 W nL tjttfy� } z,| jd||t|�f t �
� d� W Y d }~n
d }~0 0 d S )N�wbr� z/Could not write data to file (%s) from (%s): %sr� ) r� r� � copyfileobjr� r� r� r� r� r# rS rT )r� r� r� Zout_destZin_srcr r~ r~ r r� � s$
��z AnsibleModule._unsafe_writesc C s� | j s�|}tr"t|t�r4t|�}nt|t�r4t|�}t|ttf�rLt�|�}g }d}dd� |D �D ]h}|rzd}|� d� qbt
� |�r�|� d�}|dkr�|� d|d |� � qbnd}t
|| j�}|� |� qbd �d
d� |D ��| _ | j S ) NFc s s | ]}t |�V qd S r� r� )r� r r~ r~ r � <genexpr> r� z,AnsibleModule._clean_args.<locals>.<genexpr>r� r[ r z %s=********Tr% c s s | ]}t |�V qd S r� )rZ )r� r� r~ r~ r r ( r� )r� rP r� rW r$ rS r% �shlexr r �
PASSWD_ARG_RErp �findr� r� r� )r� r� Z
to_clean_argsZ
clean_argsZ is_passwdr� Zsep_idxr~ r~ r � _clean_args s4
zAnsibleModule._clean_argsc C s" t r tjdkr t�tjtj� d S )N�win32)rP r� r| �signal�SIGPIPE�SIG_DFLr
r~ r~ r �_restore_signal_handlers, s z&AnsibleModule._restore_signal_handlersr� r� c ' sh d� _ t|tttf�s*d}� jd||d� d}| r�t|t�rRd�dd� |D ��}n t|d d
�}|rzt|d d
�}|d |g}q�� jd vr�t� jd d
�d |g}q�d
}n\t|ttf�r�t r�t|d d
�}nt
r�t |dd
�}t �
|�}|r�dd� |D �}ndd� |D �}d}|
�rnt|
t��r8t
�r&t|
dd
�}
nt �r8t|
d d
�}
zt�|
tj�}W n" tj�yl � jdd� Y n0 d}d}d}tj�� }|�� j�p�i � |�| �p�i � |�r�|�dd�}|�r�d||f |d< n||d< d|v �rdd� |d �
d�D �}|�rt|��rd�|�|d< |�r$tj}� �fdd�} t||||tjtj| |d �} t
�rd|�rd|| d < nt �rx|�rxd| d < |�r�ttj � tj � |��d d
�}tj � |��r�|| d < n|�sȈ jd | d� �zJ� j �r� �!d!� �"|� � tj#|fi | ��} |�r|| � d"} d"} z t$�%� }!W n t&t'f�y< t$�(� }!Y n0 |!�)| j*t$j+� |!�)| j,t$j+� tj-d#k�r�t.�.| j*�/� t.j0t.�.| j*�/� t.j1�tj2B � t.�.| j,�/� t.j0t.�.| j,�/� t.j1�tj2B � |�r |�s�|d$7 }t|t��r�t|�}| j3�4|� | j3�5� |!�6d%�}"|"D ]\\}#}$|#j7�8� }%|%t9d�k�r:|!�:|#j7� |#j7| j*k�rR| |%7 } n|#j7| j,k�r| |%7 } �q|�r�|�;| ��r�|�s�|
�r�t<| |
|d&�} d| d'fW S |"�r�|!�=� �s�| �>� du�rȐq�n$|!�=� �s | �>� du �r | �?� �q�q | j*�5� | j,�5� |!�5� | j@}W n� t't&f�y� }& zT� �!d(� �"|�t<|&�f � |�rn� j|&jAd"d"t<|&�� �"|�d)� n|&�W Y d}&~&n~d}&~&0 tB�y� }& z\� �!d(� �"|�t<tC�D� �f � |�r� jdd"d"t<|&�tC�D� � �"|�d*� n|&�W Y d}&~&n
d}&~&0 0 |dk�r6|�r6tE| �F� � jG�}� j� �"|�|| | |d+� |
du�r^|t<| |
|d&�t<| |
|d&�fS || | fS ),a#
Execute a command, returns rc, stdout, and stderr.
:arg args: is the command to run
* If args is a list, the command will be run with shell=False.
* If args is a string and use_unsafe_shell=False it will split args to a list and run with shell=False
* If args is a string and use_unsafe_shell=True it runs with shell=True.
:kw check_rc: Whether to call fail_json in case of non zero RC.
Default False
:kw close_fds: See documentation for subprocess.Popen(). Default True
:kw executable: See documentation for subprocess.Popen(). Default None
:kw data: If given, information to write to the stdin of the command
:kw binary_data: If False, append a newline to the data. Default False
:kw path_prefix: If given, additional path to find the command in.
This adds to the PATH environment variable so helper commands in
the same directory can also be found
:kw cwd: If given, working directory to run the command inside
:kw use_unsafe_shell: See `args` parameter. Default False
:kw prompt_regex: Regex string (not a compiled regex) which can be
used to detect prompts in the stdout which would otherwise cause
the execution to hang (especially if no input data is specified)
:kw environ_update: dictionary to *update* environ variables with
:kw umask: Umask to be used when running the command. Default None
:kw encoding: Since we return native strings, on python3 we need to
know the encoding to use to transform from bytes to text. If you
want to always get bytes back, use encoding=None. The default is
"utf-8". This does not affect transformation of strings given as
args.
:kw errors: Since we return native strings, on python3 we need to
transform stdout and stderr from bytes to text. If the bytes are
undecodable in the ``encoding`` specified, then use this error
handler to deal with them. The default is ``surrogate_or_strict``
which means that the bytes will be decoded using the
surrogateescape error handler if available (available on all
python3 versions we support) otherwise a UnicodeError traceback
will be raised. This does not affect transformations of strings
given as args.
:kw expand_user_and_vars: When ``use_unsafe_shell=False`` this argument
dictates whether ``~`` is expanded in paths and environment variables
are expanded before running the command. When ``True`` a string such as
``$SHELL`` will be expanded regardless of escaping. When ``False`` and
``use_unsafe_shell=False`` no path or variable expansion will be done.
:kw pass_fds: When running on Python 3 this argument
dictates which file descriptors should be passed
to an underlying ``Popen`` constructor. On Python 2, this will
set ``close_fds`` to False.
:kw before_communicate_callback: This function will be called
after ``Popen`` object will be created
but before communicating to the process.
(``Popen`` object will be passed to callback as a first argument)
:kw ignore_invalid_cwd: This flag indicates whether an invalid ``cwd``
(non-existent or not a directory) should be ignored or should raise
an exception.
:kw handle_exceptions: This flag indicates whether an exception will
be handled inline and issue a failed_json or if the caller should
handle it.
:returns: A 3-tuple of return code (integer), stdout (native string),
and stderr (native string). On python2, stdout and stderr are both
byte strings. On python3, stdout and stderr are text strings converted
according to the encoding and errors parameters. If you want byte
strings on python3, use encoding=None to turn decoding to text off.
Nz5Argument 'args' to run_command must be list or stringi )r7 �cmdr� F� c S s g | ]}t t|�d d��qS )r� r� )r$ rZ �r� r� r~ r~ r r� ~ r� z-AnsibleModule.run_command.<locals>.<listcomp>r� r� s -c)Nz/bin/shTr� c S s0 g | ](}|d urt tj�tj�|��dd��qS r )r$ r� r� r� r� r r~ r~ r r� � r� c S s g | ]}|d urt |dd��qS r )r$ r r~ r~ r r� � r� z6invalid prompt regular expression given to run_commandr� r �PATHr{ z%s:%sZ
PYTHONPATHc S s( g | ] }|r|� d �s|� d�s|�qS )z/ansible_modlib.zipz
/debug_dir)�endswithr r~ r~ r r� � s
�r� c s � � � �rt��� d S r� )r
r� r� r~ �r� r� r~ r �preexec� s z*AnsibleModule.run_command.<locals>.preexec)r� �shell� close_fdsr� �stdoutr� Z
preexec_fn�env�pass_fdsr r� z)Provided cwd is not a valid directory: %sz Executing: r� �posix�
r" )�encodingr� zQA prompt was encountered while running a command, but no input data was specifiedz#Error Executing CMD:%s Exception:%s)r7 r r� r� r )r7 r r� r� rI r )r r7 r r� r� )Hr� r� r� rS rW r� r� r$ r� rP rQ r% r r �re�compile� MULTILINEr� r� r� �copyr� r� r �any�
subprocess�PIPEr r� �abspathr� r� r� r� r �Popenr! ZDefaultSelectorr� r� Z PollSelectorr� r Z
EVENT_READr� r� �fcntl�filenoZF_SETFLZF_GETFL�
O_NONBLOCKr� r� r� �selectZfileobjr� rR Z
unregisterr� r# Zget_mapZpoll�wait�
returncoder r( rS rT r� �rstripr� )'r� r� Zcheck_rcr r� r� Z binary_dataZ path_prefixr� Zuse_unsafe_shellZ prompt_regexZenviron_updater� r r� Zexpand_user_and_varsr Zbefore_communicate_callbackZignore_invalid_cwdZhandle_exceptionsr� r Z prompt_rer7 Zst_inr r� Zpypathsr r� r r r� �selectorZeventsr� ZeventZb_chunkr r~ r r ra 1 s B
�
,,
" &
�zAnsibleModule.run_commandc C s4 t j�t j�|��}t|d�}|�|� |�� d S )Nr )r� r� r� r� r� r� r� )r� r� rh Zfhr~ r~ r �append_to_file> s
z AnsibleModule.append_to_filec C s t |�S r� )r+ )r� r� r~ r~ r r+ D s z AnsibleModule.bytes_to_humanc C s
t ||�S r� )r, )r� �numberZisbitsr~ r~ r r, J s z AnsibleModule.human_to_bytesc C sJ zt � | d�}W n4 tyD z
tj}W n ty> d}Y n0 Y n0 |S )Ni i(# )r& r( r) ZPIPE_BUF)r� Z buffer_sizer~ r~ r �get_buffer_sizeT s
z AnsibleModule.get_buffer_size) FFNNNFFNN)NNN)N)r )T)N)NT)NT)NT)NT)T)NT)NT)NT)NN)NF)N)FN)N)F)FTNNFNNFNNNr� r� TNNTT)F)G�__name__�
__module__� __qualname__r� �propertyr� re rb r
r r r r r r r# r- r0 r. r? rC rX rf r_ � classmethodrJ � staticmethodrt rs r� r5 r� r� r� r� r� r\ r� r� r� r� r� r� r; ra r& r� r� r� r� r� r� r� r� r0 r1 r2 r� r� r� r r� r r
ra r. r+ Z pretty_bytesr, r? r0 r~ r~ r~ r r� � s� �
e
&
7
-
)
)
U
+
,
D
(
=!
&
#
# �
r� c C s t j�t j�t��S r� )r� r� r" r r� r~ r~ r~ r �get_module_pathc s r7 )N)NN)�Z
__future__r r r rg Z
__metaclass__ZFILE_ATTRIBUTES�__main__r� r Zdatetimer@ r& r� r� r9 r| r r) r r� r
rK r" r� r� r� rS �types� itertoolsr r r� r� � ImportErrorZsystemdr r Zsystemd_daemonrN Zbootedr� �AttributeErrorr Zansible.module_utils.compatr ZNoneTyper! Z_textr# r$ r% Z+ansible.module_utils.common.text.convertersr& r' r� r( Zjson_dict_bytes_to_unicodeZ$ansible.module_utils.common.arg_specr) Z+ansible.module_utils.common.text.formattersr* r+ r, r- Z(ansible.module_utils.common._json_compatr. r r� r� r� r r� ZhashlibZ attributer� r/ r� r0 r� rn r( ZshaZ/ansible.module_utils.common._collections_compatr3 r4 r5 r6 r7 r8 r9 Z"ansible.module_utils.common.localer: Z#ansible.module_utils.common.processr; Z ansible.module_utils.common.filer< r� r= r� r> r� r? r@ rA Z$ansible.module_utils.common.sys_inforB rC rD Z ansible.module_utils.pycompat24rE rF Z&ansible.module_utils.common.parametersrG rH rI rJ rK rL Zansible.module_utils.errorsrM rN rO Zansible.module_utils.sixrP rQ rR rS rT rU rV rW Z ansible.module_utils.six.movesrX rY rZ Z&ansible.module_utils.common.validationr[ r\ Z"ansible.module_utils.common._utilsr] r� Z)ansible.module_utils.parsing.convert_boolr^ r_ r` ra Z$ansible.module_utils.common.warningsrb rc rd re � frozensetr� r r r� �imapZunicode� NameErrorZ
basestringZ
_literal_evalr� r� r rl ro rr � version_infoZ_PY3_MINZ_PY2_MINZ_PY_MINr� r� �
splitlinesr� r� r� r� r� �objectr� r7 r~ r~ r~ r �<module> sP �
$ (
�
��
A8
=