File: //lib/python3/dist-packages/botocore/__pycache__/endpoint.cpython-310.pyc
o
YZ�a�5 � @ s� d dl Z d dlZd dlZd dlZd dlZd dlmZ d dlmZ d dl m
Z
d dl m Z m
Z
mZ d dlmZ d dlmZ d dlmZ d d lmZ e�e�Ze� Zd
Zd Z d d
� Z G dd� de �Z G dd� de �Z dS )� N)�create_request_object)�HTTPClientError)�URLLib3Session)�is_valid_endpoint_url�is_valid_ipv6_endpoint_url�get_environ_proxies)�first_non_none_response)�get_global_history_recorder)�
StreamingBody)�parsers�< �
c C sz | j | jd|jid�}|d dkr| j|d< |S |jr"| j|d< |S |jr6|d �d�}t| j|�|d< |S | j|d< |S )a� Convert an HTTP response object to a request dict.
This converts the requests library's HTTP response object to
a dictionary.
:type http_response: botocore.vendored.requests.model.Response
:param http_response: The HTTP response from an AWS service request.
:rtype: dict
:return: A response dictionary which will contain the following keys:
* headers (dict)
* status_code (int)
* body (string or file-like object)
�operation_name)�headers� status_code�contextr �, �bodyr zcontent-length) r r �name�content�has_event_stream_output�raw�has_streaming_output�getr
)�
http_response�operation_model�
response_dict�length� r �3/usr/lib/python3/dist-packages/botocore/endpoint.py�convert_to_response_dict( s" ��
�
�
�r c @ sz e Zd ZdZ ddd�Zdd� Zdd� Zd d d
�Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dd� Z
ddd�Zdd� ZdS ) �Endpointa,
Represents an endpoint for a particular service in a specific
region. Only an endpoint can make requests.
:ivar service: The Service object that describes this endpoints
service.
:ivar host: The fully qualified endpoint hostname.
:ivar session: The session object.
Nc C sR || _ || _|| _t�� | _|d u rt�� }|| _|| _ | j d u r't
� | _ d S d S �N) �_endpoint_prefix�_event_emitter�host� threading�Lock�_lockr �ResponseParserFactory�_response_parser_factory� http_sessionr )�selfr% �endpoint_prefix�
event_emitter�response_parser_factoryr+ r r r �__init__U s
�zEndpoint.__init__c C s d| j | jf S )Nz%s(%s))r# r% )r, r r r �__repr__b s zEndpoint.__repr__c C s t �d||� | �||�S )Nz%Making request for %s with params: %s)�logger�debug�
_send_request)r, r � request_dictr r r � make_requeste s � zEndpoint.make_requestc C s\ t |�}|r't|j|jg�|_|jj�� }dj||j d�}| j
j |||j d� | � |�}|S )Nz&request-created.{service_id}.{op_name})�
service_id�op_name)�requestr )
r �anyr r �
stream_output�
service_modelr7 � hyphenize�formatr r$ �emit�prepare_request)r, �paramsr r9 r7 �
event_name�prepared_requestr r r �create_requestj s � �
�
zEndpoint.create_requestc C s0 |� � D ]\}}t|tj�r|�d�||< qd S )Nzutf-8)�items�
isinstance�six� text_type�encode)r, r �key�valuer r r �_encode_headersz s
��zEndpoint._encode_headersc C s | � |j� |�� S r" )rL r �prepare�r, r9 r r r r@ � s zEndpoint.prepare_requestc C s� d}| � ||�}|d }| �|||�\}}| �|||||�r>|d7 }|�� | � ||�}| �|||�\}}| �|||||�s |d urTd|d v rT|d }||d d d< |d urZ|�|S )N� r �ResponseMetadata�
RetryAttempts)rD �
_get_response� _needs_retry� reset_stream) r, r5 r �attemptsr9 r �success_response� exception�
total_retriesr r r r4 � s6 �
���
��
zEndpoint._send_requestc
C sv | � ||�\}}d d ||d�}|d ur"|\}}||d< t||�|d< |jj�� } | jjd| |jf fi |�� ||fS )N)r �parsed_responser rW rY r zresponse-received.%s.%s)�_do_get_responser r< r7 r= r$ r? r )
r, r9 r r rV rW �kwargs_to_emitr rY r7 r r r rR � s. ��� ���zEndpoint._get_responsec
C sZ z;t �d|� t�d|j|j|j|j|jd�� |j j
� � }d||j f }| j
j||d�}t|�}|d u r:| �|�}W n2 tyQ } z
d |fW Y d }~S d }~w tym } zt jddd� d |fW Y d }~S d }~ww t||�}|�� } |j| d < t�d
| � |jd }
| j�|
�} | �||j�} |jd kr�| � || || � t�d
| � || fd fS )NzSending http request: %s� HTTP_REQUEST)�methodr � streaming�urlr zbefore-send.%s.%s)r9 z-Exception received when sending HTTP request.T)�exc_infor^ �
HTTP_RESPONSE�protocolr �PARSED_RESPONSE) r2 r3 �history_recorder�recordr] r �has_streaming_inputr_ r r< r7 r= r r$ r? r �_sendr � Exceptionr �copyr �metadatar* �
create_parser�parse� output_shaper �_add_modeled_error_fields)
r, r9 r r7 rB � responsesr �er �http_response_record_dictrb �parserrY r r r rZ � sV �
�����
�
�
� zEndpoint._do_get_responsec C sT |� di �� d�}|d u rd S |j}|�|�}|d u r d S |�||�}|�|� d S )N�Error�Code)r r< �shape_for_error_coderl �update) r, r rY r rr �
error_coder< � error_shape�
modeled_parser r r rn � s
z"Endpoint._add_modeled_error_fieldsc
C sb |j j�� }d||jf }| jj||| ||||d�}t|�} | d u r$dS t�d| � t �
| � dS )Nzneeds-retry.%s.%s)�response�endpoint� operationrU �caught_exceptionr5 Fz3Response received to retry, sleeping for %s secondsT) r< r7 r= r r$ r? r r2 r3 �time�sleep)
r, rU r r5 rz r} r7 rB ro �handler_responser r r rS � s$ ���
zEndpoint._needs_retryc C s | j �|�S r" )r+ �sendrN r r r rg
s zEndpoint._send)NNr" )�__name__�
__module__� __qualname__�__doc__r0 r1 r6 rD rL r@ r4 rR rZ rn rS rg r r r r r! K s
�
/
� r! c @ s@ e Zd Zdd� Zddeeeddddf dd�Zdd� Zdd � Z dS )
�EndpointCreatorc C s
|| _ d S r" )r$ )r, r. r r r r0 s
zEndpointCreator.__init__Nc
C sr t |�st|�std| ��| d u r| �|�} |j}
t�d|
|� ||| | �|�||
| | d�}t||
| j ||d�S )NzInvalid endpoint: %szSetting %s timeout as %s)�timeout�proxies�verify�max_pool_connections�socket_options� client_cert�proxies_config)r- r. r/ r+ )
r r �
ValueError� _get_proxiesr- r2 r3 �_get_verify_valuer! r$ )r, r< � region_name� endpoint_urlr� r/ r� r� �http_session_clsr� r� r� r� r- r+ r r r �create_endpoint s2 ��
�
�z EndpointCreator.create_endpointc C s t |�S r" )r )r, r_ r r r r� 9 s z EndpointCreator._get_proxiesc C s |d ur|S t j�dd�S )N�REQUESTS_CA_BUNDLET)�os�environr )r, r� r r r r� > s z!EndpointCreator._get_verify_value)
r� r� r� r0 �DEFAULT_TIMEOUT�MAX_POOL_CONNECTIONSr r� r� r� r r r r r� s
�$ r� )!r� �loggingr~ r& rG �botocore.awsrequestr �botocore.exceptionsr �botocore.httpsessionr �botocore.utilsr r r �botocore.hooksr �botocore.historyr �botocore.responser
�botocorer � getLoggerr� r2 rd r� r� r �objectr! r� r r r r �<module> s*
# G