Server : LiteSpeed System : Linux barito.iixcp.rumahweb.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64 User : elvh3918 ( 1528) PHP Version : 8.2.31 Disable Function : mail Directory : /usr/lib/python3.9/site-packages/ansible/plugins/inventory/__pycache__/ |
a
�)g�P � @ s: d dl mZmZmZ eZd dlZd dlZd dlZd dl m
Z
d dl m Z m
Z
d dlmZ d dlmZ d dlmZ d dlmZ d d lmZmZ d d
lm Z d d l m Z d d l m Z d d
l!m"Z" d dl#m$Z$m%Z% e"� Z&dd� Zd dd�Z'd dd�Z(dd� Z)G dd� de�Z*G dd� de*�Z+G dd � d e,�Z-G d d � d e,�Z.dS )!� )�absolute_import�division�print_functionN)�Mapping)� AnsibleError�AnsibleParserError)�to_safe_group_name)�
parse_address)�
AnsiblePlugin)�CachePluginAdjudicator)�to_bytes� to_native)�boolean)� string_types)�Templar)�Display)� combine_vars�load_extra_varsc C s t | ddd�S )NT)�forceZsilent)�
original_safe)�name� r �F/usr/lib/python3.9/site-packages/ansible/plugins/inventory/__init__.pyr , s r c C s d| v S )z�
A helper function that checks a given host line to see if it contains
a range pattern described in the docstring above.
Returns True if the given line contains a pattern, else False.
�[r )�liner r r � detect_range1 s r c s� g }| �r�| � ddd�� ddd��d�\}}}|�d�}t|�dkrXt|�dkrXtd��|d }|d }t|�dkrzd}n|d }|s�d
}|s�td ��|d d
kr�t|�dkr�t|�� � t|�kr�td ��� fd
d�} nt} zJtj�|�}
tj�|�} |
| k�rtd��ttj|
| d t |�� �} W n0 t
�yV t t |�t |�d t |��} Y n0 | D ]>}
d� || |
�|f�}t
|��r�|�t|�� n
|�|� �q\|S dS )a�
A helper function that expands a given line that contains a pattern
specified in top docstring, and returns a list that consists of the
expanded version.
The '[' and ']' characters are used to maintain the pseudo-code
appearance. They are replaced in this function with '|' to ease
string splitting.
References: https://docs.ansible.com/ansible/latest/user_guide/intro_inventory.html#hosts-and-groups
r �|� �]�:� � z.host range must be begin:end or begin:end:stepr �0z!host range must specify end valuez:host range must specify equal-length begin and end formatsc s t | ��� �S �N)�str�zfill)�x�Zrlenr r �filli s z#expand_hostname_range.<locals>.fillz!host range must have begin <= end� N)�replace�split�lenr r$ �stringZ
ascii_letters�index�list�int�
ValueError�range�joinr �extend�expand_hostname_range�append)r Z all_hosts�headZnrange�tailZboundsZbeg�end�stepr( Zi_begZi_end�seqZrseqZhnamer r' r r5 ; sF $
"
r5 c
K s� zt | fi |��}W nB tyV } z*dt|�v r>td| ��n|�W Y d }~n
d }~0 0 | dkr�|r�t|jdd �s�td�| ���|S )NZfact_caching_connectiona error, '%s' inventory cache plugin requires the one of the following to be set to a writeable directory path:
ansible.cfg:
[default]: fact_caching_connection,
[inventory]: cache_connection;
Environment:
ANSIBLE_INVENTORY_CACHE_CONNECTION,
ANSIBLE_CACHE_PLUGIN_CONNECTION.Zmemory�_optionsz�Unable to use cache plugin {0} for inventory. Cache options were provided but may not reconcile correctly unless set via set_options. Refer to the porting guide if the plugin derives user settings from ansible.constants.)� CacheObjectr r
�getattrZ_plugin�format)� plugin_name�kwargs�cache�er r r �get_cache_plugin� s ��rD c s` e Zd ZdZdZee�Z� fdd�Zddd�Z dd � Z
dd d �Z d
d� Z dd� Z
dd� Z� ZS )�BaseInventoryPluginz Parses an Inventory Source� generatorc s* t t| ��� i | _d | _t| _i | _d S r# )�superrE �__init__r< � inventory�display�_vars��self�� __class__r r rH � s
z BaseInventoryPlugin.__init__Tc C s& || _ || _t|d�| _t|�| _dS )az Populates inventory from the given data. Raises an error on any parse failure
:arg inventory: a copy of the previously accumulated inventory data,
to be updated with any new data this plugin provides.
The inventory can be empty if no other source/plugin ran successfully.
:arg loader: a reference to the DataLoader, which can read in YAML and JSON files,
it also has Vault support to automatically decrypt files.
:arg path: the string that represents the 'inventory source',
normally a path to a configuration file for this inventory,
but it can also be a raw string for this plugin to consume
:arg cache: a boolean that indicates if the plugin should use the cache or not
you can ignore if this plugin does not implement caching.
)�loaderN)rP rI r �templarr rK )rM rI rP �pathrB r r r �parse� s zBaseInventoryPlugin.parsec C s@ d}t |dd�}tj�|�r0t�|tj�r0d}n | j�d� |S )a� Verify if file is usable by this plugin, base does minimal accessibility check
:arg path: a string that was passed as an inventory source,
it normally is a path to a config file, but this is not a requirement,
it can also be parsed itself as the inventory data to process.
So only call this base class if you expect it to be a file.
F�surrogate_or_strict��errorsTzWSkipping due to inventory source not existing or not being readable by the current user)r �osrR �exists�access�R_OKrJ Zvvv)rM rR Zvalid�b_pathr r r � verify_file� s z BaseInventoryPlugin.verify_fileNc C sX t |t�stdt|� ��|D ]4}| jj|||d� |D ]}| j�|||| � q8q d S )Nz8Invalid data from file, expected dictionary and got:
%s)�group�port)�
isinstancer r r
rI �add_host� set_variable)rM �hosts� variablesr] r^ �host�kr r r �_populate_host_vars� s
z'BaseInventoryPlugin._populate_host_varsc
s i }z� j j|dd�}W n0 tyH } ztt|���W Y d}~n
d}~0 0 t� d�pZ� jg}|srtdt|� ��n>|�d�|vr�td|�dd� ��nt|t �s�td t
|� ��� j |� j d
� d � j
v �r� �d ��rg d �}t� fd
d�|D ��}t� �d�fi |��� _|S )z� validate config and set options as appropriate
:arg path: path to common yaml format config file for this plugin
F)rB NZ_redirected_namesz %s is emptyZpluginz!Incorrect plugin name in file: %sz
none foundzJinventory source has invalid structure, it should be a dictionary, got: %s)ZdirectZ var_optionsrB �)Z_uriZcache_connection)�_timeoutZ
cache_timeout)�_prefixZ cache_prefixc 3 s6 | ].}� � |d �dur|d � � |d �fV qdS �r Nr ��
get_option��.0�optrL r r � <genexpr>� � z8BaseInventoryPlugin._read_config_data.<locals>.<genexpr>� cache_plugin)rP Zload_from_file� Exceptionr r
r> �NAME�getr_ r �typeZ set_optionsrK r< rl �dictrD �_cache)rM rR ZconfigrC Z valid_names�cache_option_keys�
cache_optionsr rL r �_read_config_data� s$ "
z%BaseInventoryPlugin._read_config_datac C s( | j D ] }||v r|�|�| j |< qdS )a< update existing options from alternate configuration sources not normally used by Ansible.
Many API libraries already have existing configuration sources, this allows plugin author to leverage them.
:arg data: key/value pairs that correspond to configuration options for this plugin
N)r< �pop)rM �datare r r r �_consume_options� s
z$BaseInventoryPlugin._consume_optionsc C sP zt |dd�\}}W n ty. |}d}Y n0 t|�rBt|�}n|g}||fS )z�
Takes a single host pattern and returns a list of hostnames and an
optional port number that applies to all of them.
T)Z allow_rangesN)r rs r r5 )rM Z hostpattern�patternr^ Z hostnamesr r r �_expand_hostpattern s
z'BaseInventoryPlugin._expand_hostpattern)T)NN)�__name__�
__module__� __qualname__�__doc__�TYPE� staticmethodr �_sanitize_group_namerH rS r\ rf r{ r~ r� �
__classcell__r r rN r rE � s
"
rE c s$ e Zd ZdZdZ� fdd�Z� ZS )�BaseFileInventoryPluginz% Parses a File based Inventory SourceZstoragec s t t| ��� d S r# )rG r� rH rL rN r r rH ! s z BaseFileInventoryPlugin.__init__)r� r� r� r� r� rH r� r r rN r r� s r� c @ sN e Zd Ze� Zedd� �Zdd� Zdd� Zdd� Z d d
� Z
d d � Z d
d� Z dS )� Cacheablec C s | j S r# )rx rL r r r rB * s zCacheable.cachec s> � � d�}g d�}t� fdd�|D ��}t|fi |��� _d S )Nrr rg c 3 s6 | ].}� � |d �dur|d � � |d �fV qdS rj rk rm rL r r rp 1 rq z.Cacheable.load_cache_plugin.<locals>.<genexpr>)rl rw rD rx )rM r@ ry rz r rL r �load_cache_plugin. s
zCacheable.load_cache_pluginc C s d� | j| �|��S )Nz{0}_{1})r? rt �_get_cache_prefix)rM rR r r r �
get_cache_key4 s zCacheable.get_cache_keyc C sd t �� }|�t| jdd�� |�� }t �� }|�t|dd�� |�� }d�|dd� |dd� g�S )z7 create predictable unique prefix for plugin/inventory rT rU Zs_N� )�hashlibZsha1�updater rt Z hexdigestr3 )rM rR �mZd1�nZd2r r r r� 7 s zCacheable._get_cache_prefixc C s | j �� d S r# )rx �flushrL r r r � clear_cacheD s zCacheable.clear_cachec C s | j �� d S r# )rx �update_cache_if_changedrL r r r r� G s z!Cacheable.update_cache_if_changedc C s | j �� d S r# )rx Z set_cacherL r r r �set_cache_pluginJ s zCacheable.set_cache_pluginN)
r� r� r� r= rx �propertyrB r� r� r� r� r� r� r r r r r� & s
r� c @ s4 e Zd Zd dd�Zd
dd�Zddd�Zdd d
�Zd S )�
ConstructableTc C sf | j }z| �d�}W n ty* d}Y n0 |r@t|| j�|_n||_|jd|jj||jj f |d�S )zi helper method for plugins to compose variables for Ansible based on jinja2 expression and inventory varsZuse_extra_varsF�%s%s%s)�disable_lookups)
rQ rl rs r rK �available_variables�templateZ environmentZvariable_start_stringZvariable_end_string)rM r� rc r� �tZ use_extrar r r �_composeP s
�zConstructable._composeFc C s� |r�t |t�r�|D ]t}z| �|| |�}W nJ tyt } z2|rTtd||t|�f ��W Y d}~qW Y d}~n
d}~0 0 | j�|||� qdS )z5 loops over compose entries to create vars for hosts z Could not set %s for host %s: %sN)r_ rw r� rs r r
rI ra )rM Zcomposerc rd �strictZvarnameZ compositerC r r r �_set_composite_varsa s "z!Constructable._set_composite_varsc
C s� |r�t |t�r�|r(t|| j�|��� �}|| j_|D ]�}d|| }| �|�}zt | j�
|��}W nJ t y� } z2|r�t d||t
| �f ��W Y d} ~ q4W Y d} ~ n
d} ~ 0 0 |r4| j�|�}| j�||� q4dS )z} helper to create complex groups for plugins based on jinja2 conditionals, hosts that meet the conditional are added to groupz3{%% if %s %%} True {%% else %%} False {%% endif %%}z%Could not add host %s to group %s: %sN)r_ rw r rI �get_host�get_varsrQ r� r� r r� rs r r
� add_group� add_child)
rM �groupsrc rd r� �fetch_hostvarsZ
group_nameZ conditional�resultrC r r r � _add_host_to_composed_groupsm s
" z*Constructable._add_host_to_composed_groupsc C s> |�r:t |t��r:|D �] }|�r,t |t��r,|rHt|| j�|��� �}z| �|�d�|�}W nP t y� } z8|r�t
d||�d�t |�f ��W Y d}~qW Y d}~n
d}~0 0 |�dd�} |�d�}
|
dur�| dur�t
d��|s�|dk�r | du�r |�dd�} |�d d
�} |�d d�}
|
�r�z| j �
|
�}
W nN t�y~ } z4|�r^t
d |
|t |�f ��W Y d}~qW Y d}~n
d}~0 0 g }t |t��r�|dk�r�| du�r�|�| � n
|�|� n�t |t��r |D ]0}|dk�r�| du�r�|�| � n
|�|� �q�n|t |t��rl|�� D ]T\}}d
|| |f }|dk�r\| du�rNd
|| | f }n|
du �r\|}|�|� �qnt
dt|� ��|D ]|}| dk�r�| �d�du �r�d} | �d
| | |f �}| j�|�}| j�||� |
�r�| �|
�}| j�|� | j�||� �q�n*|�r8|g i fv�r8t
d|�d�|f ��qt
d| ��qdS )zc helper to create groups for plugins based on variable values and add the corresponding hosts to it�keyz6Could not generate group for host %s from %s entry: %sNZ
default_value�trailing_separatorzTparameters are mutually exclusive for keyed groups: default_value|trailing_separatorr) �prefix� separator�_Z parent_groupz3Could not generate parent group %s for group %s: %sr� FzUInvalid group name format, expected a string or a list of them or dictionary, got: %sZleading_separatorz=No key or key resulted empty for %s in host %s, invalid entryz7Invalid keyed group entry, it must be a dictionary: %s )r_ r/ rw r rI r� r� r� ru rs r r
rQ r� r r r6 r �itemsrv rl r� r� r` r� )rM �keysrc rd r� r� Zkeyedr� rC Zdefault_value_namer� r� �sepZraw_parent_nameZnew_raw_group_namesr �gnameZgvalZ bare_nameZ result_gname� parent_namer r r �_add_host_to_keyed_groups� sv
"
"
z'Constructable._add_host_to_keyed_groupsN)T)F)FT)FT)r� r� r� r� r� r� r� r r r r r� N s
r� )N)N)/Z
__future__r r r rv Z
__metaclass__r� rW r- �collections.abcr Zansible.errorsr r Zansible.inventory.groupr r Z ansible.parsing.utils.addressesr Zansible.pluginsr
Zansible.plugins.cacher r= Zansible.module_utils._textr r
Z)ansible.module_utils.parsing.convert_boolr Zansible.module_utils.sixr Zansible.templater Zansible.utils.displayr Zansible.utils.varsr r rJ r r5 rD rE r� �objectr� r� r r r r �<module> s4
H
(