관리-도구
편집 파일: galaxy_api_proxy.cpython-39.pyc
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