File: //usr/lib/python3.9/site-packages/ansible/galaxy/__pycache__/api.cpython-39.pyc
a
�)g�� � @ s� d dl mZmZmZ eZd dlZd dlZd dlZd dl Z d dl
Z
d dl Z d dl Z d dl
Z
d dlZd dlZd dlZd dlmZ d dlmZmZ d dlmZmZ d dlmZm Z m Z m Z m Z d dl m!Z" d dl#m$Z$ d d l%m&Z& d d
l'm(Z( d d l'm)Z) d d l*m+Z+ d d
l,m-Z-m.Z.m/Z/ d dl0m1Z1m2Z2 d dl3m4Z4 d dl5m6Z6 d dl7m8Z8 e4� Z9e�:� Z;dZ<ej=dej>hZ?dd� Z@dd� ZAdd� ZBdd� ZCe@d d � �ZDd d � ZEG d d!� d!e$�ZFe�Gd"g d#��ZHG d$d%� d%�ZIejJG d&d'� d'��ZKdS )(� )�absolute_import�division�print_functionN)�
HTTPStatus)�
BadStatusLine�IncompleteRead)� HTTPError�URLError)�quote� urlencode�urlparse�parse_qs�urljoin)� constants)� AnsibleError)�
user_agent)� retry_with_delays_and_condition)�generate_jittered_backoff)� string_types)�to_bytes� to_native�to_text)�open_url�prepare_multipart)�Display)�
secure_hash_s)�
makedirs_safe�d i c s � fdd�}|S )Nc s6 t � � | i |��W d � S 1 s(0 Y d S �N)� _CACHE_LOCK)�args�kwargs��func� �6/usr/lib/python3.9/site-packages/ansible/galaxy/api.py�wrapped0 s zcache_lock.<locals>.wrappedr$ )r# r& r$ r" r% �
cache_lock/ s r' c C s^ t | t�r| jtv rdS t | t�rZt| dd � }rZt |t�rB|j}t |tt t
t j f�rZdS dS )NT�orig_excF)
�
isinstance� GalaxyError� http_code�RETRY_HTTP_ERROR_CODESr �getattrr �reason� TimeoutErrorr r �socket�timeout)� exceptionr( r$ r$ r% �should_retry_error7 s
r3 c s � fdd�}|S )z�
Wrapper to lazily initialize connection info to Galaxy and verify the API versions required are available on the
endpoint.
:param versions: A list of API versions that the function supports.
c s � �fdd�}|S )Nc
s� | j �sjt�d| j � | j}d| j|f }| jdks@| jdkrDd}z| j|d|dd�}W n� tttt fy� } zx|�
d �s�|�
d
�r�� t |d
�}z| j|d|dd�}W n4 ty� } z |j d kr�|�� W Y d }~n
d }~0 0 W Y d }~n
d }~0 0 d |v�rtd
|| jf ��|| _|�
d ddi�}t|�� �dgk�rBd|d< || _ t�dd�|�� �| j| jf � t| j �� �}t���|�} | �s�td� jd���d�|�| j| jf ��� | g|�R i |��S )Nz'Initial connection to galaxy_server: %sz6Error when finding available api versions from %s (%s)zhttps://galaxy.ansible.comzhttps://galaxy.ansible.com/z https://galaxy.ansible.com/api/�GETT)�method�error_context_msg�cachez/apiz/api/� �available_versionszSTried to find galaxy API root at %s but no 'available_versions' are available on %s�v1zv1/zv2/�v2z1Found API version '%s' with Galaxy server %s (%s)�, zPGalaxy action %s requires API versions '%s' but only '%s' are available on %s %s)�_available_api_versions�display�vvvv�
api_server�name� _call_galaxyr r* �
ValueError�KeyError�endswith�_urljoinr+ �get�list�keys�join�set� intersection�__name__)
�selfr r! �n_urlr6 �data�errZnew_errr9 Zcommon_versions)r5 �versionsr$ r% r& S sN
.
����z-g_connect.<locals>.decorator.<locals>.wrappedr$ )r5 r& �rR )r5 r% � decoratorR s 8z g_connect.<locals>.decoratorr$ )rR rT r$ rS r% � g_connectK s :rU c C s< t | �}d}z
|j}W n ty( Y n0 d|j|p6df S )z* Gets the cache ID for the URL specified. Nz%s:%s� )r �portrC �hostname)�url�url_inforW r$ r$ r% � get_cache_id� s
r[ c C sh d}t j�| �sXt�dt| � � t| d�� t �| d� W d � n1 sN0 Y t �| �j }|tj
@ r�t� dt| � � dS t| dd�� }t|� � d d
�}W d � n1 s�0 Y zt
�|�}W n ty� d}Y n0 t|t��r|�d d�|k�rdt�d t| � � d |i}t| d
d��(}|�tt
�|�d d
�� W d � n1 �sZ0 Y |S )zR Loads the cache file requested if possible. The file must not be world writable. � z/Creating Galaxy API response cache file at '%s'�wi� NzKGalaxy cache has world writable access (%s), ignoring it as a cache source.�rb��mode�surrogate_or_strict��errors�versionz:Galaxy cache file at '%s' has an invalid version, clearing�wb)�os�path�isfiler> r? r �open�chmod�stat�st_mode�S_IWOTH�warning�read�json�loadsrC r) �dictrG �writer �dumps)Z b_cache_pathZ
cache_versionZ
cache_mode�fdZjson_valr7 r$ r$ r% � _load_cache� s. *
�.
8rv c G s d� dd� | d D ��S )N�/c s s$ | ] }|rt |d d��d�V qdS )ra rb rw N)r �strip)�.0�ar$ r$ r% � <genexpr>� � z_urljoin.<locals>.<genexpr>)rV )rJ )r r$ r$ r% rF � s rF c s e Zd ZdZ� fdd�Z� ZS )r* z( Error for bad Galaxy server responses. c sJ t t| ��|� |j| _|�� | _zt|�� �}t �
|�}W n t t fyV i }Y n0 | j�
d�}d|v r�|�d|j�}|�dd�}d|| j||f }n�d|v �r |�dg �} | s�i g} g }
| D ]F} | �d �p�| �d
�p�|j} | �d�p�d}
d | j| |
f }|
�|� q�d |d
�|
�f }n |�d|j�}d|| j|f }t|�| _d S )Nrw r; �message�codeZUnknownz(%s (HTTP Code: %d, Message: %s Code: %s)�v3rc Zdetail�titlez%(HTTP Code: %d, Message: %s Code: %s)z%s %sr< �defaultz %s (HTTP Code: %d, Message: %s))�superr* �__init__r~ r+ �geturlrY r ro rp rq �AttributeErrorrC �splitrG r. �appendrJ r r} )rN Z
http_errorr} Zhttp_msgZerr_infoZ url_splitZ
galaxy_msgr~ Zfull_error_msgrc Z
message_lines�errorZ error_msgZ
error_codeZ message_line�� __class__r$ r% r� � s6
zGalaxyError.__init__)rM �
__module__� __qualname__�__doc__r� �
__classcell__r$ r$ r� r% r* � s r* �CollectionMetadata)� namespacerA � created_str� modified_strc @ s e Zd Zdd� ZdS )�CollectionVersionMetadatac C s4 || _ || _|| _|| _|| _|| _|| _|| _dS )a�
Contains common information about a collection on a Galaxy server to smooth through API differences for
Collection and define a standard meta info for a collection.
:param namespace: The namespace name.
:param name: The collection name.
:param version: The version that the metadata refers to.
:param download_url: The URL to download the collection.
:param artifact_sha256: The SHA256 of the collection artifact for later verification.
:param dependencies: A dict of dependencies of the collection.
:param signatures_url: The URL to the specific version of the collection.
:param signatures: The list of signatures found at the signatures_url.
N)r� rA rd � download_url�artifact_sha256� dependencies�signatures_url�
signatures) rN r� rA rd r� r� r� r� r� r$ r$ r% r� � s z"CollectionVersionMetadata.__init__N)rM r� r� r� r$ r$ r$ r% r� � s r� c @ s� e Zd ZdZddddddded�df dd�Zd d
� Zd d � Zd
d� Zdd� Z e
e g d��dd� ��Z e
edddd�ed�dEdd��ZdFdd �Zed d � �Ze d g�d d!� �Ze d g�dGd"d#��Ze d g�dHd$d%��Ze d g�dId&d'��Ze d g�d(d)� �Ze d g�d*d+� �Ze d g�d,d-� �Ze d g�d.d/� �Ze d g�d0d1� �Z e d g�d2d3� �Z e d g�d4d5� �Z e d6d7g�d8d9� �Z e d6d7g�dJd;d<��Z e d6d7g�d=d>� �Z!e d6d7g�d?d@� �Z"e d6d7g�dAdB� �Z#e d6d7g�dCdD� �Z$dS )K� GalaxyAPIzM This class is meant to be used as a API client for an Ansible Galaxy server NTF�inf�< c
C s� || _ || _|| _|| _|| _|| _|| _| | _|p6i | _| | _ | | _
t t j
dd�}
t|
dd� tj�|
d�| _| r�t�> tj�| j�r�t�dt| j� � t�| j� W d � n1 s�0 Y d | _|
s�t| j�| _t�d| j| jf � d S )Nra rb i� r_ s api.jsonzClearing cache file (%s)z$Validate TLS certificates for %s: %s) �galaxyrA �username�password�tokenr@ �validate_certsr1 r= � _priority�_server_timeoutr �CZGALAXY_CACHE_DIRr rf rg rJ �
_b_cache_pathr �existsr> r? r �remove�_cacherv �debug)rN r� rA rY r� r� r� r� �available_api_versionsZclear_response_cacheZno_cache�priorityr1 Z b_cache_dirr$ r$ r% r� s.
* zGalaxyAPI.__init__c C s
t | j�S )z3Render GalaxyAPI as a native string representation.)r rA �rN r$ r$ r% �__str__3 s zGalaxyAPI.__str__c C s
t | j�S )z9Render GalaxyAPI as a unicode/text string representation.)r rA r� r$ r$ r% � __unicode__8 s zGalaxyAPI.__unicode__c C s dj | | j| j| jd�S )z9Render GalaxyAPI as an inspectable string representation.z><{instance!s} "{name!s}" @ {url!s} with priority {priority!s}>)�instancerA r� rY )�formatrA r� r@ r� r$ r$ r% �__repr__= s
��zGalaxyAPI.__repr__c C s( t || j�stS | j|jkp&| j| jk S )z:Return whether the instance priority is higher than other.)r) r� �NotImplementedr� rA )rN Zother_galaxy_apir$ r$ r% �__lt__H s
�zGalaxyAPI.__lt__)r: r; r c C s | j S r )r= r� r$ r$ r% r� S s z GalaxyAPI.available_api_versions� � �( )ZretriesZ
delay_baseZdelay_threshold)Zbackoff_iteratorr3 c
C s� t |�} t|�}
|s| j}t| j�} |�r"| j�r"| j�|
i �} d}
d}|| v rttj�| | d |
�}tj� � |k }d| v p�d| v }|r�|s�| | }|�
d�r�d|v r�dd d ii}nd d i}g |d
< |d
D ]}|d
� |� q�n|d
}|S |�s"tj� � }|tj d d �7 }|�
|
�dd
�| |< |�p*i }| j|||d� z4t�d| � tt|�|| j||| jt� dd�}W nl t�y� } zt||��W Y d }~nFd }~0 t�y� } z$td|t|�f |d��W Y d }~n
d }~0 0 t|�� dd�}zt � |�}W n* t �y& td|j t|�f ��Y n0 |�r�| j�r�| j|
| }d }dD ]}||v �rL|} �qh�qL|�r�d|d< |�d
g �}|| D ]}|� |� �q�n||d
< |S )Nz%Y-%m-%dT%H:%M:%SZF�expiresZpage�offset� paginatedz/v3/�links�next�resultsr\ )Zdays)r� r� )�requiredzCalling Galaxy at %s�safe)rP r� �headersr5 r1 �
http_agentZfollow_redirectsz8Unknown error when attempting to call Galaxy at '%s': %s�r( ra rb z5Failed to parse Galaxy response from '%s' as JSON:
%s)rP r� T) r r[ rg r
�queryr� �
setdefault�datetime�strptimeZutcnowrG r� Z timedelta�strftime�_add_auth_tokenr> r? r r r� r� r r r* � Exceptionr r ro rp rq rC rY )rN rY r r� r5 �
auth_requiredr6 r7 � cache_keyrZ Zcache_idr� � server_cacheZiso_datetime_formatZvalidr� Zis_paginated_urlZ
path_cache�res�result�resp�eZ resp_datarP Z
paginated_key�keyr� r$ r$ r% rB Y s�
�
�
� �
zGalaxyAPI._call_galaxyc C sD d|v r d S | j s*|r*td�ttj����| j r@|�| j �� � d S )NZ
AuthorizationzMNo access token or username set. A token can be set with --api-key or at {0}.)r� r r� r r� ZGALAXY_TOKEN_PATH�updater� )rN r� rY �
token_typer� r$ r$ r% r� � s
�zGalaxyAPI._add_auth_tokenc C sL t | jdd��*}|�tt�| j�dd�� W d � n1 s>0 Y d S )Nre r_ ra rb )ri r� rs r rp rt r� )rN ru r$ r$ r% �
_set_cache� s zGalaxyAPI._set_cacher: c
C s� t | j| jd d�d }td|i�}z t||| jdt� | jd�}W nd typ } zt |d��W Y d}~n@d}~0 t
y� } z t d t |� |d
��W Y d}~n
d}~0 0 t
�t|�� d d ��}|S )
z2
Retrieve an authentication token
r: �tokensrw � github_token�POST)rP r� r5 r� r1 z$Attempting to authenticate to galaxyNz$Unable to authenticate to galaxy: %sr� ra rb )rF r@ r� r r r� r r� r r* r� r r rp rq r ro )rN r� rY r r� r� rP r$ r$ r% � authenticate� s *zGalaxyAPI.authenticatec C s� t | j| jd d�d }|||r$|ndd�}|r:||d< n"|�d�r\|td�d d � |d< | j|t|�d
d �}|�d d �r�|d S |S )
z(
Post an import request
r: �importsrw rV )� github_user� github_repoZgithub_referenceZalternate_role_namez ansible-roler\ Nr� �r r5 r� )rF r@ r� �
startswith�lenrB r rG )rN r� r� Z reference� role_namerY r rP r$ r$ r% �create_import_task� s
�
z GalaxyAPI.create_import_taskc C sd t | j| jd d�}|dur*d||f }n(|durJ|durJd|||f }ntd��| �|�}|d S )z5
Check the status of an import task.
r: r� Nz%s?id=%dz %s?github_user=%s&github_repo=%sz/Expected task_id or github_user and github_repor� )rF r@ r� r rB )rN �task_idr� r� rY rP r$ r$ r% �get_import_task� s
zGalaxyAPI.get_import_taskc C s� t tt|���}z>|�d�}d�|dd� �}|d }|rLt�d||f � W n tyl td| ��Y n0 t| j | j
d dd||f �}| � |�}t |d �dkr�|d d S d
S ) z&
Find a role by name.
�.r ���z$- downloading role '%s', owned by %szAInvalid role name (%s). Specify role as format: username.rolenamer: �rolesz?owner__username=%s&name=%sr� N)
r �urlquoter r� rJ r> r� r rF r@ r� rB r� )rN r� �notify�partsZ user_namerY rP r$ r$ r% �lookup_role_by_name� s
�
z GalaxyAPI.lookup_role_by_namec
C s� g }z�t | j| jd d||d�}| �|�}|d }|�dd�du }t| j�}d|j|jf }|s�t ||d �}| �|�}||d 7 }|�dd�du }q\W n< ty� } z$t �
d||t | �f � W Y d} ~ n
d} ~ 0 0 |S ) z�
Fetch the list of related items for the given role.
The url comes from the 'related' field of the role.
r: r� z
?page_size=50r� � next_linkNz%s://%s/zSUnable to retrieve role (id=%s) data (%s), but this is not fatal so we continue: %s) rF r@ r� rB rG r �scheme�netlocr� r> rn r )
rN ZrelatedZrole_idr� rY rP �donerZ Zbase_urlr� r$ r$ r% �fetch_role_related s( �
� z GalaxyAPI.fetch_role_relatedc
C s� z�t | j| jd |d�}| �|�}d|v r4|d }n|}d}d|v rT|�dd�du }|s�t | j|d �}| �|�}||d 7 }|�dd�du }qT|W S ty� } z td|t|�f ��W Y d}~n
d}~0 0 dS ) z4
Fetch the list of items specified.
r: z
?page_sizer� Tr� r� Nz"Failed to download the %s list: %s)rF r@ r� rB rG r� r r )rN ZwhatrY rP r� r� r� r$ r$ r% �get_list2 s"
zGalaxyAPI.get_listc K s� t | j| jd ddd�}|r4|dttt|��� 7 }|�dd �}|�dd �}|�dd �}|�d d �}|r�t|t�r�|� d
�}|d d �
|� 7 }|r�t|t�r�|� d
�}|d
d �
|� 7 }|r�|d| 7 }|r�|d| 7 }| � |�}|S )Nr: �searchr� �?z&autocomplete=�tags� platforms� page_size�author�,z&tags_autocomplete=�+z&platforms_autocomplete=z
&page_size=%sz&username_autocomplete=%s) rF r@ r� r r� r rG r) r r� rJ rB ) rN r� r! Z
search_urlr� r� r� r� rP r$ r$ r% � search_rolesJ s&
zGalaxyAPI.search_rolesc C s> t | j| jd d�d }t||||d��}| j||dd�}|S )Nr: �notification_secretsrw )�sourcer� r� �secretr� r� )rF r@ r� r rB )rN r� r� r� r� rY r rP r$ r$ r% �
add_secreth s �zGalaxyAPI.add_secretc C s& t | j| jd d�}| j|dd�}|S )Nr: r� T)r� �rF r@ r� rB )rN rY rP r$ r$ r% � list_secretst s zGalaxyAPI.list_secretsc C s. t | j| jd d|�d }| j|ddd�}|S )Nr: r� rw T�DELETE�r� r5 r� )rN Z secret_idrY rP r$ r$ r% �
remove_secretz s zGalaxyAPI.remove_secretc C s2 t | j| jd dd||f �}| j|ddd�}|S )Nr: Z
removerolez ?github_user=%s&github_repo=%sTr� r� r� )rN r� r� rY rP r$ r$ r% � delete_role� s
�zGalaxyAPI.delete_roler; r c
C s& t � d|| j| jf � t|dd�}tj�|�sBtdt|� ��nt �
|�s\tdt|� ��t |d��"}t |�
� tjd�}W d � n1 s�0 Y t||d d
�d ��\}}|t|�d �}d
| jv r�t| j| jd
dd�d }nt| j| jd d�d }| j|||ddd| j| jf d�} | d S )z�
Publishes a collection to a Galaxy server and returns the import task URI.
:param collection_path: The path to the collection tarball to publish.
:return: The import task URI that contains the import results.
z,Publishing collection artifact '%s' to %s %sra rb z2The collection path specified '%s' does not exist.zThe collection path specified '%s' is not a tarball, use 'ansible-galaxy collection build' to create a proper release artifact.r^ )Z hash_funcNzapplication/octet-stream)�filenameZ mime_type)�sha256�file)z Content-typezContent-lengthr Z artifacts� collectionsrw r; r� Tz+Error when publishing collection to %s (%s))r r� r5 r� r6 Ztask)r> rA r@ r rf rg r� r r �tarfileZ
is_tarfileri r ro �hashlibr r r� r� rF rB )
rN Zcollection_pathZb_collection_pathZcollection_tarr Z content_typeZ b_form_datar� rO r� r$ r$ r% �publish_collection� s:
� 0��� �
��z GalaxyAPI.publish_collectionr c
C s d}d}d| j v r,t| j| j d d|d�}nt| j| j d d|d�}t�d| � t�� }d }|d
ksxt�� | |k �r2z| j|d d d
| d�}W nT ty� } z<|jdkr�� t�d| � t� |� W Y d}~q^W Y d}~n
d}~0 0 |�
dd�}|�
dd��r�q2t�d||f � t� |� t d|d �}q^|dk�rLt dt
|� ��|�
dg �D ]h} | d }
|
�� dk�r�t�d| d � n8|
�� d k�r�t�d | d � nt�d |
| d f � �qX|d k�rt
|d �
d d!��} t
|d �
d"d#| ��} t d$| | f ��dS )%aH
Waits until the import process on the Galaxy server has completed or the timeout is reached.
:param task_id: The id of the import task to wait for. This can be parsed out of the return
value for GalaxyAPI.publish_collection.
:param timeout: The timeout in seconds, 0 is no timeout.
ZwaitingNr zimports/collectionsrw r; zcollection-importsz1Waiting until Galaxy import task %s has completedr� r r4 Tz,Error when getting import task results at %s)r5 r� r6 r8 zJGalaxy import process has not started, wait %s seconds before trying again�stateZ finished_atzMGalaxy import process has a status of %s, wait %d seconds before trying again� g �?zUTimeout while waiting for the Galaxy import process to finish, check progress at '%s'�messages�levelr� z Galaxy import error message: %sr} rn z!Galaxy import warning message: %sz Galaxy import message: %s - %sZfailedr~ ZUNKNOWN� descriptionz&Unknown error, see %s for more detailsz+Galaxy import process failed: %s (Code: %s))r� rF r@ r> �timerB r* r+ Zvvv�sleeprG �minr r �lowerr� rn )
rN r� r1 r rP Zfull_url�start�waitr� r} r r~ r r$ r$ r% �wait_import_task� s`
��
�
" �
�
�zGalaxyAPI.wait_import_taskc
C s� d| j v r | j d }ddg}n| j d }ddg}t| j|d||d�}d ||| j| jf }| j||d
�}i }|D ]\}} |�| d �||< qnt||fi |��S ) z�
Gets the collection information from the Galaxy server about a specific Collection.
:param namespace: The collection namespace.
:param name: The collection name.
return: CollectionMetadata about the collection.
r )r� Z
created_at)r� Z
updated_atr; )r� Zcreated)r� �modifiedr rw z=Error when getting the collection info for %s.%s from %s (%s))r6 N)r� rF r@ rA rB rG r� )
rN r� rA �api_pathZ field_mapZinfo_urlr6 rP �metadataZ api_fieldr$ r$ r% �get_collection_metadata� s$
�
�� z!GalaxyAPI.get_collection_metadatac
C s� | j �d| j �d��}| j|d||d|dg}t|� }d|||| j| jf }| j||dd�}| �� |�d �png } t|d
d |d d |d
|d |d d |d d |d | �S )at
Gets the collection information from the Galaxy server about a specific Collection version.
:param namespace: The collection namespace.
:param name: The collection name.
:param version: Version of the collection to get the information for.
:return: CollectionVersionMetadata about the collection at the version requested.
r r; r rR rw �HError when getting collection version metadata for %s.%s:%s from %s (%s)T�r6 r7 r� r� rA Z
collectionrd r� Zartifactr r r� Zhref)r� rG r@ rF rA rB r� r� �
rN r� rA rd r Z url_pathsZn_collection_urlr6 rP r� r$ r$ r% � get_collection_version_metadata s
� �z)GalaxyAPI.get_collection_version_metadatac
C s2 d}d| j v r&| j d }ddg}d}n| j d }dg}d| j v rDdnd}t| j|d ||d
d |tf �}t|�}|j} | j�r*| j�t|�i �}
|
�d i �} z| � ||�j
} W n4 t y� }
z |
j d
krȂ g W Y d}
~
S d}
~
0 0 | �
d||f d�}|| k�r*| | d||f < |j|
v �r"|
| = | �� d||| j| jf }z| j||d| d�}W n8 t �y� }
z |
j d
k�rt� g W Y d}
~
S d}
~
0 0 d|v �r�d}nd}g }|dd� || D �7 }|}|D ]}|�
|i �}�q�|�s�q&n$|�rt|t|�j�}|�|j|�}| jt|dd�|d| d�}�q�| �� |S )z�
Gets a list of available versions for a collection on a Galaxy server.
:param namespace: The collection namespace.
:param name: The collection name.
:return: A list of versions that are available.
Fr r� r� Tr; �limitr� r rR z/?%s=%dr r8 Nz%s.%szGError when getting available collection versions for %s.%s from %s (%s))r6 r7 r� rP r� c S s g | ] }|d �qS )rd r$ )ry �vr$ r$ r% �
<listcomp>u r| z5GalaxyAPI.get_collection_versions.<locals>.<listcomp>ra rb )r� rF r@ �COLLECTION_PAGE_SIZEr rg r� r� r[ r r� r* r+ rG r� rA rB r �replacer )rN r� rA Z
relative_linkr Zpagination_pathZpage_size_nameZ versions_urlZversions_url_infor� r� Zmodified_cacheZ
modified_daterQ Zcached_modified_dater6 rP Z results_keyrR r� rg r$ r$ r% �get_collection_versions3 sj
�
�
z!GalaxyAPI.get_collection_versionsc
C s� | j �d| j �d��}| j|d||d|dg}t|� }d|||| j| jf }| j||dd�}| �� z |d } W n: ty� t� d
| j� d |� d |� d
|� �� g Y S 0 dd� | D �S dS )aG
Gets the collection signatures from the Galaxy server about a specific Collection version.
:param namespace: The collection namespace.
:param name: The collection name.
:param version: Version of the collection to get the information for.
:return: A list of signature strings.
r r; r rR rw r Tr r� zServer z has not signed r� �:c S s g | ] }|d �qS )Z signaturer$ )ry Zsignature_infor$ r$ r% r � r| z7GalaxyAPI.get_collection_signatures.<locals>.<listcomp>N)
r� rG r@ rF rA rB r� rD r> r? r r$ r$ r% �get_collection_signatures� s
� $
z#GalaxyAPI.get_collection_signatures)NNNFNFN)NF)NN)NNN)T)r )%rM r� r� r� �floatr� r� r� r� r� �propertyrU r� r r r3 rB r� r' r� r� r� r� r� r� r� r� r� r� r� r r r r r r! r# r$ r$ r$ r% r� st �
$
� � Y
-
A
W
r� )LZ
__future__r r r �typeZ
__metaclass__r r� � functoolsr rp rf r0 rk r r
� threading�httpr Z http.clientr r Z urllib.errorr r � urllib.parser
r� r r r
r Zansibler r� Zansible.errorsr Zansible.galaxy.user_agentr Zansible.module_utils.apir r Zansible.module_utils.sixr Zansible.module_utils._textr r r Zansible.module_utils.urlsr r Zansible.utils.displayr Zansible.utils.hashingr Zansible.utils.pathr r> �Lockr r ZTOO_MANY_REQUESTSZ BAD_GATEWAYr, r' r3 rU r[ rv rF r* �
namedtupler� r� �total_orderingr� r$ r$ r$ r% �<module> s\ �D
"*