File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/common/__pycache__/azure.cpython-310.pyc
Back
o ;j�4 � @ s$ d dl Z d dlZd dlZd dlZd dlZd dlmZ d dlmZ d dl m Z m Z m Z m Z mZmZ d dlmZ d dlmZmZmZmZmZ d dlmZmZmZ d dl m Z m Z d Z G d d � d e �Z!G d d � d e�Z"G dd� de�Z#G dd� de�Z$G dd� de�Z%G dd� de�Z&G dd� de�Z'dS )� N)�sha256)�LibcloudConnection)�ET�b�httplib�urlparse� urlencode� basestring)�fixxpath)� BaseDriver� RawResponse� XmlResponse�ConnectionUserAndKey�CertificateConnection)� LibcloudError�InvalidCredsError�MalformedResponseError)�AzureAuthJsonResponse�publicEnvironmentsz%a, %d %b %Y %H:%M:%S GMTc @ s e Zd Zdd� ZdS )�AzureRedirectExceptionc C s |j d | _d S )N�location)�headersr )�self�response� r �I/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/common/azure.py�__init__) s z AzureRedirectException.__init__N)�__name__� __module__� __qualname__r r r r r r ( s r c sF e Zd ZejejejejejgZ dd� Z ddd�Z � fdd�Z � Z S ) � AzureResponsec C s, t | j�}d| kodkn p|| jv S )N�� i+ )�int�status�valid_response_codes)r �ir r r �success9 s "zAzureResponse.successNc C s� d}z*| � � }t|�tjkr+|�tdd��}|�tdd��}|�d�d }d�||�}W n ty5 Y nw |r>d�||�}| j t j t j fv rKt |��td || j f | d ��) Nz Unknown errorZCode)Zxpath�Message� r z{}: {}z{} - {}z%s Status code: %d.)�driver)� parse_body�typer ZElementZfindtextr �split�formatr r# r � UNAUTHORIZED� FORBIDDENr r )r �msgZ error_msg�body�code�messager r r � parse_error= s" � � zAzureResponse.parse_errorc s0 t | j�tjk}|r| jjjrt| ��t� � � S �N) r" r# r �TEMPORARY_REDIRECT� connectionr) Zfollow_redirectsr �superr* )r Z is_redirect�� __class__r r r* W s zAzureResponse.parse_bodyr5 )r r r r � NOT_FOUND�CONFLICT� BAD_REQUESTr6 �PARTIAL_CONTENTr$ r& r4 r* � __classcell__r r r9 r r - s � r c @ s e Zd ZdS )�AzureRawResponseN)r r r r r r r r@ ` s r@ c @ s e Zd ZdZdS )�AzureBaseDriverz&Microsoft Azure Service Management APIN)r r r �namer r r r rA d s rA c s� e Zd ZdZeZeZdZe Z e Z dZ d� fdd� Zd d � Zd d � Z� fd d�Z d� fdd� Z� ZS )� AzureActiveDirectoryConnectionzI Represents a single connection to Azure using Azure AD for Blob z Azure AD Authz 2017-11-09TN�defaultc s� t � j||fi | �� t|t�rt| }t|t�s$tdd�t�� � ��t � |d �j | _ |d | _ || _ || _|| _|| _d S )Nz�cloud_environment must be one of '%s' or a dict containing keys 'resourceManagerEndpointUrl', 'activeDirectoryEndpointUrl', 'activeDirectoryResourceId', 'storageEndpointSuffix'z', 'ZactiveDirectoryEndpointUrlZactiveDirectoryResourceId)r8 r � isinstancer r �dict� Exception�join�keysr �hostname� login_hostZlogin_resource�host�identity� tenant_idZstorage_account_id) r �keyZsecretZsecurerL �portrN rM Zcloud_environment�kwargsr9 r r r u s& ���� z'AzureActiveDirectoryConnection.__init__c C s8 t �tt �� �|d< | j|d< d|d< d| j |d< |S )N� x-ms-date� x-ms-versionzapplication/xmlz Content-Typez Bearer %s� Authorization)�time�strftime�AZURE_TIME_FORMAT�gmtime� API_VERSION� access_token�r r r r r �add_default_headers� s z2AzureActiveDirectoryConnection.add_default_headersc C sz | j | jd| jd�}|�� td| j| jdd��}ddi}|�dd | j ||� t |� � |�}|j d | _ |j d | _ d S ) zM Log in and get bearer token used to authorize API requests. i� )�timeoutZclient_credentialszhttps://storage.azure.com/)Z grant_typeZ client_idZ client_secretZresourcez Content-typez!application/x-www-form-urlencoded�POSTz/%s/oauth2/tokenrZ � expires_onN)� conn_classrK r] �connectr �user_idrO �requestrN r � getresponse�objectrZ r_ )r �conn�paramsr Zjsr r r �get_client_credentials� s �� z5AzureActiveDirectoryConnection.get_client_credentialsc s | � � t� jdi |��S )Nr )rh r8 ra )r rQ r9 r r ra � s z&AzureActiveDirectoryConnection.connect�GETFc s< t � � d t| j�kr| �� t� j||||||||| d� S )Ni, )rg �datar �method�raw�stream�json� retry_failed)rU r" r_ rh r8 rc ) r �actionrg rj r rk rl rm rn ro rQ r9 r r rc � s �z&AzureActiveDirectoryConnection.request)TNNNNrD )NNNri FFNN)r r r �__doc__r r` rA r) rB r � responseClsr@ �rawResponseClsrY r r\ rh ra rc r? r r r9 r rC h s6 �! �rC c @ s> e Zd ZdZeZeZdZdd� Z dd� Z d dd �Z d d � Z d S )�AzureConnectionz1 Represents a single connection to Azure z 2012-02-12c C s |S r5 r )r rg r r r �add_default_params� s z"AzureConnection.add_default_paramsc C s^ t �|�}t�tt�� �|d< | j|d< | j| j||| j | j | j d�|d< |� dd � ||fS )NrR rS )rk r rg �account� secret_key�pathrT �Host) �copy�deepcopyrU rV rW rX rY �_get_azure_auth_signaturerk rb rO rp �pop)r rg r r r r �pre_connect_hook� s � z AzureConnection.pre_connect_hook�/c C s< g }g }i } |� � D ] \} } | �� } t| ��� } | �d�r%|�| | f� q | | | < q | �| |�} |g| } |�� |D ] \} } | �d�| | �� q;| �d�||�� |� � D ]\}} |�|�� t| ��� f� qV|�� |D ] \}} | �d�|| �� qnt d� | ��}t |�}t � t j||td��� �}d�| j|�d��S )aj Signature = Base64( HMAC-SHA1( YourSecretAccessKeyID, UTF-8-Encoding-Of( StringToSign ) ) ) ); StringToSign = HTTP-VERB + " " + Content-Encoding + " " + Content-Language + " " + Content-Length + " " + Content-MD5 + " " + Content-Type + " " + Date + " " + If-Modified-Since + " " + If-Match + " " + If-None-Match + " " + If-Unmodified-Since + " " + Range + " " + CanonicalizedHeaders + CanonicalizedResource; zx-ms-z{}:{}z/{}{}r( )Z digestmodzSharedKey {}:{}zutf-8)�items�lower�str�strip� startswith�append� _format_special_header_values�sortr- r rH �base64� b64encode�hmac�newr �digestrb �decode)r rk r rg rv rw rx Zxms_header_valuesZ param_listZ headers_copy�header�value�special_header_valuesZvalues_to_signrO Zstring_to_signZb64_hmacr r r r| � s0 z)AzureConnection._get_azure_auth_signaturec C sr |dv}| j dk}g d�}g }|D ]%}|�� }||v r#|�|| � q|dkr1|r1|r1|�d� q|�d� q|S )N)ri �HEADz 2014-02-14) zcontent-encodingzcontent-language�content-lengthz content-md5z content-type�datezif-modified-sincezif-matchz if-none-matchzif-unmodified-since�ranger� �0� )rY r� r� )r r rk Z is_changeZ is_old_apiZspecial_header_keysr� r� r r r r� 8 s z-AzureConnection._format_special_header_valuesN)r ) r r r rq r rr r@ rs rY ru r~ r| r� r r r r rt � s Art c s@ e Zd ZdZeZeZeZ dZ dZ dZ � fdd�Z dd� Z� ZS ) � AzureServiceManagementConnectionzD Authentication class for "Service Account" authentication. z'Azure Service Management API Connectionzmanagement.core.windows.netr� c s` t � j|g|�R i |�� || _tj�|�}|| _tj�|�o$tj�|�}|s+t d��|| _ dS )aX Check to see if PyCrypto is available, and convert key file path into a key string if the key is in a file. :param subscription_id: Azure subscription ID. :type subscription_id: ``str`` :param key_file: The PEM file used to authenticate with the service. :type key_file: ``str`` zgYou need an certificate PEM file to authenticate with Microsoft Azure. This can be found in the portal.N) r8 r �subscription_id�osrx � expanduser�keyfile�exists�isfiler �key_file)r r� r� �argsrQ ZkeypathZ is_file_pathr9 r r r m s � z)AzureServiceManagementConnection.__init__c C s d|d< t �tt �� �|d< |S )ze @inherits: :class:`Connection.add_default_headers` TODO: move to constant.. z 2014-05-01rS rR )rU rV rW rX r[ r r r r\ � s z4AzureServiceManagementConnection.add_default_headers)r r r rq rA r) r rr r@ rs rB rL r� r r\ r? r r r9 r r� Z s r� )(r� rz r� rU r� �hashlibr Z libcloud.httpr Zlibcloud.utils.py3r r r r r r Zlibcloud.utils.xmlr Zlibcloud.common.baser r r r r Zlibcloud.common.typesr r r Zlibcloud.common.azure_armr r rW rG r r r@ rA rC rt r� r r r r �<module> s* 3l
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings