File: //lib/python3/dist-packages/botocore/__pycache__/args.cpython-310.pyc
o
<&�a!B � @ s� d Z ddlZddlZddlZddlZddlZddlZddlm Z ddl
m Z ddl m
Z
e�e�ZddgZg d�ZG d d
� d
e�ZdS ) z�Internal module to help with normalizing botocore client args.
This module (and all function/classes within this module) should be
considered internal, and *not* a public API.
� N)�
RequestSigner)�Config)�EndpointCreator�legacy�regional)zap-northeast-1z
ap-south-1zap-southeast-1zap-southeast-2�
aws-globalz ca-central-1z eu-central-1z
eu-north-1z eu-west-1z eu-west-2z eu-west-3z sa-east-1� us-east-1z us-east-2z us-west-1z us-west-2c @ s� e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'S )(�ClientArgsCreatorc C s( || _ || _|| _|| _|| _|| _d S �N)�_event_emitter� _user_agent�_response_parser_factory�_loader�_exceptions_factory�
_config_store)�self�
event_emitter�
user_agent�response_parser_factory�loader�exceptions_factory� config_store� r �//usr/lib/python3/dist-packages/botocore/args.py�__init__; s
zClientArgsCreator.__init__c
C s" | � ||| ||||�}
|
d } |
d } |
d }
|
d }|
d }|
d }|
d �dd �}|
d }|
d
}|
d }t�| j�}t|j||
d |
d
||�}||d< tdi |��}t|�}|j|||
d || j |j
|j |j |j
f||j|jd� }tj�|| �}tj�|�}||||||| j||| jd�
S )N� service_name�parameter_validation�endpoint_config�protocol�
config_kwargs� s3_config�metadata� partition�socket_options�signing_region� region_name� signing_name�signature_version�s3� endpoint_url)
r% r) �verifyr �max_pool_connections�proxies�timeoutr# � client_cert�proxies_config)
�
serializer�endpoint�response_parserr �request_signer�
service_modelr �
client_configr" r r )�compute_client_args�get�copyr r �
service_idr r �create_endpointr
r+ r, �connect_timeout� read_timeoutr. r/ �botocore� serialize�create_serializer�parsers�
create_parserr r ) r r4 r% � is_securer) r* � credentials�
scoped_configr5 �endpoint_bridge�
final_argsr r r r r r r" r# r$ �endpoint_region_namer �signer�
new_config�endpoint_creatorr1 r0 r2 r r r �get_client_argsD sd � �
� � �z!ClientArgsCreator.get_client_argsc
C st |j }|jd } d}
|r|jsd}
n|r#|�d�} | d ur#tj�| �}
| j} |d ur>|jd ur2|j} |j d ur>| d|j 7 } | �
|�}
| j ||||||
d�}|d �dg �}t |d |d
| d �}d |v rk|j
dd
� d|v ru|j
dd� |d ur�|j
|j|j|j|j|j|j|j|jd� | �|� | �
|�}
|dv }|r�d |v r�|
d u r�i }
d|
d< ||
| || ||
| �|�d�S )Nr TFr z %s)r r% r) rB rE r r! �tagsr% r' )r% r' r � dualstack)�use_dualstack_endpoint�fips)�use_fips_endpoint)r; r< r+ r, r/ �retriesr. �inject_host_prefix)r( z
s3-controlrN )r r r r r r r r# )�endpoint_prefixr! r r7 r= �utils�ensure_booleanr r �user_agent_extra�compute_s3_config�_compute_endpoint_config�dict�updater; r< r+ r, r/ rQ r. rR �_compute_retry_config�_compute_socket_options)r r4 r5 rE r% r) rB rD r r r � raw_valuer r r �endpoint_variant_tagsr �
is_s3_servicer r r r6 ~ sz
�� �
�z%ClientArgsCreator.compute_client_argsc C sH | j �d�}|d ur"|jd ur"|d u r|j}|S |�� }|�|j� |S )Nr( )r �get_config_variabler( r8 rZ )r r5 �s3_configurationr r r rW � s
� z#ClientArgsCreator.compute_s3_configc C sT |||||d�}|dkr| j dd|i|��S |dkr"| jdi |��S | jdi |��S )N)r r% r) rB rE r( r �stsr )�_compute_s3_endpoint_config� _compute_sts_endpoint_config�_resolve_endpoint)r r r% r) rB rE r �resolve_endpoint_kwargsr r r rX � s ���z*ClientArgsCreator._compute_endpoint_configc K sX | � |d |�}|rd |d< | jdi |��}| �||d � |r*|d dkr*d|d< |S )Nr% rE r r r )�_should_force_s3_globalre �!_set_region_if_custom_s3_endpoint)r r rf �force_s3_globalr r r r rc � s ��z-ClientArgsCreator._compute_s3_endpoint_configc C s2 d}|rd|v r|d }| � |� |dko|dv S )Nr �us_east_1_regional_endpoint)r N)� _validate_s3_regional_config)r r% r �s3_regional_configr r r rg � s
�z)ClientArgsCreator._should_force_s3_globalc C s |t vr tjj|d��d S )N)�%s3_us_east_1_regional_endpoint_config)� VALID_REGIONAL_ENDPOINTS_CONFIGr= �
exceptions�+InvalidS3UsEast1RegionalEndpointConfigError)r �
config_valr r r rk s ��z.ClientArgsCreator._validate_s3_regional_configc C sF |d d u r |d d u r!|� d�}|d |d< |d |d< d S d S d S )Nr$ r% r( ��resolve)r r rE r1 r r r rh
s
�z3ClientArgsCreator._set_region_if_custom_s3_endpointc K s: | j di |��}| �|d |d |�r| �||d � |S )Nr% r) rB r )re � _should_set_global_sts_endpoint�_set_global_sts_endpoint)r rf r r r r rd s ��z.ClientArgsCreator._compute_sts_endpoint_configc C s. |d � d�}|s |r
dS | �� dko|tv S )Nr! rL Fr )r7 �"_get_sts_regional_endpoints_config�LEGACY_GLOBAL_STS_REGIONS)r r% r) r r^ r r r rt # s �z1ClientArgsCreator._should_set_global_sts_endpointc C s. | j �d�}|s
d}|tvrtjj|d��|S )N�sts_regional_endpointsr )� sts_regional_endpoints_config)r r` rn r= ro �&InvalidSTSRegionalEndpointsConfigError)r ry r r r rv - s ���z4ClientArgsCreator._get_sts_regional_endpoints_configc C s$ |rdnd}d| |d< d|d< d S )N�https�httpz%s://sts.amazonaws.comr) r r$ r )r r rB �schemer r r ru 8 s z*ClientArgsCreator._set_global_sts_endpointc C s |� ||||�S r
rr )r r r% r) rB rE r r r re = s �z#ClientArgsCreator._resolve_endpointc C s> t jt jdfg}|r | �|�dd��r |�t jt jdf� |S )N� �
tcp_keepaliveF)�socket� IPPROTO_TCP� TCP_NODELAY�_ensure_booleanr7 �append�
SOL_SOCKET� SO_KEEPALIVE)r rD r# r r r r\ B s �z)ClientArgsCreator._compute_socket_optionsc C s | � |� | �|� d S r
)�_compute_retry_max_attempts�_compute_retry_mode)r r r r r r[ M s
z'ClientArgsCreator._compute_retry_configc C s� |� d�}|d ur&d|v r|�dd � d S d|v r&|�d�}|d |d< d S | j�d�}|d ur@|d u r:i }||d< ||d< d S d S )NrQ �total_max_attempts� max_attemptsr~ )r7 �popr r` )r r rQ �valuer� r r r r� Q s
�z-ClientArgsCreator._compute_retry_max_attemptsc C sP |� d�}|d u ri }||d< nd|v rd S | j�d�}|d u r"d}||d< d S )NrQ �mode�
retry_moder )r7 r r` )r r rQ r� r r r r� q s
z%ClientArgsCreator._compute_retry_modec C s t |t�r|S |�� dkS )N�true)�
isinstance�bool�lower)r �valr r r r� s
z!ClientArgsCreator._ensure_booleanN)�__name__�
__module__� __qualname__r rK r6 rW rX rc rg rk rh rd rt rv ru re r\ r[ r� r� r� r r r r r : s( :J
r )�__doc__r8 �loggingr� �botocore.exceptionsr= �botocore.serialize�botocore.utils�botocore.signersr �botocore.configr �botocore.endpointr � getLoggerr� �loggerrn rw �objectr r r r r �<module> s
�