HEX
Server: Apache/2.4.52 (Ubuntu)
System: Linux spn-python 5.15.0-89-generic #99-Ubuntu SMP Mon Oct 30 20:42:41 UTC 2023 x86_64
User: arjun (1000)
PHP: 8.1.2-1ubuntu2.20
Disabled: NONE
$ pwd: /home/arjun/projects/env/lib/python3.10/site-packages/boto/__pycache__/
Upload Files
File: //home/arjun/projects/env/lib/python3.10/site-packages/boto/__pycache__/connection.cpython-310.pyc
o

we3��@sdZddlmZddlZddlZddlZddlZddlZddlZddlZddl	Z
ddlZddlm
Z
ddlmZddlZddlZddlZddlZddlmZmZddlmZmZmZmZmZddlmZdd	lmZdd
lmZddlmZddlm Z dd
l!m"Z"dZ#zddl$Z$ddlm%Z%e&e$d�r�dZ#Wn	e'y�Ynwzddl(Z(Wn
e'y�ddl)Z(Ynwe*dd�dD��Z+ddd�Z,ej-�.ej-�/ej-�0ej1j2��d�Z3Gdd�de4�Z5Gdd�de4�Z6Gdd�de4�Z7Gdd �d ej8�Z8Gd!d"�d"e4�Z9Gd#d$�d$e9�Z:dS)%z"
Handles basic connections to AWS
�)�datetimeN)�auth)�auth_handler)�config�	UserAgent)�six�http_client�urlparse�quote�encodebytes)�AWSConnectionError)�BotoClientError)�BotoServerError)�PleaseRetryException)�Provider)�	ResultSetF)�https_connection�SSLErrorTccs�|]}|tjvVqdS�N)�os�environ)�.0�key�r�H/home/arjun/projects/env/lib/python3.10/site-packages/boto/connection.py�	<genexpr>Ws�r)�
USER_IS_ADMIN�CURRENT_VERSION_ID�APPLICATION_ID��P)TFzcacerts.txtc@sHeZdZdZdd�Zdd�Zdd�Zdd	�Zd
d�Zdd
�Z	dd�Z
dS)�HostConnectionPoola�
    A pool of connections for one remote (host,port,is_secure).

    When connections are added to the pool, they are put into a
    pending queue.  The _mexe method returns connections to the pool
    before the response body has been read, so they connections aren't
    ready to send another request yet.  They stay in the pending queue
    until they are ready for another request, at which point they are
    returned to the pool of ready connections.

    The pool of ready connections is an ordered list of
    (connection,time) pairs, where the time is the time the connection
    was returned from _mexe.  After a certain period of time,
    connections are considered stale, and discarded rather than being
    reused.  This saves having to wait for the connection to time out
    if AWS has decided to close it on the other end because of
    inactivity.

    Thread Safety:

        This class is used only from ConnectionPool while it's mutex
        is held.
    cCs
g|_dSr)�queue��selfrrr�__init__z�
zHostConnectionPool.__init__cCs
t|j�S)z�
        Returns the number of connections in the pool for this host.
        Some of the connections may still be in use, and may not be
        ready to be returned by get().
        )�lenr"r#rrr�size}s
zHostConnectionPool.sizecCs|j�|t��f�dS)zZ
        Adds a connection to the pool, along with the time it was
        added.
        N)r"�append�time)r$�connrrr�put�szHostConnectionPool.putcCsL|��tt|j��D]}|j�d�\}}|�|�r|S|�|�qdS)z�
        Returns the next connection in this pool that is ready to be
        reused.  Returns None if there aren't any.
        rN)�clean�ranger'r"�pop�_conn_readyr,)r$�_r+rrr�get�s
zHostConnectionPool.getcCs$trdSt|dd�}|dup|��S)aZ
        There is a nice state diagram at the top of http_client.py.  It
        indicates that once the response headers have been read (which
        _mexe does before adding the connection to the pool), a
        response is attached to the connection, and it stays there
        until it's done reading.  This isn't entirely true: even after
        the client is done reading, the response may be closed, but
        not removed from the connection yet.

        This is ugly, reading a private instance variable, but the
        state we care about isn't available in any public methods.
        F�_HTTPConnection__responseN)�
ON_APP_ENGINE�getattr�isclosed)r$r+�responserrrr0�s
zHostConnectionPool._conn_readycCsXt|j�dkr&|�|jd�r*|j�d�t|j�dkr(|�|jd�sdSdSdSdS)z/
        Get rid of stale connections.
        rN)r'r"�_pair_staler/r#rrrr-�s.�zHostConnectionPool.cleancCs|\}}t��}|tj|kS)z[
        Returns true of the (connection,time) pair is too old to be
        used.
        )r*�ConnectionPool�STALE_DURATION)r$�pair�_conn�return_time�nowrrrr8�szHostConnectionPool._pair_staleN)�__name__�
__module__�__qualname__�__doc__r%r(r,r2r0r-r8rrrrr!`s	r!c@sPeZdZdZdZdZdd�Zdd�Zdd	�Zd
d�Z	dd
�Z
dd�Zdd�ZdS)r9z�
    A connection pool that expires connections after a fixed period of
    time.  This saves time spent waiting for a connection that AWS has
    timed out on the other end.

    This class is thread-safe.
    g@gN@cCs,i|_d|_t��|_t�ddtj�t_dS)Ng�Boto�connection_stale_duration)	�host_to_pool�last_clean_time�	threading�Lock�mutexr�getfloatr9r:r#rrrr%�s
��zConnectionPool.__init__cCst�|j�}i|d<|d=|S)NrErI)�copy�__dict__)r$�pickled_dictrrr�__getstate__�szConnectionPool.__getstate__cCs|��dSr)r%)r$�dctrrr�__setstate__��zConnectionPool.__setstate__cCstdd�|j��D��S)z@
        Returns the number of connections in the pool.
        css�|]}|��VqdSr)r()r�poolrrrr�s�z&ConnectionPool.size.<locals>.<genexpr>)�sumrE�valuesr#rrrr(�szConnectionPool.sizecCsf|��|j�"|||f}||jvr	Wd�dS|j|��Wd�S1s,wYdS)z�
        Gets a connection from the pool for the named host.  Returns
        None if there is no connection that can be reused. It's the caller's
        responsibility to call close() on the connection when it's no longer
        needed.
        N)r-rIrEr2)r$�host�port�	is_securerrrr�get_http_connections

�$�z"ConnectionPool.get_http_connectioncCs\|j�!|||f}||jvrt�|j|<|j|�|�Wd�dS1s'wYdS)zm
        Adds a connection to the pool of connections that can be
        reused for the named host.
        N)rIrEr!r,)r$rUrVrWr+rrrr�put_http_connections

"�z"ConnectionPool.put_http_connectioncCs�|j�Dt��}|j|j|kr?g}|j��D]\}}|��|��dkr*|�|�q|D]}|j|=q-||_Wd�dSWd�dS1sJwYdS)a+
        Clean up the stale connections in all of the pools, and then
        get rid of empty pools.  Pools clean themselves every time a
        connection is fetched; this cleaning takes care of pools that
        aren't being used any more, so nothing is being gotten from
        them.
        rN)	rIr*rF�CLEAN_INTERVALrE�itemsr-r(r))r$r>�	to_removerUrRrrrr-s
�
�"�zConnectionPool.cleanN)
r?r@rArBrZr:r%rNrPr(rXrYr-rrrrr9�s
r9c@s$eZdZdd�Zdd�Zdd�ZdS)�HTTPRequestc

Cs|||_||_||_||_||_|dur|}||_||_|r6d|vr6|ddkr6|jdkr6|��|_|jd=n||_|	|_	dS)ayRepresents an HTTP request.

        :type method: string
        :param method: The HTTP method name, 'GET', 'POST', 'PUT' etc.

        :type protocol: string
        :param protocol: The http protocol used, 'http' or 'https'.

        :type host: string
        :param host: Host to which the request is addressed. eg. abc.com

        :type port: int
        :param port: port on which the request is being sent. Zero means unset,
            in which case default port will be chosen.

        :type path: string
        :param path: URL path that is being accessed.

        :type auth_path: string
        :param path: The part of the URL path used when creating the
            authentication string.

        :type params: dict
        :param params: HTTP url query parameters, with key as name of
            the param, and value as value of param.

        :type headers: dict
        :param headers: HTTP headers, with key as name of the header and value
            as value of header.

        :type body: string
        :param body: Body of the HTTP request. If not present, will be None or
            empty string ('').
        N�Transfer-Encoding�chunked�PUT)
�method�protocolrUrV�path�	auth_path�paramsrK�headers�body)
r$rarbrUrVrcrdrerfrgrrrr%1s $



zHTTPRequest.__init__c	Cs(d|j|j|j|j|j|j|j|jfS)NzTmethod:(%s) protocol:(%s) host(%s) port(%s) path(%s) params(%s) headers(%s) body(%s))rarbrUrVrcrerfrgr#rrr�__str__hs��zHTTPRequest.__str__cKs�t|dd�s*|jD]}|j|}t|tj�r#d}t|�d�|�|j|<q	t|dd�t|jd<|j	j
|fi|��d|jvrVd|jvsJ|jdd	krXtt|j
��|jd<dSdSdS)
N�_headers_quotedFz!"#$%&'()*+,/:;<=>?@[\]^`{|}~ �utf-8Tz
User-AgentzContent-Lengthr^r_)r5rf�
isinstancer�	text_typer
�encode�setattrr�
_auth_handler�add_auth�strr'rg)r$�
connection�kwargsr�val�saferrr�	authorizens 

�


�zHTTPRequest.authorizeN)r?r@rAr%rhrvrrrrr]/s7r]c@seZdZdd�Zddd�ZdS)�HTTPResponsecOs$tjj|g|�Ri|��d|_dS)N�)rrwr%�_cached_response)r$�argsrsrrrr%�s
zHTTPResponse.__init__NcCs0|dur|jstj�|�|_|jStj�||�S)a<Read the response.

        This method does not have the same behavior as
        http_client.HTTPResponse.read.  Instead, if this method is called with
        no ``amt`` arg, then the response body will be cached.  Subsequent
        calls to ``read()`` with no args **will return the cached response**.

        N)ryrrw�read)r$�amtrrrr{�s
	zHTTPResponse.readr)r?r@rAr%r{rrrrrw�srwc@s\eZdZ								d?dd�Zdd	�Zd
d�Zdd
�Zdd�Zeee�Z	dd�Z
dd�Zee
e�Zdd�Z
ee
�Z
dd�Zee�ZeZeZdd�Zee�ZeZeZdd�Zee�Zd@dd�ZdAdd�Zd d!�Zd"d#�Zd$d%�Zd&d'�Zd(d)�ZdBd*d+�ZdAd,d-�Zd.d/�Zd0d1�Zd2d3�Z d4d5�Z!		dCd6d7�Z"	dDd9d:�Z#			dEd;d<�Z$d=d>�Z%dS)F�AWSAuthConnectionNTr�/�awscCs*||_d|_t�dd�rt�dd�}||_t�dd|�|_|jr&ts&t	d��t�
ddt�}|dkr3d}||_|r<||_
nt||_
|�||||	�tjtjtjtjf|_g|_tr`|j�tj�tjf|_|durx|d	|_|j|d
7_nd|_|r�d|_nd|_||_ ||_!t"|
t#j$�s�d	}
t�%dd
|
�|_&d|_'i|_(t)j*d	t)j*d
fdkr�t�%ddd�|j(d<t"|
t+�r�|
|_,n
|
|_-t+|j-||||�|_,|j,j r�|j,j |_ |j,j
r�|j,j
|_
|j,j'r�|j,j'|_'t.�|_/|j |j
|jf|_0d|_1t2�3|t|j,|�4��|_5t6|dd�du�r|j7|_8d|_9dS)a0
        :type host: str
        :param host: The host to make the connection to

        :keyword str aws_access_key_id: Your AWS Access Key ID (provided by
            Amazon). If none is specified, the value in your
            ``AWS_ACCESS_KEY_ID`` environmental variable is used.
        :keyword str aws_secret_access_key: Your AWS Secret Access Key
            (provided by Amazon). If none is specified, the value in your
            ``AWS_SECRET_ACCESS_KEY`` environmental variable is used.
        :keyword str security_token: The security token associated with
            temporary credentials issued by STS.  Optional unless using
            temporary credentials.  If none is specified, the environment
            variable ``AWS_SECURITY_TOKEN`` is used if defined.

        :type is_secure: boolean
        :param is_secure: Whether the connection is over SSL

        :type https_connection_factory: list or tuple
        :param https_connection_factory: A pair of an HTTP connection
            factory and the exceptions to catch.  The factory should have
            a similar interface to L{http_client.HTTPSConnection}.

        :param str proxy: Address/hostname for a proxy server

        :type proxy_port: int
        :param proxy_port: The port to use when connecting over a proxy

        :type proxy_user: str
        :param proxy_user: The username to connect with on the proxy

        :type proxy_pass: str
        :param proxy_pass: The password to use when connection over a proxy.

        :type port: int
        :param port: The port to use to connect

        :type suppress_consec_slashes: bool
        :param suppress_consec_slashes: If provided, controls whether
            consecutive slashes will be suppressed in key paths.

        :type validate_certs: bool
        :param validate_certs: Controls whether SSL certificates
            will be validated or not.  Defaults to True.

        :type profile_name: str
        :param profile_name: Override usual Credentials section in config
            file to use a named set of keys instead.
        �rCrW�https_validate_certificatesz�SSL server certificate validation is enabled in boto configuration, but Python dependencies required to support this feature are not available. Certificate validation is only supported when running under Python 2.6 or later.�ca_certificates_file�systemNr��https�http�debug)�r��http_socket_timeout�F�timeout�AuthServiceName):�suppress_consec_slashes�num_retriesr�
has_option�
getbooleanrW�getboolr��HAVE_HTTPS_CONNECTIONr
�	get_value�DEFAULT_CA_CERTS_FILEr�rV�PORTS_BY_SECURITY�handle_proxyr�
HTTPException�socket�error�gaierror�
BadStatusLine�http_exceptions�http_unretryable_exceptionsr)r�InvalidCertificateException�errno�EINTR�socket_exception_values�https_connection_factoryrbrUrcrkr�
integer_types�getintr��host_header�http_connection_kwargs�sys�version_infor�provider�_provider_typer9�_pool�_connection�_last_rsr�get_auth_handler�_required_auth_capabilityror5r��auth_service_name�request_hook)r$rU�aws_access_key_id�aws_secret_access_keyrWrV�proxy�
proxy_port�
proxy_user�
proxy_passr�r�rcr��security_tokenr��validate_certs�profile_name�
certs_filerrrr%�s�9�
��
��


�
�


�
zAWSAuthConnection.__init__cCsd|jj|jfS)Nz%s:%s)�	__class__r?rUr#rrr�__repr__>szAWSAuthConnection.__repr__cC�gSrrr#rrrr�A�z+AWSAuthConnection._required_auth_capabilitycC�t|jd�S)N�service_name�r5ror#rrr�_get_auth_service_nameDrQz(AWSAuthConnection._get_auth_service_namecC�||j_dSr)ror��r$�valuerrr�_set_auth_service_nameJrQz(AWSAuthConnection._set_auth_service_namecCr�)N�region_namer�r#rrr�_get_auth_region_nameNrQz'AWSAuthConnection._get_auth_region_namecCr�r)ror�r�rrr�_set_auth_region_nameQrQz'AWSAuthConnection._set_auth_region_namecCs|j|j�Sr)rXr�r#rrrrrUrQzAWSAuthConnection.connectioncC�|jjSr)r��
access_keyr#rrrr�Y�z#AWSAuthConnection.aws_access_key_idcCr�r)r��
secret_keyr#rrrr�_r�z'AWSAuthConnection.aws_secret_access_keycCr�r)r�r�r#rrrr�er�zAWSAuthConnection.profile_namecCs�|js
|jt�dd|�S|�d�}|dkr#||d�}|d|�}nd}|ddkr.d}nd}|j�d�}|�|�d��d	d
�|D�}dd�|�}|ddkrX|rX|d7}|r^||}|S)Nz^(/*)/z\1�?r���r~TFcSsg|]}|r|�qSrr)r�prrr�
<listcomp>|sz.AWSAuthConnection.get_path.<locals>.<listcomp>)r�rc�re�sub�find�split�extend�join)r$rc�posre�
need_trailing�
path_elementsrrr�get_pathis&
zAWSAuthConnection.get_pathcCsh|s|j}|dkr|j}|Strtjdd�dks"tjdd�dvr+|dkr+|j}|Sd|j|f}|S)Nr �z2.5)z2.6z2.7r�%s:%d)rVrUr4r��version)r$rV�signature_hostrrr�server_name�s��zAWSAuthConnection.server_namecCs||_||_||_||_dtjvr<|js<t�d�}|�tjd�}|r;|�	d�|_|�	d�|_|�	d�|_|�	d�|_n,|jsGt
�ddd�|_|jsRt
�dd	d�|_|js]t
�dd
d�|_|jsht
�ddd�|_|jsv|jrvtd�|j
|_tj�d
d�p�tj�dd�|_|jdu|_dS)N�
http_proxyzX(?:http://)?(?:(?P<user>[\w\-\.]+):(?P<pass>.*)@)?(?P<host>[\w\-\.]+)(?::(?P<port>\d+))?rUrV�user�passrCr�r�r�r�zFhttp_proxy environment variable does not specify a port, using default�no_proxyrx�NO_PROXY)r�r�r�r�rrr��compile�match�grouprr��printrVr2r��	use_proxy)r$r�r�r�r��patternr�rrrr��s8��zAWSAuthConnection.handle_proxycCs*|j�|||�}|dur|S|�|||�Sr)r�rX�new_http_connection)r$rUrVrWr+rrrrX�sz%AWSAuthConnection.get_http_connectioncCs^|jsdS|jdkrdS|}|�d�d}|j�d�D]}|r,|�|�s)|�|�r,dSqdS)NF�*T�:r�,)r�r��endswith)r$rU�hostonly�namerrr�
skip_proxy�s
�zAWSAuthConnection.skip_proxycCs`|dur|��}tj�|�}|j��}||d<|jr+|s+|�|�s+|j}t	|j
�|d<|rmtj�d||�|jrH|�|�sH|�
||rDdpEd�}nC|jrQ|�|�}n:|jrctrctj|fd|ji|��}n(tj|fi|��}ntj�d|�|jr�|j|fi|��}n	tj|fi|��}|jdkr�|�|j�|�d�d	|jkr�||jkr�|||f|_t|_|S)
NrVz1establishing HTTPS connection: host=%s, kwargs=%srr �ca_certsz'establishing HTTP connection: kwargs=%sr�r�r)r��boto�utils�
parse_hostr�rKr�r�r��intr��logr��	proxy_sslr�r�r�r�CertValidatingHTTPSConnectionr�r�HTTPSConnection�HTTPConnection�set_debuglevelr�rUrWr�rw�response_class)r$rUrVrWr�rrrrrr��sh

��
����������
z%AWSAuthConnection.new_http_connectioncCs|j�||||�dSr)r�rY)r$rUrVrWrrrrrrYsz%AWSAuthConnection.put_http_connectioncCs |r|rd||f}nd|j|jf}|j�d�}|dur*t�|jt|j�f|�}nt�|jt|j�f�}t	j
�d|�|�d|�|�dt
�|jrq|jrq|����D]
\}}|�d||f�qVt�ddd	�rp|�d
�n|�d
�tj|d|jd�}|��|jd
kr�t�dd|j|j|j|jf��|��t�|�}|jr�tr�d}	|jr�|	d|j7}	n|	d7}	t	j
�|	�|j�dd�}
|j�dd�}tj ||
|tj!|jd�}|�"�}
|j�#dd�d}t$�%|
|�s�t$�&||
d��nt'td�r�tj�(|�}n
t�|dd�}t�)||�}||_*|S)Nr�r�z'Proxy connection: CONNECT %s HTTP/1.0
zCONNECT %s HTTP/1.0
zUser-Agent: %s
z%s: %s
rC�"send_crlf_after_proxy_auth_headersFz
T)�strict�
debuglevel��i����z*Error talking to HTTP proxy %s:%s: %s (%s)z,wrapping ssl socket for proxied connection; zCA certificate file=%szusing system provided SSL certs�key_file�	cert_file)�keyfile�certfile�	cert_reqsr�r�rzhostname mismatch�ssl)+rUrVr�r2r��create_connectionr�r�r�r�r�r��sendallrr�r��get_proxy_auth_headerr[rr�rrw�begin�statusr��reason�closer�r�r�r�r
�wrap_socket�
CERT_REQUIRED�getpeercertr�r�ValidateCertificateHostnamer��hasattr�	SSLSocket�
FakeSocket�sock)r$rUrVr�r�k�v�resp�h�msgrr�sslSock�cert�hostnamerrrr�sv��
�

���

���
zAWSAuthConnection.proxy_sslcCs|jd|p	|��|}|S)N�://)rbr�)r$rcrUrrr�prefix_proxy_to_pathUsz&AWSAuthConnection.prefix_proxy_to_pathcCs t|jd|j�}dd|iS)Nr�zProxy-AuthorizationzBasic %s)rr�r�)r$rrrrr
Ysz'AWSAuthConnection.get_proxy_auth_headercCsZ|jsdS|js|jr|jrd|j|jf}nd|j}nd}d||jt|jp)|j�fS)Nz%s:%s@z%s@rxzhttp://%s%s:%s)r�r�r�r�rqr�rV)r$�
login_inforrr�get_proxy_url_with_auth^sz)AWSAuthConnection.get_proxy_url_with_authcCsJz|j�|j|�|jd<WdSty$|j�dd�d|jd<YdSw)N�Hostr�r�r)ror�rUrf�AttributeErrorr�)r$�requestrrr�set_host_headerls��z!AWSAuthConnection.set_host_headercCs
||_dSr)r�)r$�hookrrr�set_request_hooksr&z"AWSAuthConnection.set_request_hookc
Cs�tj�d|j�tj�d|j�tj�d|j�tj�d|j�tj�d|j�tj�d|j�tj�d|j	�d}d}d}|durRt
�d	d
|j�}n|}d}	|�
|j|j|j�}
t|jt�sst|jd�rs|j�d
�|_|	|k�rGtt��d|	tj
�d	dd��}�zDtj�d|jj�|j|d�d|��vr�t|dd�s�|j�d�s�|�|�tj�d|j�t��|_t|�r�||
|j|j|j|j�}n|
� |j|j|j|j�|
�!�}tj�d|�"��|�#d�}|jdkr�t|dd�r�d|_$t|��r!|||	|�}
|
�r!|
\}}	}|�rtj�|�t%�&|�Wqs|j'dv�rHd|j'}|d|7}tj�|�|�(�}t|t��rG|�)d
�}n�|j'dk�sW|j'd k�sW|�s�|�#d!�}|d"k�rf|
�*�n|�+|j|j|j|
�|j,du�r~|j,�-||�|WSt.|�\}|_|_}}}|�r�|jd#|7_d$|jv�r�|j�/d$d%�\|_|_d&|d'}||j|j7}tj�|�|�
|j|j|d(k�}
d}WqsWnkt0�y�}ztj�d)|�|�1|j|j|j�}
|j2}|}WYd}~nFd}~w|j3�y9}z4|j4D]}t||��rtj�d*|j5j6���qtj�d+|j5j6�|�1|j|j|j�}
|}WYd}~nd}~wwt%�&|�|	d%7}	|	|ksx|j,du�rV|j,j-||d,d-�|�rat7|j'|j8|��|�rf|�d.}t9|��)/a>
        mexe - Multi-execute inside a loop, retrying multiple times to handle
               transient Internet errors by simply trying again.
               Also handles redirects.

        This code was inspired by the S3Utils classes posted to the boto-users
        Google group by Larry Bates.  Thanks!

        z
Method: %szPath: %szData: %szHeaders: %szHost: %szPort: %sz
Params: %sNrCr�rrmrjr��max_retry_delay�<z	Token: %s)rr�s3�anonFr&zFinal headers: %szResponse headers: %s�location�HEADr_)i�i�i�i�zReceived %d response.  zRetrying in %3.1f secondsi,i�rrrr�r�r�zRedirecting: %sr"r�z!encountered a retry exception: %sz0encountered unretryable %s exception, re-raisingz&encountered %s exception, reconnectingT)r�z-Please report this exception as a Boto Issue!):r�r�r�rarcrgrfrUrVrerr�r�rXrWrk�bytesrrm�min�randomr2r�r�rvr�r5r)rr>�
start_time�callabler(�getresponse�
getheaders�	getheaderr_r*�sleeprr{�decoderrYr��handle_request_datar	r�rr�r7r�r�r�r?rrr
)r$r(�sender�override_num_retries�
retry_handlerr7rg�exr��irr�
next_sleepr0rr�conn_header_value�schemere�query�fragment�e�unretryablerrr�_mexevs��
�

��
�




��


������
�������
�izAWSAuthConnection._mexerxc
Cs�|�|�}|dur|�|�}|duri}n|��}|dur i}n|��}|jr3tj�d|�s3|j|d<|p7|j}|jrZ|�|�sZ|sD|}|�	||�}|j
rZ|jrZ|jsZ|�
|���t||j||j|||||�	S)NrU)r�rKr�r�r��find_matching_headersrUr�r�r#r�r�rW�updater
r]rbrV)r$rarcrdrerf�datarUrrr�build_base_http_requests*




�z)AWSAuthConnection.build_base_http_requestc	Cs4|	duri}	|�||||	|||�}|j||||
d�S)z?Makes a request to the server, with stock multiple-retry logic.N)r?)rMrI)r$rarcrfrLrUrdr=r>rer?�http_requestrrr�make_request&s
�
�zAWSAuthConnection.make_requestcCstj�d�d|_dS)z�(Optional) Close any open HTTP connections.  This is non-destructive,
        and making a new request will open a connection again.zclosing all HTTP connectionsN)r�r�r�r�r#rrrr1s
zAWSAuthConnection.close)NNTNNNNNrNr~rNTTN)r~r)NN)NNN)NNrxN)NrxNNNNNN)&r?r@rAr%r�r�r�r��propertyr�r�r��auth_region_namerrr��gs_access_key_idr�r��gs_secret_access_keyr�r�r�r�r�rXr�r�rYr�r#r
r%r)r+rIrMrOrrrrrr}�sn
�



$9

F
�
�
�r}cs�eZdZdZeZ					d�fdd�	Zd	d
�Zdd�Zddd�Z	dd�Z
dd�Z		
ddd�Z		
ddd�Z
ddd�Z�ZS)�AWSQueryConnectionrxNTrr~rcs4tt|�j|	|||||||||
|||
|||d�dS)N)r�r�r�r�)�superrTr%)r$r�r�rWrVr�r�r�r�rUr�r�rcr�r�r�r��r�rrr%>s

�zAWSQueryConnection.__init__cCr�rrr#rrrr�Nr�z,AWSQueryConnection._required_auth_capabilitycCstj�|�Sr)r�r��get_utf8_valuer�rrrrWQrQz!AWSQueryConnection.get_utf8_value�GETc	CsB|�||d|id|j�}|r||jd<|jr|j|jd<|�|�S)Nrx�Action�Version)rMrUre�
APIVersionrI)r$�actionrerc�verbrNrrrrOTs
�

zAWSQueryConnection.make_requestcCsFt|tj�r	|g}tdt|�d�D]}||d|d||f<qdS)Nr�z%s.%d)rkr�string_typesr.r')r$rer[�labelrArrr�build_list_params^s
�z$AWSQueryConnection.build_list_paramscCsLt|d�D]\}}d||f}t||�D]\}}	d||f}
|	||
<qqdS)aSerialize a list of structures.

        For example::

            items = [('foo', 'bar', 'baz'), ('foo2', 'bar2', 'baz2')]
            label = 'ParamName.member'
            names = ('One', 'Two', 'Three')
            self.build_complex_list_params(params, items, label, names)

        would result in the params dict being updated with these params::

            ParamName.member.1.One = foo
            ParamName.member.1.Two = bar
            ParamName.member.1.Three = baz

            ParamName.member.2.One = foo2
            ParamName.member.2.Two = bar2
            ParamName.member.2.Three = baz2

        :type params: dict
        :param params: The params dict.  The complex list params
            will be added to this dict.

        :type items: list of tuples
        :param items: The list to serialize.

        :type label: string
        :param label: The prefix to apply to the parameter.

        :type names: tuple of strings
        :param names: The names associated with each tuple element.

        r�z%s.%sN)�	enumerate�zip)r$rer[r_�namesrA�item�current_prefixrr��full_keyrrr�build_complex_list_paramsds"
��z,AWSQueryConnection.build_complex_list_paramscCs�|s|}|�||||�}|��}tj�|�|s)tj�d|�|�|j|j|��|jdkrMt	|�}	tj
�|	|�}
t|t
j�rD|�d�}tj�||
�|	Stj�d|j|jf�tj�d|�|�|j|j|���N�Null body %srrj�%s %s�%s)rOr{r�r�r�r��
ResponseErrorrrr�handler�
XmlHandlerrkrrlrm�xml�sax�parseString)r$r\re�markersrc�parentr]r7rg�rsrrrr�get_list��$

zAWSQueryConnection.get_listcCs�|s|}|�||||�}|��}tj�|�|s)tj�d|�|�|j|j|��|jdkrM||�}	tj	�
|	|�}
t|tj
�rD|�d�}tj�||
�|	Stj�d|j|jf�tj�d|�|�|j|j|��rh)rOr{r�r�r�r�rlrrrmrnrkrrlrmrorprq)r$r\re�clsrcrsr]r7rg�objrrrr�
get_object�rvzAWSQueryConnection.get_objectc
Cs�|s|}|�||||�}|��}tj�|�|s)tj�d|�|�|j|j|��|jdkrBt	�}tj
�||�}	tj
�||	�|jStj�d|j|jf�tj�d|�|�|j|j|��)Nrirrjrk)rOr{r�r�r�r�rlrrrrmrnrorprq)
r$r\rercrsr]r7rgrtrrrr�
get_status�s 
zAWSQueryConnection.get_status)NNTNNNNNNrNr~NTNr)Nr~rX)r~NrX)r?r@rAr[rrlr%r�rWrOr`rgruryrz�
__classcell__rrrVrrT9s*�

*
�
�rT);rBrr�rr4r�r�r�r*�xml.saxrorKr�rr�
boto.utils�boto.handler�boto.cacertsrr�boto.compatrrr	r
r�boto.exceptionrr
rr�
boto.providerr�boto.resultsetrr�r
rr�ImportErrorrG�dummy_threading�allr4r�rcr��dirname�abspath�cacerts�__file__r��objectr!r9r]rwr}rTrrrr�<module>sp)
����"jeT
@ Telegram