Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/storage/drivers/__pycache__/google_storage.cpython-39.pyc
Ðазад
a q�hk; � @ s d dl Z d dlZd dlZd dlmZ d dlmZ d dlmZ d dlm Z d dl m Z d dl m Z d dl mZ d d l mZ d d l mZ d d lmZ d d lmZ d ZdZde Zdd� ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de �Z G dd� de�Z G d d � d e�Z dS ) � N)�ConnectionUserAndKey)�GoogleAuthType)�GoogleOAuth2Credential)�GoogleResponse)� ProviderError)�BaseS3Connection)�BaseS3StorageDriver)� S3RawResponse)� S3Response)�httplib��urlquoteZGOOG1z 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`` � )�safeNr )�name� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/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 6 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 s^ |p t �|�| _t �| j�r8t||| j|fi |��| _nd | _tt| �j|||fi |�� d S �N) r � guess_type� auth_typeZ is_oauth2r �oauth2_credential�superr! �__init__)�self�user_id�key�securer$ Zcredential_file�kwargs�� __class__r r r' R s �� �z GoogleStorageConnection.__init__c C s0 t jjdd�}||d< | �� }|r,||| j< |S )NT)�usegmt�Date)�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 )Nr8 )�getattrZdriver)r( r r r r4 e s z#GoogleStorageConnection.get_projectc C sF | j tjkr.| �||�}dt| j|f |d< nd| jj |d< ||fS )Nz%s %s:%s� AuthorizationzBearer )r$ r ZGCS_S3�_get_s3_auth_signature�SIGNATURE_IDENTIFIERr) r% Z access_token)r( �paramsr6 � signaturer r r �pre_connect_hookh s � �z(GoogleStorageConnection.pre_connect_hookc C s| i }t �|�}|�� D ]D\}}|�� }|dv sD|�tj�sDt|t�sN|||< q|�� ||< qt j | j ||d| j | j tjd�S )z3Hacky wrapper to work with S3's get_auth_signature.)r7 z content-typeN)�methodr6 r> �expiresZ secret_key�pathZ vendor_prefix)�copy�deepcopy�items�lower� startswith�GoogleStorageDriver�http_vendor_prefix� isinstance�strr Zget_auth_signaturerA r* �action)r( r> r6 Z headers_copyZ params_copy�k�vZk_lowerr r r r< r s( �� �z.GoogleStorageConnection._get_s3_auth_signature)TNN)r r r �__doc__�hostr � responseClsr �rawResponseClsr5 r' r9 r4 r@ r< � __classcell__r r r- r r! E s � r! c @ s e Zd ZdS )� GCSResponseN)r r r r r r r rU � s rU 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 t| ��|�}d|d< |S )Nzapplication/jsonz Content-Type)r& rV r9 )r( r6 r- r r r9 � s �z/GoogleStorageJSONConnection.add_default_headers) r r r rP rQ rU rR rS r9 rT r r r- r rV � s rV c s| e Zd ZdZdZdZeZeZ dZ e Z dZ dZdZd� fdd � Zd d � Zd d � Zdd� Zddd�Zddd�Zddd�Z� ZS )rI 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 s8 t t| �j||fi |�� || _t||fi |��| _d S r" )r& rI r' r8 rV �json_connection)r( r* �secretr8 r, r- r r r' � s ��z GoogleStorageDriver.__init__c C s> z| j �d| � tjW S tyj } z:|jtjkr6n |jtjkrTtj W Y d}~S � W Y d}~n d}~0 0 z | j jd| ddidd� W nV ty� } z>|jtjtj fv r�tj W Y d}~S |jtjkr̂ W Y d}~n d}~0 0 z| j �d| � tj W S t�y6 } z"|jtjtjfv�r"� W Y d}~n d}~0 0 tj S ) 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)r6 rA z/storage/v1/b/%s) rX �requestr r r � http_coder � FORBIDDEN� NOT_FOUNDr �PRECONDITION_FAILEDr r )r( �container_name�er r r �_get_container_permissions� s8 � � z.GoogleStorageDriver._get_container_permissionsc C s t | jd�}|r|jS dS dS )z.Gets this drivers' authenticated user, if any.r% N)r: � connectionr) )r( Z oauth2_credsr r r � _get_user s z GoogleStorageDriver._get_userc C s� z | j �d||f � tjW S tyT } z |jtjtjfvr@� W Y d}~n d}~0 0 z | j �d||f � tj W S ty� } z |jtjtjfvr�� W Y d}~n d}~0 0 tj S )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/%s/o/%s/aclNz/storage/v1/b/%s/o/%s) rX r] r r r r^ r r_ r` r r )r( rb � object_namerc r r r �_get_object_permissions s" � �z+GoogleStorageDriver._get_object_permissionsc C s^ t |�}|s*| �� }|s"td��nd| }|r>d|||f }n d||f }| 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/%s/o/%s/acl/%sz/storage/v1/b/%s/acl/%sr\ )rA N)r rf � ValueErrorrX r] )r( rb rh �entityr) �urlr r r �ex_delete_permissions- 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 ri rd )r( rb rh Z obj_permsr r r �ex_get_permissionsP s ���z&GoogleStorageDriver.ex_get_permissionsc C s� t |�}t|t�rT|rtnt}z|j| }W qj tyP td|||f ��Y qj0 nt|t�sjtd| ��|s�| � � }|s�td��nd| }|r�d||f }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.rj rk rg rZ �POST)�rolerm )rA �dataN)r rK �intr r r � IndexErrorrl rL rf rX r] �json�dumps)r( rb rh rm rr Zpermsr) rn r r r �ex_set_permissionsd s6 �� ��z&GoogleStorageDriver.ex_set_permissions)NN)NN)N)NNN)r r r rP r Zwebsiter! Z connectionClsrV ZjsonConnectionClsZ hash_type� NAMESPACE� namespaceZsupports_chunked_encodingZ supports_s3_multipart_uploadrJ r' rd rf ri ro rp rx rT r r r- r rI � s* 1# � # �rI ) rD rv � email.utilsr1 Zlibcloud.common.baser Zlibcloud.common.googler r r Zlibcloud.common.typesr Zlibcloud.storage.drivers.s3r r r r Zlibcloud.utils.py3r r r= Z API_VERSIONry r �objectr r r! rU rV rI r r r r �<module> s. H
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка