File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/common/__pycache__/aws.cpython-310.pyc
Back
o ;j�@ � @ s� d dl Z d dlZd dlZd dlZd dlmZmZmZ d dlmZ d dl m Z d dl m Z m Z m Z mZmZmZ d dlmZmZ d dlmZmZmZmZ d dlmZmZ zd dl Z W n e ye d dl Z Y nw g d �Z d Z d Z!d �"� Z#G d d� de�Z$G dd� de$�Z%G dd� de�Z&G dd� d�Z'G dd� de'�Z(G dd� de'�Z)G dd� d�Z*G dd � d e&�Z+G d d � d e�Z,d&d d!�Z-d"d#� Z.G d$d%� d%e�Z/dS )'� N)�Dict�Type�Optional)�sha256)�datetime)�ET�b�httplib�urlquote� basestring� _real_unicode)�findall_ignore_namespace�findtext_ignore_namespace)� BaseDriver� XmlResponse� JsonResponse�ConnectionUserAndKey)�InvalidCredsError�MalformedResponseError)�AWSBaseResponse�AWSGenericResponse�AWSTokenConnection�SignedAWSConnection�AWSRequestSignerAlgorithmV2�AWSRequestSignerAlgorithmV4� AWSDriver�2zUNSIGNED-PAYLOADa� "params" dictionary contains an attribute "%s" which value (%s, %s) is not a string. Parameters are sent via query parameters and not via request body and as such, all the values need to be of a simple type (string, int, bool). For arrays and other complex types, you should use notation similar to this one: params['TagSpecification.1.Tag.Value'] = 'foo' params['TagSpecification.2.Tag.Value'] = 'bar' See https://docs.aws.amazon.com/AWSEC2/latest/APIReference/Query-Requests.html for details. c @ s e Zd ZdZdd� ZdS )r Nc C s( t |d| jd�}t |d| jd�}||fS )z� Parse code and message from the provided error element. :return: ``tuple`` with two elements: (code, message) :rtype: ``tuple`` ZCode��element�xpath� namespace�Message)r r )�selfr �code�message� r% �G/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/common/aws.py�_parse_error_detailsE s �z$AWSBaseResponse._parse_error_details)�__name__� __module__� __qualname__r r' r% r% r% r& r B s r c @ s$ e Zd ZdZi Zdd� Zdd� ZdS )r Nc C s | j tjtjtjfv S �N)�statusr �OK�CREATED�ACCEPTED)r" r% r% r& �success` s zAWSGenericResponse.successc C s. | j j}t| j�}|tjkr"| js tt| j�d | j ��t| j��zt � | j�}W n t y; t d| j| j jd��w | jrIt|| j| jd�}n|g}g }|D ]A}| j|d�\}}| j�|d �} | d u ro|�d�||�� qPi } t| d�r�| jD ] } | |v r�|| | | < qy| d || j jd�| ���d �|�S ) Nz: zFailed to parse XML)�body�driverr )r �{}: {}�kwargs)�valuer2 � r% )� connection�context�intr, r � FORBIDDENr1 r �str�errorr ZXML� Exceptionr r2 r r r r' � exceptions�get�append�format�hasattrr4 �join) r" r8 r, r1 ZerrsZmsgs�errr# r$ Z exceptionCls�params�keyr% r% r& � parse_errorc sB �� � � z AWSGenericResponse.parse_error)r( r) r* r r> r0 rG r% r% r% r& r T s r c sH e Zd Z d � fdd� Z� fdd�Z� fdd�Z� ZS ) r TNc s* | | _ t� j|||||||| | |d� d S )N)�secure�host�port�url�timeout� retry_delay�backoff� proxy_url��token�super�__init__) r" �user_idrF rH rI rJ rK rL rO rQ rM rN �� __class__r% r& rS � s �zAWSTokenConnection.__init__c � | j r| j |d< t� �|�S �Nzx-amz-security-token)rQ rR �add_default_params�r" rE rU r% r& rY � s z%AWSTokenConnection.add_default_paramsc rW rX )rQ rR �add_default_headers�r" �headersrU r% r& r[ � s z&AWSTokenConnection.add_default_headers) TNNNNNNNN)r( r) r* rS rY r[ � __classcell__r% r% rU r& r � s � r c @ s, e Zd ZdZdd� Zd dd�Zd d d �ZdS ) �AWSRequestSignerz@ Class which handles signing the outgoing AWS requests. c C s || _ || _|| _|| _dS )aI :param access_key: Access key. :type access_key: ``str`` :param access_secret: Access secret. :type access_secret: ``str`` :param version: API version. :type version: ``str`` :param connection: Connection instance. :type connection: :class:`Connection` N�� access_key� access_secret�versionr7 )r" ra rb rc r7 r% r% r& rS � s zAWSRequestSigner.__init__�GET�/c C s |S r+ r% �r" rE �method�pathr% r% r& �get_request_params� s z#AWSRequestSigner.get_request_paramsNc C s ||fS r+ r% �r" rE r] rg rh �datar% r% r& �get_request_headers� s z$AWSRequestSigner.get_request_headers�rd re �rd re N)r( r) r* �__doc__rS ri rl r% r% r% r& r_ � s r_ c @ s e Zd Zddd�Zd dd�ZdS ) r rd re c C sR d|d< d|d< | j |d< | j|d< t�dt�� �|d< | j|| j|d �|d < |S ) Nr ZSignatureVersionZ HmacSHA256ZSignatureMethodZAWSAccessKeyId�Versionz%Y-%m-%dT%H:%M:%SZZ Timestamp)rE � secret_keyrh Z Signature)ra rc �time�strftime�gmtime�_get_aws_auth_paramrb rf r% r% r& ri � s �z.AWSRequestSignerAlgorithmV2.get_request_paramsc C s� | j }t|�� �}|�� g }|D ]}t|| �}|�t|dd�d t|dd� � qd�|�} |j} |j r;|j dksC|j sL|j dkrL| dt|j � 7 } d �d | || f�} t � t jt|�t| �td ��� �} | �d �S ) aU Creates the signature required for AWS, per http://bit.ly/aR7GaQ [docs.amazonwebservices.com]: StringToSign = HTTPVerb + " " + ValueOfHostHeaderInLowercase + " " + HTTPRequestURI + " " + CanonicalizedQueryString <from the preceding step> � ��safe�=z-_~�&i� �P �:r6 rd )Z digestmodzutf-8)r7 �list�keys�sortr; r@ r rC rI rH rJ �base64� b64encode�hmac�newr r �digest�decode) r" rE rq rh r7 r~ �pairsrF r5 �qs�hostname�string_to_signZb64_hmacr% r% r& ru � s& $ � � z/AWSRequestSignerAlgorithmV2._get_aws_auth_paramNrm )re )r( r) r* ri ru r% r% r% r& r � s r c @ st e Zd Zd dd�Zd dd�Zd dd �Zd d � Zd d � Zdd� Zdd� Z dd� Z dd� Z d dd�Z dd� Z dd� ZdS ) r rd re c C s |dkr | j |d< |S )Nrd rp )rc rf r% r% r& ri s z.AWSRequestSignerAlgorithmV4.get_request_paramsNc C sH t �� }|�d�|d< | �||�|d< | j||||||d�|d< ||fS )N�%Y%m%dT%H%M%SZz X-AMZ-DatezX-AMZ-Content-SHA256�rE r] �dtrg rh rk Z Authorization)r �utcnowrs �_get_payload_hash� _get_authorization_v4_header)r" rE r] rg rh rk �nowr% r% r& rl s �z/AWSRequestSignerAlgorithmV4.get_request_headersc C sB | j |d�}| j|d�}| j||||||d�} d| j||| d� S )N)r� )r] r� zNAWS4-HMAC-SHA256 Credential=%(u)s/%(c)s, SignedHeaders=%(sh)s, Signature=%(s)s)�u�c�sh�s)�_get_credential_scope�_get_signed_headers�_get_signaturera ) r" rE r] r� rg rh rk Zcredentials_scopeZsigned_headersZ signaturer% r% r& r� s ����z8AWSRequestSignerAlgorithmV4._get_authorization_v4_headerc C s. | � |�}| j||||||d�}t||dd�S )Nr� T�rF �msg�hex)�_get_key_to_sign_with�_get_string_to_sign�_sign) r" rE r] r� rg rh rk rF r� r% r% r& r� . s �z*AWSRequestSignerAlgorithmV4._get_signaturec C s2 t t t t d| j |�d��| jjj�| jj�d�S )NZAWS4�%Y%m%d� aws4_request)r� rb rs r7 r2 � region_name� service_name�r" r� r% r% r& r� 5 s ���z1AWSRequestSignerAlgorithmV4._get_key_to_sign_withc C s6 | j |||||d�}d�d|�d�| �|�t|�g�S )N�rE r] rg rh rk r6 zAWS4-HMAC-SHA256r� )�_get_canonical_requestrC rs r� �_hash)r" rE r] r� rg rh rk Zcanonical_requestr% r% r& r� A s ���z/AWSRequestSignerAlgorithmV4._get_string_to_signc C s" d� |�d�| jjj| jjdg�S )Nre r� r� )rC rs r7 r2 r� r� r� r% r% r& r� O s ��z1AWSRequestSignerAlgorithmV4._get_credential_scopec C s" d� dd� t|�� tjd�D ��S )N�;c S s g | ]}|� � �qS r% ��lower)�.0�kr% r% r& � <listcomp>Z s zCAWSRequestSignerAlgorithmV4._get_signed_headers.<locals>.<listcomp>�rF )rC �sortedr~ r; r� r\ r% r% r& r� Y s "z/AWSRequestSignerAlgorithmV4._get_signed_headersc C s( d� dd� t|�� dd� d�D ��d S )Nr6 c S s* g | ]\}}d � |�� t|��� g��qS )r| )rC r� r; �strip�r� r� �vr% r% r& r� _ s ��zFAWSRequestSignerAlgorithmV4._get_canonical_headers.<locals>.<listcomp>c S s | d � � S )Nr r� )r� r% r% r& �<lambda>a s zDAWSRequestSignerAlgorithmV4._get_canonical_headers.<locals>.<lambda>r� �rC r� �itemsr\ r% r% r& �_get_canonical_headers\ s ����z2AWSRequestSignerAlgorithmV4._get_canonical_headersc C sD |t u rtS |dv r |r t|d�st|d�rtS t|�S tS td�S )N)�POST�PUT�next�__next__rv )�UnsignedPayloadSentinel�UNSIGNED_PAYLOADrB r� )r" rg rk r% r% r& r� g s z-AWSRequestSignerAlgorithmV4._get_payload_hashc C s d� dd� t|�� �D ��S )Nrz c S s0 g | ]\}}d � t|dd�tt|�dd���qS )z{}={}rv rw �~)rA r r; r� r% r% r& r� x s ��zCAWSRequestSignerAlgorithmV4._get_request_params.<locals>.<listcomp>r� rZ r% r% r& �_get_request_paramsu s ��z/AWSRequestSignerAlgorithmV4._get_request_paramsc C s0 d� ||| �|�| �|�| �|�| �||�g�S )Nr6 )rC r� r� r� r� rj r% r% r& r� ~ s ��z2AWSRequestSignerAlgorithmV4._get_canonical_requestrm rn r+ )r( r) r* ri rl r� r� r� r� r� r� r� r� r� r� r% r% r% r& r s r c @ s e Zd ZdS )r� N)r( r) r* r% r% r% r& r� � s r� c sF e Zd ZdZdddddddddef � fdd� Zdd� Zdd� Z� ZS ) r NTc st t � j|||||||| | | |d� t| �| _| jdkr t} n| jdkr&t} ntd| ��| | j| j| j | d�| _ d S )N) rT rF rH rI rJ rK rL rQ rM rN rO r �4z!Unsupported signature_version: %sr` ) rR rS r; �signature_versionr r � ValueErrorrT rF rc �signer)r" rT rF rH rI rJ rK rL rO rQ rM rN r� Z signer_clsrU r% r& rS � s2 � �z SignedAWSConnection.__init__c C sX | j j|| j| jd�}|�� D ]\}}t|tttt f�s)t ||t |�f }t |��q|S )N)rE rg rh ) r� ri rg �actionr� � isinstancer r r9 �bool�PARAMS_NOT_STRING_ERROR_MSG�typer� )r" rE rF r5 r� r% r% r& rY � s �z&SignedAWSConnection.add_default_paramsc C s( | j j||| j| j| jd�\}}||fS )Nr� )r� rl rg r� rk )r" rE r] r% r% r& �pre_connect_hook� s �z$SignedAWSConnection.pre_connect_hook) r( r) r* rc �DEFAULT_SIGNATURE_VERSIONrS rY r� r^ r% r% rU r& r � s �, r c @ s e Zd ZdZdd� ZdS )�AWSJsonResponsezU Amazon ECS response class. ECS API uses JSON unlike the s3, elb drivers c C s0 t �| j�}|d }|�d|d �}d�||�S )NZ__typer! r$ r3 )�json�loadsr1 r? rA )r" �responser# r$ r% r% r& rG � s zAWSJsonResponse.parse_errorN)r( r) r* ro rG r% r% r% r& r� � s r� Fc C s< |rt �t| �t|�tj��� S t �t| �t|�tj��� S r+ )r� r� r �hashlibr � hexdigestr� r� r% r% r& r� � s r� c C s t �t| ���� S r+ )r� r r r� )r� r% r% r& r� � s r� c s8 e Zd Z d� fdd� Z� fdd�Z� ZS )r NTc s. || _ t� j|f|||||||d�| �� d S )N)�secretrH rI rJ � api_version�regionrQ rP ) r" rF r� rH rI rJ r� r� rQ r4 rU r% r& rS � s �� �zAWSDriver.__init__c s t � �� }| j|d< |S )NrQ )rR �_ex_connection_class_kwargsrQ )r" r4 rU r% r& r� s z%AWSDriver._ex_connection_class_kwargs)NTNNNNN)r( r) r* rS r� r^ r% r% rU r& r � s �r )F)0r� rr r� r� �typingr r r r r Zlibcloud.utils.py3r r r r r r Zlibcloud.utils.xmlr r Zlibcloud.common.baser r r r Zlibcloud.common.typesr r Z simplejsonr� � ImportError�__all__r� r� r� r� r r r r_ r r r� r r� r� r� r r% r% r% r& �<module> sD � �>* 0G
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings