File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/common/__pycache__/google.cpython-310.pyc
Back
o ;j � � @ sx d Z ddlZddlZddlZddlZddlZddlZddlZddlZ ddl m Z ddl m Z mZ ddlmZmZmZmZ ddlmZmZmZmZ ddlmZmZ ddl m Z zddl Z W n e yi ddl Z Y nw z dd l!m"Z" dd l#m$Z$ dd l%m&Z& dd l'm(Z( dd l)m*Z* W n e y� dZ(Y nw dZ+e�,e-�Z.dd� Z/dd� Z0dd� Z1d;de e2 fdd�Z3G dd� de�Z4G dd � d e�Z5G d d � d e5�Z6G d d � d e5�Z7G d!d"� d"e5�Z8G d#d$� d$e5�Z9G d%d&� d&e5�Z:G d'd(� d(e5�Z;G d)d*� d*e�Z<G d+d,� d,e�Z=G d-d.� d.e�Z>G d/d0� d0e>�Z?G d1d2� d2e>�Z@G d3d4� d4e>�ZAG d5d6� d6�ZBG d7d8� d8�ZCG d9d:� d:ee�ZDdS )<a� Module for Google Connection and Authentication classes. Information about setting up your Google OAUTH2 credentials: For libcloud, there are two basic methods for authenticating to Google using OAUTH2: Service Accounts and Client IDs for Installed Applications. Both are initially set up from the Cloud Console Console - https://cloud.google.com/console Setting up Service Account authentication (note that you need the cryptography package installed to use this): - Go to the Console - Go to your project and then to "APIs & auth" on the left - Click on "Credentials" - Click on "Create New Client ID..." - Select "Service account" and click on "Create Client ID" - Download the Private Key (should happen automatically). The key you download is in JSON format. - Move the .json file to a safe location. - Optionally, you may choose to Generate a PKCS12 key from the Console. It needs to be converted to the PEM format. Please note, the PKCS12 format is deprecated and may be removed in a future release. - Convert the key using OpenSSL (the default password is 'notasecret'). - Move the .pem file to a safe location. - To Authenticate, you will need to pass the Service Account's "Email address" in as the user_id and the path to the .pem file as the key. Setting up Installed Application authentication: - Go to the Console - Go to your project and then to "APIs & auth" on the left - Click on "Credentials" - Select "Installed application" and "Other" then click on "Create Client ID" - To Authenticate, pass in the "Client ID" as the user_id and the "Client secret" as the key - The first time that you do this, the libcloud will give you a URL to visit. Copy and paste the URL into a browser. - When you go to the URL it will ask you to log in (if you aren't already) and ask you if you want to allow the project access to your account. - Click on Accept and you will be given a code. - Paste that code at the prompt given to you by the Google libcloud connection. - At that point, a token & refresh token will be stored in your home directory and will be used for authentication. Please remember to secure your keys and access tokens. � N)�Optional)� HTTPServer�BaseHTTPRequestHandler)�b�httplib�urlparse� urlencode)� BaseDriver� JsonResponse�PollingConnection�ConnectionUserAndKey)� LibcloudError� ProviderError)�get_response_object)� exceptions)�default_backend)� serialization)�SHA256)�PKCS1v15z%Y-%m-%dT%H:%M:%SZc C s t j �� S )z? Mocked in libcloud.test.common.google.GoogleTestCase. )�datetime�utcnow� r r �J/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/common/google.py�_utcnowi � r c C s | � t�S )zC Return string of datetime_obj in the UTC Timestamp Format )�strftime�UTC_TIMESTAMP_FORMAT)Z datetime_objr r r �_utc_timestampp r r c C s t j �| t�S )zS Return datetime obj where date and time are pulled from timestamp string. )r �strptimer )� timestampr r r �_from_utc_timestampw � r � � retry_failedc C sh zd| � d� }ddi}t|||d�}|jd|jfW S ty3 } z dt|�d fW Y d }~S d }~ww )Nz3http://metadata.google.internal/computeMetadata/v1/�/zMetadata-FlavorZGoogle)�headersr# r" ���)�lstripr �status�body� Exception�str)�pathr# �urlr% �response�er r r �_get_gce_metadata~ s ��r0 c @ s e Zd ZdZdd� Zdd� ZdS )�GoogleAuthErrorz6Generic Error class for various authentication errors.c C s || _ d S �N)�value)�selfr3 r r r �__init__� � zGoogleAuthError.__init__c C s t | j�S r2 )�reprr3 �r4 r r r �__repr__� r6 zGoogleAuthError.__repr__N)�__name__� __module__� __qualname__�__doc__r5 r9 r r r r r1 � s r1 c � e Zd Zd� fdd� Z� ZS )�GoogleBaseErrorNc s || _ t� �|||� d S r2 )�code�superr5 �r4 r3 � http_coder@ �driver�� __class__r r r5 � s zGoogleBaseError.__init__r2 �r: r; r< r5 � __classcell__r r rE r r? � � r? c @ � e Zd ZdS )�InvalidRequestErrorN�r: r; r< r r r r rK � � rK c @ rJ )�JsonParseErrorNrL r r r r rN � rM rN c r> )�ResourceNotFoundErrorNc s` || _ t|t�r&d|v r&|d �d�dkr&|d �d�dkr&|d d |d< t� �|||� d S )N�messager$ � z projects/zs. A missing project error may be an authentication issue. Please ensure your auth credentials match your project. )r@ � isinstance�dict�countrA r5 rB rE r r r5 � s � �z ResourceNotFoundError.__init__r2 rG r r rE r rO � rI rO c @ rJ )�QuotaExceededErrorNrL r r r r rU � rM rU c @ rJ )�ResourceExistsErrorNrL r r r r rV � rM rV c @ rJ )�ResourceInUseErrorNrL r r r r rW � rM rW c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) �GoogleResponsez% Google Base Response class. c C s dS )z� Determine if the request was successful. For the Google response class, tag all responses as successful and raise appropriate Exceptions from parse_body. :return: C{True} Tr r8 r r r �success� s zGoogleResponse.successc C st d|d v r|d d d }n|d }d|v r%|� d�}|� d�}||fS d}d|v r0|� d�}|� d|�}||fS ) aU Get the error code and message from a JSON response. Return just the first error if there are multiple errors. :param body: The body of the JSON response dictionary :type body: ``dict`` :return: Tuple containing error code and message :rtype: ``tuple`` of ``str`` or ``int`` �errors�errorr r@ rP N�reasonZerror_description)�get)r4 r) �errr@ rP r r r � _get_error� s � zGoogleResponse._get_errorc C s� t | j�dkr | js | jS d}zt�| j�}W n ty% | j}d}Y nw tjtjtj tj g}| j |v r|r>t || j d��d|v r}| � |�\}}|dkrTt|| j |��|dkr_t|| j |��|dkrjt|| j |��|�d �rvt|| j |��t|| j |��|S | j tjkr�|s�d|v r�| � |�\}}n|}d}t|| j |��| j tjkr�|s�d|v r�| � |�\}}n|}d}t|| j |��|s�d|v r�| � |�\}}n|}d}t|| j |��) z� Parse the JSON response body, or raise exceptions as appropriate. :return: JSON dictionary :rtype: ``dict`` r FTNr[ ZQUOTA_EXCEEDEDZRESOURCE_ALREADY_EXISTSZ alreadyExistsZRESOURCE_IN_USE)�lenr) Zparse_zero_length_body�json�loadsr* r �OK�CREATED�ACCEPTED�CONFLICTr( rN r_ rU rV � startswithrW r? � NOT_FOUNDrO � BAD_REQUESTrK )r4 Z json_errorr) Zvalid_http_codesr@ rP r r r � parse_body� s\ �� zGoogleResponse.parse_bodyN)r: r; r< r= rY r_ rj r r r r rX � s rX c @ s e Zd ZdZdS )�GoogleBaseDriverz Google APIN)r: r; r< �namer r r r rk / s rk c sZ e Zd ZdZeZeZdZdZ dZ dZ d� fdd � Z d d � Z d d � Zdd� Z� ZS )�GoogleBaseAuthConnectionzo Base class for Google Authentication. Should be subclassed for specific types of authentication. z Google Authzaccounts.google.comz/o/oauth2/authi� N�http://127.0.0.1c s: |pg }d� |�| _|| _|| _t� j||fi |�� dS )a� :param user_id: The email address (for service accounts) or Client ID (for installed apps) to be used for authentication. :type user_id: ``str`` :param key: The RSA Key (for service accounts) or file path containing key or Client Secret (for installed apps) to be used for authentication. :type key: ``str`` :param scopes: A list of urls defining the scope of authentication to grant. :type scopes: ``list`` :keyword redirect_uri: The Redirect URI for the authentication request. See Google OAUTH2 documentation for more info. :type redirect_uri: ``str`` :keyword login_hint: Login hint for authentication request. Useful for Installed Application authentication. :type login_hint: ``str`` � N)�join�scopes� redirect_uri� login_hintrA r5 )r4 �user_id�keyrq rr rs �kwargsrE r r r5 @ s z!GoogleBaseAuthConnection.__init__c C � d|d< | j |d< |S )zE Add defaults for 'Content-Type' and 'Host' headers. z!application/x-www-form-urlencoded� Content-Type�Host��host�r4 r% r r r �add_default_headersh � z,GoogleBaseAuthConnection.add_default_headersc C sh t |�}z | jdd|d�}W n ty td��w |j}d|v r2t� tj|d d� }t|�|d< |S )aC Return an updated token from a token request body. :param request_body: A dictionary of values to send in the body of the token request. :type request_body: ``dict`` :return: A dictionary with updated token information :rtype: ``dict`` z/o/oauth2/token�POST)�method�datazMInvalid authorization response, please check your credentials and time drift.� expires_in��seconds� expire_time) r �request�AttributeErrorr1 �objectr r � timedeltar )r4 Z request_bodyr� r. � token_infor� r r r �_token_requestp s �� z'GoogleBaseAuthConnection._token_requestc C s | � � S )a� Refresh the current token. Fetch an updated refresh token from internal metadata service. :param token_info: Dictionary containing token information. (Not used, but here for compatibility) :type token_info: ``dict`` :return: A dictionary containing updated token information. :rtype: ``dict`` )� get_new_token)r4 r� r r r � refresh_token� s z&GoogleBaseAuthConnection.refresh_token)NNrn N)r: r; r< r= rk rD rX � responseClsrl r{ � auth_path�redirect_uri_portr5 r} r� r� rH r r rE r rm 3 s �(rm c @ s@ e Zd ZdZdZdd� Zdd� Zdd� Zed d � �Z d d � Z d S )� GoogleInstalledAppAuthConnectionzEAuthentication connection for "Installed Application" authentication.zLibcloud Requestc C s^ d| j | j| j| jd�}| jr| j|d< t|�}d�| j| j|�}t d� t |� | � � }|S )z� Give the user a URL that they can visit to authenticate. Mocked in libcloud.test.common.google.GoogleTestCase. :return: Code supplied by the user after authenticating :rtype: ``str`` r@ )Z response_type� client_idrr �scope�staters zhttps://{}{}?{}z, Please Go to the following URL and sign in:) rt �_redirect_uri_with_portrq �_staters r �formatr{ r� �print�$_receive_code_through_local_loopback)r4 Z auth_paramsr� r- r@ r r r �get_code� s � z)GoogleInstalledAppAuthConnection.get_codec C s( | � � }|| j| j| jdd�}| �|�S )z� Get a new token. Generally used when no previous token exists or there is no refresh token :return: Dictionary containing token information :rtype: ``dict`` Zauthorization_code)r@ r� � client_secretrr � grant_type)r� rt ru r� r� )r4 r@ Z token_requestr r r r� � s � z.GoogleInstalledAppAuthConnection.get_new_tokenc C sH d|vr| � � S |d | j| jdd�}| �|�}d|vr"|d |d< |S )a) Use the refresh token supplied in the token info to get a new token. :param token_info: Dictionary containing current token information :type token_info: ``dict`` :return: A dictionary containing updated token information. :rtype: ``dict`` r� )r� r� r� r� )r� rt ru r� )r4 r� Zrefresh_requestZ new_tokenr r r r� � s � z.GoogleInstalledAppAuthConnection.refresh_tokenc C s | j d t| j� S )N�:)rr r+ r� r8 r r r r� � s z8GoogleInstalledAppAuthConnection._redirect_uri_with_portc sx d� G � �fdd�dt �}d�jv s d�jv s d�jv r"d�jf}n�j�jf}t||d�}|�� � du r:td��� S ) a� Start a local HTTP server that listens to a single GET request that is expected to be made by the loopback in the sign-in process and stops again afterwards. See https://developers.google.com/identity/protocols/oauth2/native-app#redirect-uri_loopback :return: The access code that was extracted from the local loopback GET request :rtype: ``str`` Nc s e Zd Z� �fdd�ZdS )zaGoogleInstalledAppAuthConnection._receive_code_through_local_loopback.<locals>.AccessCodeReceiverc s� t � | j�j}tdd� |�d�D ��}d|v r-|d tj��j�kr-t d� �j|d ���|d � | � d� | � dd � | � � | j�d � | j�d � d S ) Nc s s � | ]}|� d �V qdS )�=N)�split)�.0Zqcr r r � <genexpr>� s � z{GoogleInstalledAppAuthConnection._receive_code_through_local_loopback.<locals>.AccessCodeReceiver.do_GET.<locals>.<genexpr>�&r� z9States do not match: {} != {}, can't trust authenticationr@ �� z Content-typez text/htmls2 <html><head><title>Libcloud Sign-In</title></head>s' <body><p>You can now close this tab</p>)r r, �queryrS r� �urllib�parse�quoter� � ValueErrorr� Z send_responseZ send_headerZ end_headersZwfile�write)Zself_r� Zquery_components�Z access_coder4 r r �do_GET� s � �� zhGoogleInstalledAppAuthConnection._receive_code_through_local_loopback.<locals>.AccessCodeReceiver.do_GETN)r: r; r< r� r r� r r �AccessCodeReceiver� s r� z 127.0.0.1z[::1]Z localhost)�server_addressZRequestHandlerClasszECould not receive OAuth2 code: could not extract code though loopback)r rr r� r Zhandle_request� RuntimeError)r4 r� r� Zserverr r� r r� � s �zEGoogleInstalledAppAuthConnection._receive_code_through_local_loopbackN) r: r; r< r= r� r� r� r� �propertyr� r� r r r r r� � s r� c s( e Zd ZdZ� fdd�Zdd� Z� ZS )� GoogleServiceAcctAuthConnectionz:Authentication class for "Service Account" authentication.c s� t du rtd��t|t�r|}d}n>tj�|�}tj�|�rLtj�|�rLzt |�� }|� � }W d � n1 s8w Y W n t yK td| ��w |}d}z&zt � |�}W n tya Y n tyi Y nw W d|v rt|d }n|}n d|v r�|d }w |}w z tjt|�dt� d� W n5 ty� } ztd| ��d}~w ty� } ztd| ��d}~w tjy� } ztd| ��d}~ww t� j||g|�R i |�� dS )a� Check to see if cryptography is available, and convert PEM key file into a key string, or extract the key from JSON object, string or file. :param user_id: Email address to be used for Service Account authentication. :type user_id: ``str`` :param key: The path to a PEM/JSON file containing the private RSA key, or a str/dict containing the PEM/JSON. :type key: ``str`` or ``dict`` NzAcryptography library required for Service Account Authentication.z&Missing (or unreadable) key file: '%s'Z private_key��passwordZbackendz%Unable to decode provided PEM key: %s)r r1 rR rS �osr, � expanduser�exists�isfile�open�read�OSErrorra rb � TypeErrorr� r �load_pem_private_keyr r r ZUnsupportedAlgorithmrA r5 ) r4 rt ru �argsrv Z key_contentZkey_path�fr/ rE r r r5 s\ � �� � �� � � � �� z(GoogleServiceAcctAuthConnection.__init__c C s� ddd�}t �tt�|���}| j| jdtt�� �d tt�� �d�}t �tt�|���}d� ||f�}t j t| j �dt � d �}|jt|�t� t� d �}t �|�}d� ||f�}d |d �} | �| �S ) z� Get a new token using the email address and RSA Key. :return: Dictionary containing token information :rtype: ``dict`` ZRS256ZJWT)Zalg�typz*https://accounts.google.com/o/oauth2/tokeni )Zissr� Zaud�expZiat� .Nr� )r� �padding� algorithmz+urn:ietf:params:oauth:grant-type:jwt-bearer)r� Z assertion)�base64�urlsafe_b64encoder ra �dumpsrt rq �int�timerp r r� ru r �signr r r� ) r4 �header� header_encZ claim_setZ claim_set_encrP ru Z signatureZjwtr� r r r r� a s( �� � z-GoogleServiceAcctAuthConnection.get_new_token)r: r; r< r= r5 r� rH r r rE r r� s Ar� c @ s e Zd ZdZdd� ZdS )�"GoogleGCEServiceAcctAuthConnectionzrAuthentication class for self-authentication when used with a GCE instance that supports serviceAccounts. c C sv d}t |�\}}}|tjkrtd��|tjkr tdt|� ��t�|�}d|v r9t� t j |d d� }t |�|d< |S )z� Get a new token from the internal metadata service. :return: Dictionary containing token information :rtype: ``dict`` z(/instance/service-accounts/default/tokenz7Service Accounts are not enabled for this GCE instance.z'Internal GCE Authorization failed: '%s'r� r� r� ) r0 r rh r� rc r+ ra rb r r r� r )r4 r, rC � http_reasonr� r� r r r r� � s z0GoogleGCEServiceAcctAuthConnection.get_new_tokenN)r: r; r< r= r� r r r r r� � s r� c @ s~ e Zd ZdZdZdZdZdZeeeegZeeegZ e dd� �Z e dd � �Z e d d � �Ze d d � �Ze dd� �Ze dd� �ZdS )�GoogleAuthTypez� SA (Service Account), IA (Installed Application), GCE (Auth from a GCE instance with service account enabled) GCS_S3 (Cloud Storage S3 interoperability authentication) �SA�IA�GCE�GCS_S3c C sD | � |�r| jS | �|�r| jS | �|�r| jS | �� r | jS | jS r2 )�_is_sar� � _is_gcs_s3r� �_is_installed_applicationr� �_is_gcer� )�clsrt r r r � guess_type� s zGoogleAuthType.guess_typec C s || j v S r2 )� OAUTH2_TYPES)r� � auth_typer r r � is_oauth2� � zGoogleAuthType.is_oauth2c C � | � d�S )Nzapps.googleusercontent.com��endswith�rt r r r r� � r� z(GoogleAuthType._is_installed_applicationc C s& t dd�\} }}| tjkr|rdS dS )z� Checks if we can access the GCE metadata server. Mocked in libcloud.test.common.google.GoogleTestCase. F)r# T)r0 r rc )rC r� r) r r r r� � s zGoogleAuthType._is_gcec C r� )zN Checks S3 key format: alphanumeric chars starting with GOOG. ZGOOG)rg r� r r r r� � s zGoogleAuthType._is_gcs_s3c C r� )Nz.gserviceaccount.comr� r� r r r r� � r� zGoogleAuthType._is_saN)r: r; r< r= r� r� r� r� � ALL_TYPESr� � classmethodr� r� � staticmethodr� r� r� r� r r r r r� � s( r� c @ sJ e Zd ZdZddd�Zedd� �Zedd� �Zd d � Zd d � Z d d� Z dS )�GoogleOAuth2Credentialz~/.google_libcloud_authNc K s4 |pt �|�| _| jt jvrtd| j ��t �| j�s"td| j ��|| _|| _d�| j |g�}|p3|| _ |p:g d�| _ | � � | _ | jt jkrTt| j| j fi |��| _n3| jt jkrit| j| j| j fi |��| _n | jt jkr~t| j| j| j fi |��| _n tdt| j� ��| j d u r�| j�� | _ | �� d S d S )NzInvalid auth type: %sz'Auth type %s cannot be used with OAuth2�.)z'https://www.googleapis.com/auth/computez7https://www.googleapis.com/auth/devstorage.full_controlz7https://www.googleapis.com/auth/ndev.clouddns.readwritezInvalid auth_type: %s)r� r� r� r� r1 r� rt ru rp �default_credential_file�credential_filerq �_get_token_from_file�tokenr� r� � oauth2_connr� r� r� r� r+ r� �_write_token_to_file)r4 rt ru r� r� rq rv r� r r r r5 � sD � � � � � � �z GoogleOAuth2Credential.__init__c C s | j t� k r | �� | jd S )N� access_token)�token_expire_utc_datetimer �_refresh_tokenr� r8 r r r r� s z#GoogleOAuth2Credential.access_tokenc C s t | jd �S )Nr� )r r� r8 r r r r� s z0GoogleOAuth2Credential.token_expire_utc_datetimec C s | j �| j�| _| �� d S r2 )r� r� r� r� r8 r r r r� s z%GoogleOAuth2Credential._refresh_tokenc C s� d}t j�t j�| j��}z t|�� }|�� }W d � n1 s!w Y t�|�}W |S t t fyK } zt � d|t |�� W Y d}~|S d}~ww )z� Read credential file and return token information. Mocked in libcloud.test.common.google.GoogleTestCase. :return: Token information dictionary, or None :rtype: ``dict`` or ``None`` Nz3Failed to read cached auth token from file "%s": %s)r� r, �realpathr� r� r� r� ra rb r� r� �LOG�infor+ )r4 r� �filenamer� r� r/ r r r r� s � � ��z+GoogleOAuth2Credential._get_token_from_filec C s� t j�| j�}t j�|�}z7t�| j�}t jt j B t j B }t � t � ||t dd��d��}|�|� W d � W dS 1 s=w Y W dS ty` } zt�d|t|�� W Y d}~dS d}~ww )zo Write token to credential file. Mocked in libcloud.test.common.google.GoogleTestCase. Z600� �wNz+Failed to write auth token to file "%s": %s)r� r, r� r� r� ra r� r� �O_CREAT�O_WRONLY�O_TRUNC�fdopenr� r� r� r* r� r� r+ )r4 r� r� Z write_flagsr� r/ r r r r� 4 s &� ��z+GoogleOAuth2Credential._write_token_to_file)NNN) r: r; r< r� r5 r� r� r� r� r� r� r r r r r� � s ' r� c sz e Zd ZdZeZeZdZdZ dZ d� fdd� Z dd � Z d d � Z d d � Z� fdd�Zdd� Zdd� Zdd� Z� ZS )�GoogleBaseConnectionz7Base connection class for interacting with Google APIs.zwww.googleapis.comg @� Nc sl t � j||fi |�� t|||||fi |��| _d�tjd tjd tjd �}d�|tj�}| �|� dS )a Determine authentication type, set up appropriate authentication connection and get initial authentication information. :param user_id: The email address (for service accounts) or Client ID (for installed apps) to be used for authentication. :type user_id: ``str`` :param key: The RSA Key (for service accounts) or file path containing key or Client Secret (for installed apps) to be used for authentication. :type key: ``str`` :keyword auth_type: See GoogleAuthType class for list and description of accepted values. If not supplied, auth_type will be guessed based on value of user_id or if the code is running on a GCE instance. :type auth_type: ``str`` :keyword credential_file: Path to file for caching authentication information. :type credential_file: ``str`` :keyword scopes: List of OAuth2 scope URLs. The empty default sets read/write access to Compute, Storage, and DNS. :type scopes: ``list`` z{}.{}.{}r rQ � z Python {}/{}N) rA r5 r� �oauth2_credentialr� �sys� version_info�platformZuser_agent_append) r4 rt ru r� r� rq rv Z python_verZ ver_platformrE r r r5 Q s % ���z GoogleBaseConnection.__init__c C rw )zD @inherits: :class:`Connection.add_default_headers` zapplication/jsonrx ry rz r| r r r r} � r~ z(GoogleBaseConnection.add_default_headersc C s d| j j |d< ||fS )z� Check to make sure that token hasn't expired. If it has, get an updated token. Also, add the token to the headers. @inherits: :class:`Connection.pre_connect_hook` zBearer Z Authorization)r� r� )r4 �paramsr% r r r �pre_connect_hook� s z%GoogleBaseConnection.pre_connect_hookc C s t �|�S )zEncode data to JSON)ra r� )r4 r� r r r � encode_data� r� z GoogleBaseConnection.encode_datac s� d}d}||d k r:z t � j|i |��W S ty3 } z|jtjkr'|d }n|�W Y d}~nd}~ww ||d k s t � j|i |��S )z8 @inherits: :class:`Connection.request` � r rQ N)rA r� r� �errnoZ ECONNRESET)r4 r� rv ZretriesZtriesr/ rE r r r� � s ��� � z GoogleBaseConnection.requestc C s |j d dkr dS dS )z� Determine if operation has completed based on response. :param response: JSON response :type response: I{responseCls} :return: True if complete, False otherwise :rtype: ``bool`` r( ZDONETF�r� )r4 r. r r r � has_completed� s z"GoogleBaseConnection.has_completedc C s d|j d iS )zO @inherits: :class:`PollingConnection.get_poll_request_kwargs` �actionZselfLinkr )r4 r. �contextZrequest_kwargsr r r �get_poll_request_kwargs� r! z,GoogleBaseConnection.get_poll_request_kwargsc C sF |� d�r t�|�}t�dd|d |d |d f�}|S | j| }|S )a� Update action to correct request path. In many places, the Google API returns a full URL to a resource. This will strip the scheme and host off of the path and just return the request. Otherwise, it will prepend the base request_path to the action. :param action: The action to be called in the http request :type action: ``str`` :return: The modified request based on the action :rtype: ``str`` zhttps://r" r� � r )rg r �urlsplit� urlunsplitZ request_path)r4 r �ur� r r r �morph_action_hook� s �z&GoogleBaseConnection.morph_action_hook)NNNN)r: r; r< r= rk rD rX r� r{ Z poll_interval�timeoutr5 r} r r r� r r r rH r r rE r r� H s& �3 r� )r" N)Er= r� r� r� r r� �loggingr � urllib.parser� �typingr Z http.serverr r Zlibcloud.utils.py3r r r r Zlibcloud.common.baser r r r Zlibcloud.common.typesr r Zlibcloud.utils.connectionr Z simplejsonra � ImportErrorZ cryptographyr Z cryptography.hazmat.backendsr Z cryptography.hazmat.primitivesr Z%cryptography.hazmat.primitives.hashesr Z1cryptography.hazmat.primitives.asymmetric.paddingr r � getLoggerr: r� r r r �boolr0 r1 r? rK rN rO rU rV rW rX rk rm r� r� r� r� r� r� r r r r �<module> sj 4 � � qf lDb
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings