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 : /lib/python3.9/site-packages/ansible/galaxy/collection/__pycache__/ |
a
�)g$ � @ s� d Z ddlmZmZmZ eZddlZej rRddl
m Z ddl m
Z
ddlmZmZ ddl
mZmZ ddlmZ dd lmZ e� ZG d
d � d �ZdS ) z8A facade for interfacing with multiple Galaxy instances.� )�absolute_import�division�print_functionN)�CollectionVersionMetadata)�ConcreteArtifactsManager)� Candidate� Requirement)� GalaxyAPI� GalaxyError)�to_text)�Displayc @ sV e Zd ZdZddd�Zedd� �Zdd� Zd d
� Zd d � Z d
d� Z
dd� Z dd� Z dS )�MultiGalaxyAPIProxyz<A proxy that abstracts talking to multiple Galaxy instances.Fc C s || _ || _|| _dS )z Initialize the target APIs list.N)�_apis�_concrete_art_mgr�_offline)�selfZapisZconcrete_artifacts_managerZoffline� r �N/usr/lib/python3.9/site-packages/ansible/galaxy/collection/galaxy_api_proxy.py�__init__ s z MultiGalaxyAPIProxy.__init__c C s | j S �N)r �r r r r �is_offline_mode_requested& s z-MultiGalaxyAPIProxy.is_offline_mode_requestedc C s | j rtd��d S )NzAThe calling code is not supposed to be invoked in 'offline' mode.)r �NotImplementedErrorr r r r �*_assert_that_offline_mode_is_not_requested* s z>MultiGalaxyAPIProxy._assert_that_offline_mode_is_not_requestedc
c s� | j r
g S d}d}t|jt�r&|jfn| j}|D ]�}z|�|j|j�}W nl typ } z|}W Y d}~q0d}~0 t y� } z.t
� dj |j
|jt|�d�� |}W Y d}~q0d}~0 0 d}|D ]} || fV q�q0|s�|dur�|�dS )z�Helper for get_collection_versions.
Yield api, version pairs for all APIs,
and reraise the last error if no valid API was found.
FN�zSkipping Galaxy server {server!s}. Got an unexpected error when getting available versions of collection {fqcn!s}: {err!s}�Zserver�fqcn�errT)r �
isinstance�srcr r �get_collection_versions� namespace�namer
� Exception�display�warning�format�
api_serverr r )
r � requirementZ found_apiZ
last_error�api_lookup_order�apiZversions�api_err� unknown_err�versionr r r �_get_collection_versions. s6
�
���
z,MultiGalaxyAPIProxy._get_collection_versionsc C sL |j r| j�|�|jfhS t|jt�r.|jfn| j}tdd� | �|�D ��S )z8Get a set of unique versions for FQCN on Galaxy servers.c s s | ]\}}||fV qd S r r )�.0r* r- r r r � <genexpr>k s �z>MultiGalaxyAPIProxy.get_collection_versions.<locals>.<genexpr>) �is_concrete_artifactr Z get_direct_collection_versionr r r r �setr. )r r( r) r r r r Z s ���
�
���z+MultiGalaxyAPIProxy.get_collection_versionsc C s� | � � t|jt�r |jfn| j}|D ]�}z|�|j|j|j�}W nl t yj } z|}W Y d}~q&d}~0 t
y� } z.|}t � dj
|j|jt|�d�� W Y d}~q&d}~0 0 | j�||j|j|j|j|j� | S q&|�dS )z2Retrieve collection metadata of a given candidate.Nr r )r r r r r � get_collection_version_metadatar! r" �verr
r# r$ r% r& r' r r r Zsave_collection_sourceZ download_urlZartifact_sha256�tokenZsignatures_urlZ
signatures)r �collection_candidater) r* Zversion_metadatar+ �last_errr, r r r r3 r sB
�
���� �
z3MultiGalaxyAPIProxy.get_collection_version_metadatac C s |j r| j�|�S | �|�jS )z6Retrieve collection dependencies of a given candidate.)r1 r Z"get_direct_collection_dependenciesr3 Z dependencies)r r6 r r r �get_collection_dependencies� s ����z/MultiGalaxyAPIProxy.get_collection_dependenciesc
C s� | � � |j}|j}|j}d }t|jt�r2|jfn| j}|D ]�}z|�|||�W S t y| } z|}W Y d }~q<d }~0 t
y� } z.| }t � dj
|j|jt| �d�� W Y d } ~ q<d } ~ 0 0 q<|r�|�g S )Nr r )r r! r" r4 r r r r Zget_collection_signaturesr
r# r$ r% r& r' r r )
r r6 r! r" r- r7 r) r* r+ r, r r r �get_signatures� s4
�
���
z"MultiGalaxyAPIProxy.get_signaturesN)F)
�__name__�
__module__� __qualname__�__doc__r �propertyr r r. r r3 r8 r9 r r r r r
s
,2r
)r= Z
__future__r r r �typeZ
__metaclass__�typing�t�
TYPE_CHECKINGZansible.galaxy.apir Z3ansible.galaxy.collection.concrete_artifact_managerr Z0ansible.galaxy.dependency_resolution.dataclassesr r r r
Zansible.module_utils._textr Zansible.utils.displayr r$ r
r r r r �<module> s