Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/test/storage/__pycache__/test_s3.cpython-39.pyc
Ðазад
a r�hn� � @ s� d dl Z d dlZd dlZd dlZd dlmZ d dlmZ d dlZd dlm Z d dlm Z d dl Z d dl mZ d dl mZ d dl mZ d d l mZ d d l mZ d d l mZ d d l mZ d d lmZ d dlmZmZ d dlmZmZ d dl m Z d dl m Z d dl m Z d dl m Z d dl m!Z! d dl m"Z" d dl#m$Z$m%Z% d dl#m&Z&m'Z' d dl#m(Z( d dl m)Z) d dl*m+Z+ d dl*m,Z,m-Z-m.Z. d d l/m0Z0 d d l1m2Z2 d d l3m4Z4 G d d � d e4e,j5�Z6G d!d"� d"e,j5�Z7e8d#k�r�e�9e,�:� � dS )$� N)�BytesIO)�sha1)�Mock)� PropertyMock)�ET)�httplib)�urlparse)�parse_qs)�StringIO)�PY3)�exhaust_iterator)�InvalidCredsError)� LibcloudError�MalformedResponseError)� Container�Object)�ContainerDoesNotExistError)�ContainerError)�ContainerIsNotEmptyError)�InvalidContainerNameError)�ObjectDoesNotExistError)�ObjectHashMismatchError)�BaseS3Connection�S3SignatureV4Connection)�S3StorageDriver�S3USWestStorageDriver)� CHUNK_SIZE)�b)�MockHttp)�unittest� make_response�generate_random_data)�StorageFileFixtures)�STORAGE_S3_PARAMS)�BaseRangeDownloadMockHttpc @ s( e Zd Zed�Zi Zdd� Zdd� Zdd� Zdd � Z d d � Z d d � Z dd� Z dd� Z dd� Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd*d+� Zd,d-� Zd.d/� Z d0d1� Z d2d3� Z d4d5� Z d6d7� Z d8d9� Z!d:d;� Z"d<d=� Z#d>d?� Z$d@dA� Z%dBdC� Z&dDdE� Z'dFS )G� S3MockHttpZs3c C s t jd| jt jt j fS �N� )r � UNAUTHORIZED� base_headers� responses�OK��self�method�url�body�headers� r2 ��/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_s3.py� _UNAUTHORIZED? s �zS3MockHttp._UNAUTHORIZEDc C s t jd| jt jt j fS r& )r �MOVED_PERMANENTLYr) r* r+ r, r2 r2 r3 �_DIFFERENT_REGIONE s �z S3MockHttp._DIFFERENT_REGIONc C s$ | j �d�}tj|| jtjtj fS )N�list_containers_empty.xml��fixtures�loadr r+ r) r* r, r2 r2 r3 �_list_containers_EMPTYK s �z!S3MockHttp._list_containers_EMPTYc C s< d|v r|d dksJ �| j �d�}tj|| jtjtj fS )Nzx-amz-security-token�asdfr7 r8 r, r2 r2 r3 �_list_containers_TOKENR s �z!S3MockHttp._list_containers_TOKENc C s$ | j �d�}tj|| jtjtj fS )N�list_containers.xmlr8 r, r2 r2 r3 �_list_containers[ s �zS3MockHttp._list_containersc C s$ | j �d�}tj|| jtjtj fS )Nz list_container_objects_empty.xmlr8 r, r2 r2 r3 �_test_container_EMPTYb s �z S3MockHttp._test_container_EMPTYc C s$ | j �d�}tj|| jtjtj fS �Nzlist_container_objects.xmlr8 r, r2 r2 r3 �_test_containeri s �zS3MockHttp._test_containerc C s< |� d�dkrd}nd}| j�|�}tj|| jtjtj fS )Nz3.zip���z)list_container_objects_not_exhausted1.xmlz)list_container_objects_not_exhausted2.xml)�findr9 r: r r+ r) r* )r- r. r/ r0 r1 � file_namer2 r2 r3 �_test_container_ITERATORp s �z#S3MockHttp._test_container_ITERATORc C s$ | j �d�}tj|| jtjtj fS rA r8 r, r2 r2 r3 �_test2_get_object} s �z S3MockHttp._test2_get_objectc C s2 | j �d�}dddddd�}tj||tjtj fS )Nr> �application/zipz"e31208wqsdoj329jd"�monkeys�12345� Thu, 13 Sep 2012 07:13:22 GMT)� content-type�etagzx-amz-meta-rabbitszcontent-lengthz last-modified)r9 r: r r+ r* r, r2 r2 r3 �_test2_test_get_object� s � �z!S3MockHttp._test2_test_get_objectc C s t j||t jt j fS �N)r � BAD_REQUESTr* r+ r, r2 r2 r3 �_new_container_INVALID_NAME� s �z&S3MockHttp._new_container_INVALID_NAMEc C s t j||t jt j fS rO �r �CONFLICTr* r+ r, r2 r2 r3 � _new_container_ALREADY_EXISTS� s �z(S3MockHttp._new_container_ALREADY_EXISTSc C s2 |dkrt j}n|dkr t j}|||t jt j fS )N�PUT�DELETE)r r+ � NO_CONTENTr* )r- r. r/ r0 r1 �statusr2 r2 r3 �_new_container� s �zS3MockHttp._new_containerc C s t j||t jt j fS rO �r � NOT_FOUNDr* r+ r, r2 r2 r3 �_new_container_DOESNT_EXIST� s �z&S3MockHttp._new_container_DOESNT_EXISTc C s t j||t jt j fS rO rR r, r2 r2 r3 �_new_container_NOT_EMPTY� s �z#S3MockHttp._new_container_NOT_EMPTYc C s$ | j �d�}tj|| jtjtj fS rA r8 r, r2 r2 r3 �_test1_get_container� s �z S3MockHttp._test1_get_containerc C s t jd| jt jt j fS r& �r r[ r) r* r, r2 r2 r3 �_container1_get_container� s �z$S3MockHttp._container1_get_containerc C s t jd| jt jt j fS r& r_ r, r2 r2 r3 �_test_inexistent_get_object� s �z&S3MockHttp._test_inexistent_get_objectc C s t j||t jt j fS rO �r rW r* r+ r, r2 r2 r3 �_foo_bar_container� s �z S3MockHttp._foo_bar_containerc C s t j||t jt j fS rO rZ r, r2 r2 r3 � _foo_bar_container_NOT_FOUND� s �z'S3MockHttp._foo_bar_container_NOT_FOUNDc C s t j||t jt j fS rO rZ r, r2 r2 r3 �+_foo_bar_container_foo_bar_object_NOT_FOUND� s �z6S3MockHttp._foo_bar_container_foo_bar_object_NOT_FOUNDc C s t j||t jt j fS rO rb r, r2 r2 r3 �(_foo_bar_container_foo_bar_object_DELETE� s �z3S3MockHttp._foo_bar_container_foo_bar_object_DELETEc C s" d}ddi}t j||t jt j fS �Nr' rM �""0cc175b9c0f1b6a831c399e269772661"�r r+ r* r, r2 r2 r3 �'_foo_bar_container_foo_test_stream_data� s �z2S3MockHttp._foo_bar_container_foo_test_stream_datac C s� |dkrVd|v r2| j �d�}tj||tjtj fS | j �d�}tj||tjtj fS n<|dkrttjd|tjtj fS ddi}tjd|tjtj fS d S ) N�POSTZuploadIdzcomplete_multipart.xmlzinitiate_multipart.xmlrV r' rM rh )r9 r: r r+ r* rW r, r2 r2 r3 �1_foo_bar_container_foo_test_stream_data_MULTIPART� s4 � � � �z<S3MockHttp._foo_bar_container_foo_test_stream_data_MULTIPARTc C sL t �|�j}t|�}d|vr*| j�d�}n | j�d�}tj||tjtj fS )Nz key-markerzlist_multipart_1.xmlzlist_multipart_2.xml) r �urlsplit�queryr r9 r: r r+ r* )r- r. r/ r0 r1 Z query_stringrn r2 r2 r3 �!_foo_bar_container_LIST_MULTIPART s �z,S3MockHttp._foo_bar_container_LIST_MULTIPARTc C s d}t j||t jt j fS r& �r rW r* r, r2 r2 r3 �,_foo_bar_container_my_divisor_LIST_MULTIPART# s �z7S3MockHttp._foo_bar_container_my_divisor_LIST_MULTIPARTc C s d}t j||t jt j fS r& rp r, r2 r2 r3 �/_foo_bar_container_my_movie_m2ts_LIST_MULTIPART+ s �z:S3MockHttp._foo_bar_container_my_movie_m2ts_LIST_MULTIPARTc C s� t | j�dkr| js| jS z:zt�| j�}W n$ tyP t�| j�d��}Y n0 W n& tyz td| j| j j d��Y n0 |S )Nr �utf-8zFailed to parse XML)r0 �driver) �lenr0 Zparse_zero_length_bodyr �XML� ValueError�encode� Exceptionr � connectionrt )r- r0 r2 r2 r3 � parse_body3 s � zS3MockHttp.parse_bodyc C s t d�}tj||tjtj fS �N�� �r! r r+ r* r, r2 r2 r3 �!_foo_bar_container_foo_bar_objectC s �z,S3MockHttp._foo_bar_container_foo_bar_objectc C sX d}| � d|v � | �|d d� | �|d |�\}}tj|||d � |tjtj fS )N�0123456789123456789�Rangez bytes=5-6� �� assertTrue� assertEqualZ'_get_start_and_end_bytes_from_range_strr �PARTIAL_CONTENTr* �r- r. r/ r0 r1 � start_bytes� end_bytesr2 r2 r3 �'_foo_bar_container_foo_bar_object_rangeK s �z2S3MockHttp._foo_bar_container_foo_bar_object_rangec C sX d}| � d|v � | �|d d� | �|d |�\}}tj|||d � |tjtj fS )Nr� r� z bytes=4-6r� r� r� r2 r2 r3 �._foo_bar_container_foo_bar_object_range_streamY s �z9S3MockHttp._foo_bar_container_foo_bar_object_range_streamc C s t d�}tj||tjtj fS r| r~ r, r2 r2 r3 �+_foo_bar_container_foo_bar_object_NO_BUFFERg s �z6S3MockHttp._foo_bar_container_foo_bar_object_NO_BUFFERc C s" d}ddi}t j||t jt j fS rg ri r, r2 r2 r3 �"_foo_bar_container_foo_test_uploado s �z-S3MockHttp._foo_bar_container_foo_test_uploadc C s d}t j||t jt j fS r& ri r, r2 r2 r3 �._foo_bar_container_foo_bar_object_INVALID_SIZEx s �z9S3MockHttp._foo_bar_container_foo_bar_object_INVALID_SIZEN)(�__name__� __module__� __qualname__r" r9 r) r4 r6 r; r= r? r@ rB rF rG rN rQ rT rY r\ r] r^ r` ra rc rd re rf rj rl ro rq rr r{ r r� r� r� r� r� r2 r2 r2 r3 r% : sH r% c @ s� e Zd ZeZeZeZe dd� �Z dd� Z dd� Z dd� Z d d � Zd d � Zd d� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Z d'd(� Z d)d*� Z d+d,� Z d-d.� Z d/d0� Z!d1d2� Z"d3d4� Z#d5d6� Z$d7d8� Z%d9d:� Z&d;d<� Z'd=d>� Z(d?d@� Z)dAdB� Z*dCdD� Z+e,�-dE�dFdG� �Z.dHdI� Z/dJdK� Z0dLdM� Z1dNdO� Z2dPdQ� Z3dRdS� Z4dTdU� Z5dVdW� Z6dXdY� Z7dZd[� Z8d\d]� Z9d^d_� Z:d`da� Z;dbdc� Z<ddde� Z=dfdg� Z>dhdi� Z?djS )k�S3Testsc C s | j | j� S rO )� driver_type� driver_args�r- r2 r2 r3 � create_driver� s zS3Tests.create_driverc C s4 | j | jj_d | j _| �� | _tj� t �d | _ d S )Nz.temp) �mock_response_klassr� � connectionClsZ conn_class�typer� rt �os�path�abspath�__file__� _file_pathr� r2 r2 r3 �setUp� s z S3Tests.setUpc C s | � � d S rO )�_remove_test_filer� r2 r2 r3 �tearDown� s zS3Tests.tearDownc C s( zt �| j� W n ty" Y n0 d S rO )r� �unlinkr� �OSErrorr� r2 r2 r3 r� � s zS3Tests._remove_test_filec C sR | j jdd�}| �|d� | j jdd�}| �|d� | j jdd�}| �|d� d S )NZvalid��namezvalid/~z valid/~%foo zvalid/~%25foo%20)rt Z_clean_object_namer� )r- �cleanedr2 r2 r3 �test_clean_object_name� s z S3Tests.test_clean_object_namec C s\ d| j _z| j�� W n6 tyL } z | �dt|t�� W Y d }~nd }~0 0 | �d� d S )Nr( T�Exception was not thrown)r� r� rt �list_containersr r� � isinstance�fail)r- �er2 r2 r3 �test_invalid_credentials� s (z S3Tests.test_invalid_credentialsc C s* d| j _| j| jddi�| _| j�� d S )NZlist_containers_TOKEN�tokenr< )r� r� r� r� rt r� r� r2 r2 r3 � test_token� s zS3Tests.test_tokenc C sh d}t jddddd�ddid |d d d �}d }t�tjt|�t|�td ��� �}|� d�}| � ||� d S )Nzssssh!�GET�barzTYPE!Z test_value)�foorL z x-aws-testZhelloZworld�/zx-aws)r. r1 �params�expires� secret_keyr� Z vendor_prefixz#GET TYPE! x-aws-test:test_value /)� digestmodrs ) r Zget_auth_signature�base64� b64encode�hmac�newr r �digest�decoder� )r- r� �sigZstring_to_signZb64_hmacZ expected_sigr2 r2 r3 �test_signature� s& �� � zS3Tests.test_signaturec C s8 d| j _z| j�� W n ty( Y n 0 | �d� d S )NZDIFFERENT_REGIONr� )r� r� rt r� r r� r� r2 r2 r3 �*test_bucket_is_located_in_different_region� s z2S3Tests.test_bucket_is_located_in_different_regionc C s& d| j _| j�� }| �t|�d� d S )NZlist_containers_EMPTYr )r� r� rt r� r� ru �r- � containersr2 r2 r3 �test_list_containers_empty� s z"S3Tests.test_list_containers_emptyc C s: d| j _| j�� }| �t|�d� | �d|d jv � d S )Nr� � Z creation_dater� )r� r� rt r� r� ru r� �extrar� r2 r2 r3 � test_list_containers_success� s z$S3Tests.test_list_containers_successc C s: d| j _tdi | jd�}| jj|d�}| �t|�d� d S )NZEMPTY�test_container�r� r� rt �� containerr )r� r� r rt �list_container_objectsr� ru )r- r� �objectsr2 r2 r3 �!test_list_container_objects_empty� s �z)S3Tests.test_list_container_objects_emptyc C s� d | j _tdi | jd�}| jj|d�}| �t|�d� dd� |D �d }| �|jd� | �|jd � | �|j j d� | �|j d d � | � d |j v � d S ) Nr� r� r� r� c S s g | ]}|j d kr|�qS �z1.zipr� ��.0�or2 r2 r3 � <listcomp>� � z?S3Tests.test_list_container_objects_success.<locals>.<listcomp>r � 4397da7a7649e8085de9916c240e8166�� � last_modifiedz2011-04-09T19:05:18.000Z�owner)r� r� r rt r� r� ru �hash�sizer� r� r� r� � meta_data�r- r� r� �objr2 r2 r3 �#test_list_container_objects_success� s � �z+S3Tests.test_list_container_objects_successc C s� d| j _tdi | jd�}| jj|d�}dd� |D �d }| �|jd� | �|jd � | �|jj d� | � ||v � | �t |�d � d S ) NZITERATORr� r� r� c S s g | ]}|j d kr|�qS r� r� r� r2 r2 r3 r� � r� zIS3Tests.test_list_container_objects_iterator_has_more.<locals>.<listcomp>r r� r� � ) r� r� r rt r� r� r� r� r� r� r� ru r� r2 r2 r3 �-test_list_container_objects_iterator_has_more� s �z5S3Tests.test_list_container_objects_iterator_has_morec C s� d | j _tdi | jd�}| jj|dd�}| �t|�d� dd� |D �d }| �|jd � | �|jd � | �|j j d� | � d |j v � d S ) Nr� r� Z test_prefix)r� �prefixr� c S s g | ]}|j d kr|�qS r� r� r� r2 r2 r3 r� r� zCS3Tests.test_list_container_objects_with_prefix.<locals>.<listcomp>r r� r� r� ) r� r� r rt r� r� ru r� r� r� r� r� r� r� r2 r2 r3 �'test_list_container_objects_with_prefix s ��z/S3Tests.test_list_container_objects_with_prefixc C s< d| j _z| jjdd� W n ty, Y n 0 | �d� d S )N� get_containerZ container1��container_namer� )r� r� rt r� r r� r� r2 r2 r3 � test_get_container_doesnt_exist s z'S3Tests.test_get_container_doesnt_existc C s( d| j _| jjdd�}| �|jd� d S )Nr� Ztest1r� )r� r� rt r� r� r� �r- r� r2 r2 r3 �test_get_container_success s z"S3Tests.test_get_container_successc C s� d| j _| jjddd�}t| jjt�r�| jj|dd�}t�|�}t� |j �}| � t |d �d� | � t |d d �d � | � |d d g� n6| �t�� | j�|� W d � n1 s�0 Y d S ) N� get_object�test2�test�r� � object_name� )Z ex_expiryzX-Amz-Signaturer� r z X-Amz-ExpiresZ43200)r� r� rt r� � issubclassr� r Zget_object_cdn_urlr r rn r� ru Z assertGreaterZ assertRaises�NotImplementedError)r- r� Zcdn_urlr/ rn r2 r2 r3 �test_get_object_cdn_url s � z S3Tests.test_get_object_cdn_urlc C s> d| j _z| jjddd� W n ty. Y n 0 | �d� d S )Nr� ztest-inexistentr� r� r� )r� r� rt r� r r� r� r2 r2 r3 �&test_get_object_container_doesnt_exist1 s � z.S3Tests.test_get_object_container_doesnt_existc C s� d| j _| jjddd�}| �|jd� | �|jjd� | �|jd� | �|jd� | �|j d d� | �|j d d � | �|j d d � d S ) Nr� r� r� r� rJ Ze31208wqsdoj329jdr� rK � content_typerH ZrabbitsrI ) r� r� rt r� r� r� r� r� r� r� r� )r- r� r2 r2 r3 �test_get_object_success= s � �z S3Tests.test_get_object_successc C s< d| j _z| jjdd� W n ty, Y n 0 | �d� d S )NZ INVALID_NAME� new_containerr� r� )r� r� rt �create_containerr r� r� r2 r2 r3 �!test_create_container_bad_requestM s z)S3Tests.test_create_container_bad_requestc C s< d| j _z| jjdd� W n ty, Y n 0 | �d� d S )NZALREADY_EXISTSz new-containerr� r� )r� r� rt r� r r� r� r2 r2 r3 �$test_create_container_already_existsW s z,S3Tests.test_create_container_already_existsc C s, d | j _d}| jj|d�}| �|j|� d S )Nr� r� )r� r� rt r� r� r� )r- r� r� r2 r2 r3 � test_create_container_successa s z%S3Tests.test_create_container_successc C sL t dd | jd�}d| j_z| jj|d� W n ty< Y n 0 | �d� d S )Nr� r� Z DOESNT_EXISTr� r� )r rt r� r� �delete_containerr r� r� r2 r2 r3 �"test_delete_container_doesnt_existh s � z*S3Tests.test_delete_container_doesnt_existc C sh t dd | jd�}d| j_z| jj|d� W n ty< Y n 0 | �d� d | j_| �| jj|d�� d S )Nr� r� Z NOT_EMPTYr� r� )r rt r� r� r� r r� r� r� r2 r2 r3 � test_delete_container_not_emptys s � z'S3Tests.test_delete_container_not_emptyc C sL d| j _tdi | jd�}z| jj|d� W n ty< Y n 0 | �d� d S )Nr[ �foo_bar_containerr� r� z7Container does not exist but an exception was notthrown)r� r� r rt r� r r� r� r2 r2 r3 � test_delete_container_not_found� s � z'S3Tests.test_delete_container_not_foundc C s0 d | j _tdd | jd�}| �| jj|d�� d S )Nr� r� r� )r� r� r rt r� r� r� r2 r2 r3 � test_delete_container_success� s �z%S3Tests.test_delete_container_successc C sP t di | jd�}tddd i |d | jd�}| j}| jj||ddd�}| �|� d S )Nr� r� �foo_bar_objectr} �r� r� r� r� r� r� rt T�r� �destination_path�overwrite_existing�delete_on_failure)r rt r r� r� �download_objectr� �r- r� r� r �resultr2 r2 r3 � test_download_object_success� s � ��z$S3Tests.test_download_object_successc C s� t di | jd�}tddd i |d | jd�}| j}| jj||ddddd �}| �|� t| jd ��}|�� }W d � n1 sz0 Y | � |d � d S ) Nr� r� Zfoo_bar_object_range� r r� � T)r� r r� r� r r �rZ56) r rt r r� r� Zdownload_object_ranger� �open�readr� )r- r� r� r r �fp�contentr2 r2 r3 �"test_download_object_range_success� s& � �� &z*S3Tests.test_download_object_range_successc C sR t di | jd�}tddd i |d | jd�}| jj|ddd�}t|�}| �|d � d S ) Nr� r� Zfoo_bar_object_range_streamr r � r )r� r� r� s 456)r rt r r� Z download_object_range_as_streamr r� )r- r� r� �iteratorr r2 r2 r3 �,test_download_object_range_as_stream_success� s � ��z4S3Tests.test_download_object_range_as_stream_successc 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 dd�}| �|� d S )N� mock responser� �� �;"content" attribute was accessed but it shouldn't have been�mock content attribute�r� Z side_effect�� aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaar� r� �foo_bar_object_NO_BUFFERr} r FTr )r r1 � status_coder ry r� r r � iter_content� return_valuert rz � getresponser r r� r� r r� )r- � mock_response�msgr� r� r r r2 r2 r3 �3test_download_object_data_is_not_buffered_in_memory� s0 � � ��z;S3Tests.test_download_object_data_is_not_buffered_in_memoryc C s� t dd�}i |_d|_d}d}tdt|�d�t|�_tdt|�d�t|�_td �|j _ t � | j j _ || j j j _ td i | j d �}td d d i |d | jd�}| j j|d�}t|�}tr�|�d�}| �|d � d S )Nr r� r z<"response" attribute was accessed but it shouldn't have beenr zmock response attributer r r r� r� r r} r �r� rs )r r1 rX r ry r� �responser r r r rt rz �requestr r r� �download_object_as_streamr r r� r� )r- r Zmsg1Zmsg2r� r� r r2 r2 r3 �=test_download_object_as_stream_data_is_not_buffered_in_memory� s4 � � � � zES3Tests.test_download_object_as_stream_data_is_not_buffered_in_memoryc C sX d| j _tdi | jd�}tddd i |d | jd�}| j}| jj||ddd �}| �|� d S ) N� INVALID_SIZEr� r� r� r} r FTr ) r� r� r rt r r� r� r Z assertFalser r2 r2 r3 �&test_download_object_invalid_file_size s � ��z.S3Tests.test_download_object_invalid_file_sizec C sv d| j _tdi | jd�}tddd i |d | jd�}tj�t �}z| jj ||ddd � W n t yf Y n 0 | � d � d S ) Nr' r� r� r� r} r FTr r� ) r� r� r rt r r� r� r� r� r� r r r� )r- r� r� r r2 r2 r3 �0test_download_object_invalid_file_already_exists s$ � � � z8S3Tests.test_download_object_invalid_file_already_existsz8The MockHttp classes cannot support this test at presentc C s~ t di | jd�}tddd i |d | jd�}d dd�}| jj}|| j_z,| jj|dd �}| �t|d �� W || j_n || j_0 d S ) Nr� r� r� r} r c S s |j �d�S )N� )� _responser )r- r� �callback�callback_kwargsr# Zsuccess_status_coder2 r2 r3 �mock_get_object) s zGS3Tests.test_download_object_as_stream_success.<locals>.mock_get_objectr* )r� � chunk_size�__iter__)N)r rt r r� Z _get_objectr% r� �hasattr)r- r� r� r. �old_func�streamr2 r2 r3 �&test_download_object_as_stream_success s" � � � �z.S3Tests.test_download_object_as_stream_successc C s� t j�t�}tdi | jd�}d}z| jj|||ddd� W n@ tyz } z(| �t |�� � � d�dk� W Y d }~nd }~0 0 | � d � d S ) Nr� r� �foo_test_uploadTz invalid-class)� file_pathr� r� � verify_hashZex_storage_classzinvalid storage classrC r� ) r� r� r� r� r rt � upload_objectrw r� �str�lowerrD r� )r- r6 r� r� r� r2 r2 r3 �+test_upload_object_invalid_ex_storage_class6 s � � 2z3S3Tests.test_upload_object_invalid_ex_storage_classc C s� d dd�}| j j}|| j _tj�t�}tdi | jd�}d}zBz| jj|||dd� W n t yf Y n 0 | � d� W || j _n || j _0 d S ) Nc S s ddi}t d|d�ddd�S )NrM z"foobar"r �r1 r} Zhash343hhash89h932439jsaa89�r# Zbytes_transferredZ data_hash�r �r- r� r� � request_path�request_methodr1 r6 r3 r2 r2 r3 � upload_fileJ s �z=S3Tests.test_upload_object_invalid_hash1.<locals>.upload_filer� r� r5 T�r6 r� r� r7 �9Invalid hash was returned but an exception was not thrown)NNNNNNN� r� �_upload_objectr� r� r� r� r rt r8 r r� �r- rB r2 r6 r� r� r2 r2 r3 � test_upload_object_invalid_hash1G s, � � � �z(S3Tests.test_upload_object_invalid_hash1c C s� d dd�}| j j}|| j _tj�t�}tdi | jd�}d}zBz| jj|||dd� W n t yf Y n 0 | � d� W || j _n || j _0 d S ) Nc S s ddi}t d|d�ddd�S )NrM z "hash343hhash89h932439jsaa89"r r< r} � 0cc175b9c0f1b6a831c399e269772661r= r> r? r2 r2 r3 rB g s �z=S3Tests.test_upload_object_invalid_hash2.<locals>.upload_filer� r� r5 TrC rD )NNNNNNNrE rG r2 r2 r3 � test_upload_object_invalid_hash2d s, � � � �z(S3Tests.test_upload_object_invalid_hash2c C sj ddd�}| j j}|| j _tj�t�}tdi | jd�}d}z | jj|||dd� W || j _n || j _0 d S ) Nc S s ddd�}t d|d�ddd�S ) NZblahblahzaws:kms)rM z x-amz-server-side-encryptionr r< r} Zhash343hhash89h932439jsaa81r= r> r? r2 r2 r3 rB � s �zKS3Tests.test_upload_object_invalid_hash_kms_encryption.<locals>.upload_filer� r� r5 TrC )NNNNNNN) r� rF r� r� r� r� r rt r8 rG r2 r2 r3 �.test_upload_object_invalid_hash_kms_encryption� s" � � �z6S3Tests.test_upload_object_invalid_hash_kms_encryptionc C s� d dd�}d | j _| jj}|| j_tj�t�}tdi | j d�}d}dddii}| j j ||||d d �}| � |j d� | � |j d � | �d|jv � || j_d S ) Nc S s t dddid�ddd�S )Nr rM rI r< r} r= r> r? r2 r2 r3 rB � s ��z7S3Tests.test_upload_object_success.<locals>.upload_filer� r� r5 r� z some-valueZfoobarT�r6 r� r� r� r7 r} )NNNNNNN)r� r� r� rF r� r� r� r� r rt r8 r� r� r� r� r� �r- rB r2 r6 r� r� r� r� r2 r2 r3 �test_upload_object_success� s. � � �z"S3Tests.test_upload_object_successc C s� d dd�}d | j _| jj}|| j_tj�t�}tdi | j d�}d}ddi}| j j ||||dd �}| � |j d� | � |j d � | � |jd d� || j_d S ) Nc S s ddi}t d|d�ddd�S )NrM rI r r< r} r= r> r? r2 r2 r3 rB � s �z8S3Tests.test_upload_object_with_acl.<locals>.upload_filer� r� r5 Zaclz public-readTrL r} )NNNNNNN)r� r� r� rF r� r� r� r� r rt r8 r� r� r� r� rM r2 r2 r3 �test_upload_object_with_acl� s. � ��z#S3Tests.test_upload_object_with_aclc C sv | j jrd| j_nd | j_tdi | j d�}d}ttd��}ddi}| j j||||d�}| �|j |� | �|j d � d S ) N� MULTIPARTr� r� �foo_test_stream_datar' r� � text/plain�r� r� r r� r � rt � supports_s3_multipart_uploadr� r� r r r �upload_object_via_streamr� r� r� �r- r� r� r r� r� r2 r2 r3 �#test_upload_empty_object_via_stream� s � �z+S3Tests.test_upload_empty_object_via_streamc C sv | j jrd| j_nd | j_tdi | j d�}d}ttd��}ddi}| j j||||d�}| �|j |� | �|j d � d S � NrP r� r� rQ �234r� rR rS � rT rW r2 r2 r3 �#test_upload_small_object_via_stream� s � �z+S3Tests.test_upload_small_object_via_streamc C s~ | j jrd| j_nd | j_tdi | j d�}d}ttdt ��}ddi}| j j||||d�}| � |j |� | � |j td � d S rY ) rt rU r� r� r r r r rV r� r� r� rW r2 r2 r3 �!test_upload_big_object_via_stream� s ��z)S3Tests.test_upload_big_object_via_streamc C s� | j jrd| j_nd | j_tdi | j d�}d}ttd��}tjddd��2}d |_ | j j |||d � |� |� W d � n1 s�0 Y d S ) NrP r� r� rQ rZ z)libcloud.utils.files.guess_file_mime_typeT)Zautospec)rH N)r� r� r ) rt rU r� r� r r r �mock�patchr rV Zassert_called_with)r- r� r� r Zmock_guess_file_mime_typer2 r2 r3 �2test_upload_object_via_stream_guess_file_mime_type s& � ��z:S3Tests.test_upload_object_via_stream_guess_file_mime_typec C sn | j js d S d| j_dd� }tdi | j d�}d}|� }ddi}z| j j||||d � W n tyh Y n0 d S ) NrP c s s& t dd�D ]} t| �V q td��d S )Nr r� zError in fetching data)�ranger9 � RuntimeError)�ir2 r2 r3 �_faulty_iterator% s zES3Tests.test_upload_object_via_stream_abort.<locals>._faulty_iteratorr� r� rQ r� rR rS )rt rU r� r� r rV ry )r- rd r� r� r r� r2 r2 r3 �#test_upload_object_via_stream_abort s& �� z+S3Tests.test_upload_object_via_stream_abortc C s� | j js d S d| j_dt_tdi | j d�}| j �|�D ]J}| �|j d � | �|j d � | �|j d � | �|j d � | �|j d � q6d S �NZLIST_MULTIPARTr� r� r� )rt rU r� r� r �RESPONSES_PER_REQUESTr Z ex_iterate_multipart_uploadsZassertNotEqual�key�idZ created_atr� Z initiator)r- r� �uploadr2 r2 r3 � test_s3_list_multipart_uploads: s �z&S3Tests.test_s3_list_multipart_uploadsc C s: | j js d S d| j_dt_tdi | j d�}| j �|� d S rf )rt rU r� r� r rg r Z ex_cleanup_all_multipart_uploadsr� r2 r2 r3 � test_s3_abort_multipart_uploadsK s �z'S3Tests.test_s3_abort_multipart_uploadsc C sd d| j _tdi | jd�}tddd d d || jd�}z| jj|d� W n tyT Y n 0 | �d� d S ) Nr[ r� r� r� �� �r� r� r� r� r� r� rt r" r� )r� r� r rt r � delete_objectr r� )r- r� r� r2 r2 r3 � test_delete_object_not_foundW s � � z$S3Tests.test_delete_object_not_foundc C sL d| j _tdi | jd�}tddd d d || jd�}| jj|d�}| �|� d S )NrV r� r� r� rm rn r" )r� r� r rt r ro r� )r- r� r� r r2 r2 r3 �test_delete_object_successd s � �z"S3Tests.test_delete_object_successc C sr t | j� }| �|jd� | �|jjd� t | jddi�}| �|jd� | �|jjd� t | jddi�}| �|jd� | �|jjd� t | jddi�}| �|jd� | �|jjd� | �|jd� | �|jjd� t �� D ]"}t | jd|i�}| �|j|� q�d}| jt|t g| j�R dd i� t | jdd d ��}| �|jd� | �|jjd � t | jd d i�}| �|jjd � d S )Nz us-east-1zs3.amazonaws.com�regionz us-west-2zs3-us-west-2.amazonaws.comz ap-south-1zs3-ap-south-1.amazonaws.comz"Invalid or unsupported region: foor� z host1.bar.com)rr �hostrs z host2.bar.com) r r� r� rr rz rs Z list_regions�assertRaisesRegexrw )r- rt Zdriver1Zdriver2rr Z expected_msgZdriver3Zdriver4r2 r2 r3 � test_region_keyword_argumentn s8 ��z$S3Tests.test_region_keyword_argumentc C s t | j� }| �|jd� d S )Nz us-west-1)r r� r� rr )r- rt r2 r2 r3 �'test_deprecated_driver_class_per_region� s z/S3Tests.test_deprecated_driver_class_per_regionN)@r� r� r� r r� r# r� r% r� � classmethodr� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r! r& r( r) r �skipr4 r; rH rJ rK rN rO rX r\ r] r` re rk rl rp rq ru rv r2 r2 r2 r3 r� � sr " )r� �__main__);r� r� r� �sys�ior �hashlibr r^ r r Zlibcloud.utils.filesZlibcloudZlibcloud.utils.py3r r r r r r r Zlibcloud.common.typesr r r Zlibcloud.storage.baser r Zlibcloud.storage.typesr r r r r r Zlibcloud.storage.drivers.s3r r r r r r Z libcloud.testr r r r! Zlibcloud.test.file_fixturesr" Zlibcloud.test.secretsr# Zlibcloud.test.storage.baser$ ZTestCaser% r� r� �exit�mainr2 r2 r2 r3 �<module> s\ J
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка