File: //usr/local/CyberCP/lib64/python3.10/site-packages/botocore/__pycache__/discovery.cpython-310.pyc
o
�h++ � @ s� d dl Z d dlZd dlZd dlmZ d dlmZmZmZ d dl m
Z
d dl m Z e �
e�ZG dd� de�ZG dd � d e�ZG d
d � d e�Zd d
� ZG dd� d�ZG dd� d�ZG dd� d�ZdS )� N)�
xform_name)�
BotoCoreError�ConnectionError�HTTPClientError)�OperationNotFoundError)�CachedPropertyc @ s e Zd ZdS )�EndpointDiscoveryExceptionN)�__name__�
__module__� __qualname__� r r �E/usr/local/CyberCP/lib/python3.10/site-packages/botocore/discovery.pyr s r c @ � e Zd ZdZdZdS )�EndpointDiscoveryRequiredzBEndpoint Discovery is disabled but is required for this operation.zAEndpoint Discovery is not enabled but this operation requires it.N�r r
r �__doc__�fmtr r r r
r � r c @ r )� EndpointDiscoveryRefreshFailedz=Endpoint Discovery failed to the refresh the known endpoints.z<Endpoint Discovery failed to refresh the required endpoints.Nr r r r r
r # r r c K s" | j }|r
|�d�rt� �d S d S )N�required)�endpoint_discovery�getr )�model�kwargsr r r r
�,block_endpoint_discovery_required_operations) s �r c @ sN e Zd Zdd� Zedd� �Zedd� �Zdd� Zd d
� Zd d � Z ddd�Z
d
S )�EndpointDiscoveryModelc C �
|| _ d S �N)�_service_model)�self�
service_modelr r r
�__init__0 �
z EndpointDiscoveryModel.__init__c C s | j j}t|j�S r )r � endpoint_discovery_operationr �name)r �discovery_operationr r r
�discovery_operation_name3 s
z/EndpointDiscoveryModel.discovery_operation_namec C s& | j j}g }|jrt|jj�� �}|S r )r r# � input_shape�list�members�keys)r r% r* r r r
�discovery_operation_keys8 s
z/EndpointDiscoveryModel.discovery_operation_keysc C s2 z| j �|�}|j�dd�W S ty Y dS w )Nr F)r �operation_modelr r r )r �operation_namer, r r r
�discovery_required_for@ s � �z-EndpointDiscoveryModel.discovery_required_forc s> | j � |�d�s|�dd � |�dd � � fdd�|�� D �S )N� Identifiers� Operationc s i | ] \}}|� v r||�qS r r ��.0�k�v��
input_keysr r
�
<dictcomp>O s zEEndpointDiscoveryModel.discovery_operation_kwargs.<locals>.<dictcomp>)r+ r �pop�items�r r r r5 r
�discovery_operation_kwargsI s
z1EndpointDiscoveryModel.discovery_operation_kwargsc C s | � |j|�S r )� _gather_idsr' �r � operation�paramsr r r
�gather_identifiersQ � z)EndpointDiscoveryModel.gather_identifiersNc C sb |d u ri }|j �� D ]#\}}|j�d�r || ||< q |jdkr.||v r.| �||| |� q |S )N�endpointdiscoveryid� structure)r) r9 �metadatar � type_namer< )r �shaper? �ids� member_name� member_shaper r r
r< T s �z"EndpointDiscoveryModel._gather_idsr ) r r
r r! r r& r+ r. r; r@ r< r r r r
r / s
r c @ sp e Zd Z ddd�Zdd� Zdd� Zd d
� Zd d � Zd
d� Zdd� Z dd� Z
dd� Z dd� Z dd� Z
dd� ZdS ) �EndpointDiscoveryManagerNTc C sP |d u ri }|| _ i | _|d u rtj}|| _|| _t�|�| _t|j j
�| _ d S r ) �_cache�_failed_attempts�time�_time�_always_discover�weakref�proxy�_clientr �metar �_model)r �client�cache� current_time�always_discoverr r r
r! d s z!EndpointDiscoveryManager.__init__c C s8 |d }| � � }|D ]}|�d�}||d |d< q
|S )N� Endpoints�CachePeriodInMinutes�< �
Expiration)rN r )r �response� endpointsrW �endpoint�
cache_timer r r
�_parse_endpointsu s
z)EndpointDiscoveryManager._parse_endpointsc C s t |t�r
tt|�� ��S |S r )�
isinstance�dict�tuple�sortedr9 )r �valuer r r
� _cache_item} s
z$EndpointDiscoveryManager._cache_itemc s0 � j jdi |��}t� fdd�t|�� �D ��S )Nc 3 s � | ]
\}}� � |�V qd S r )rg r1 �r r r
� <genexpr>� s � z=EndpointDiscoveryManager._create_cache_key.<locals>.<genexpr>r )rT r; rd re r9 r: r rh r
�_create_cache_key� s z*EndpointDiscoveryManager._create_cache_keyc C s | j �||�S r )rT r@ r= r r r
r@ � rA z+EndpointDiscoveryManager.gather_identifiersc K s* | j di |��}|| jv r| j|= d S d S )Nr )rj rK )r r � cache_keyr r r
�delete_endpoints� s
�z)EndpointDiscoveryManager.delete_endpointsc K s@ | j jdi |��}| j j}t| j|�}t�d|� |di |��S )Nz%Discovering endpoints with kwargs: %sr )rT r; r& �getattrrR �logger�debug)r r r- r% r r r
�_describe_endpoints� s
z,EndpointDiscoveryManager._describe_endpointsc s. || j vrd S | �� � � fdd�| j | D �S )Nc s g | ]
}� |d k r|�qS )r\ r )r2 �e��nowr r
�
<listcomp>� s zCEndpointDiscoveryManager._get_current_endpoints.<locals>.<listcomp>)rK rN )r �keyr rr r
�_get_current_endpoints� s
z/EndpointDiscoveryManager._get_current_endpointsc K st | j di |��}z | jdi |��}| �|�}|| j|< | j�|d � |W S ttfy9 | �� d | j|< Y d S w )Nr[ r ) rj rp ra rK rL r8 r r rN )r r rk r] r^ r r r
�_refresh_current_endpoints� s
�z3EndpointDiscoveryManager._refresh_current_endpointsc C s0 || j v r| �� }|| j | k rdS | j |= dS )NTF)rL rN )r rk rs r r r
�_recently_failed� s
z)EndpointDiscoveryManager._recently_failedc C s |d d S )Nr �Addressr )r r^ r r r
�_select_endpoint� s z)EndpointDiscoveryManager._select_endpointc K s� |d }| j �|�}| js|st�d|� �� d S | jdi |��}| �|�}|r-| �|�S | �|�}|sC| j di |��}|rC| �|�S t�d|� | j
� |d �}|rW| �|�S |rm|rj| j di |��}|rj| �|�S t � �d S )Nr0 z?Optional discovery disabled. Skipping discovery for Operation: z%Endpoint Discovery has failed for: %sr )
rT r. rO rn ro rj rv rz rx rw rK r r )r r r> �discovery_requiredrk r^ �recently_failed�
stale_entriesr r r
�describe_endpoint� s6
�
z*EndpointDiscoveryManager.describe_endpoint)NNT)r r
r r! ra rg rj r@ rl rp rv rw rx rz r~ r r r r
rJ c s
� rJ c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd S ) �EndpointDiscoveryHandlerc C r r )�_manager)r �managerr r r
r! � r" z!EndpointDiscoveryHandler.__init__c C s@ |� d|� �| j� |�d|� �| j� |� d|� �| j� d S )Nzbefore-parameter-build.zrequest-created.z needs-retry.)�registerr@ �register_first�discover_endpoint�handle_retries)r �events�
service_idr r r
r� � s � �z!EndpointDiscoveryHandler.registerc K s0 |j }|d u r d S | j�||�}d|i|d< d S )N� identifiers� discovery)r r� r@ )r r? r �contextr r rG r r r
r@ � s
z+EndpointDiscoveryHandler.gather_identifiersc K sn |j �di ��d�}|d u rd S | jj||d�}|d u r#t�d� d S |�d�s,d| }t�d|� ||_d S )Nr� r� �r0 r/ z&Failed to discover and inject endpoint�httpzhttps://z!Injecting discovered endpoint: %s)r� r r� r~ rn ro �
startswith�url)r �requestr- r rG r_ r r r
r� � s �
z*EndpointDiscoveryHandler.discover_endpointc
K s� |d u rd S |\}}|� di �� d�}|� di �� d�}|dkr&|dkr&d S |� di �}|� di �� d �} | d u r;d S | jj|j| d
� d S ) N�ResponseMetadata�HTTPStatusCode�Error�Codei� �InvalidEndpointExceptionr� r� r� r� r )r r� rl r$ )
r � request_dictr] r> r �_�status�
error_coder� rG r r r
r� s �z'EndpointDiscoveryHandler.handle_retriesN)r r
r r! r� r@ r� r� r r r r
r � s r )�loggingrM rP �botocorer �botocore.exceptionsr r r �botocore.modelr �botocore.utilsr � getLoggerr rn r r r r r rJ r r r r r
�<module> s
4}