File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/common/__pycache__/openstack.cpython-310.pyc
Back
o ;jP � @ s� d Z ddlmZmZ ddlmZmZ ddlmZ ddl m Z m Z m Z ddl mZ ddlmZmZmZmZ zddlZW n eyG ddlZY nw d Zg d �Zg d �ZG d d � d e�ZG dd� de�ZG dd� de�Z G dd� d�Z dS )z Common utilities for OpenStack � )�ET�httplib)�Response�ConnectionUserAndKey)� ProviderError)� LibcloudError�MalformedResponseError�KeyPairDoesNotExistError)� BaseHTTPError)�AUTH_TOKEN_HEADER�OpenStackServiceCatalog�OpenStackIdentityTokenScope�get_class_for_auth_versionN�1.1)r z2.0� 2.0_apikey� 2.0_passwordz3.xz 3.x_password)�OpenStackBaseConnection�OpenStackResponse�OpenStackException�OpenStackDriverMixinc s� e Zd ZdZdZdZdZdZdZdZ dZ dZ dZ dZ dddddddddejddddddddddf� fdd� Zdd � Zd � fd d� Zdd� Zdd� Zdd� Zdd� Zdd� Z� fdd�Zdd � Zd d � Z� ZS ) r a� Base class for OpenStack connections. :param user_id: User name to use when authenticating :type user_id: ``str`` :param key: Secret to use when authenticating. :type key: ``str`` :param secure: Use HTTPS? (True by default.) :type secure: ``bool`` :param ex_force_base_url: Base URL for connection requests. If not specified, this will be determined by authenticating. :type ex_force_base_url: ``str`` :param ex_force_auth_url: Base URL for authentication requests. :type ex_force_auth_url: ``str`` :param ex_force_auth_version: Authentication version to use. If not specified, defaults to AUTH_API_VERSION. :type ex_force_auth_version: ``str`` :param ex_force_auth_token: Authentication token to use for connection requests. If specified, the connection will not attempt to authenticate, and the value of ex_force_base_url will be used to determine the base request URL. If ex_force_auth_token is passed in, ex_force_base_url must also be provided. :type ex_force_auth_token: ``str`` :param token_scope: Whether to scope a token to a "project", a "domain" or "unscoped". :type token_scope: ``str`` :param ex_domain_name: When authenticating, provide this domain name to the identity service. A scoped token will be returned. Some cloud providers require the domain name to be provided at authentication time. Others will use a default domain if none is provided. :type ex_domain_name: ``str`` :param ex_tenant_name: When authenticating, provide this tenant name to the identity service. A scoped token will be returned. Some cloud providers require the tenant name to be provided at authentication time. Others will use a default tenant if none is provided. :type ex_tenant_name: ``str`` :param ex_tenant_domain_id: When authenticating, provide this tenant domain id to the identity service. A scoped token will be returned. Some cloud providers require the tenant domain id to be provided at authentication time. Others will use a default tenant domain id if none is provided. :type ex_tenant_domain_id: ``str`` :param ex_force_service_type: Service type to use when selecting an service. If not specified, a provider specific default will be used. :type ex_force_service_type: ``str`` :param ex_force_service_name: Service name to use when selecting an service. If not specified, a provider specific default will be used. :type ex_force_service_name: ``str`` :param ex_force_service_region: Region to use when selecting an service. If not specified, a provider specific default will be used. :type ex_force_service_region: ``str`` :param ex_auth_cache: External cache where authentication tokens are stored for reuse by other processes. Tokens are always cached in memory on the driver instance. To share tokens among multiple drivers, processes, or systems, pass a cache here. :type ex_auth_cache: :class:`OpenStackAuthenticationCache` NT�Default�defaultc s� t � j|||||||d� | r| | _|| _|| _| | _| | _| | _| | _|| _ || _ || _ || _ || _ || _|| _d | _| rD|sDtd��| rI| | _| jsOt| _| �� }|sYtd��d S )N)�secure�timeout� retry_delay�backoff� proxy_urlzHMust also provide ex_force_base_url when specifying ex_force_auth_token.z)OpenStack instance must have auth_url set)�super�__init__� _auth_versionZbase_url�_ex_force_base_url�_ex_force_auth_url�_ex_force_auth_token�_ex_token_scope�_ex_domain_name�_ex_tenant_name�_ex_tenant_domain_id�_ex_force_service_type�_ex_force_service_name�_ex_force_service_region�_ex_force_microversion�_ex_auth_cache�_osar � auth_token�AUTH_API_VERSION� _get_auth_url)�self�user_id�keyr �host�portr r �ex_force_base_url�ex_force_auth_url�ex_force_auth_version�ex_force_auth_token�ex_token_scope�ex_domain_name�ex_tenant_name�ex_tenant_domain_id�ex_force_service_type�ex_force_service_name�ex_force_service_region�ex_force_microversion� ex_auth_cacher r �auth_url�� __class__� �M/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/common/openstack.pyr � sJ � ��z OpenStackBaseConnection.__init__c C sR | j s&| �� }t| jd�}||| j| j| j| j| j| j | j | j | | j d� | _ | j S )zz Retrieve identity / authentication class instance. :rtype: :class:`OpenStackIdentityConnection` )� auth_version) rB r1 r2 Z tenant_nameZtenant_domain_idZ domain_nameZ token_scoper r Z parent_connZ auth_cache) r, r/ r r r1 r2 r% r& r$ r# r r r+ )r0 rB �clsrE rE rF �get_auth_class� s" �z&OpenStackBaseConnection.get_auth_class� �GETFc s� |pi }|pi }t | dd �}|�� dv r|r||d< z t� j||||||d�W S tyE } z|jtjkr@| jd u r@| � � � � � d }~ww )N�default_content_type)�POST�PUTz Content-Type)�action�params�data�method�headers�raw) �getattr�upperr �requestr �coder � UNAUTHORIZEDr" rI Zclear_cached_auth_context) r0 rO rP rQ rS rR rT rL �exrC rE rF rW � s( � ��z OpenStackBaseConnection.requestc C s | j }| jdur | j}|S )z� Retrieve auth url for this instance using either "ex_force_auth_url" constructor kwarg of "auth_url" class variable. N)rB r! )r0 rB rE rE rF r/ s z%OpenStackBaseConnection._get_auth_urlc C s | j d u r | �� | j S �N)�service_catalog�!_populate_hosts_and_request_paths�r0 rE rE rF �get_service_catalog s z+OpenStackBaseConnection.get_service_catalogc C s | j r| j S | jS )z� Gets the service name used to look up the endpoint in the service catalog. :return: name of the service in the catalog )r( � service_namer^ rE rE rF �get_service_name# s z(OpenStackBaseConnection.get_service_namec C s^ | j }| j}| j}| jr| j}| jr| j}| jr| j}| jj|||d�}|j}|s-t d��|S )z� Selects the endpoint to use based on provider specific values, or overrides passed in by the user when setting up the driver. :returns: url of the relevant endpoint for the driver )� service_type�nameZregionz!Could not find specified endpoint) rb r` �service_regionr' r( r) r\ � get_endpoint�urlr )r0 rb r` rd Zendpointrf rE rE rF re / s �z$OpenStackBaseConnection.get_endpointc C s� | j |t< | j|d< | jrE| j�� �� }t|�dkr#|d }|d }nt|�dkr0d}|d }ntd��| jrE| j� |�rEd� ||�|d< |S ) NZAccept� r � Zcomputez-Invalid microversion format: servicename X.XXz{} {}zOpenStack-API-Version) r- r � accept_formatr* �strip�split�lenr rb � startswith�format)r0 rS Z microversionrb rE rE rF �add_default_headersL s" �z+OpenStackBaseConnection.add_default_headersc s | � � t� �|�S r[ )r] r �morph_action_hook)r0 rO rC rE rF rp b s z)OpenStackBaseConnection.morph_action_hookc C sV | j | j| jf}| �|�}|\| _ | _| _| _| j | j| jf}||kr)| �� d S d S r[ )r3 r4 r Z_tuple_from_urlZ request_path�connect)r0 rf Z prev_conn�resultZnew_connrE rE rF �_set_up_connection_infof s �z/OpenStackBaseConnection._set_up_connection_infoc C s� | � � }| jr| j| jd� dS |�� sI| jdkr ddi}n | jdkr(ddi}ni }|jd i |��}|j| _|j| _|j | _ t |j | jd�}|| _ | jpO| � � }| j|d� dS ) z� OpenStack uses a separate host for API calls which is only provided after an initial authentication request. )rf Nr Z auth_typeZapi_keyr �password)r\ rG rE )rI r" rs r Zis_token_validr Z authenticater- �auth_token_expires�auth_user_infor Zurlsr\ re )r0 Zosa�kwargsZoscrf rE rE rF r] p s$ z9OpenStackBaseConnection._populate_hosts_and_request_paths)NrJ NrK F) �__name__� __module__� __qualname__�__doc__rB r- ru rv r\ rb r` rd ri r r �PROJECTr rI rW r/ r_ ra re ro rp rs r] � __classcell__rE rE rC rF r ; sV S�E r c @ s e Zd ZdS )r N)rx ry rz rE rE rE rF r � s r c @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � ZdS ) r Nc C s" t | j�}d| kodkS S )N�� i+ )�int�status)r0 �irE rE rF �success� s zOpenStackResponse.successc C s* | j �d�pd}|�� }|�|�� �dkS )Nz content-typerJ ���)rS �get�lower�find)r0 � content_typeZcontent_type_valuerE rE rF �has_content_type� s z"OpenStackResponse.has_content_typec C s� | j tjks | js d S | �d�r(zt�| j�W S ty' td| j| j d��w | �d�rEzt � | j�W S tyD td| j| j d��w | jS )N�application/xmlzFailed to parse XML)�body�driver�application/jsonzFailed to parse JSON) r� r � NO_CONTENTr� r� r ZXML� Exceptionr � node_driver�json�loadsr^ rE rE rF � parse_body� s& �� ��z OpenStackResponse.parse_bodyc C s� | � � }| �d�rd�dd� |�� D ��}nQ| �d�ret|�� �}| jj}| jj}|� dd �}t |�dkrKd|d v rK|d d d krK|rKt ||d ��t |�dkrbd |d v rbd �d d� |D ��}n|}n|}d� | j | j|�S )Nr� z; c S s g | ] }|j r|j p d �qS )rJ )�text)�.0�errrE rE rF � <listcomp>� s z1OpenStackResponse.parse_error.<locals>.<listcomp>r� � key_pair_namer rX i� )rc r� �message�;c S s g | ]}|d �qS )r� rE )r� Z fault_datarE rE rF r� � s z{} {} {})r� r� �joinZ getiterator�list�values� connection�contextr� r� rl r rn r� �error)r0 r� r� r� r� r� r� rE rE rF � parse_error� s& � z OpenStackResponse.parse_error)rx ry rz r� r� r� r� r� rE rE rE rF r � s r c @ s: e Zd Zddddejddddddddf dd�Zdd� ZdS )r Nr r c O sR || _ || _|| _|| _|| _|| _|| _|| _| | _| | _ | | _ | | _ | | _ d S r[ ) r r! �_ex_force_auth_versionr" r# r$ r% r& r' r( r) r+ r* )r0 r5 r6 r7 r8 r9 r: r; r< r= r> r? rA r@ �argsrw rE rE rF r � s z OpenStackDriverMixin.__init__c C s� i }| j r | j |d< | jr| j|d< | jr| j|d< | jr"| j|d< | jr*| j|d< | jr2| j|d< | jr:| j|d< | jrB| j|d< | jrJ| j|d < | j rR| j |d < | j rZ| j |d < | j d urd| j |d < | j rl| j |d< |S )zd Returns certain ``ex_*`` parameters for this connection. :rtype: ``dict`` r5 r8 r6 r7 r9 r: r; r< r= r> r? NrA r@ ) r r" r! r� r# r$ r% r& r' r( r) r+ r* )r0 �rvrE rE rF �openstack_connection_kwargs s8 z0OpenStackDriverMixin.openstack_connection_kwargs)rx ry rz r r| r r� rE rE rE rF r � s � r ) r{ Zlibcloud.utils.py3r r Zlibcloud.common.baser r Zlibcloud.common.typesr Zlibcloud.compute.typesr r r Zlibcloud.common.exceptionsr Z"libcloud.common.openstack_identityr r r r Z simplejsonr� � ImportErrorr. ZAUTH_VERSIONS_WITH_EXPIRES�__all__r r r r rE rE rE rF �<module> s* � aC
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings