File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/storage/drivers/__pycache__/google_storage.cpython-310.pyc
Back
o ;j�; � @ s� d dl Z d dlZd dlZd dlmZmZ d dlmZm Z d dl m Z d dl m Z d dlmZmZmZ d dlmZmZmZmZ dZd Zd e Zd d � ZG d d� d�ZG dd� d�Z G dd� de �Z G dd� de�Z G dd� de �Z G dd� de�Z dS )� N)�Dict�Optional)�httplib�urlquote)�ConnectionUserAndKey)� ProviderError)�GoogleAuthType�GoogleResponse�GoogleOAuth2Credential)� S3Response� S3RawResponse�BaseS3Connection�BaseS3StorageDriverZGOOG1z 2006-03-01z http://doc.s3.amazonaws.com/%sc C s | rt | dd�S dS )a) Return the URL encoded name. name=None returns None. Useful for input checking without having to check for None first. :param name: The object name :type name: ``str`` or ``None`` :return: The url-encoded object name or None if name=None. :rtype ``str`` or ``None`` � )�safeN)r )�name� r �[/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/storage/drivers/google_storage.py�_clean_object_name' s r c @ s$ e Zd Zg d�ZdZdZdZdZdS )�ContainerPermissions)�NONE�READER�WRITER�OWNERr � � � N)�__name__� __module__� __qualname__�valuesr r r r r r r r r 5 s r c @ s e Zd Zg d�ZdZdZdZdS )�ObjectPermissions)r r r r r r N)r r r r r r r r r r r r! = s r! c sR e Zd ZdZdZeZeZdZ d� fdd� Z dd � Z d d � Z d d � Z dd� Z� ZS )�GoogleStorageConnectionz� Represents a single connection to the Google storage API endpoint. This can either authenticate via the Google OAuth2 methods or via the S3 HMAC interoperability method. zstorage.googleapis.comzx-goog-project-idTNc sZ |pt �|�| _t �| j�r t||| j|fi |��| _nd | _t� j|||fi |�� d S �N)r Z guess_type� auth_typeZ is_oauth2r �oauth2_credential�super�__init__)�self�user_id�keyZsecurer$ Zcredential_file�kwargs�� __class__r r r' Q s � � z GoogleStorageConnection.__init__c C s0 t jjdd�}||d< | �� }|r||| j< |S )NT)�usegmtZDate)�email�utils� formatdate� get_project�PROJECT_ID_HEADER)r( �headers�date�projectr r r �add_default_headers[ s z+GoogleStorageConnection.add_default_headersc C s t | jdd �S )Nr6 )�getattrZdriver)r( r r r r2 c s z#GoogleStorageConnection.get_projectc C sL | j tjkr| �||�}d�t| j|�|d< ||fS d| jj |d< ||fS )Nz{} {}:{}Z AuthorizationzBearer ) r$ r ZGCS_S3�_get_s3_auth_signature�format�SIGNATURE_IDENTIFIERr) r% Z access_token)r( �paramsr4 Z signaturer r r �pre_connect_hookf s ��z(GoogleStorageConnection.pre_connect_hookc C s| i }t �|�}|�� D ]"\}}|�� }|dv s"|�tj�s"t|t�s'|||< q |�� ||< q t j | j ||d| j | j tjd�S )z3Hacky wrapper to work with S3's get_auth_signature.)r5 z content-typeN)�methodr4 r< ZexpiresZ secret_key�pathZ vendor_prefix)�copy�deepcopy�items�lower� startswith�GoogleStorageDriver�http_vendor_prefix� isinstance�strr Zget_auth_signaturer> r* �action)r( r< r4 Z headers_copyZ params_copy�k�vZk_lowerr r r r9 r s( �� �z.GoogleStorageConnection._get_s3_auth_signature)TNN)r r r �__doc__�hostr � responseClsr �rawResponseClsr3 r' r7 r2 r= r9 � __classcell__r r r, r r" D s r" c @ s e Zd ZdS )� GCSResponseN)r r r r r r r rQ � s rQ c s, e Zd ZdZdZeZdZ� fdd�Z� Z S )�GoogleStorageJSONConnectionz� Represents a single connection to the Google storage JSON API endpoint. This can either authenticate via the Google OAuth2 methods or via the S3 HMAC interoperability method. zwww.googleapis.comNc s t � �|�}d|d< |S )Nzapplication/jsonz Content-Type)r& r7 )r( r4 r, r r r7 � s z/GoogleStorageJSONConnection.add_default_headers) r r r rL rM rQ rN rO r7 rP r r r, r rR � s rR c s� e Zd ZdZdZdZeZeZ dZ e Z dZ dZdZd� fdd � Zd d � Zd d � Zdd� Zddd�Zddd�Zd dd�Zdeeef dee fdd�Z� Z S ) rE a Driver for Google Cloud Storage. Can authenticate via standard Google Cloud methods (Service Accounts, Installed App credentials, and GCE instance service accounts) Examples: Service Accounts:: driver = GoogleStorageDriver(key=client_email, secret=private_key, ...) Installed Application:: driver = GoogleStorageDriver(key=client_id, secret=client_secret, ...) From GCE instance:: driver = GoogleStorageDriver(key=foo, secret=bar, ...) Can also authenticate via Google Cloud Storage's S3 HMAC interoperability API. S3 user keys are 20 alphanumeric characters, starting with GOOG. Example:: driver = GoogleStorageDriver(key='GOOG0123456789ABCXYZ', secret=key_secret) zGoogle Cloud Storagez http://cloud.google.com/storage�md5Fzx-googNc s4 t � j||fi |�� || _t||fi |��| _d S r# )r& r' r6 rR �json_connection)r( r* Zsecretr6 r+ r, r r r' � s z GoogleStorageDriver.__init__c C s8 z | j �d| � tjW S ty5 } z |jtjkrn|jtjkr*tj W Y d}~S � W Y d}~nd}~ww z| j jd| ddidd� W n+ typ } z |jtjtj fv r_tj W Y d}~S |jtjkrf� W Y d}~nd}~ww z | j �d| � tj W S ty� } z|jtjtjfvr�� W Y d}~tj S d}~ww ) a Return the container permissions for the current authenticated user. :param container_name: The container name. :param container_name: ``str`` :return: The permissions on the container. :rtype: ``int`` from ContainerPermissions �/storage/v1/b/%s/aclNz /storage/v1/b/%s/o/writecheckzx-goog-if-generation-match�0�DELETE)r4 r> z/storage/v1/b/%s) rT �requestr r r � http_coder � FORBIDDEN� NOT_FOUNDr �PRECONDITION_FAILEDr r )r( �container_name�er r r �_get_container_permissions� sH ��� � ��� ���z.GoogleStorageDriver._get_container_permissionsc C s t | jd�}|r |jS dS )z.Gets this drivers' authenticated user, if any.r% N)r8 � connectionr) )r( Z oauth2_credsr r r � _get_user s z GoogleStorageDriver._get_userc C s� z| j �d�||�� tjW S ty* } z|jtjtj fvr � W Y d}~nd}~ww z| j �d�||�� tj W S tyW } z|jtjtj fvrK� W Y d}~tj S d}~ww )a� Return the object permissions for the current authenticated user. If the object does not exist, or no object_name is given, return the default object permissions. :param container_name: The container name. :type container_name: ``str`` :param object_name: The object name. :type object_name: ``str`` :return: The permissions on the object or default object permissions. :rtype: ``int`` from ObjectPermissions �/storage/v1/b/{}/o/{}/aclNz/storage/v1/b/{}/o/{}) rT rX r: r! r r rY r rZ r[ r r )r( r] � object_namer^ r r r �_get_object_permissions s. � ��� � ���z+GoogleStorageDriver._get_object_permissionsc C s\ t |�}|s| �� }|std��d| }|r d�|||�}nd�||�}| jj|dd� dS )aP Delete permissions for an ACL entity on a container or object. :param container_name: The container name. :type container_name: ``str`` :param object_name: The object name. Optional. Not providing an object will delete a container permission. :type object_name: ``str`` :param entity: The entity to whose permission will be deleted. Optional. If not provided, the role will be applied to the authenticated user, if using an OAuth2 authentication scheme. :type entity: ``str`` or ``None`` �BMust provide an entity. Driver is not using an authenticated user.�user-%sz /storage/v1/b/{}/o/{}/acl/{}z/storage/v1/b/{}/acl/{}rW )r> N)r ra � ValueErrorr: rT rX )r( r] rc �entityr) �urlr r r �ex_delete_permissions3 s � z)GoogleStorageDriver.ex_delete_permissionsc C s* t |�}|r | �||�nd}| �|�|fS )a! Return the permissions for the currently authenticated user. :param container_name: The container name. :type container_name: ``str`` :param object_name: The object name. Optional. Not providing an object will return only container permissions. :type object_name: ``str`` or ``None`` :return: A tuple of container and object permissions. :rtype: ``tuple`` of (``int``, ``int`` or ``None``) from ContainerPermissions and ObjectPermissions, respectively. N)r rd r_ )r( r] rc Z obj_permsr r r �ex_get_permissionsT s �z&GoogleStorageDriver.ex_get_permissionsc C s� t |�}t|t�r'|r tnt}z|j| }W n ty& td|||f ��w t|t�s2td| ��|sB| � � }|s>td��d| }|rKd� ||�}nd| }| j j |dt �||d��d � d S ) ah Set the permissions for an ACL entity on a container or an object. :param container_name: The container name. :type container_name: ``str`` :param object_name: The object name. Optional. Not providing an object will apply the acl to the container. :type object_name: ``str`` :param entity: The entity to which apply the role. Optional. If not provided, the role will be applied to the authenticated user, if using an OAuth2 authentication scheme. :type entity: ``str`` :param role: The permission/role to set on the entity. :type role: ``int`` from ContainerPermissions or ObjectPermissions or ``str``. :raises ValueError: If no entity was given, but was required. Or if the role isn't valid for the bucket or object. z7%s is not a valid role level for container=%s object=%sz %s is not a valid permission.re rf rb rU �POST)�rolerh )r> �dataN)r rG �intr! r r � IndexErrorrg rH ra r: rT rX �json�dumps)r( r] rc rh rm Zpermsr) ri r r r �ex_set_permissionsi s6 ��� � �z&GoogleStorageDriver.ex_set_permissionsr4 �returnc C s |� dd �}|� d|�}|S )Nz x-goog-stored-content-lengthzcontent-length)�get)r( r4 Zx_goog_content_length�content_lengthr r r � _get_content_length_from_headers� s z4GoogleStorageDriver._get_content_length_from_headers)NNr# )NNN) r r r rL r Zwebsiter" Z connectionClsrR ZjsonConnectionClsZ hash_type� NAMESPACE� namespaceZsupports_chunked_encodingZ supports_s3_multipart_uploadrF r' r_ ra rd rj rk rs r rH r ro rw rP r r r, r rE � s& 2 % ! &6rE )!r@ rq � email.utilsr/ �typingr r Zlibcloud.utils.py3r r Zlibcloud.common.baser Zlibcloud.common.typesr Zlibcloud.common.googler r r Zlibcloud.storage.drivers.s3r r r r r; Z API_VERSIONrx r r r! r" rQ rR rE r r r r �<module> s& L
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings