File: //lib/python3.9/site-packages/ansible/vars/__pycache__/manager.cpython-39.pyc
a
�)gR� � @ sp d dl mZmZmZ eZd dlZd dlZd dlm Z d dl
m Z m Z m
Z
d dlmZ d dlmZ d dlmZ d dlmZmZmZmZmZmZ d d l m Z d d
l m Z m Z d d l!m"Z" d d l#m$Z$m%Z% d d
l&m'Z' d dl(m)Z) d dl*m+Z+ d dl,m-Z- d dl.m/Z/ d dl0m1Z1m2Z2m3Z3 d dl4m5Z5 d dl6m7Z7m8Z8 d dl9m:Z:m;Z; e-� Z<dd� Z=G dd� d�Z>G dd� de �Z?dS ) � )�absolute_import�division�print_functionN)� defaultdict)�Mapping�MutableMapping�Sequence)�sha1)�UndefinedError)� constants)� AnsibleError�AnsibleParserError�AnsibleUndefinedVariable�AnsibleFileNotFound�AnsibleAssertionError�AnsibleTemplateError)�Host)� sort_groups�get_group_vars)�to_text)� text_type� string_types)�
lookup_loader)� FactCache)�Templar)�Display)�listify_lookup_plugin_terms)� combine_vars�load_extra_vars�load_options_vars)�wrap_var)�namespace_facts� clean_facts)� get_vars_from_inventory_sources�get_vars_from_pathc C sN | du r dS t | t�s | g}n| }|D ]"}t |t�s&td| t| �f ��q&|S )z�
Ensures that vars contained in the parameter passed in are
returned as a list of dictionaries, to ensure for instance
that vars loaded from a file conform to an expected state.
Nzevariable files must contain either a dictionary of variables, or a list of dictionaries. Got: %s (%s))�
isinstance�listr r �type)�a�data�item� r+ �8/usr/lib/python3.9/site-packages/ansible/vars/manager.py�preprocess_vars2 s
r- c @ s� e Zd Zeg d��Zd dd�Zdd� Zdd� Zed d
� �Z d d � Z
d dd�Z d dd�Z dd� Z
dd� Zdd� Zdd� Zdd � ZdS ) �VariableManager)Zplugins_by_group�groups_plugins_play�groups_plugins_inventory�groups_inventory�all_plugins_play�all_plugins_inventory�
all_inventoryNc
C s� t t�| _t t�| _t t�| _t t�| _t t�| _|| _|| _d | _ dt
t � d���
� | _t|�| _| j�dd�}t|du p�|�| _t| jd�| _z t� | _W n8 ty� } z t�t|�� i | _W Y d }~n
d }~0 0 d S )N�__omit_place_holder__%s�@ �basedirF��loader)r �dict�_nonpersistent_fact_cache� _vars_cache� _extra_vars�_host_vars_files�_group_vars_files�
_inventory�_loader� _hostvarsr �os�urandom� hexdigest� _omit_tokenr �
_options_vars�get�bool� safe_basedirr r � _fact_cacher �display�warningr )�selfr9 � inventory� version_infor7 �er+ r+ r, �__init__L s$
zVariableManager.__init__c C s4 t | j| j| j| j| j| j| j| j| j | j
d�
}|S )N)
�
fact_cache�
np_fact_cache�
vars_cache�
extra_vars�host_vars_files�group_vars_files�
omit_token� options_varsrO rJ ) r: rK r; r< r= r> r? rF rG r@ rJ �rN r) r+ r+ r, � __getstate__j s � z VariableManager.__getstate__c C s� |� dtt��| _|� dtt��| _|� dtt��| _|� dt� �| _|� dtt��| _|� dtt��| _|� ddt t
� d ��� � �| _
|� d
d �| _|� d t� �| _|� d d
�| _d | _d | _d S )NrS rT rU rV rW rX rY r5 r6 rO rZ rJ F)rH r r: rK r; r< r= r> r? r rC rD rE rF r@ rG rJ rA rB r[ r+ r+ r, � __setstate__y s z VariableManager.__setstate__c C s | j S �N)r= �rN r+ r+ r, rV � s zVariableManager.extra_varsc C s
|| _ d S r^ )r@ )rN rO r+ r+ r, �
set_inventory� s z VariableManager.set_inventoryT�taskc
"
s< t �d� t� }
�j|||||||d�} i ��fdd�� g ��jrN�j�� g�|rv|�� D ]} � |
| �� d| j �}
qZ|r�t
j dkr�|� � �n2t
j dv r�|� � d g�nt
j d kr�t
d
t
j ��|jd ur�|s�|jt
jv r�� |
|jj|�� d �d|jj �}
|�r��jj�d��td
d� |�� D ����fdd�}
��fdd��� ���fdd���fdd�}��fdd�}��fdd�}�fdd �}��fd d �}��fd d �}� ���fd!d"�}t
jD ]N}|�jv �r�t �d#||j f � � |
t� | � d$| �}
nt �d%| � �q�� |
|�� d&| �}
� |
�|g�d'| �}
� |
�|g�d(| �}
z^t �j �|j i ��}|
t |�O }
t
j �r�� |
t t |��d)�}
n � |
t d*|�d*i �i�d)�}
W n t!�y� Y n0 |�r� |
|�� d+�}
|�"� }�z�|D �]�}t#|
�j$�}t#|| �}t%�j|d,�}|}t&|t'��s$|g}z�|D ]�} |�(| �} t&| t)��sPt
d-| ��zd|� � } �j�*| d.| � } } t+�jj,| d/d0d1��} | d u�r�| D ]}!� |
|!d2| �}
�q�W �q W n. t-�y� Y �q*Y n t.�y� � Y n0 �q*|�r |�r t-d3| ��W nl t/t0f�yn |d u�rV�j �|j t� ��d4��rV|d u�rVt0d5| |d6��nt �1d7| � Y �q�Y n0 t �1d8| � �q�W n( t2�y� t.d9|t3|�f ��Y n0 t
j4�s�|�� D ] } � |
| jd0d:�d;| j �}
�q�|�r"|j�r� |
|jj|�� d0d:�d;|jj �}
� |
|�� d<�}
|�r^� |
�j5�|�6� t� �d=�}
� |
�j7�|j t� �d>�}
|�r�|j�r�� |
|j�8|�� �d?|jj �}
� |
|�9� d@�}
� |
�j$dA�}
� |
| dB�}
|�r�|j:|
dC< |�s�|�r�|
�;� |
d.< |�r|�r|j<d u�r|�r��=|||
�\|
dD< |
dE< t �dF� t
j>�r4t?�@|
��S |
S d S )Gan
Returns the variables, with optional "context" given via the parameters
for the play, host, and task (which could possibly result in different
sets of variables being returned due to the additional context).
The order of precedence is:
- play->roles->get_default_vars (if there is a play context)
- group_vars_files[host] (if there is a host context)
- host_vars_files[host] (if there is a host context)
- host->get_vars (if there is a host context)
- fact_cache[host] (if there is a host context)
- play vars (if there is a play context)
- play vars_files (if there's no host context, ignore
file names that cannot be templated)
- task->get_vars (if there is a task context)
- vars_cache[host] (if there is a host context)
- extra vars
``_hosts`` and ``_hosts_all`` should be considered private args, with only internal trusted callers relying
on the functionality they provide. These arguments may be removed at a later date without a deprecation
period and without warning.
z in VariableManager get_vars())�play�hostra �include_hostvars�include_delegate_to�_hosts�
_hosts_allc s" t jr|D ] }|� |< q
t| |�S )z�
Wrapper function to update var sources dict and call combine_vars()
See notes in the VarsWithSources docstring for caveats and limitations of the source tracking
)�C�
DEFAULT_DEBUGr )r) Znew_data�source�key)�
_vars_sourcesr+ r, �_combine_and_track� s
z4VariableManager.get_vars.<locals>._combine_and_trackzrole '%s' defaults�all)Zbottom� playbook_dirr �topz Unknown playbook vars logic: %sN)Z dep_chainc S s g | ]}|j d vr|�qS ))rn ��name)�.0�gr+ r+ r, �
<listcomp>� � z,VariableManager.get_vars.<locals>.<listcomp>c s� i }z| � � j||�}W n� ty� z:|D ]0}t|t�rL|| �|j�O }q,|| �|j�O }q,W nF ty� t| d�r�t d| j
| j f ��nt d| j
| j f ��Y n0 Y n0 |S )N�runz)Cannot use v1 type vars plugin %s from %sz Invalid vars plugin %s from %s) �get_varsrA �AttributeErrorr% r Z
get_host_varsrr r �hasattrr Z
_load_nameZ_original_path)Zplugin�path�entitiesr) Zentityr_ r+ r, �_get_plugin_vars� s
z2VariableManager.get_vars.<locals>._get_plugin_varsc s t � j� jj| ��S )z) merges all entities by inventory source )r# rA r@ Z_sources)r| )rN �stager+ r, �_plugins_inventory� s z4VariableManager.get_vars.<locals>._plugins_inventoryc s. i }�D ] }� |t �j|| ��d| �}q|S )z& merges all entities adjacent to play z path '%s')r$ rA )r| r) r{ )rm �basedirsrN r~ r+ r, �
_plugins_play� s z/VariableManager.get_vars.<locals>._plugins_playc s � � � S r^ )rx r+ )� all_groupr+ r, r4 s z/VariableManager.get_vars.<locals>.all_inventoryc s
� �g�S r^ r+ r+ )r r� r+ r, r3 s z7VariableManager.get_vars.<locals>.all_plugins_inventoryc s
� �g�S r^ r+ r+ )r� r� r+ r, r2 s z2VariableManager.get_vars.<locals>.all_plugins_playc s t � �S )z gets group vars from inventory )r r+ )� host_groupsr+ r, r1 s z2VariableManager.get_vars.<locals>.groups_inventoryc s � ��S )z/ gets plugin sources from inventory for groups r+ r+ )r r� r+ r, r0 s z:VariableManager.get_vars.<locals>.groups_plugins_inventoryc s � ��S )z* gets plugin sources from play for groups r+ r+ )r� r� r+ r, r/ s z5VariableManager.get_vars.<locals>.groups_plugins_playc sJ i } �D ]<}� | | �|�d| �| |< � | | �|�d| �| |< q| S )z�
merges all plugin sources by group,
This should be used instead, NOT in combination with the other groups_plugins* functions
z inventory group_vars for '%s'z playbook group_vars for '%s'r+ )r) �group)rm r r� r� r+ r, �plugins_by_groups s
z3VariableManager.get_vars.<locals>.plugins_by_groupsz Calling %s to load vars for %sz!group vars, precedence entry '%s'z.Ignoring unknown variable precedence entry: %szhost vars for '%s'z inventory host_vars for '%s'zplaybook host_vars for '%s'�factsZ
ansible_localz play vars�r9 � variablesz�Invalid vars_files entry found: %r
vars_files entries should be either a string type or a list of string types after template expansion�varsTF)Zunsafe�cachezplay vars_files from '%s'zvars file %s was not foundZ module_setupzTan undefined variable was found when attempting to template the vars_files item '%s')�objz4skipping vars_file '%s' due to an undefined variablezRead vars_file '%s'zXError while reading vars files - please supply a list of file names. Got '%s' of type %s)Zinclude_paramszrole '%s' varsz task varsZ include_varsZset_factzrole '%s' paramszinclude paramsz
extra varsz
magic vars� environmentZansible_delegated_vars�_ansible_loop_cachezdone with get_vars())ArL �debugr: �_get_magic_variablesrJ rA � get_basedirZ get_rolesZget_default_varsrr rh ZPLAYBOOK_VARS_ROOT�get_search_pathr �_role�actionZ_ACTION_INCLUDE_ROLEZ
get_dep_chainr@ �groupsrH r Z
get_groupsZVARIABLE_PRECEDENCE�_ALLOWED�localsrM rx r rK r! ZINJECT_FACTS_AS_VARSr" �KeyErrorZget_vars_filesr r= r r% r& �templater Zpath_dwim_relative_stackr- Zload_from_filer r
r
r Zvvv� TypeErrorr' ZDEFAULT_PRIVATE_ROLE_VARSr< �get_namer; Zget_role_paramsZget_include_paramsr� �copy� delegate_to�_get_delegated_varsri �VarsWithSources�new_vars_with_sources)"rN rb rc ra rd re Z use_cacherf rg r~ Zall_varsZmagic_variablesZroler} r4 r3 r2 r1 r0 r/ r� �entryr� Z
vars_filesZvars_file_itemZ temp_vars�templarZvars_file_listZ vars_fileZplay_search_stackZ
found_fileZ real_filer) r* r+ ) rm r r� rl r� r� r� rN r~ r, rx � s
�
�
��
.��
�
�
zVariableManager.get_varsc s i }t j�| j�� �|d< tj|d< tj|d< � r�t dd� � j
D ��} dd� � j
D �}
t t | |
��|d< |
|d < | |d
< |d |d < � � � |d < |r�|j
r�|j
j d
d�|d< |j
j|d< t|j
j�|d< |j
j|d< |j
� � |d< | jdu�r�| j�� |d< � �r�t| jd�} � j�s,| �� j��r,d} n � j�p6d} |�sXdd� | jj| dd�D �}|�srdd� | j�� D �}|dd� |d < � fd d�|d D �|d < � fd d�|D �|d < |d |d!< | j|d"< | j�� D ]\}
}|||
< �q�| j du�r|�r| j |d#< |S )$z�
Returns a dictionary of so-called "magic" variables in Ansible,
which are special variables we set internally for use.
ro Zansible_playbook_pythonZansible_config_filec S s" h | ]}|� � D ] }|�� �qqS r+ )Zget_all_dependenciesr� )rs �r�dr+ r+ r, � <setcomp>� rv z7VariableManager._get_magic_variables.<locals>.<setcomp>c S s g | ] }|� � �qS r+ )r� )rs r� r+ r+ r, ru � rv z8VariableManager._get_magic_variables.<locals>.<listcomp>Zansible_role_namesZansible_play_role_namesZ ansible_dependent_role_namesZ
role_namesZansible_play_nameF)Zinclude_role_fqcnZ role_nameZ role_pathZ role_uuidZansible_collection_nameZansible_role_nameNr� r8 rn c S s g | ]
}|j �qS r+ rq �rs �hr+ r+ r, ru � rv T)�pattern�ignore_restrictionsc S s g | ]
}|j �qS r+ rq r� r+ r+ r, ru � rv Zansible_play_hosts_allc s g | ]}|� j vr|�qS r+ �Z_removed_hosts�rs �x�rb r+ r, ru � rv Zansible_play_hostsc s g | ]}|� j vr|�qS r+ r� r� r� r+ r, ru � rv Zansible_play_batchZ
play_hostsZomitZhostvars) rC r{ �abspathrA r� �sys�
executablerh Z CONFIG_FILEr& Zroles�setr� r� Z
_role_pathr Z_uuidZ_role_collectionr@ Zget_groups_dictr Z finalized� is_template�hosts� get_hostsrF rG �itemsrB )rN rb rc ra rd re rf rg r� Zdependency_role_namesZplay_role_namesr� r� �optionZ option_valuer+ r� r, r� � sP
z$VariableManager._get_magic_variablesc s� t |d�si d fS |�� }|�� |d< | j�� |d vrL|d �| j�� � t| j|d�� g }d}|jd u�r4|jtv �r$d}|jdkr�d}zzt |j
� |dd�}|s�� fdd �|D �}tj |j| j� d
�} d D ]}
|
|j v r� q�q�t
| d |
d
� t| j||d��}W n t�y d g}Y n0 ntd|j ��nD|j
d u�rnz� �|j
�}W n t�yj d g}Y n0 n
d}d g}t� } t|jdd�} d}
|D �]}|d u�r�||| < |� _� j|jdd�}||jk�r�d}
|d u �r�td|jd��t|t��s tdt|� |jd��|| v �r�q�d }| j d u�rz| j � |�}|d u �r�| j j ddd�D ] }|j |k�rP|} �q��qPt |d�}n
t |d�}| j!|||ddd�| |< |� d�| | d< �q�d }|�r�|
�r�|}| |fS )N�loopZansible_search_pathr� TZ first_foundF)�termsr� �fail_on_undefinedZ convert_barec s g | ]}� � |�s|�qS r+ )r� )rs �t�r� r+ r, ru , rv z7VariableManager._get_delegated_vars.<locals>.<listcomp>)r9 r� )r� �var�fileZ_subdir�s)r� r� zDFailed to find the lookup named '%s' in the available lookup pluginsZloop_varr* )r� z$Undefined delegate_to host for task:)�messager� z^the field 'delegate_to' has an invalid type (%s), and could not be converted to a string type.)Z
ignore_limitsr� rq )rb rc ra re rd Zinventory_hostname)"rz r� r� rA r� �appendr Z loop_withr r r� rH r� �setattrr rw r r r� r: �getattrZ loop_controlZavailable_variablesr� Z_dsr% r r' r@ Zget_hostr� �addressr rx )rN rb ra Zexisting_variablesZ vars_copyr� Zhas_loopZfailZ
loop_termsZmylookupZsubdirZdelegated_host_varsZitem_varZ cache_itemsr* Zdelegated_host_nameZdelegated_hostr� r� r+ r� r, r� s�
��
�
z#VariableManager._get_delegated_varsc C s | j �|d� dS )z-
Clears the facts for a host
N)rK �pop)rN �hostnamer+ r+ r, � clear_facts� s zVariableManager.clear_factsc C st t |t�stdt|� ��z| j| }W n ty> |}Y n(0 t |t�s^td�|t|����||O }|| j|< dS )�O
Sets or updates the given facts for a host in the fact cache.
zIthe type of 'facts' to set for host_facts should be a Mapping but is a %szCThe object retrieved for {0} must be a MutableMapping but was a {1}N) r% r r r' rK r� r r� �format)rN rc r� Z
host_cacher+ r+ r, �set_host_facts� s
�z VariableManager.set_host_factsc C sR t |t�stdt|� ��z| j| |O < W n tyL || j|< Y n0 dS )r� zRthe type of 'facts' to set for nonpersistent_facts should be a Mapping but is a %sN)r% r r r' r; r� )rN rc r� r+ r+ r, �set_nonpersistent_facts� s
z'VariableManager.set_nonpersistent_factsc C sp || j vrt� | j |< || j | v r^t| j | | t�r^t|t�r^t| j | ||i�| j |< n|| j | |< dS )z<
Sets a value in the vars_cache for a host.
N)r< r: r% r r )rN rc Zvarname�valuer+ r+ r, �set_host_variable� s
, z!VariableManager.set_host_variable)NNN) NNNTTTNNra )NN)�__name__�
__module__� __qualname__� frozensetr� rR r\ r] �propertyrV r` rx r� r� r� r� r� r� r+ r+ r+ r, r. G s&
�
3
H
r. c @ sd e Zd ZdZdd� Zedd� �Zdd� Zdd � Zd
d � Z d d
� Z
dd� Z dd� Z dd� Z
dd� ZdS )r� a"
Dict-like class for vars that also provides source information for each var
This class can only store the source for top-level vars. It does no tracking
on its own, just shows a debug message with the information that it is provided
when a particular var is accessed.
c O s t |i |��| _i | _dS )z Dict-compatible constructor N)r: r) �sources)rN �args�kwargsr+ r+ r, rR � s zVarsWithSources.__init__c C s | |�}||_ |S )z@ Alternate constructor method to instantiate class with sources )r� )�clsr) r� �vr+ r+ r, r� � s z%VarsWithSources.new_vars_with_sourcesc C s | j �|d �S r^ )r� rH �rN rk r+ r+ r, �
get_source� s zVarsWithSources.get_sourcec C s* | j | }t�d|| j�|d�f � |S )Nz variable '%s' from source: %s�unknown)r) rL r� r� rH )rN rk �valr+ r+ r, � __getitem__� s
zVarsWithSources.__getitem__c C s || j |< d S r^ �r) )rN rk r� r+ r+ r, � __setitem__� s zVarsWithSources.__setitem__c C s | j |= d S r^ r� r� r+ r+ r, � __delitem__� s zVarsWithSources.__delitem__c C s
t | j�S r^ )�iterr) r_ r+ r+ r, �__iter__� s zVarsWithSources.__iter__c C s
t | j�S r^ )�lenr) r_ r+ r+ r, �__len__� s zVarsWithSources.__len__c C s | j �|�S r^ )r) � __contains__r� r+ r+ r, r� � s z VarsWithSources.__contains__c C s t �| j�� | j�� �S r^ )r� r� r) r� r� r_ r+ r+ r, r� � s zVarsWithSources.copyN)r� r� r� �__doc__rR � classmethodr� r� r� r� r� r� r� r� r� r+ r+ r+ r, r� � s
r� )@Z
__future__r r r r' Z
__metaclass__rC r� � collectionsr �collections.abcr r r Zhashlibr Zjinja2.exceptionsr
Zansibler rh Zansible.errorsr r
r r r r Zansible.inventory.hostr Zansible.inventory.helpersr r Zansible.module_utils._textr Zansible.module_utils.sixr r Zansible.plugins.loaderr Zansible.vars.fact_cacher Zansible.templater Zansible.utils.displayr Zansible.utils.listifyr Zansible.utils.varsr r r Zansible.utils.unsafe_proxyr Zansible.vars.cleanr! r" Zansible.vars.pluginsr# r$ rL r- r. r� r+ r+ r+ r, �<module> s< |