File: //home/arjun/projects/env/lib/python3.10/site-packages/botocore/__pycache__/args.cpython-310.pyc
o
*we�w � @ s� d Z ddlZddlZddlZddlZddlZddlZddlm Z ddl
m Z ddl m
Z ddl mZ ddlmZ ddlmZ dd lmZmZ e�e�Zd
d gZg d �Zd
Z G dd� d�Z dS )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)�Config)�EndpointCreator)�EndpointResolverBuiltins)�EndpointRulesetResolver)�
RequestSigner)�UserAgentString)�ensure_boolean�is_s3_accelerate_url�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-2�2 c @ s� e Zd Z d:dd�Z d;dd�Zdd� Zdd � Zd
d � Zd d
� Zdd� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd:d$d%�Zd&d'� Zd(d)� Zd*d+� Zd,d-� Zd.d/� Zd0d1� Zd2d3� Zd4d5� Z d6d7� Z d8d9� Z dS )<�ClientArgsCreatorNc C s> || _ || _|| _|| _|| _|d u rt�� | _d S || _d S �N)�_event_emitter�_response_parser_factory�_loader�_exceptions_factory�
_config_storer �from_environment�_session_ua_creator)�self�
event_emitter�
user_agent�response_parser_factory�loader�exceptions_factory� config_store�user_agent_creator� r �F/home/arjun/projects/env/lib/python3.10/site-packages/botocore/args.py�__init__A s
zClientArgsCreator.__init__c
#
C sn | � ||| ||||�}
|
d }|
d }|
d }|
d }|
d }|
d }|d �dd �}|
d }|
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�|�}!|r�|jnd }"|"|_| | | |||| j||| j| |!d� S )N� service_name�parameter_validation�endpoint_config�protocol�
config_kwargs� s3_config�metadata� partition�socket_options�configured_endpoint_url�signing_region� region_name� signing_name�signature_version�s3� endpoint_url)
r. r2 �verifyr �max_pool_connections�proxies�timeoutr+ � client_cert�proxies_config) �
serializer�endpoint�response_parserr �request_signer�
service_modelr �
client_configr* r �endpoint_ruleset_resolverr r ) �compute_client_args�get�copyr r �
service_idr r �create_endpointr r4 r5 �connect_timeout� read_timeoutr7 r8 �botocore� serialize�create_serializer�parsers�
create_parser�_build_endpoint_resolverr �with_client_configr �_supplied_user_agentr r )#r r= r. � is_securer2 r3 � credentials�
scoped_configr> �endpoint_bridge�
auth_token�endpoints_ruleset_data�partition_data�
final_argsr# r$ r% r& r' r( r* r+ r, r- �endpoint_region_namer �signer�
new_config�endpoint_creatorr: r9 r; �ruleset_resolver�client_ua_creator� supplied_uar r r! �get_client_argsU s� �
�
�� ���z!ClientArgsCreator.get_client_argsc C s� |j }|jd } d}
|r|jsd}
n|r!|�d�} | d ur!t| �}
| �|�} | j||d�}
| j|||
||| d�}|d �dg �}| j� |��
� }t |d |d
|d �}d |v r]|j dd
� d|v rg|j dd� |d ur�|j |j
|j|j|j|j|j|j|j|j|j|j|j|j|jd� | �|� | � |� | � |� | � |� | �|�} | � |�}|r�d |v r�| d u r�i } d| d< ||
|
|| || | � ||�d�S )Nr& TFr$ )r> r2 )r# r. r2 rO rR r( r) �tagsr. r0 )r. r0 r � dualstack)�use_dualstack_endpoint�fips)�use_fips_endpoint)rE rF r4 r5 r8 �retriesr7 �inject_host_prefix�
tcp_keepalive�user_agent_extra�user_agent_appid�"request_min_compression_size_bytes�disable_request_compression�client_context_paramsra )r# r$ r, r% r& r' r( r+ )!�endpoint_prefixr) r$ rA r �compute_s3_config� _compute_configured_endpoint_url�_compute_endpoint_configr rM � to_string�dict�updaterE rF r4 r5 r8 rd r7 re rf rg rh ri rj rk �_compute_retry_config�_compute_connect_timeout� _compute_user_agent_appid_config�#_compute_request_compression_config�_is_s3_service�_compute_socket_options)r r= r> rR r. r2 rO rQ r# r& r$ � raw_valuer( r, r% �endpoint_variant_tags�preliminary_ua_stringr' �
is_s3_servicer r r! r@ � s�
����� �
��z%ClientArgsCreator.compute_client_argsc C s0 |d ur|S | � |�rt�d� |S | j�d�S )Nz"Ignoring configured endpoint URLs.r2 )� _ignore_configured_endpoint_urls�logger�debugr �get_config_variable)r r> r2 r r r! rn ) s
z2ClientArgsCreator._compute_configured_endpoint_urlc C s |r
|j d ur
|j S | j�d�S )N� ignore_configured_endpoint_urls)r� r r� )r r> r r r! r} 3 s �
�z2ClientArgsCreator._ignore_configured_endpoint_urlsc C sH | j �d�}|d ur"|jd ur"|d u r|j}|S |�� }|�|j� |S )Nr1 )r r� r1 rB rr )r r> �s3_configurationr r r! rm > s
� z#ClientArgsCreator.compute_s3_configc C s |dv S )a, Whether the service is S3 or S3 Control.
Note that throughout this class, service_name refers to the endpoint
prefix, not the folder name of the service in botocore/data. For
S3 Control, the folder name is 's3control' but the endpoint prefix is
's3-control'.
)r1 z
s3-controlr )r r# r r r! rw Q s z ClientArgsCreator._is_s3_servicec C sT |||||d�}|dkr| j dd|i|��S |dkr"| jdi |��S | jdi |��S )N)r# r. r2 rO rR r1 r( �stsr )�_compute_s3_endpoint_config� _compute_sts_endpoint_config�_resolve_endpoint)r r# r. r2 rO rR r( �resolve_endpoint_kwargsr r r! ro [ s
���z*ClientArgsCreator._compute_endpoint_configc K sX | � |d |�}|rd |d< | jdi |��}| �||d � |r*|d dkr*d|d< |S )Nr. rR r r
r )�_should_force_s3_globalr� �!_set_region_if_custom_s3_endpoint)r r( r� �force_s3_globalr% r r r! r� s s ��z-ClientArgsCreator._compute_s3_endpoint_configc C s6 d}|rd|v r|d }| � |� |dv }|dko|S )Nr
�us_east_1_regional_endpoint)r
N)� _validate_s3_regional_config)r r. r( �s3_regional_config�is_global_regionr r r! r� � 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_CONFIGrG �
exceptions�+InvalidS3UsEast1RegionalEndpointConfigError)r �
config_valr r r! r� � 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. r1 ��resolve)r r% rR r: r r r! r� � s
�z3ClientArgsCreator._set_region_if_custom_s3_endpointc K s: | j di |��}| �|d |d |�r| �||d � |S )Nr. r2 rO r )r� � _should_set_global_sts_endpoint�_set_global_sts_endpoint)r r� r% r r r! r� � s ��z.ClientArgsCreator._compute_sts_endpoint_configc C s6 |o
|� di �� d�}|s|rdS | �� dko|tv S )Nr) r_ Fr
)rA �"_get_sts_regional_endpoints_config�LEGACY_GLOBAL_STS_REGIONS)r r. r2 r% �has_variant_tagsr r r! r� � 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� r� rG r� �&InvalidSTSRegionalEndpointsConfigError)r r� r r r! r� � s ���z4ClientArgsCreator._get_sts_regional_endpoints_configc C s$ |rdnd}d| |d< d|d< d S )N�https�httpz%s://sts.amazonaws.comr2 r
r- r )r r% rO �schemer r r! r� � s z*ClientArgsCreator._set_global_sts_endpointc C s |� ||||�S r r� )r r# r. r2 rO rR r r r! r� � s �z#ClientArgsCreator._resolve_endpointc C sP t jt jdfg}|o |j}|o| �|�dd��}|s |r&|�t jt jdf� |S )N� rf F) �socket� IPPROTO_TCP� TCP_NODELAYrf �_ensure_booleanrA �append�
SOL_SOCKET� SO_KEEPALIVE)r rQ r> r+ �client_keepalive�scoped_keepaliver r r! rx � s
�z)ClientArgsCreator._compute_socket_optionsc C s | � |� | �|� d S r )�_compute_retry_max_attempts�_compute_retry_mode)r r' r r r! rs � 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 )Nrd �total_max_attempts� max_attemptsr� )rA �popr r� )r r' rd �valuer� r r r! r� � 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 )Nrd �mode�
retry_moder
�rA r r� )r r' rd r� r r r! r� s
z%ClientArgsCreator._compute_retry_modec C s6 |� d�}|d ur d S | j�d�}|r||d< d S d S )NrE r� )r r' rE r r r! rt s
� �z*ClientArgsCreator._compute_connect_timeoutc C sd |� d�}|� d�}|d u r| j�d�}| �|�}||d< |d u r(| j�d�}nt|�}||d< d S )Nri rj )rA r r� � _validate_min_compression_sizer )r r' �min_size�disabledr r r! rv * s
�
� z5ClientArgsCreator._compute_request_compression_configc C s� d}d}|d urLd|� d�}zt |�}W n ttfy. |� dt|�� d�}tjj|d��w || kr9|ksLn |� d|� d |� d
�}tjj|d��|S ) Nr� i zInvalid value "z)" for request_min_compression_size_bytes.z$ Value must be an integer. Received z instead.)� error_msgz Value must be between z and �.)�int�
ValueError� TypeError�typerG r� �InvalidConfigError)r r� �min_allowed_min_size�max_allowed_min_size�error_msg_base�msgr r r! r� @ s.
� ������z0ClientArgsCreator._validate_min_compression_sizec C s t |t�r|S |�� dkS )N�true)�
isinstance�bool�lower)r �valr r r! r� Y s
z!ClientArgsCreator._ensure_booleanc
C s� |d u rd S | � |�p i } |j}
|
dv s|d u r|}n|}| j||
| |
||jd�}|d ur3|jp1i }ni }| �|
�r?|�| � |d urF|jnd }t|||||| | |d�S )N)r1 r� )r. r# r( rR �client_endpoint_url�legacy_endpoint_url)�endpoint_ruleset_datarU r= �builtins�client_contextr �use_ssl�requested_auth_scheme) rm rl �*compute_endpoint_resolver_builtin_defaults�hostrk rw rr r0 r )r rT rU r> r= rW r. r2 r: rO rR r �
s3_config_raw�service_name_raw�eprv2_region_name�resolver_builtinsr� � sig_versionr r r! rL _ sD �
���z*ClientArgsCreator._build_endpoint_resolverc C s� |r|}n |� � s |}nd }|�dd�rd}n|d ur't|�s'|�d�dk}n|�d�dk}tj|tj|d u r<|�d�p=dtj|d u rH|�|�pIdtj | j
|d d d�tj | � ||�tj
|�dd�tj|tj|�dd �tj|�dd�tj|�d
d�tj|i S ) N�use_accelerate_endpointF�addressing_style�virtual�pathrc )r. r2 r% �use_arn_regionT�$s3_disable_multiregion_access_points)�resolver_uses_builtin_datarA r � EPRBuiltins�
AWS_REGION� AWS_USE_FIPS�$_resolve_endpoint_variant_config_var�AWS_USE_DUALSTACK� _resolve_use_dualstack_endpoint�AWS_STS_USE_GLOBAL_ENDPOINTr� �AWS_S3_USE_GLOBAL_ENDPOINTr� �AWS_S3_ACCELERATE�AWS_S3_FORCE_PATH_STYLE�AWS_S3_USE_ARN_REGION� AWS_S3CONTROL_USE_ARN_REGION�AWS_S3_DISABLE_MRAP� SDK_ENDPOINT) r r. r# r( rR r� r� �given_endpoint�force_path_styler r r! r� � sd
������
�����z<ClientArgsCreator.compute_endpoint_resolver_builtin_defaultsc C sP |� d�}|d u r| j�d�}|d ur"t|�tkr"t�dt� d�� ||d< d S )Nrh zHThe configured value for user_agent_appid exceeds the maximum length of z characters.)rA r r� �len�USERAGENT_APPID_MAXLENr~ �warning)r r' rh r r r! ru � s
� �� z2ClientArgsCreator._compute_user_agent_appid_configr )NNN) �__name__�
__module__� __qualname__r" r^ r@ rn r} rm rw ro r� r� r� r� r� r� r� r� r� rx rs r� r� rt rv r� r� rL r� ru r r r r! r @ sB
�
�ki
@ Tr ) �__doc__rB �loggingr� �botocore.exceptionsrG �botocore.parsers�botocore.serialize�botocore.configr �botocore.endpointr �botocore.regionsr r� r �botocore.signersr �botocore.useragentr �botocore.utilsr r � getLoggerr� r~ r� r� r� r r r r r! �<module> s*
�