Dashboard
PHP:
8.2.30
OS:
Linux
User:
dh_nv8b2m
/
/
usr
/
local
/
lib
/
python3.10
/
dist-packages
/
ansible
/
plugins
/
__pycache__
📤 Upload
📝 New File
📁 New Folder
Close
Editing: loader.cpython-310.pyc
o O�h=( � @ s� d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlm Z m Z d dl m Z d dl mZ d dlm m mZ ddlmZ ddlmZ d d lmZ d d lmZ d d l m Z m Z m Z m!Z! d d l"m#Z#m$Z$m%Z% d d l&m'Z' d dl(m)Z) d dl*m+Z+ d dl,m-Z-m.Z.m/Z/m0Z0 d dl1m2Z2m3Z3 d dl4m5Z5m6Z6 d dl7m8Z8 d dl9m:Z: d dl;m<Z< zd dl=m>Z> d dl?m@Z@ W n eAy� dZ>dZ@Y nw d dlBZ e eC�ZDe8� ZEe dddg�ZFdd � ZGd d � ZHd|d d �ZId!d"� ZJG d#d$� d$eK�ZLG d%d&� d&eK�ZMG d'd(� d(�ZNG d)d*� d*eN�ZOd}d,d-�ZPd.d/� ZQd0d1� ZRd2d3� ZSd~d4d5�ZTd~d6d7�ZUeNd8d9e jVd:�ZWeNd;d<e jXd=d>d?�ZYeNd@dAe jZdB�Z[eNdCdDe j\dE�Z]eNdFdGe j^dHdIdJidKdL�Z_eNdMdNdOdO�Z`eNdPdQe jadR�ZbeNdPdSe jcdT�ZdeNdPdSe jcdT�ZeeNdUdVe jfdWdXd?�ZgeOdYdZe jhd[e�ZieOd\d]e jjd^e�ZkeNd_d`e jldadbd?�ZmeNdcdde jndedfd?�ZoeNdgdhe jpdi�ZqeNdjdke jrdldmd?�ZseNdndoe jtdpdqd?�ZueNdrdse jvdt�ZweNdudve jxdwdxd?�ZyeNdydze jzd{�Z{dS )� )� annotationsN)� defaultdict� namedtuple)� import_module)� format_exc� )�AnsibleJinja2Filter)�AnsibleJinja2Test)� __version__)� constants)� AnsibleError� AnsiblePluginCircularRedirect�AnsiblePluginRemovedError�(AnsibleCollectionUnsupportedVersionError)�to_bytes�to_text� to_native)� string_types)� from_yaml)� AnsibleLoader)�get_plugin_class� MODULE_CACHE� PATH_CACHE�PLUGIN_PATH_CACHE)�AnsibleCollectionConfig�AnsibleCollectionRef)�_AnsibleCollectionFinder�_get_collection_metadata)�Display)� add_fragments)� _is_unsafe)� SpecifierSet)�Version�get_with_context_result�object�plugin_load_contextc C s dd� t � �� D �S )Nc S s" g | ] \}}t |t�r||f�qS � )� isinstance� PluginLoader)�.0�name�objr& r& �A/usr/local/lib/python3.10/dist-packages/ansible/plugins/loader.py� <listcomp>9 s " z*get_all_plugin_loaders.<locals>.<listcomp>)�globals�itemsr& r& r& r, �get_all_plugin_loaders8 s r0 c C s~ t j�t| dd��}t j�|�r4t� D ] \}}|jr1t j�|t|j��}t j�|�r1|�t |�� qdS t � dt | � � dS )z3 add any existing plugin dirs in the path provided �surrogate_or_strict��errorszFIgnoring invalid path provided to plugin path: '%s' is not a directoryN) �os�path� expanduserr �isdirr0 �subdir�join� add_directoryr �display�warning)r5 �b_pathr* r+ � plugin_pathr& r& r, �add_all_plugin_dirs< s ��r? c C s� | s>d} |r:t |t�r9tj�|�}zt�|�}W n ty# d }Y nw |d u r9t�� D ] }||j v r8|j } nq,nt d��t�| �}|sKt d| ��|rSt |d|� |S )N�shz;Either a shell type or a shell executable must be provided z.Could not find the shell plugin required (%s).� executable) r' r r4 r5 �basename� shell_loader�get� Exception�all�COMPATIBLE_SHELLS� SHELL_FAMILYr �setattr)� shell_typerA �shell_filename�shellr& r& r, �get_shell_pluginI s0 � �� rM c C s0 t tjt d| �}|D ] }|j|dd� q d S )Nz %s_loaderT)� with_subdir)�getattr�sys�modules�__name__r: )� which_loader�paths�loaderr5 r& r& r, �add_dirs_to_loaderj s �rV c @ s e Zd Zdd� ZdS )�PluginPathContextc C s || _ || _d S �N)r5 �internal)�selfr5 rY r& r& r, �__init__r s zPluginPathContext.__init__N)rR � __module__� __qualname__r[ r& r& r& r, rW q s rW c @ s@ e Zd Zdd� Zedd� �Zdd� Zdd� Zd d � Zd d � Z d S )�PluginLoadContextc C sj d | _ g | _g | _g | _g | _d | _d | _d | _d | _d | _ d| _ d | _ d | _ g | _ d| _d | _d | _d S �NF)� original_name� redirect_list� error_list�import_error_list� load_attempts�pending_redirect� exit_reason�plugin_resolved_path�plugin_resolved_name�plugin_resolved_collection� deprecated� removal_date�removal_version�deprecation_warnings�resolved�_resolved_fqcn� action_plugin�rZ r& r& r, r[ x s" zPluginLoadContext.__init__c C sf | j sd S | js0| jd }t�|�r |�d�r |�d�d }| jr-t�|�s-| jd | }|| _| jS )N����ansible.legacy.�.)rn ro ra r � is_valid_fqcr� startswith�splitri )rZ � final_pluginr& r& r, � resolved_fqcn� s z PluginLoadContext.resolved_fqcnc C s� |s| S |� dd �p d}|� dd �}|� dd �}|d ur d }d�||r%dnd|�}tj||||d� d| _|r:|| _|r?|| _| j�|� | S ) N� warning_text� rk rl z {0} has been deprecated.{1}{2}� )�date�version�collection_nameT)rD �formatr; rj rk rl rm �append)rZ r* � deprecationr rz rk rl r& r& r, �record_deprecation� s z$PluginLoadContext.record_deprecationc C s. d | _ || _|| _|| _|| _d| _|| _| S )NT)re rh rg ri rf rn rp )rZ � resolved_name� resolved_path�resolved_collectionrf rp r& r& r, �resolve� s zPluginLoadContext.resolvec C s || _ d�| j|�| _d| _| S )Nz+pending redirect resolution from {0} to {1}F)re r� r` rf rn )rZ � redirect_namer& r& r, �redirect� s zPluginLoadContext.redirectc C s d | _ || _d| _| S r_ )re rf rn )rZ rf r& r& r, �nope� s zPluginLoadContext.nopeN) rR r\ r] r[ �propertyry r� r� r� r� r& r& r& r, r^ w s r^ c @ s e Zd ZdZd<dd�Zedd� �Zdd� Zd d � Zd d � Z d d� Z dd� Z dd� Z dd� Z d=dd�Zd=dd�Zd=dd�Zd d � Zd>d d �Zd?d!d"�Zd>d#d$�Zd@d&d'�Zd@d(d)�Zd%d d de� fd*d+�ZdAd,d-�Zd?d.d/�ZeZd0d1� Z d<d2d3�Z d4d5� Z d6d7� Z d<d8d9�Z d:d;� Z!dS )Br( z� PluginLoader loads plugins from the configured plugin directories. It searches for plugins by iterating through the combined list of play basedirs, configured paths, and the python path. The first match is used. Nc C s� |d u ri n|}|| _ || _|| _|| _|| _|r"t|t�s"|g}n|s&g }|| _|tvr1i t|< |t vr9d t |< |t vrCt t �t |< g | _ t| | _t | | _t | | _| jdkr\i nd | _t� | _d S �N� vars_plugins)� class_name� base_class�packager8 �aliasesr' �list�configr r r r �dict� _extra_dirs� _module_cache�_paths�_plugin_path_cache�_plugin_instance_cache�set�_searched_paths)rZ r� r� r� r8 r� �required_base_classr& r& r, r[ � s. zPluginLoader.__init__c C s t �| j�S rX )r � legacy_plugin_dir_to_plugin_typer8 rq r& r& r, �type� s zPluginLoader.typec C s d� | j�S )NzPluginLoader(type={0}))r� r� rq r& r& r, �__repr__� s zPluginLoader.__repr__c C sv t jrd | _d S i t| j< d t| j< tt�t| j< t| j | _ t| j | _t| j | _ | j dkr2i nd | _ t � | _d S r� )�C�OLD_PLUGIN_CACHE_CLEARINGr� r r� r r r� r r� r� r8 r� r� r� rq r& r& r, � _clear_caches� s zPluginLoader._clear_cachesc C s� |� d�}|� d�}|� d�}|� d�}|� d�}|� d�}|� d�t|< |� d�t|< | �||||||� |� d g �| _|� d t� �| _d S ) z Deserializer. r� r� r� r8 r� r� r r r� r� N)rD r r r[ r� r� r� )rZ �datar� r� r� r8 r� r� r& r& r, � __setstate__ s zPluginLoader.__setstate__c C s8 t | j| j| j| j| j| j| j| jt | j t | j d� S )z Serializer. ) r� r� r� r� r8 r� r� r� r r ) r� r� r� r� r� r8 r� r� r� r r rq r& r& r, � __getstate__ s �zPluginLoader.__getstate__c C s, g }|D ] }||vr|� |� qtj�|�S )z; Returns a string suitable for printing of the search path )r� r4 �pathsepr9 )rZ rT �ret�ir& r& r, � format_paths2 s � zPluginLoader.format_pathsc C s | � | jdd��S )NF��subdirs)r� � _get_pathsrq r& r& r, � print_paths< s zPluginLoader.print_pathsc C sR g }|� |� tj|dd�D ]\}}}d|v r&|D ] }|� tj�||�� qq|S )NT)� followlinksz __init__.py)r� r4 �walkr5 r9 )rZ �dir�results�rootr� �files�xr& r& r, �_all_directories? s �z PluginLoader._all_directoriesTc C sv | j sg S t| d�s/t| j �}| j �d�dd� }|D ]}t||�}qttj�|j �dd�| _ |r7| � | j �S | j gS )z# Gets the path of a Python package � package_pathrt r Nr1 r2 ) r� �hasattr� __import__rw rO r r4 r5 �dirname�__file__r� r� )rZ r� �m�parts� parent_modr& r& r, �_get_package_pathsH s z PluginLoader._get_package_pathsc C s� | j dur| j S dd� | jD �}| jdurd| jD ]K}tj�tj�|��}|rQt�d| �t�d| � }|D ]}t|dd�}tj� |�rP||vrP|� t |d�� q6t|dd�}||vrc|� t |d�� q|� d d� | j |d �D �� |jd d � d � || _ |S )zE Return a list of PluginPathContext objects to search for plugins in Nc S � g | ]}t |d ��qS �F�rW �r) �pr& r& r, r- ` � z8PluginLoader._get_paths_with_context.<locals>.<listcomp>z%s/*z%s/*/*r1 r2 Fc S r� �Tr� r� r& r& r, r- t r� r� c S s | j �d�S )Nz/windows)r5 �endswith)r� r& r& r, �<lambda>� s z6PluginLoader._get_paths_with_context.<locals>.<lambda>��key)r� r� r� r4 r5 �abspathr6 �globr r7 r� rW �extendr� �sort)rZ r� r� r5 �contents�cr& r& r, �_get_paths_with_contextW s* � � z$PluginLoader._get_paths_with_contextc C s | j |d�}dd� |D �S )z1 Return a list of paths to search for plugins in r� c S s g | ]}|j �qS r& )r5 )r) �path_with_contextr& r& r, r- � s z+PluginLoader._get_paths.<locals>.<listcomp>)r� )rZ r� �paths_with_contextr& r& r, r� � s zPluginLoader._get_pathsc C s� | j rLt| j �}|tjv rNtj�||�sPtt|dd�|d��� }|rRt ||t |dkd� d|v rTt |d t �rVtj� |||d � t�d||f � dS dS dS dS dS dS dS ) zf Reads plugin docs to find configuration setting definitions, to push to config manager for later use � DOCUMENTATIONr{ )� file_name�module)�fragment_loader� is_module�optionsz%Loaded config def from plugin (%s/%s)N)r� r r� �CONFIGURABLE_PLUGINSr� � has_configuration_definitionr rO �get_single_datar r� r' r� �+initialize_plugin_configuration_definitionsr; �debug)rZ r* r� r5 � type_name�dstringr& r& r, �_load_config_defs� s �z PluginLoader._load_config_defsFc C s` t j�|�}|dur,|rt j�|| j�}|| jvr.| j�|� | �� t� d| � dS dS dS )z1 Adds an additional directory to the search path Nz Added %s to loader search path) r4 r5 �realpathr9 r8 r� r� r� r; r� )rZ � directoryrN r& r& r, r: � s �zPluginLoader.add_directoryc C s� t |j�}|s d S z t |jd�|� � W n ty Y nw t|dd �}|s)d S |jr6d�|j|jg�}n|j}|�di ��|i ��|| d �}|sY|�di ��|i ��|d �}|S )Nz .plugins.{0}�_collection_metart �plugin_routing) r � n_python_collection_package_namer� � ImportErrorrO r� r9 �resourcerD )rZ �acr� plugin_type� extension�collection_pkg�collection_meta�subdir_qualified_resource�entryr& r& r, � _query_collection_routing_meta� s$ � z+PluginLoader._query_collection_routing_metac C s� d|_ t�| j�}t�||�}| j|||d�}d}|r�|�dd�} |s+|�|| |j� |�dd�} | rl| �d�} | �d�} | �d�pCd } d � || rKd nd | �} t j | | | d |jd �}| |_ | |_ d |_ ||_t||d��|�dd�}|r�t�|�s�td|j� d|� d|� d���t �d� |||�� ||jvr�|j�|� |�|�S | jdkr�|�d�}t|jdd�}d� |j|�}|r�||7 }tj�|j�}|s�zt |j�}W n t y� |� d� |j�� Y S w t j �!|j"�}t j �#||�}t j �$|��r |�%|t&|�|jd� ||j�|�S |�r|� d � t&|�|j��S d d � t'�(t j �#||�d �D �}|�s6|� d � ||j��S t)|�}t*|�d!k�rKt �+d"d#�#|� � |�%|t&|d$ �|jd%� ||j�|�S )&z�Search builtin paths to find a plugin. No external paths are searched, meaning plugins inside roles inside collections will be ignored. F)r� Nr� � tombstonerk rl rz r{ z{0} has been removed.{1}{2}r| T)�msgr~ r} �removedr �r% r� � Collection � contains invalid redirect for �: �6. Redirects must use fully qualified collection names.z"redirecting (type: {0}) {1} to {2}rQ rp �strictr2 �{0}.{1}z Python package {0} not foundz found exact match for {0} in {1}zno match for {0} in {1}c S s( g | ]}t j�|�r|�tj�s|�qS r& )r4 r5 �isfiler� r� �MODULE_IGNORE_EXTS�r) �fr& r& r, r- 3 s � �z0PluginLoader._find_fq_plugin.<locals>.<listcomp>z.*z+failed fuzzy extension match for {0} in {1}r zDFound several possible candidates for the plugin but using first: %s�,r z*found fuzzy extension match for {0} in {1}),rn r r� r8 � from_fqcrr� rD r� � collectionr� r; �get_deprecation_messagerk rl rf r ru r �vvra r� r� r� r r� �n_python_package_namerP rQ r r� r� r4 r5 r� r� r9 �existsr� r r� �iglob�sorted�lenr� )rZ �fq_namer� r% �ignore_deprecatedr� r� �routing_metadatarp r� r� rk rl rz � removed_msgr� � n_resource� full_name�pkg�pkg_path�n_resource_path� found_filesr& r& r, �_find_fq_plugin� s� � � ����z PluginLoader._find_fq_pluginr{ c C s( | � |||||�}|jr|jr|jS dS )z Find a plugin named name N)�find_plugin_with_contextrn rg )rZ r* �mod_typer � check_aliases�collection_list�resultr& r& r, � find_pluginC s zPluginLoader.find_pluginc C s~ t � }||_ | j||||||d�}|jr.|j|jv r%td�|j|j���|j}d|_|}nnq|jr=t� d�||j�� |S )zg Find a plugin named name, returning contextual info about the load, recursively resolving redirection Tr� z.plugin redirect loop resolving {0} (path: {1})Nz;errors were encountered during the plugin load for {0}: {1}) r^ r` �_resolve_plugin_stepre ra r r� rb r; r< )rZ r* r r r r r% r r& r& r, r K s � z%PluginLoader.find_plugin_with_contextc s� |st d��|j�� � d|_� t| j v r d�� �|_|S |r#|}n| jr)d}nd}t � � �s2|r߈ � d�s�d� v s=|sA� g}n � fdd �|D �}|D ]y} z<|j �| � | � d �rg| � � �d �||||�}n| j| |||d �}|jr~| |jvr~|j�| � |js�|jr�|W S W qL tttfy� � ty� } z |j�| � W Y d } ~ qLd } ~ w ty� } z|j�t| �� W Y d } ~ qLd } ~ ww |jr�tjd �� d�|j��d� d�� �|_|S | � � ||||�S )Nz A PluginLoadContext is requiredFz#{0} matched a defined plugin filterz.pyr{ �Ansiblert c s g | ]}d � |� ��qS )r� )r� )r) r� �r* r& r, r- � s z5PluginLoader._resolve_plugin_step.<locals>.<listcomp>zansible.legacyrs )r% r z)plugin lookup for {0} failed; errors: {1}z; )r� zno matches found for {0}) � ValueErrorra r� rn �_PLUGIN_FILTERSr� r� rf r� r ru rv rd �_find_plugin_legacy� removeprefixr re r r r r� rc rE rb r r; r� r9 ) rZ r* r r r r r% �suffix� candidates�candidate_name�ie�exr& r r, r i sZ � � �� �� z!PluginLoader._resolve_plugin_stepc sb d|_ |r �j�||�}�j| }z#|| }|j|_||_|jr"dnd|_|jr,d| n||_ d|_ |W S t y= Y nw �fdd��� � D �D ]�}|j}t |�� t �d| � |j�|� |j} z� fd d�t�� �D �} W n ty� } zt �d t| � � W Y d } ~ nd } ~ ww d d� | D �D ]|�tj���} t�fd d�tjD ��r�q�tj�| �} | d }z| d }W n ty� d}Y nw t�dd��|�jd vr�t �| ��jd |< | �jd vr�t �| ��jd | < |�j| vr�t �| ��j| |< | �j| v�rt �| ��j| | < q��j � |� z'|| }|j|_||_|j�r(dnd|_|j�r3d| n||_ d|_ |W S t �yG Y qIw |� d��s�d| }||v �r�|| }|�sptj� |j��spt �!d|�"d� � |j|_||_|j�r}dnd|_|j�r�d| n||_ d|_ |S d�#|�}d|v�r�t$�%|��r��j&||||d�S |�'d�#|��S )z�Search library and various *_plugins paths in order to find the file. This was behavior prior to the existence of collections. F�ansible.builtinr{ �ansible.builtin.Tc 3 s2 � | ]}|j � jvrtj �t|j ��r|V qd S rX )r5 r� r4 r7 r r� rq r& r, � <genexpr>� s �0 z3PluginLoader._find_plugin_legacy.<locals>.<genexpr>z trying %sc 3 s � | ] }t j�� |�V qd S rX )r4 r5 r9 r� )r= r& r, r' � s � z Error accessing plugin paths: %sNc s s. � | ]}t j�|�r|�d �st|�V qdS )s __init__.pyN)r4 r5 r� r� r r� r& r& r, r' � s �, c 3 s � | ]}� � |�V qd S rX )r� )r) r� )� full_pathr& r, r' � s � r r r1 r2 �_z�%s is kept for backwards compatibility but usage is discouraged. The module documentation details page may explain more about this rationale.zansible.builtin.{0}rt )r r� r% r z.{0} is not eligible for last-chance resolution)(rn r� rD r� r5 rg rh rY ri ro �KeyErrorr� r r; r� rd r� r4 �listdir�OSErrorr< r rB �anyr� r� �splitext� IndexErrorrW r� �addrv �islinkrj �lstripr� r ru r r� )rZ r* r% r r r � pull_cacher� r5 rY � full_paths�er � splitname� base_namer� � alias_name�candidate_fqcrr& )r= r( rZ r, r � s� � �� � � � � z PluginLoader._find_plugin_legacyc C s\ z | j ||d�duW S ty- } zt|t�r� t�d�t|��� W Y d}~dS d}~ww )z& Checks if a plugin named name exists �r Nzhas_plugin error: {0})r rE r' r r; r� r� r )rZ r* r r$ r& r& r, � has_plugin s "��zPluginLoader.has_pluginc C s� |� d�r|}nd�| j|g�}|tjv rtj| S t�� �: t�dt� t j � t |�t |��}t j � |�}|tj|< z|j�|� W n tyO tj|= � w W d � |S 1 s[w Y |S )N�ansible_collections.rt �ignore)rv r9 r� rP rQ �warnings�catch_warnings� simplefilter�RuntimeWarning� importlib�util�spec_from_file_locationr �module_from_specrU � exec_modulerE )rZ r* r5 r �specr� r& r& r, �_load_module_source* s* �� ��z PluginLoader._load_module_sourcec C s� t |d|� t |d|� t |d|pg � g }|r |�|� |r)|�|d d d� � |s2td|� ���t |d|� t |d|d � d S ) N�_original_path� _load_name�_redirected_namesrr z Missing FQCN for plugin source �ansible_aliases� ansible_namer )rI r� r� r )rZ r+ r* r5 �redirected_namesrn �namesr& r& r, �_update_objectI s zPluginLoader._update_objectc O s | j |g|�R i |��jS rX )�get_with_contextr$ )rZ r* �args�kwargsr& r& r, rD \ s zPluginLoader.getc O s� t |�r|�� }d}|�dd�}|�dd�}|| jv r | j| }| jp$i �|� }r3|d jr3t|� S | j||d�}|jr@|j sEtd|�S |j } d| vrW|j rWd� |j | f�} |j } |j } | jpai �| � }rp|d jrpt|� S |jptg } | | jvr�| �| | �| j| < d}| �| | j| | � t| j| | j�} | jr�t| j| jgd �}zt|| j�}W n ty� td|� Y S w t| |�s�td|�S | j| j| | j| ||d � |�s z t� | �}| � || | | | � | j |g|�R i |�� |} W n, t �y } z d |j d v �rt!�"d | t#|�f � td|�W Y d}~S � d}~ww | � | | | | | � | jdu�r>t| dd��r>| |f| j| < n| jdu�rLdt$� f| j| < t| |�S )z9 instantiates a plugin of the given name using arguments T� class_onlyFr Nr r: rt ��fromlist��found_in_cacherT �abstractr zHReturning not found on "%s" as it has unimplemented abstract methods; %s� is_stateless)%r � _strip_unsafe�popr� r� rD rn r# r rg ry ri r9 rh ra r� rH r� rO r� r� r� r� �AttributeError� issubclass�_display_plugin_loadr� r$ �__new__rP r[ � TypeErrorrR r; �vr r^ )rZ r* rR rS rX rT r � cached_resultr% r �resolved_type_namer5 rN r+ r� � plugin_class�instancer5 r& r& r, rQ _ sl � �� z PluginLoader.get_with_contextc C sb t jr/d|tj�|�|f }t|�dkr d|| �|�f }|s!|r(d|||f }t�|� dS dS )zd formats data to display debug info for plugin loading, also avoids processing unless really needed zLoading %s '%s' from %sr z%s (searched paths: %s)z%%s (found_in_cache=%s, class_only=%s)N) r� � DEFAULT_DEBUGr4 r5 rB r r� r; r� )rZ r� r* �searched_pathsr5 rX rT r� r& r& r, r_ � s �z!PluginLoader._display_plugin_loadc o s� � |� dd�}|� dd�}|� dd�}|r|rtd��g }d}t� }| �� D ]"} t�ttj�| jd���} | j s=|� | � |� t | tjj d�� q&t� } |D �]�} tj�| �d } tj� | �}t| t�}|ri| }n|}|s||t| j v r|t�d | � qN|d ks�|d kr�| jd kr�t�d| � qN|r�|| v r�t�d| � qN| �|� |r�| V qN| |v r�|}nd|� �}| jp�i �|� }r�|d jr�|d V qN| | jv�r| jdv r�d�t t | ��|�}n|}z| � || �}W n t �y } zt� d| t!|�f � W Y d}~qNd}~ww || j| < d}n| j| }| �"||| � zt#|| j$�}W n t%�yD } zt� d| t!|�f � W Y d}~qNd}~ww | j&�rlt'| j| j&gd�}zt#|| j&�}W n t%�yd Y qNw t(||��slqN| j)| j$|| j*| ||d� |�s�z ||i |��}W n t+�y� } zt� d| t!|�f � W Y d}~nd}~ww | j,||| |d� | jdu�r�d}t-|d��r�|j.}nt-|d ��r�|j/}tj0d d d � |�s�| �1|�d |V qNdS ) a Iterate through all plugins of this type, in configured paths (no collections) A plugin loader is initialized with a specific type. This function is an iterator returning all of the plugins of that type to the caller. :kwarg path_only: If this is set to True, then we return the paths to where the plugins reside instead of an instance of the plugin. This conflicts with class_only and both should not be set. :kwarg class_only: If this is set to True then we return the python class which implements a plugin rather than an instance of the plugin. This conflicts with path_only and both should not be set. :kwarg _dedupe: By default, we only return one plugin per plugin name. Deduplication happens in the same way as the :meth:`get` and :meth:`find_plugin` methods resolve which plugin should take precedence. If this is set to False, then we return all of the plugins found, including those with duplicate names. In the case of duplicates, the order in which they are returned is the one that would take precedence first, followed by the others in decreasing precedence order. This should only be used by subclasses which want to manage their own deduplication of the plugins. :*args: Any extra arguments are passed to each plugin when it is instantiated. :**kwargs: Any extra keyword arguments are passed to each plugin when it is instantiated. �_dedupeT� path_onlyFrT �HDo not set both path_only and class_only when calling PluginLoader.all()z*.pyr� r z+'%s' skipped due to a defined plugin filterr[ �base�ansible.plugins.cachez!'%s' skipped due to reserved namez'%s' skipped as duplicater& r )�filter�testz{0}_{1}z%Skipping plugin (%s), cannot load: %sNz2Skipping plugin (%s) as it seems to be invalid: %srU rW z5Skipping plugin (%s) as it seems to be incomplete: %s�rn �REQUIRES_ENABLED�REQUIRES_WHITELISTzaThe VarsModule class variable 'REQUIRES_WHITELIST' is deprecated. Use 'REQUIRES_ENABLED' instead.gq= ףp@�r~ )2r\ r r� r� r� r r4 r5 r9 rY �updater� r rB r. r' � Jinja2Loaderr r� r; r� r0 r� rD rn r� r� r� �abs�hashrH rE r< r r� rO r� r] r� r� r^ r_ r� ra rP r� rq rr rj rQ )rZ rR rS �deduperj rT � all_matchesrX �legacy_excluding_builtinr� �matches�loaded_modulesr5 r* rB �is_j2�ref_name�fqcnrc r r� r5 r+ re � needs_enabledr& r& r, rF � s� � " �� ��� "�� ��zPluginLoader.all�NNr� r� rX �r{ FFN)FFN)"rR r\ r] �__doc__r[ r� r� r� r� r� r� r� r� r� r� r� r� r� r: r� r r r r^ r r r; � __contains__rH rP rD rQ r_ rF r& r& r& r, r( � sB $ 5 m � I k Y r( c sl e Zd ZdZd� fdd� Z� fdd�Zdd d �Zed d � �Zd d� Z � fdd�Z dd� Z � fdd�Z � Z S )ru a PluginLoader optimized for Jinja2 plugins The filter and test plugins are Jinja2 plugins encapsulated inside of our plugin format. We need to do a few things differently in the base class because of file == plugin assumptions and dedupe logic. Nc s, t t| �j||||||d� || _i | _d S )N�r� r� )�superru r[ �_plugin_wrapper_type� _cached_non_collection_wrappers)rZ r� r� r� r8 �plugin_wrapper_typer� r� �� __class__r& r, r[ l s zJinja2Loader.__init__c s t t| ��� i | _d S rX )r� ru r� r� rq r� r& r, r� q s zJinja2Loader._clear_cachesr{ Fc C s t d��)Nz,find_plugin is not supported on Jinja2Loader)�NotImplementedError)rZ r* r r r r r& r& r, r u s zJinja2Loader.find_pluginc C s t | j�d S )N�s)r r� rq r& r& r, �method_map_namex s z Jinja2Loader.method_map_namec C sZ g }d� d|d| j|g�}z|| jvr | �||�| j|< | j| }t|| j�}W n ty? } z td||t|�f ��d }~ww |� } | d u rOtd||f ��z t| | j �} | � � � } W n! ty} } zt � d| jt |�|f � |W Y d }~S d }~ww | D ]*\} } d� || f�}d� || f�}| �| �}||v r�q�| j||||d� |�|� q�|S )Nrt �ansible_collections�pluginsz Failed to load %s for %s: %szCould not find %s.%sz9Ignoring %s plugins in '%s' as it seems to be invalid: %rrp )r9 r� r� rH rO r� rE r* r r� r/ r; r< r r� rP r� )rZ r r> r* r� r r� r+ r5 � plugin_impl� method_map� plugin_map� func_name�funcr �full�pluginr& r& r, �get_contained_plugins| s> �� �� z"Jinja2Loader.get_contained_pluginsc $ s� |� dd� |� dd � t� }|�d�}| j|i |�� | j�|� }rBd|_||_|j|_ |j � d�r6dnd|_ |j |_ t||�S d }t|�\}}t� } || v rYtd | d ��| �|� t�|| j�} | sntd �|���zt| j�} W n ty� } z td �|t| ����d } ~ ww | �d i ��| ji ��|i �} | �d�}|r�|�d�p�d}|�d�}|�d�}| j� � � d|� d|r�dnd� |� �}t j |||| jd� | �d�}|�r |�d�p�d}|�d�}|�d�}| j� � � d|� d|r�dnd� |� �}t j |||| jdd�}t |��| �dd �}|�rHt�!|��s.td| j� d| j� d | j"� d |� d � ��t|| jd �\}}t �#d �| j| j| j"|�� |}nnqNzt$| j%�}W n t&�yd } ztt| ���d } ~ ww | j}| j'�rsd!�|| j'�}z�t(j)|j*|d d"�D ]�\}}}|�r��q~z t+t,| �j-|g|�R i |��}t.|j/| j0�} | � �1� } W n# t2�y� } zt �3d#| j� d$|� d%| � �� W Y d } ~ �q~d } ~ ww | D ]@\} } d �4|| f�} d&| j� d'| j� d | j'� d | � �}!|| | fv �r | �5| �}|�r |j6}| j7||!|j/j| d(� |j |_ n�qːq~W nH t �y% }" z tt|"�d |"d)��d }"~"w ttf�y/ � t2�yW }# z t �3d*�t|#��� t �#d+�t8� �� tt|#�d |#d)��d }#~#ww t||�S ),NrT Fr rs Tr& r% r{ z*recursive collection redirect found for %rr zinvalid plugin name: {0}z Invalid plugin FQCN ({0}): {1}r� r� rz rk rl z "z" has been deprecated.r| )r~ r} r r� z" has been removed.)r~ r} r r� r� r� r� rt r� r� )r z&redirecting (type: {0}) {1}.{2} to {3}r� )�prefixz Skipping z plugins in z$'; an error occurred while loading: r< z .plugins.rp )�orig_excz>An unexpected error occurred during Jinja2 plugin loading: {0}z2Unexpected error during Jinja2 plugin loading: {0})9r\ r^ r � _ensure_non_collection_wrappersr� rD rn rh rI rg rM rv ri ro r# �get_fqcr_and_namer� r r0 r �try_parse_fqcrr� r* r� r r r r �titler; rj r r ru r� �vvvr r r� r� �pkgutil� iter_modules�__path__r� ru rQ rO r$ r� r/ rE r< r9 r� r% rP r )$rZ r* rR rS �context� known_pluginr� r� �leaf_key�seenr� �tsr5 � routing_entry�deprecation_entryrz rk rl �tombstone_entry�exc_msgr� �next_keyr � parent_prefix�dummy� module_name�ispkgr� r� r� r� r� r �src_name�aprer$ r� r& r, rQ � s� �� & & � "� �; �� �� " �� ��� z Jinja2Loader.get_with_contextc o s� � |� dd � |� dd�}|� dd�}|r|rtd��| j|i |�� |r4dd� | j�� D �E d H d S dd� | j�� D �E d H d S ) Nri rj FrT rk c s s � | ]}|j V qd S rX )rI �r) �wr& r& r, r' 4 s � z#Jinja2Loader.all.<locals>.<genexpr>c s s � | ]}|V qd S rX r& r� r& r& r, r' 6 s � )r\ r r� r� �values)rZ rR rS rj rT r& r& r, rF ) s � zJinja2Loader.allc s� | j rd S tt| �j|i |��D ]�}|j�d�}t|| j�}z|� }W n tyC } zt � d| j t |j �|f � W Y d }~qd }~ww |�� D ]�}d|v r[t �|� d|j � d�� qH|t| j v rjt �d| � qH| �|| �} |} |j�d�dkr�d�|j�d�d d� �nd} |�| �s�| � d|� �} | j| ||j | d � || h} |r�| �d|� �� | D ]!} | j �| � }r�t �d | � d |j � d |j � d �� q�| | j | < q�qHqd S )Nr& z9Skipping %s plugins in '%s' as it seems to be invalid: %rrt z skipped in z.; Jinja plugin short names may not contain "."z)%s skipped due to a defined plugin filter� r{ rp z Jinja plugin z from z" skipped; shadowed by plugin from �))r� r� ru rF rM rv rO r� rE r; �vvvvr� r rI �keysr� r r� r� �countr9 rw rP r0 rD )rZ rR rS �p_map� is_builtin� plugins_listr� r5 � plugin_name�wrapperr r � target_names� target_name�existing_pluginr� r& r, r� 8 sL �� . � ���z,Jinja2Loader._ensure_non_collection_wrappersr� r� )rR r\ r] r� r[ r� r r� r� r� rQ rF r� � __classcell__r& r& r� r, ru d s & ru r% c C s: d| vr| }|d | }||fS | � d�d }| }||fS )Nrt rr )rw )r� r r* �fqcrr& r& r, r� h s �r� c C s� t } d}tjd u r d}ntj}d}tj�|�r�t|d��7}zt|�� �}W n& t yK } zt � d� |t |��� | W Y d }~W d � S d }~ww W d � n1 sVw Y z|d }W n tyt t � d� |�� | Y S w t |�}|�� }|dkr�d |v r�t jd d d � d |vr�|d |d < |d = z t|d �| d< W n ty� t � d� |�� | Y S w | d | d< nt � d� |�� n |r�t � d� |�� d| d v r�td� t|����| S )NFz /etc/ansible/plugin_filters.ymlT�rbz;The plugin filter file, {0} was not parsable. Skipping: {1}�filter_versionz2The plugin filter file, {0} was invalid. Skipping.z1.0�module_blacklistzC'module_blacklist' is being removed in favor of 'module_rejectlist'z2.18rs �module_rejectlist�ansible.moduleszXUnable to parse the plugin filter file {0} as module_rejectlist is not a list. Skipping.�ansible.plugins.actionz^The plugin filter file, {0} was a version not recognized by this version of Ansible. Skipping.z5The plugin filter file, {0} does not exist. Skipping.�statz�The stat module was specified in the module reject list file, {0}, but Ansible will not function without the stat module. Please remove stat from the reject list.)r r� �PLUGIN_FILTERS_CFGr4 r5 r �openr �readrE r; r< r� r r* �striprj � frozensetra r r )�filters�user_set� filter_cfgr� � filter_datar5 r~ r& r& r, �_load_plugin_filters sr ���� � �� ���� �r� c C s� t �td�| |��� t| �}z/t|�dd�t�s9tj � d�}d�| t�}|dkr1t � |� W d S |dkr<t |��W d S W d S t yF � tya } zt � d�| |�� W Y d }~d S d }~ww ) Nz Loading collection {0} from {1}�requires_ansibler{ �'COLLECTIONS_ON_ANSIBLE_VERSION_MISMATCHz3Collection {0} does not support Ansible version {1}r< �errorzQError parsing collection metadata requires_ansible value from collection {0}: {1})r; r� r r� r �(_does_collection_support_ansible_versionrD �ansible_versionr� r� �get_config_valuer< r r rE )r �collection_pathr� �mismatch_behavior�messager$ r& r& r, �_on_collection_load_handler� s$ � ��r� c C s6 | sdS t s t�d� dS t | �}t|�j}|�|�S )NTz_packaging Python module unavailable; unable to validate collection Ansible version requirements)r! r; r< r" � base_version�contains)�requirement_stringr� �ss�base_ansible_versionr& r& r, r� � s r� c C sT t jr t�d� d S | d u rg } t| �tj }t|tj�}|� � t j t 7 _ d S )Nz3AnsibleCollectionFinder has already been configured) r �collection_finderr> �warnr� r� �COLLECTIONS_PATHSr �COLLECTIONS_SCAN_SYS_PATH�_install�on_collection_loadr� )�prefix_collections_pathrT �finderr& r& r, � _configure_collection_loader� s r� c C s t � t| � dS )a� Initialize the plugin filters and the collection loaders This method must be called to configure and insert the collection python loaders into ``sys.meta_path`` and ``sys.path_hooks``. This method is only called in ``CLI.run`` after CLI args have been parsed, so that instantiation of the collection finder can utilize parsed CLI args, and to not cause side effects. N)r� r� )r� r& r& r, �init_plugin_loader� s r� �ModuleDocFragmentz ansible.plugins.doc_fragments� doc_fragments� ActionModuler� �action_plugins� ActionBase)r� � CacheModulerm � cache_plugins�CallbackModulezansible.plugins.callback�callback_plugins� Connectionzansible.plugins.connection�connection_plugins�paramiko� paramiko_ssh�ConnectionBaser� � ShellModulezansible.plugins.shell� shell_pluginsr{ r� �libraryzansible.module_utils� module_utils� LookupModulezansible.plugins.lookup�lookup_plugins� LookupBase� FilterModulezansible.plugins.filter�filter_plugins� TestModulezansible.plugins.test� test_plugins�StrategyModulezansible.plugins.strategy�strategy_plugins� StrategyBase�TerminalModulezansible.plugins.terminal�terminal_plugins� TerminalBase� VarsModulezansible.plugins.varsr� �Cliconfzansible.plugins.cliconf�cliconf_plugins� CliconfBase�Netconfzansible.plugins.netconf�netconf_plugins� NetconfBase�InventoryModulezansible.plugins.inventory�inventory_plugins�HttpApizansible.plugins.httpapi�httpapi_plugins� HttpApiBase� BecomeModulezansible.plugins.become�become_pluginsr� )r% rX )|� __future__r r� r4 �os.pathr� rP r> � collectionsr r rB r � tracebackr �"ansible.module_utils.compat.typingr �compat�typing�trn r ro r �ansibler r� r r� �ansible.errorsr r r r �+ansible.module_utils.common.text.convertersr r r �ansible.module_utils.sixr �ansible.parsing.utils.yamlr �ansible.parsing.yaml.loaderr �ansible.pluginsr r r r � ansible.utils.collection_loaderr r �2ansible.utils.collection_loader._collection_finderr r �ansible.utils.displayr �ansible.utils.plugin_docsr �ansible.utils.unsafe_proxyr �packaging.specifiersr! �packaging.versionr" r� �importlib.utilr� r r; r# r0 r? rM rV r$ rW r^ r( ru r� r� r� r� r� r� �DOC_FRAGMENT_PLUGIN_PATHr� �DEFAULT_ACTION_PLUGIN_PATH� action_loader�DEFAULT_CACHE_PLUGIN_PATH� cache_loader� DEFAULT_CALLBACK_PLUGIN_PATH�callback_loader� DEFAULT_CONNECTION_PLUGIN_PATH�connection_loaderrC �DEFAULT_MODULE_PATH� module_loader�DEFAULT_MODULE_UTILS_PATH�module_utils_loader�ps_module_utils_loader�DEFAULT_LOOKUP_PLUGIN_PATH� lookup_loader�DEFAULT_FILTER_PLUGIN_PATH� filter_loader�DEFAULT_TEST_PLUGIN_PATH� test_loader� DEFAULT_STRATEGY_PLUGIN_PATH�strategy_loader� DEFAULT_TERMINAL_PLUGIN_PATH�terminal_loader�DEFAULT_VARS_PLUGIN_PATH� vars_loader�DEFAULT_CLICONF_PLUGIN_PATH�cliconf_loader�DEFAULT_NETCONF_PLUGIN_PATH�netconf_loader� DEFAULT_INVENTORY_PLUGIN_PATH�inventory_loader�DEFAULT_HTTPAPI_PLUGIN_PATH�httpapi_loader�BECOME_PLUGIN_PATH� become_loaderr& r& r& r, �<module> s~ � !R " @ ����� ��� ������������
Save
Cancel