File: //lib/python3.6/site-packages/botocore/__pycache__/args.cpython-36.pyc
3
�T_�> � @ s� d Z ddlZddlZddlZddlZddlZddlZddlm Z ddl
m Z ddl m
Z
eje�ZddgZdd d
d d d
ddddddddddgZG dd� de�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�legacyZregionalzap-northeast-1z
ap-south-1zap-southeast-1zap-southeast-2z
aws-globalz ca-central-1z eu-central-1z
eu-north-1z eu-west-1z eu-west-2z eu-west-3z sa-east-1z 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_factoryZ config_store� r �/usr/lib/python3.6/args.py�__init__; s zClientArgsCreator.__init__c
C s | j ||| ||||�}
|
d } |
d } |
d }
|
d }|
d }|
d }|
d jdd �}|
d }|
d
}|
d }tj| j�}t|j||
d |
d
||�}||d< tf |�}t|�}|j|||
d || j |j
|j |j |j
f||jd�
}tjj|| �}tjj|�}||||||| j||| jd�
S )N� service_name�parameter_validation�endpoint_config�protocol�
config_kwargs� s3_config�metadata� partition�socket_options�signing_region� region_nameZ signing_name�signature_version�s3� endpoint_url) r r# �verifyr �max_pool_connections�proxiesZtimeoutr � client_cert)
�
serializer�endpoint�response_parserr Zrequest_signer�
service_modelr �
client_configr r )�compute_client_args�get�copyr r Z
service_idr r Zcreate_endpointr r% r& �connect_timeout� read_timeoutr' �botocoreZ serializeZcreate_serializerZparsersZ
create_parserr
r ) r
r+ r � is_securer# r$ Z credentials�
scoped_configr, �endpoint_bridgeZ
final_argsr r r r r r r r r Zendpoint_region_namer ZsignerZ
new_configZendpoint_creatorr) r( r* r r r �get_client_argsD sX
z!ClientArgsCreator.get_client_argsc C s |j }|jd } d}
|r&|j r&d}
n"|rH|jd�} | d k rHtjj| �}
| j} |d k r~|jd k rf|j} |j d k r~| d|j 7 } | j
|�}
| j ||||||
d�}t |d |d | d �}|d k r�|j
|j|j|j|j|j|j|jd
� | j|� | j
|�}
||
| || ||
| j|�d �S ) Nr TFr z %s)r r r# r3 r5 r r r! )r r! r )r0 r1 r% r& �retriesr' �inject_host_prefix)r r r r r r r r )Zendpoint_prefixr r r. r2 ZutilsZensure_booleanr r Zuser_agent_extra�compute_s3_config�_compute_endpoint_config�dict�updater0 r1 r% r& r7 r' r8 �_compute_retry_config�_compute_socket_options)r
r+ r, r5 r r# r3 r4 r r r Z raw_valuer r r r r r r r- } s\
z%ClientArgsCreator.compute_client_argsc C sF | j jd�}|d k rB|jd k rB|d kr.|j}n|j� }|j|j� |S )Nr" )r �get_config_variabler" r/ r< )r
r, Zs3_configurationr r r r9 � s
z#ClientArgsCreator.compute_s3_configc C sL |||||d�}|dkr,| j f d|i|��S |dkr@| jf |�S | jf |�S )N)r r r# r3 r5 r" r �sts)�_compute_s3_endpoint_config� _compute_sts_endpoint_config�_resolve_endpoint)r
r r r# r3 r5 r �resolve_endpoint_kwargsr r r r: � s z*ClientArgsCreator._compute_endpoint_configc K sT | j |d |�}|r d |d< | jf |�}| j||d � |rP|d dkrPd|d< |S )Nr r5 z
aws-globalz us-east-1)�_should_force_s3_globalrC �!_set_region_if_custom_s3_endpoint)r
r rD Zforce_s3_globalr r r r rA � s z-ClientArgsCreator._compute_s3_endpoint_configc C s2 d}|r"d|kr"|d }| j |� |dko0|dkS )Nr Zus_east_1_regional_endpoint� us-east-1)rG N)� _validate_s3_regional_config)r
r r Zs3_regional_configr r r rE � s
z)ClientArgsCreator._should_force_s3_globalc C s |t krtjj|d��d S )N)Z%s3_us_east_1_regional_endpoint_config)� VALID_REGIONAL_ENDPOINTS_CONFIGr2 �
exceptionsZ+InvalidS3UsEast1RegionalEndpointConfigError)r
Z
config_valr r r rH � s z.ClientArgsCreator._validate_s3_regional_configc C s> |d d kr:|d d kr:|j d�}|d |d< |d |d< d S )Nr r r" )�resolve)r
r r5 r) r r r rF � s
z3ClientArgsCreator._set_region_if_custom_s3_endpointc K s4 | j f |�}| j|d |d �r0| j||d � |S )Nr r# r3 )rC � _should_set_global_sts_endpoint�_set_global_sts_endpoint)r
rD r r r r rB s
z.ClientArgsCreator._compute_sts_endpoint_configc C s |rdS | j � dko|tkS )NFr )�"_get_sts_regional_endpoints_config�LEGACY_GLOBAL_STS_REGIONS)r
r r# r r r rL s z1ClientArgsCreator._should_set_global_sts_endpointc C s. | j jd�}|sd}|tkr*tjj|d��|S )NZsts_regional_endpointsr )� sts_regional_endpoints_config)r r? rI r2 rJ Z&InvalidSTSRegionalEndpointsConfigError)r
rP r r r rN s z4ClientArgsCreator._get_sts_regional_endpoints_configc C s$ |rdnd}d| |d< d|d< d S )NZhttpsZhttpz%s://sts.amazonaws.comr# z us-east-1r r )r
r r3 �schemer r r rM % s z*ClientArgsCreator._set_global_sts_endpointc C s |j ||||�S )N)rK )r
r r r# r3 r5 r r r rC * s z#ClientArgsCreator._resolve_endpointc C s> t jt jdfg}|r:| j|jdd��r:|jt jt jdf� |S )N� Z
tcp_keepaliveF)�socketZ IPPROTO_TCPZ TCP_NODELAY�_ensure_booleanr. �appendZ
SOL_SOCKETZ SO_KEEPALIVE)r
r4 r r r r r> / s z)ClientArgsCreator._compute_socket_optionsc C s | j |� | j|� d S )N)�_compute_retry_max_attempts�_compute_retry_mode)r
r r r r r= : s
z'ClientArgsCreator._compute_retry_configc C s� |j d�}|d k rLd|kr*|jdd � d S d|krL|jd�}|d |d< d S | jjd�}|d k r||d krti }||d< ||d< d S )Nr7 Ztotal_max_attempts� max_attemptsrR )r. �popr r? )r
r r7 �valuerX r r r rV > s
z-ClientArgsCreator._compute_retry_max_attemptsc C sP |j d�}|d kr i }||d< n d|kr,d S | jjd�}|d krDd}||d< d S )Nr7 �mode�
retry_moder )r. r r? )r
r r7 r\ r r r rW ^ s
z%ClientArgsCreator._compute_retry_modec C s t |t�r|S |j� dkS d S )N�true)�
isinstance�bool�lower)r
�valr r r rT l s
z!ClientArgsCreator._ensure_booleanN)�__name__�
__module__� __qualname__r r6 r- r9 r: rA rE rH rF rB rL rN rM rC r> r= rV rW rT r r r r r : s& 9<
r )�__doc__r/ ZloggingrS Zbotocore.exceptionsr2 Zbotocore.serializeZbotocore.utilsZbotocore.signersr Zbotocore.configr Zbotocore.endpointr Z getLoggerrb ZloggerrI rO �objectr r r r r �<module> s: