Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/test/storage/__pycache__/test_google_storage.cpython-39.pyc
Ðазад
a r�hVT � @ sx d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ d dlZ d dl Z d dlm Z d dlm Z d dl mZ d dlmZ d dlmZ d dlmZ d d lmZ d d lmZ d d lmZ d d lmZ d d l m Z d dl m Z m Z d dl!m"Z" d dl!m#Z# ej$Z%ej&Z'e j(j)dd�Z*dd� Z+G dd� de �Z,G dd� de�Z-G dd� de�Z.G dd � d e e�Z/e0d k�rte�1e�2� � dS ) � N)�BytesIO)�Mock)� PropertyMock)�GoogleAuthType)�InvalidCredsError)� Container)�Object)�google_storage)�StorageMockHttp)�GoogleTestCase)�StorageFileFixtures)� STORAGE_GOOGLE_STORAGE_PARAMS)�S3Tests� S3MockHttp)�httplib)�StringIOT)�usegmtc C s8 t j| }dd| ||d�gii}| t�|�|t j| fS )N�error�errors)�code�message�reason)r � responses�json�dumps)r �headersr �body� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/libcloud/test/storage/test_google_storage.py� _error_helper1 s ���� r c @ s$ e Zd Zed�Zdd� Zdd� ZdS )�GoogleStorageMockHttpr c C s2 | j �d�}dddddd�}tj||tjtj fS )Nzlist_containers.xmlzapplication/zipz"e31208wqsdoj329jd"ZmonkeysZ12345z Thu, 13 Sep 2012 07:13:22 GMT)� content-type�etagzx-goog-meta-rabbitszcontent-lengthz last-modified��fixtures�loadr �OKr ��self�method�urlr r r r r �_test2_test_get_objectD s �z,GoogleStorageMockHttp._test2_test_get_objectc C s t jd| jt jt j fS )N� )r � UNAUTHORIZED� base_headersr r& r' r r r � _container_path_UNAUTHORIZEDR s �z2GoogleStorageMockHttp._container_path_UNAUTHORIZEDN)�__name__� __module__� __qualname__r r$ r+ r/ r r r r r A s r c @ s� e Zd ZdZed�Zi Ze�d�Z e j j Z e jj Zeeje�Zeeje�Zeeje�Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dS )�GoogleStorageJSONMockHttpa# Extracts bucket and object out of requests and routes to methods of the forms (bucket, object, entity, and type are sanitized values {'-', '.', '/' are replaced with '_'}): _<bucket>[_<type>] _<bucket>_acl[_entity][_<type>] _<bucket>_defaultObjectAcl[_<entity>][_<type>] _<bucket>_<object>[_<type>] _<bucket>_<object>_acl[_<entity>][_<type>] Ugly example: /storage/v1/b/test-bucket/o/test-object/acl/test-entity with type='FOO' yields _test_bucket_test_object_acl_test_entity_FOO r z`/storage/[^/]+/b/([^/]+)(?:/(defaultObjectAcl(?:/[^/]+)?$)|(?:/o/(.+?))?(?:/(acl(?:/[^/]+)?))?$)c C sj | j �|�}|s td| ��d�dd� |�� D ��}|rFd||f }nd| }|�dd��dd��d d�S ) Nz%s is not a valid path.�_c S s g | ] }|r|�qS r r )�.0�gr r r � <listcomp>� � z>GoogleStorageJSONMockHttp._get_method_name.<locals>.<listcomp>z_%s_%sz_%s�/�.�-)�path_rgx�match� ValueError�join�groups�replace)r( �typeZ use_param�qs�pathr= Z joined_groups� meth_namer r r �_get_method_name| s z*GoogleStorageJSONMockHttp._get_method_namec C s" | j �|�}tj|i tjtj fS �Nr# )r( Zfixturer r r r �_response_helper� s z*GoogleStorageJSONMockHttp._response_helperc C s6 |dkrt d| ��| jtjjk r(| jS | �d�S dS )zBucket request.�GET�%s is not implemented.zget_container.jsonN)�NotImplementedError� bucket_permsr �ContainerPermissions�READER� _FORBIDDENrH r' r r r � _test_bucket� s z&GoogleStorageJSONMockHttp._test_bucketc C s6 |dkrt d| ��| jtjjk r(| jS | �d�S dS )zBucket list ACL request.rI rJ zlist_container_acl.jsonN)rK rL r rM �OWNERrO rH r' r r r �_test_bucket_acl� s z*GoogleStorageJSONMockHttp._test_bucket_aclc C s6 |dkrt d| ��| jtjjk r(| jS | �d�S dS )zObject request.rI rJ zget_object.jsonN)rK � object_permsr �ObjectPermissionsrN rO rH r' r r r �_test_bucket_test_object� s z2GoogleStorageJSONMockHttp._test_bucket_test_objectc C s6 |dkrt d| ��| jtjjk r(| jS | �d�S dS )zObject list ACL request.rI rJ zlist_object_acl.jsonN)rK rS r rT rQ rO rH r' r r r � _test_bucket_test_object_acl� s z6GoogleStorageJSONMockHttp._test_bucket_test_object_aclc C sL |� d�}|dks|dkr.d||f }t|��| jtjjk rB| jS | jS d S )Nzx-goog-if-generation-match�DELETE�0z=Improper write check delete strategy. method: %s, headers: %s)�getr> rL r rM ZWRITERrO �_PRECONDITION_FAILED)r( r) r* r r Z gen_match�msgr r r �_test_bucket_writecheck� s �z1GoogleStorageJSONMockHttp._test_bucket_writecheckN) r0 r1 r2 �__doc__r r$ r. �re�compiler< r rM �NONErL rT rS r r � FORBIDDENrO � NOT_FOUND� _NOT_FOUND�PRECONDITION_FAILEDrZ rF rH rP rR rU rV r\ r r r r r3 Y s( � � r3 c @ sJ e Zd Ze�d�dd� �Ze�d�dd� �Ze�d�dd � �Zd d � Zd S ) �GoogleStorageConnectionTestzemail.utils.formatdatec C s� t |_ddi}d}tdddtjd�}tjd d�|_t|�}t |d < | � |� t|��|� tdddtjd�}tj|d�|_t|�}t |d < ||tj < | � |� t|��|� d S ) N�startingr z foo-project�foo_user�bar_keyT��secureZ auth_type�� return_value�Date) �TODAYrl �CONN_CLSr �GCS_S3�mockr Z get_project�dict� assertEqualZadd_default_headersZPROJECT_ID_HEADER)r( Zmock_formatdate�starting_headers�project�connr r r r �test_add_default_headers� s0 ��� �z4GoogleStorageConnectionTest.test_add_default_headersz?libcloud.storage.drivers.s3.BaseS3Connection.get_auth_signaturec C s� d|_ i }tddddd�}tddddd�}td d d tjd �}d |_d|_|�||�}| �||� | � |d� |j d ||d d ddd� d S )Nzmock signature!zX-GOOG: MAINTAIN UPPERCASE!z Header key should be loweredz#application/mIXED casING MAINTAINEDz LOWER THIS!)rm � x-goog-fooz x-Goog-barz Content-Type�Otherz lower this!)�dater! rx z x-goog-bar�otherrg rh Tri rI z/pathzx-goog)r) r �params�expiresZ secret_keyrD Z vendor_prefix) rl rn ro r rp r) �action�_get_s3_auth_signatureZassertNotEqualrs �assert_called_once_with)r( Zmock_s3_auth_sig_method�starting_paramsrt Zmodified_headersrv �resultr r r �test_get_s3_auth_signature� s8 ��� �z6GoogleStorageConnectionTest.test_get_s3_auth_signaturez-libcloud.common.google.GoogleOAuth2Credentialc C s� t �� |_ddi}ddi}tdddtjd�}t �� |_t �� |_d|j_t |�}d |d < |� t |�t |��}| � |||f� d S ) Nrf r| r rg rh Tri z Access_Token!zBearer Access_Token!� Authorization) rq r rl ro r ZGCEr �oauth2_credentialZ access_tokenrr �pre_connect_hookrs )r( Zmock_oauth2_credential_initr� rt rv �expected_headersr� r r r � test_pre_connect_hook_oauth2 s � �z8GoogleStorageConnectionTest.test_pre_connect_hook_oauth2c s� ddi}ddi}� fdd�� t dddtjd �}� |_d |_d |_t|�}d tjdd f |d< |� t|�t|��}| � |t|�|f� | � � j |� | � � j |� | � |j� d S )Nrf r| r c s t �| �� _t �|�� _dS )N�fake signature!)�copy�deepcopy� params_passed�headers_passed)r| r ��fake_hmac_methodr r r� " s zPGoogleStorageConnectionTest.test_pre_connect_hook_hmac.<locals>.fake_hmac_methodrg rh Tri rI z/fooz%s %s:%sr� r� )ro r rp r r~ r) rr r ZSIGNATURE_IDENTIFIERr� rs r� r� Z assertIsNoner� )r( r� rt rv r� r� r r� r �test_pre_connect_hook_hmac s, ��� �z6GoogleStorageConnectionTest.test_pre_connect_hook_hmacN) r0 r1 r2 rq �patchrw r� r� r� r r r r re � s # re c s� e Zd ZejZeZeZ � fdd�Z dd� Z dd� Z dd� Z d d � Zd d � Zd d� Zdd� Zdd� Zdd� Zdd� Zdd� Z� ZS )�GoogleStorageTestsc s t t| ��� t| jj_d S rG )�superr� �setUpr3 � driver_typeZjsonConnectionClsZ conn_class�r( �� __class__r r r� @ s zGoogleStorageTests.setUpc C s | � � d S rG )Z_remove_test_filer� r r r �tearDownD s zGoogleStorageTests.tearDownc C s d S rG r r� r r r �test_billing_not_enabledG s z+GoogleStorageTests.test_billing_not_enabledc C s d S rG r r� r r r � test_tokenK s z GoogleStorageTests.test_tokenc C sd t �� }|| jj_| jjdddd� d}|j|dd� |�� | jjddd� d}|j|dd� d S ) N�bucket�object�user-foo)�entityz*/storage/v1/b/bucket/o/object/acl/user-foorW �r) z!/storage/v1/b/bucket/acl/user-foo)rq r �driver�json_connection�request�ex_delete_permissionsr� � reset_mock�r( � mock_requestr* r r r �test_delete_permissionsO s �z*GoogleStorageTests.test_delete_permissionsc C s� t �� }t jd d�}|| j_|| jj_| �t| jjdd� | �t| jjd� |� � d|_ | j�dd� d}|j |dd� |� � d|_ | j�d� d}|j |dd� d S ) Nrk r� r� � foo@foo.comz2/storage/v1/b/bucket/o/object/acl/user-foo@foo.comrW r� z)/storage/v1/b/bucket/acl/user-foo@foo.com) rq r r� � _get_userr� r� � assertRaisesr> r� �assert_not_calledrl r� r� �r( r� Z mock_get_userr* r r r �!test_delete_permissions_no_entity_ s( � � z4GoogleStorageTests.test_delete_permissions_no_entityc sN � fdd�}t ttjj��}t ttjj��}|D ]}|D ]}|||� q8q0d S )Nc s. | t _|t _� j�dd�}� �|| |f� d S )Nz test-bucketz test-object)r3 rL rS r� Zex_get_permissionsrs )rL rS Zpermsr� r r �test_permission_config} s �zGGoogleStorageTests.test_get_permissions.<locals>.test_permission_config)�range�lenr rM �valuesrT )r( r� Z bucket_levelsZ object_levelsrL rS r r� r �test_get_permissions| s z'GoogleStorageTests.test_get_permissionsc C s t �� }|| jj_| jjddddd� d}|j|dt�ddd��d � |� � | jjdddt j j d� d}|j|dt�ddd��d � |� � | jjdddd� d }|j|dt�ddd��d � |� � | jjddt j j d� d }|j|dt�ddd��d � d S ) Nr� r� r� rQ )r� �role�!/storage/v1/b/bucket/o/object/acl�POST�r� r� �r) �data�/storage/v1/b/bucket/acl)rq r r� r� r� �ex_set_permissionsr� r r r� r rT rQ rM r� r r r �test_set_permissions� sN ��������z'GoogleStorageTests.test_set_permissionsc C s� t �� }|| jj_| �t| jjdd� | �t| jjd� |�� | jt| jjddt j j d� |�� | jt| jjdt j j d� |�� d S )Nr� r� �r� ) rq r r� r� r� r� r> r� r� r rM rQ rT )r( r� r r r � test_set_permissions_bad_roles� s& � � � �z1GoogleStorageTests.test_set_permissions_bad_rolesc C s� t �� }t jd d�}|| j_|| jj_| jt| jjdddd� | jt| jjddd� |� � d|_ | jjdddd� d}|j |dt � dd d ��d � |�� d|_ | jjddd� d }|j |dt � dd d ��d � d S ) Nrk r� r� rQ r� r� r� r� zuser-foo@foo.comr� r� r� )rq r r� r� r� r� r� r> r� r� rl r� r r r� r� r r r � test_set_permissions_no_entity� s6 � ���z1GoogleStorageTests.test_set_permissions_no_entityc C sZ d| j _td| ji d�}t�t��$ | j�td�|d� W d � n1 sL0 Y d S )Nr- � container)�namer� �extra� rD ) �mock_response_klassrB r r� �pytestZraisesr Zupload_object_via_streamr )r( r� r r r �"test_invalid_credentials_on_upload� s �z5GoogleStorageTests.test_invalid_credentials_on_uploadc C s� t dd�}i |_d|_d}tdt|�d�t|�_td�|j_ t � | j j j _ || j j j j _ t di | j d �}td d d i |d | jd �}| j}| j j||d d d�}| �|� d S )Nz mock response)r� �� z;"content" attribute was accessed but it shouldn't have beenzmock content attribute)r� Z side_effectA� aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaZfoo_bar_container)r� r� r� Zfoo_bar_object_NO_BUFFERi� )r� �size�hashr� r� Z meta_datar� T)�obj�destination_pathZoverwrite_existingZdelete_on_failure)r r � status_coder � ExceptionrB �contentr � iter_contentrl r� � connection� getresponser r r� Z _file_pathZdownload_objectZ assertTrue)r( Z mock_responser[ r� r� r� r� r r r �3test_download_object_data_is_not_buffered_in_memory� s0 � � ��zFGoogleStorageTests.test_download_object_data_is_not_buffered_in_memory)r0 r1 r2 r ZGoogleStorageDriverr� r Z driver_argsr r� r� r� r� r� r� r� r� r� r� r� r� r� � __classcell__r r r� r r� ; s )"r� �__main__)3r� r rq r^ �sysZunittest�ior � email.utils�emailr� r r Zlibcloud.common.googler Zlibcloud.common.typesr Zlibcloud.storage.baser r Zlibcloud.storage.driversr Z libcloud.testr Z libcloud.test.common.test_googler Zlibcloud.test.file_fixturesr Zlibcloud.test.secretsr Z libcloud.test.storage.test_s3r r Zlibcloud.utils.py3r r ZGoogleStorageConnectionro ZGoogleStorageJSONConnectionZ JSON_CONN_CLS�utils� formatdatern r r r3 re r� r0 �exit�mainr r r r �<module> sB lv Y
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка