Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/test/storage/__pycache__/test_cloudfiles.cpython-39.pyc
Ðазад
a r�h� � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ d dlZd dlm Z d dl Z d dl m Z d dl m Z d dl Zd dlmZ d dlmZ d dlmZ d d lmZ d d lmZ d d l mZ d d lmZ d d lmZmZmZ 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$ d dl%m&Z& d dl%m'Z'm(Z(m)Z) d dl*m+Z+ d dl,m-Z- G dd� de'j.�Z/G dd � d e/�Z0G d d � d e/�Z1G d d � d e-e'j.�Z2e3d!k�r�e�4e'�5� � dS )"� N)�BytesIO)�sha1)�Mock)� PropertyMock)�b)�httplib)�urlquote)�StringIO)�PY3)�exhaust_iterator)�MalformedResponseError)� CHUNK_SIZE� Container�Object)�ContainerAlreadyExistsError)�ContainerDoesNotExistError)�ContainerIsNotEmptyError)�ObjectDoesNotExistError)�ObjectHashMismatchError)�InvalidContainerNameError)�CloudFilesStorageDriver)�MockHttp)�unittest�generate_random_data� make_response)�StorageFileFixtures)�BaseRangeDownloadMockHttpc @ s e Zd ZeZdZi ZdZdd� Zdd� Z dd� Z d d � Z d d � Z d d� Z dd� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zd+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(dEdF� Z)dGdH� Z*dIdJ� Z+dKdL� Z,dMdN� Z-dOdP� Z.dQdR� Z/dSdT� Z0dUdV� Z1dWdX� Z2dYdZ� Z3e4�5d[�d\d]� �Z6d^d_� Z7d`da� Z8dbdc� Z9ddde� Z:e;�<df�dgdh� �Z=didj� Z>dkdl� Z?dmdn� Z@dodp� ZAdqdr� ZBdsdt� ZCe4�5du�dvdw� �ZDdxdy� ZEdzd{� ZFd|S )}�CloudFilesTests)�dummyr �ordc C sP t | jj_d t _| j�� }| j|d< | j| ji |��| _ | j j � � | � � d S )N�region) �CloudFilesMockHttp� driver_klass� connectionClsZ conn_class�type� driver_kwargs�copyr � driver_args�driver� connectionZ!_populate_hosts_and_request_paths�_remove_test_file)�selfr% � 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_cloudfiles.py�setUp> s � zCloudFilesTests.setUpc C s | � � d S �N)r* �r+ r, r, r- �tearDownK s zCloudFilesTests.tearDownc C s\ t dddd�}z |�� W n2 tyL } z| �|jd� W Y d }~nd }~0 0 | �d� d S )Nr( r �invalid�Zex_force_service_regionz!Could not find specified endpoint�Exception was not thrown)r �list_containers� Exception� assertEqual�value�fail)r+ r( �er, r, r- �$test_invalid_ex_force_service_regionN s � $z4CloudFilesTests.test_invalid_ex_force_service_regionc C s t dddd�}|�� d S )Nr( r ZORDr3 )r r5 )r+ r( r, r, r- � test_ex_force_service_regionY s �z,CloudFilesTests.test_ex_force_service_regionc C s\ d}d|d�}t d i |��}|�� | �|d |jj� | �d|jj� | �d|jj� d S ) Nz+https://cdn2.clouddrive.com/v1/MossoCloudFSzsome-auth-token)�ex_force_auth_tokenZex_force_base_urlr( r r= zcdn2.clouddrive.comz/v1/MossoCloudFS)r( r )r r5 r7 r) Z auth_token�host� request_path)r+ �base_url�kwargsr( r, r, r- � test_force_auth_token_kwargs^ s � ���z,CloudFilesTests.test_force_auth_token_kwargsc C sD ddd�}t di |��}| �|d |jj� | �|d |jj� d S ) Nz2.0z"https://identity.api.rackspace.com)�ex_force_auth_version�ex_force_auth_urlr( r rD rC )r( r )r r7 r) Z_ex_force_auth_urlZ _auth_version)r+ rA r( r, r, r- �test_force_auth_url_kwargsn s � � �z*CloudFilesTests.test_force_auth_url_kwargsc C s6 dt _z| j�� W n ty& Y n 0 | �d� d S )NZMALFORMED_JSONr4 )r! r$ r( r5 r r9 r0 r, r, r- �"test_invalid_json_throws_exceptionz s z2CloudFilesTests.test_invalid_json_throws_exceptionc C sJ d| j }| �|| jj�� � d| jj_| �d| jj�� � d| jj_d S )Nz3https://storage4.%s1.clouddrive.com/v1/MossoCloudFSTz*https://cdn.clouddrive.com/v1/MossoCloudFSF)r r7 r( r) Z get_endpointZ cdn_request)r+ �urlr, r, r- �test_service_catalog� s � � �z$CloudFilesTests.test_service_catalogc C sz dt _| j�� }| �t|�d� d t _| j�� }| �t|�d� dd� |D �d }| �|jd d� | �|jd d � d S ) N�EMPTYr � c S s g | ]}|j d kr|�qS )Z container2��name)�.0�cr, r, r- � <listcomp>� � z8CloudFilesTests.test_list_containers.<locals>.<listcomp>� object_count�x �sizei�FE)r! r$ r( r5 r7 �len�extra)r+ � containers� containerr, r, r- �test_list_containers� s z$CloudFilesTests.test_list_containersc C s� dt _tdi | jd�}| jj|d�}| �t|�d� d t _| jj|d�}| �t|�d� dd� |D �d }| �|jd � | �|jd � | �|j j d� d S ) NrI �test_container�rL rU r( �rW r � c S s g | ]}|j d kr|�qS �z foo test 1rK �rM �or, r, r- rO � rP z?CloudFilesTests.test_list_container_objects.<locals>.<listcomp>� 16265549b5bda64ecdaa5156de4c97cc�H� � r! r$ r r( �list_container_objectsr7 rT �hashrS rW rL �r+ rW �objects�objr, r, r- �test_list_container_objects� s �z+CloudFilesTests.test_list_container_objectsc C s8 dt _tdi | jd�}| jj|d�}| �t|�d� d S )NrI ztest container 1rZ r[ r )r! r$ r r( rc r7 rT )r+ rW rf r, r, r- �(test_list_container_object_name_encoding� s �z8CloudFilesTests.test_list_container_object_name_encodingc C s� dt _tdi | jd�}| jj|dd�}| �t|�d� d t _| jj|dd�}| �t|�d� d d � |D �d }| �|jd � | �|jd � | �|j j d� d S ) NrI rY rZ Z test_prefix1)rW �prefixr Z test_prefix2r\ c S s g | ]}|j d kr|�qS r] rK r^ r, r, r- rO � rP zKCloudFilesTests.test_list_container_objects_with_prefix.<locals>.<listcomp>r` ra rb re r, r, r- �'test_list_container_objects_with_prefix� s" ���z7CloudFilesTests.test_list_container_objects_with_prefixc C sv dt _tdi | jd�}| jj|d�}| �t|�d� dd� |D �d }| �|jd � | �|jd � | �|j j d� d S ) NZITERATORrY rZ r[ � c S s g | ]}|j d kr|�qS )z foo-test-1rK r^ r, r, r- rO � rP zHCloudFilesTests.test_list_container_objects_iterator.<locals>.<listcomp>r r` ra rb re r, r, r- �$test_list_container_objects_iterator� s �z4CloudFilesTests.test_list_container_objects_iteratorc C sD | j jdd�}| �|jd� | �|jd d� | �|jd d� d S )NrY ��container_namerQ i rS i�� )r( � get_containerr7 rL rU �r+ rW r, r, r- �test_get_container� s z"CloudFilesTests.test_get_containerc C s4 z| j jdd� W n ty$ Y n 0 | �d� d S )N� not_foundrn r4 )r( rp r r9 r0 r, r, r- � test_get_container_not_found� s z,CloudFilesTests.test_get_container_not_foundc C s� | j jddd�}| �|jjd� | �|jd� | �|jd� | �|jd d� | �|jd d � | �|jd d � | �|jd d � d S )NrY � test_object�ro � object_namei+ � 6b21c4a111ac178feacf9ec9d0c71f17� content_type�application/zipZ last_modified� Tue, 25 Jan 2011 22:01:49 GMTzfoo-bar�test 1zbar-foo�test 2) r( � get_objectr7 rW rL rS rd rU � meta_data�r+ rg r, r, r- �test_get_object_success� s � �z'CloudFilesTests.test_get_object_successc C s" | j jddd�}| �|jd� d S )NrY z~/test_object/rv )r( r~ r7 rL r� r, r, r- �$test_get_object_object_name_encoding� s �z4CloudFilesTests.test_get_object_object_name_encodingc C s6 z| j jddd� W n ty& Y n 0 | �d� d S )NrY rs rv r4 )r( r~ r r9 r0 r, r, r- �test_get_object_not_found� s � z)CloudFilesTests.test_get_object_not_foundc C sB | j jdd�}| �t|t�� | �|jd� | �|jd d� d S )N�test_create_containerrn rQ r )r( �create_container� assertTrue� isinstancer r7 rL rU rq r, r, r- � test_create_container_success� s �z-CloudFilesTests.test_create_container_successc C s: dt _z| jjdd� W n ty* Y n 0 | �d� d S )NZALREADY_EXISTSr� rn z8Container already exists but an exception was not thrown)r! r$ r( r� r r9 r0 r, r, r- �$test_create_container_already_exists s � �z4CloudFilesTests.test_create_container_already_existsc C sN d� dd� tdd�D ��}z| jj|d� W n ty> Y n 0 | �d� d S )N� c S s g | ]}d �qS )�xr, )rM r� r, r, r- rO rP zOCloudFilesTests.test_create_container_invalid_name_too_long.<locals>.<listcomp>r i rn zJInvalid name was provided (name is too long), but exception was not thrown)�join�ranger( r� r r9 )r+ rL r, r, r- �+test_create_container_invalid_name_too_long s �z;CloudFilesTests.test_create_container_invalid_name_too_longc C s4 z| j jdd� W n ty$ Y n 0 | �d� d S )Nz test/slashes/rn zOInvalid name was provided (name contains slashes), but exception was not thrown)r( r� r r9 r0 r, r, r- �2test_create_container_invalid_name_slashes_in_name s �zBCloudFilesTests.test_create_container_invalid_name_slashes_in_namec C s* t di | d�}| jj|d�}| �|� d S )N�foo_bar_containerrZ r[ )r r( �delete_containerr� �r+ rW �resultr, r, r- � test_delete_container_success" s z-CloudFilesTests.test_delete_container_successc C sH dt _tdi | d�}z| jj|d� W n ty8 Y n 0 | �d� d S )N� NOT_FOUNDr� rZ r[ z8Container does not exist but an exception was not thrown)r! r$ r r( r� r r9 rq r, r, r- � test_delete_container_not_found' s �z/CloudFilesTests.test_delete_container_not_foundc C sH dt _tdi | d�}z| jj|d� W n ty8 Y n 0 | �d� d S )NZ NOT_EMPTYr� rZ r[ z6Container is not empty but an exception was not thrown)r! r$ r r( r� r r9 rq r, r, r- � test_delete_container_not_empty2 s z/CloudFilesTests.test_delete_container_not_emptyc C sV t di | d�}tddd i |d td�}tj�t�d }| jj||ddd �}| � |� d S ) Nr� rZ �foo_bar_object�� �rL rS rd rU rW r r( �.tempFT�rg �destination_path�overwrite_existing�delete_on_failure) r r r �os�path�abspath�__file__r( �download_objectr� �r+ rW rg r� r� r, r, r- � test_download_object_success< s ��z,CloudFilesTests.test_download_object_successc C s\ dt _tdi | d�}tddd i |d td�}tj�t�d }| j j ||dd d �}| � |� d S ) NZ INVALID_SIZEr� rZ r� r� r� r� FTr� ) r! r$ r r r r� r� r� r� r( r� Z assertFalser� r, r, r- �&test_download_object_invalid_file_sizeH s ��z6CloudFilesTests.test_download_object_invalid_file_sizec C st dt _tdi | d�}tddd i |d td�}tj�t�d }z| j j ||dd d � W n t yd Y n 0 | � d � d S ) Nr� r� rZ r� r� r� r� FTr� �5Object does not exist but an exception was not thrown) r! r$ r r r r� r� r� r� r( r� r r9 )r+ rW rg r� r, r, r- �&test_download_object_success_not_foundU s$ �� z6CloudFilesTests.test_download_object_success_not_foundc C s� t di | d�}tddd i |d td�}tj�t�d }| jj||ddd d d �}| � |� t |d ��}|� � }W d � n1 s~0 Y | � |d � d S )Nr� rZ �foo_bar_object_range� r� r� rl � FT)rg r� � start_bytes� end_bytesr� r� �r�56) r r r r� r� r� r� r( Zdownload_object_ranger� �open�readr7 )r+ rW rg r� r� �fp�contentr, r, r- �"test_download_object_range_successi s" �� &z2CloudFilesTests.test_download_object_range_successc C sH t di | d�}tddd i |d td�}| jj|d d�}| �t|d�� d S )Nr� rZ r� r� r� )rg � chunk_size�__iter__)r r r r( �download_object_as_streamr� �hasattr)r+ rW rg �streamr, r, r- � test_download_object_as_stream| s ��z.CloudFilesTests.test_download_object_as_streamc 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 | j d�}| j j|d�}t|�}tr�|�d�}| �|d � d S )Nz mock responserK �� z<"response" attribute was accessed but it shouldn't have beenz;"content" attribute was accessed but it shouldn't have beenzmock response attribute)rL Z side_effectzmock content attributeA� aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaar� rZ Zfoo_bar_object_NO_BUFFERr� r� �rg �utf-8)r �headers�statusr r6 r$ �responser� r � iter_content� return_valuer( r) �requestr r r� r r �decoder7 )r+ Z mock_responseZmsg1Zmsg2rW rg r� r, r, r- �=test_download_object_as_stream_data_is_not_buffered_in_memory� s4 � � � � zMCloudFilesTests.test_download_object_as_stream_data_is_not_buffered_in_memoryc C s~ t di | d�}tddd i |d td�}| jjdd|d d�}| �t|d �� d �d d � |D ��}| �|d � | �t |�|j � d S )Nr� rZ r� � r� rl r� )r� r� rg r� r� r� c s s | ]}|� d �V qdS )r� N)r� )rM �chunkr, r, r- � <genexpr>� rP zOCloudFilesTests.test_download_object_range_as_stream_success.<locals>.<genexpr>r� ) r r r r( Z download_object_range_as_streamr� r� r� r7 rT rS )r+ rW rg r� Zconsumed_streamr, r, r- �,test_download_object_range_as_stream_success� s �� z<CloudFilesTests.test_download_object_range_as_stream_successc C s� d dd�}t j}|t _tj�t�}tdi | d�}d}dddii}| jj||||d �}| � |j d� | � |j d � | � d|j v � |t _d S ) Nc S s t dddid�ddd�S �N�� �etag� 0cc175b9c0f1b6a831c399e269772661�r� r� �r� Zbytes_transferred� data_hash�r �r+ rw ry r? �request_methodr� � file_pathr� r, r, r- � upload_file� s �z?CloudFilesTests.test_upload_object_success.<locals>.upload_filer� rZ �foo_test_uploadr z some-value�foobar�r� rW rU rw r� )NNNNNNN)r �_upload_objectr� r� r� r� r r( � upload_objectr7 rL rS r� r �r+ r� �old_funcr� rW rw rU rg r, r, r- �test_upload_object_success� s$ � �z*CloudFilesTests.test_upload_object_successc s� d dd�}t j}|t _�jjj�tj�tj�t �d�}t di �d�}d}i }� ��fdd�� � �jj_d � _ �jj ||||d �}�� |jd� �� |jd � |t _��jj_d S ) Nc S s t dddid�ddd�S )Nr� r� r� r� r r� r� r� r, r, r- r� � s �zHCloudFilesTests.test_upload_object_zero_size_object.<locals>.upload_filez __init__.pyr� rZ �emptyc s( �� |d d d� d� _�| i |��S )Nr� zContent-Lengthr T)r7 �called)�argsrA ��funcZ old_requestr+ r, r- r� � s zACloudFilesTests.test_upload_object_zero_size_object.<locals>.funcFr� r )NNNNNNN)r r� r( r) r� r� r� r� �dirnamer� r r� r� r7 rL rS r� r, r� r- �#test_upload_object_zero_size_object� s, � �z3CloudFilesTests.test_upload_object_zero_size_objectc C s� dt _d dd�}tj}|t_tj�t�}tdi | d�}d}z@z| j j |||dd� W n t yf Y n 0 | � d � W |t_n|t_0 d S ) NZ INVALID_HASHc S s t dddid�ddd�S )Nr� r� r� r� r� z blah blahr� r� r� r, r, r- r� � s �zDCloudFilesTests.test_upload_object_invalid_hash.<locals>.upload_filer� rZ r� T)r� rW rw � verify_hashz9Invalid hash was returned but an exception was not thrown)NNNNNNN) r! r$ r r� r� r� r� r� r r( r� r r9 )r+ r� r� r� rW rw r, r, r- � test_upload_object_invalid_hash� s* � � �z/CloudFilesTests.test_upload_object_invalid_hashc C sj dd� }t jjj}|t jj_tj�t�}tdi | d�}d}| j j |d||d�}| � |j |� |t jj_d S )Nc S s dS )N)NNr, rK r, r, r- �no_content_type s zKCloudFilesTests.test_upload_object_no_content_type.<locals>.no_content_typer� rZ r� F)r� r� rW rw ) �libcloud�utils�files�guess_file_mime_typer� r� r� r� r r( r� r7 rL )r+ r� r� r� rW rw rg r, r, r- �"test_upload_object_no_content_type s �z2CloudFilesTests.test_upload_object_no_content_typec C s� dd� }t jjj}|t jj_tj�td �}tdi | d�}d}zBz| j j |||d� W n t yh Y n 0 | � d� W |t jj_n |t jj_0 d S ) Nc S s dS �N)rz Nr, rK r, r, r- �dummy_content_type s zNCloudFilesTests.test_upload_object_inexistent_file.<locals>.dummy_content_typez .inexistentr� rZ r� �r� rW rw z*Inexistent but an exception was not thrown) r� r� r� r� r� r� r� r� r r( r� �OSErrorr9 )r+ r� r� r� rW rw r, r, r- �"test_upload_object_inexistent_file s � z2CloudFilesTests.test_upload_object_inexistent_filec C sl dd� }t jjj}|t jj_tdi | d�}d}ttd��}z | jj|||d� W |t jj_n |t jj_0 d S )Nc S s dS r� r, rK r, r, r- r� . s zICloudFilesTests.test_upload_object_via_stream.<locals>.dummy_content_typer� rZ Zfoo_test_stream_dataZ235�rW rw �iterator) r� r� r� r� r r r r( �upload_object_via_stream�r+ r� r� rW rw r� r, r, r- � test_upload_object_via_stream- s �z-CloudFilesTests.test_upload_object_via_streamc C s� dd� }t jjj}|t jj_tdi | d�}d}ttd��}|�d� | �|� � d� z | j j |||d� W |t jj_n |t jj_0 d S ) Nc S s dS r� r, rK r, r, r- r� ? s z\CloudFilesTests.test_upload_object_via_stream_stream_seek_at_end.<locals>.dummy_content_typer� rZ Zfoo_test_stream_data_seekZ 123456789r� r� ) r� r� r� r� r r r �seekr7 �tellr( r� r� r, r, r- �0test_upload_object_via_stream_stream_seek_at_end> s �z@CloudFilesTests.test_upload_object_via_stream_stream_seek_at_endc C s@ t di | d�}tddd i |d td�}| jj|d�}| �|� d S )Nr� rZ r� r� r� r� )r r r r( � delete_objectr� )r+ rW rg r� r, r, r- �test_delete_object_successS s �z*CloudFilesTests.test_delete_object_successc C s^ dt _tdi | d�}tddd i |d td�}z| jj|d� W n tyN Y n 0 | �d� d S ) Nr� r� rZ r� r� r� r� r� ) r! r$ r r r r( r� r r9 �r+ rW rg r, r, r- � test_delete_object_not_found[ s � z,CloudFilesTests.test_delete_object_not_foundc C sV | j �� }| �t|t�� | �d|v � | �d|v � | �d|v � | �d|v � d S )NrQ �container_count� bytes_used� temp_url_key)r( �ex_get_meta_datar� r� �dict)r+ r r, r, r- �test_ex_get_meta_datah s z%CloudFilesTests.test_ex_get_meta_datac C sD dt _tdi | jd�}tddd i |d | d�}| �| jj|d�� d S )NZ PURGE_SUCCESSr� rZ �objectr� r� r� �r! r$ r r( r r� Zex_purge_object_from_cdnr� r, r, r- � test_ex_purge_object_from_cdnp s � �z-CloudFilesTests.test_ex_purge_object_from_cdnc C sF dt _tdi | jd�}tddd i |d | d�}| �| jj|dd�� d S ) NZPURGE_SUCCESS_EMAILr� rZ r r� r� � test@test.com)rg �emailr r� r, r, r- �(test_ex_purge_object_from_cdn_with_emailz s � � �z8CloudFilesTests.test_ex_purge_object_from_cdn_with_emailzos.path.getsizec C sp d|_ tj}tjdd�}|t_tj�t�}t di | d�}d}| j j |||d�}|t_| � |j � | �|d� d S )Nr �test�r� r� rZ r� r� )r� r r� �mockr r� r� r� r� r r( �ex_multipart_upload_objectr� r� r7 )r+ Z getsize_mockr� Zmocked_upload_objectr� rW rw rg r, r, r- �/test_ex_multipart_upload_object_for_small_files� s � z?CloudFilesTests.test_ex_multipart_upload_object_for_small_filesc C s� t j}t j}tjdd�}tjdd�}|t _|t _d}tj�t�}t t � t tj� |��| ��}tdi | d�}d} | jj||| |d� |t _|t _| �|j|� | �|jd � d S ) NZ test_partr Z test_manifestrl r� rZ r� )r� rW rw r� � )r �_upload_object_part�_upload_object_manifestr r r� r� r� r� �int�math�ceil�float�getsizer r( r r7 Z call_countr� ) r+ r r Zmocked__upload_object_partZ mocked__upload_object_manifest�partsr� r� rW rw r, r, r- �'test_ex_multipart_upload_object_success� s* � �z7CloudFilesTests.test_ex_multipart_upload_object_successc C s� t j}tjdd�}|t _d}d}|d| }tdi | d�}| j�|||d � |t _t|j�d }| � |d |� | � |d |� d S ) Nr r r� ru z/%08dr� rZ r rw rW ) r � _put_objectr r r r( r �tuple� call_argsr7 )r+ r Zmocked__put_objectZ part_numberrw Z expected_namerW � func_kwargsr, r, r- �test__upload_object_part� s �z(CloudFilesTests.test__upload_object_partc s� ddd�}ddi� � � |� d� �fdd � }|�jj_td i �jd �}z �jjtd �|d |d� W n tyt Y n 0 ��d� dS )zy Test we can add some ``Cross-origin resource sharing`` headers to the request about to be sent. zhttp://mozilla.comz http://storage.clouddrive.com)zAccess-Control-Allow-OriginZOriginz Content-Typezapplication/octet-streamNTc s �� � |� td��d S )NZoops)ZassertDictEqual�NotImplementedError)r? �method�datar� �raw�Zexpected_headersr+ r, r- �intercept_request� s zZCloudFilesTests.test_upload_object_via_stream_with_cors_headers.<locals>.intercept_requestZCORSrZ � blob data like an image or videoru )r� rW rw r� z\Expected NotImplementedError to be thrown to verify we actually checked the expected headers)NNNT) �updater( r) r� r r� �iterr r9 )r+ Z cors_headersr$ rW r, r# r- �/test_upload_object_via_stream_with_cors_headers� s* �� � � z?CloudFilesTests.test_upload_object_via_stream_with_cors_headersc C s< t di | jd�}d}|jt|�dd�}| �t|�|j� d S )N�py3rZ r% Z img_or_vid�r� rw )r r( r� r' r7 rT rS )r+ rW � bytes_blobZmocked_responser, r, r- �1test_upload_object_via_stream_python3_bytes_error� s �zACloudFilesTests.test_upload_object_via_stream_python3_bytes_errorz*Skipping as chunking is disabled in 2.0rc1c s� d� dd� ttd �D ��}dt �d�}|d t|d t� �d��ddt|td � �d��dd g}g �G � �fd d �d t�� � | jj_t d i | j d �}|j t |�dd� | � |�� d S )Nr� c S s g | ]}d �qS )� r, )rM �_r, r, r- rO � rP zRCloudFilesTests.test_upload_object_via_stream_chunked_encoding.<locals>.<listcomp>r z%X�utf8s s 1 s 0 c s* e Zd Zd�� �fdd� Zdd� Z� ZS )zYCloudFilesTests.test_upload_object_via_stream_chunked_encoding.<locals>.InterceptResponseNc s: t �| �j||d� | jjj� �� fdd�}|| jj_d S )N)r) r� c s �| � � � | � d S r/ )�append)r! )� logged_data�old_sendr, r- �intercept_send s zzCloudFilesTests.test_upload_object_via_stream_chunked_encoding.<locals>.InterceptResponse.__init__.<locals>.intercept_send)�super�__init__r) �send)r+ r) r� r3 )�InterceptResponse� __class__r1 )r2 r- r5 s � zbCloudFilesTests.test_upload_object_via_stream_chunked_encoding.<locals>.InterceptResponse.__init__c S s, ddi}|� | j� tj}|d|tj| fS )Nr� Z d79fb00c27b50494a463e680d459c90cr� �r& � base_headersr �CREATED� responses)r+ r rG �bodyr� Z_201r, r, r- � _v1_MossoCloudFS_py3_img_or_vid2 s zzCloudFilesTests.test_upload_object_via_stream_chunked_encoding.<locals>.InterceptResponse._v1_MossoCloudFS_py3_img_or_vid2)N)�__name__� __module__� __qualname__r5 r> � __classcell__r, �r7 r1 )r8 r- r7 s r7 r) rZ Z img_or_vid2r* )r� r� r �encode�bytesr r" r# ZrawResponseClsr r( r� r' ZassertListEqual)r+ r+ Zhex_chunk_size�expectedrW r, rC r- �.test_upload_object_via_stream_chunked_encoding� s& � �z>CloudFilesTests.test_upload_object_via_stream_chunked_encodingc C s� | j �� }|�td�� |�� }tdddd|ii�}| j jj}tj |d�}|| j j_t di | d�}d }| j � ||� t |j �\}} || j j_| �|d d |j d | � | �| d d |jd | d � | �| d d� d S )Nr� �CloudFilesResponser, r� r� r r� rZ ru r �/zX-Object-Manifestr �PUT)r( Z_get_hash_functionr& r � hexdigestr$ r) r� r r r r r r r7 rL ) r+ Z hash_functionr� � fake_response�_request�mocked_requestrW rw Z func_argsr r, r, r- � test__upload_object_manifest* s* � ��z,CloudFilesTests.test__upload_object_manifestc C s� t dddddii�}| jjj}tj|d�}|| jj_tdi | d�}d }z>z| j�||� W n tyl Y n 0 | � d � W || jj_n || jj_0 d S ) NrH r, r� r� Z0000000r r� rZ ru r4 ) r$ r( r) r� r r r r r r9 )r+ rL rM rN rW rw r, r, r- �'test__upload_object_manifest_wrong_hashF s � z7CloudFilesTests.test__upload_object_manifest_wrong_hashc C sp ddd�}t j}|t _d}d}tj�t�}| jj|d�}| �|j |� | jj |||d�}| �|j |� |t _d S )Nc S s t dddid�ddd�S r� r� r� r, r, r- r� [ s �zSCloudFilesTests.test_create_container_put_object_name_encoding.<locals>.upload_file� speci@l_name� m@obj€ctrn r� )NNNNNNN) r r� r� r� r� r� r( r� r7 rL r� )r+ r� r� ro rw r� rW rg r, r, r- �.test_create_container_put_object_name_encodingZ s" � �z>CloudFilesTests.test_create_container_put_object_name_encodingc C s, t di | d�}| jj|dd�}| �|� d S )Nr� rZ z index.html)rW Z index_file)r r( Zex_enable_static_websiter� r� r, r, r- � test_ex_enable_static_websiter s �z-CloudFilesTests.test_ex_enable_static_websitec C s, t di | d�}| jj|dd�}| �|� d S )Nr� rZ z error.html)rW � file_name)r r( Zex_set_error_pager� r� r, r, r- �test_ex_set_error_pagex s �z&CloudFilesTests.test_ex_set_error_pagec C s | j �d�}| �|� d S )Nza key)r( Z$ex_set_account_metadata_temp_url_keyr� )r+ r� r, r, r- �)test_ex_set_account_metadata_temp_url_key~ s z9CloudFilesTests.test_ex_set_account_metadata_temp_url_keyz(libcloud.storage.drivers.cloudfiles.timec C s� d|_ t�� | j_ddddd�| jj_ tdi | d�}tddd i |d | d �}d d }t�t d�t |�t �� � }| j� |d �}d | j |f }| �d�t|��d�t|��� d S )Nr r Zfoo�r� rQ r r r� rZ r� r� r� z%s %s %s)�GET�< z1/v1/MossoCloudFS/foo_bar_container/foo_bar_objectrY zxhttps://storage4.%s1.clouddrive.com/v1/MossoCloudFS/foo_bar_container/foo_bar_object?temp_url_expires=60&temp_url_sig=%sr� )r� r r r( r r r �hmac�newr r rK �ex_get_object_temp_urlr r7 r� �sorted)r+ �timerW rg Z hmac_body�sig�retZtemp_urlr, r, r- �test_ex_get_object_temp_url� s& � ��z+CloudFilesTests.test_ex_get_object_temp_urlc C s\ t �� | j_dddd d�| jj_tdi | d�}tddd i |d | d�}| �t| jj |d� d S ) Nr rX r� rZ r� r� r� rY ) r r r( r r� r r Z assertRaises�KeyErrorr] r� r, r, r- �3test_ex_get_object_temp_url_no_key_raises_key_error� s � � �zCCloudFilesTests.test_ex_get_object_temp_url_no_key_raises_key_errorc C s6 t j�t�d }zt �|� W n ty0 Y n0 d S )Nr� )r� r� r� r� �unlinkr� )r+ r� r, r, r- r* � s z!CloudFilesTests._remove_test_fileN)Gr? r@ rA r r" r' r% r r. r1 r; r< rB rE rF rH rX rh ri rk rm rr rt 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 �patchr r r r( r, r �skiprG rO rP rS rT rV rW rb rd r* r, r, r, r- r 8 s� ! ! * 0 r c @ s e Zd ZeZdZdS )�CloudFilesDeprecatedUSTestsr N�r? r@ rA r r" r r, r, r, r- rh � s rh c @ s e Zd ZeZdZdS )�CloudFilesDeprecatedUKTestsZlonNri r, r, r, r- rj � s rj c @ s e Zd Zed�ZddiZdd� Zdd� Zdd � Zd d � Z d d � Z dd� Z dd� Z dd� Z dd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd*d+� Zd,d-� Zd.d/� Zd0d1� Z d2d3� Z d4d5� Z d6d7� Z d8d9� Z d:d;� Z!d<d=� Z"d>d?� Z#d@dA� Z$dBdC� Z%dDS )Er! Z cloudfiles� content-typez application/json; charset=UTF-8c C s. t �| j�}| j�d�}tj||tjtj fS )Nz_v2_0__auth.json)r& �deepcopyr: �fixtures�loadr �OKr< �r+ r rG r= r� r, r, r- � _v2_0_tokens� s �z CloudFilesMockHttp._v2_0_tokensc C s d}t j|| jt jt j fS )Nzbroken: json /*"�r � NO_CONTENTr: r< ro rp r, r, r- � _v1_MossoCloudFS_MALFORMED_JSON� s �z2CloudFilesMockHttp._v1_MossoCloudFS_MALFORMED_JSONc C s t j|| jt jt j fS r/ rr rp r, r, r- �_v1_MossoCloudFS_EMPTY� s �z)CloudFilesMockHttp._v1_MossoCloudFS_EMPTYc C s| t �| j�}|dkr(| j�d�}tj}n@|dkrV| j�d�}tj}|�dddd�� n|d krhd }tj}|||tj tj fS ) NrY zlist_containers.json�HEADzmeta_data.json�10Z400Z1234567)zx-account-container-countzx-account-object-countzx-account-bytes-used�POSTr� ) r& rl r: rm rn r ro rs r& r< �r+ r rG r= r� � status_coder, r, r- �_v1_MossoCloudFS� s � z#CloudFilesMockHttp._v1_MossoCloudFSc C s. |dkrd}nt d��tj|| jtjtj fS �Nrv r� zInvalid method�� ValueErrorr r� r: r< ro rp r, r, r- �_v1_MossoCloudFS_not_found� s �z-CloudFilesMockHttp._v1_MossoCloudFS_not_foundc C s$ | j �d�}tj|| jtjtj fS �N�!list_container_objects_empty.json�rm rn r ro r: r< rp r, r, r- �%_v1_MossoCloudFS_test_container_EMPTY� s �z8CloudFilesMockHttp._v1_MossoCloudFS_test_container_EMPTYc C s$ | j �d�}tj|| jtjtj fS r� r� rp r, r, r- �+_v1_MossoCloudFS_test_20container_201_EMPTY� s �z>CloudFilesMockHttp._v1_MossoCloudFS_test_20container_201_EMPTYc C s� t �| j�}|dkrB|�d�dkr6| j�d�}tj}qld}tj}n*|dkrl| j�d�}tj}|� dd d �� |||tj tj fS ) NrY �marker���zlist_container_objects.jsonr� rv r� Z800Z1234568)zx-container-object-countzx-container-bytes-used) r& rl r: �findrm rn r ro rs r& r< ry r, r, r- � _v1_MossoCloudFS_test_container� s �z2CloudFilesMockHttp._v1_MossoCloudFS_test_containerc C sn t �| j�}|�d�dkr.| j�d�}tj}n,|�d�dkrHd}tj}n| j�d�}tj}|||tj tj fS )Nz foo-test-3r� z*list_container_objects_not_exhausted2.jsonz foo-test-5r� z*list_container_objects_not_exhausted1.json) r& rl r: r� rm rn r ro rs r< ry r, r, r- �(_v1_MossoCloudFS_test_container_ITERATOR s ��z;CloudFilesMockHttp._v1_MossoCloudFS_test_container_ITERATORc C s. |dkrd}nt d��tj|| jtjtj fS r| r} rp r, r, r- �)_v1_MossoCloudFS_test_container_not_found$ s �z<CloudFilesMockHttp._v1_MossoCloudFS_test_container_not_foundc C sR t �| j�}|dkr>| j�d�}tj}|�ddddddd �� |||tjtj fS � Nrv r� Z555r{ rx r| r} rz )�content-lengthz last-modifiedr� zx-object-meta-foo-barzx-object-meta-bar-foork � r& rl r: rm rn r rs r& r< ro ry r, r, r- �+_v1_MossoCloudFS_test_container_test_object0 s �z>CloudFilesMockHttp._v1_MossoCloudFS_test_container_test_objectc C sR t �| j�}|dkr>| j�d�}tj}|�ddddddd �� |||tjtj fS r� r� ry r, r, r- �/_v1_MossoCloudFS_test_container__7E_test_object? s �zBCloudFilesMockHttp._v1_MossoCloudFS_test_container__7E_test_objectc C sN t �| j�}| j�d�}t �| j�}|�ddd�� tj}|||tjtj fS )Nr� �18� Mon, 28 Feb 2011 07:52:57 GMT�r� �date) r& rl r: rm rn r& r r; r< ro ry r, r, r- �&_v1_MossoCloudFS_test_create_containerN s �z9CloudFilesMockHttp._v1_MossoCloudFS_test_create_containerc C sh d}t |�}| �||v � t�| j�}| j�d�}t�| j�}|�ddd�� tj }|||tj tj fS )NrQ r� r� r� r� ) r r� r& rl r: rm rn r& r r; r< ro )r+ r rG r= r� ro Zencoded_container_namerz r, r, r- � _v1_MossoCloudFS_speci_40l_nameZ s �z2CloudFilesMockHttp._v1_MossoCloudFS_speci_40l_namec C s@ t �| j�}| j�d�}|�ddi� tj}|||tjtj fS )Nr� rk z text/plain) r& rl r: rm rn r& r �ACCEPTEDr< ro ry r, r, r- �5_v1_MossoCloudFS_test_create_container_ALREADY_EXISTSj s zHCloudFilesMockHttp._v1_MossoCloudFS_test_create_container_ALREADY_EXISTSc C sN |dkr"| j �d�}| j}tj}n|dkr:d}| j}tj}|||tjtj fS )N�DELETEr� rx r� )rm rn r: r rs r� r< ro ry r, r, r- �"_v1_MossoCloudFS_foo_bar_containers s z5CloudFilesMockHttp._v1_MossoCloudFS_foo_bar_containerc C s( |dkr| j }tj}|||tjtj fS )Nr� )r: r rs r< ro ry r, r, r- �7_v1_MossoCloudFS_foo_bar_container_object_PURGE_SUCCESS� s zJCloudFilesMockHttp._v1_MossoCloudFS_foo_bar_container_object_PURGE_SUCCESSc C s8 |dkr$| � |d d� | j}tj}|||tjtj fS )Nr� z X-Purge-Emailr )r7 r: r rs r< ro ry r, r, r- �=_v1_MossoCloudFS_foo_bar_container_object_PURGE_SUCCESS_EMAIL� s zPCloudFilesMockHttp._v1_MossoCloudFS_foo_bar_container_object_PURGE_SUCCESS_EMAILc C s4 |dkr | j �d�}| j}tj}|||tjtj fS �Nr� r� )rm rn r: r r� r< ro ry r, r, r- �,_v1_MossoCloudFS_foo_bar_container_NOT_FOUND� s z?CloudFilesMockHttp._v1_MossoCloudFS_foo_bar_container_NOT_FOUNDc C s4 |dkr | j �d�}| j}tj}|||tjtj fS r� )rm rn r: r �CONFLICTr< ro ry r, r, r- �,_v1_MossoCloudFS_foo_bar_container_NOT_EMPTY� s z?CloudFilesMockHttp._v1_MossoCloudFS_foo_bar_container_NOT_EMPTYc C s` |dkr4| j �d�}| j}tj}|||tjtj fS |dkr\td�}tj|| jtjtj fS d S )Nr� r� rY r� )rm rn r: r rs r< ro r ry r, r, r- �1_v1_MossoCloudFS_foo_bar_container_foo_bar_object� s �zDCloudFilesMockHttp._v1_MossoCloudFS_foo_bar_container_foo_bar_objectc C sf |dkrbd}| � d|v � | �|d d� | �|d |�\}}tj|||d � | jtjtj fS d S )NrY Z0123456789123456789�Rangez bytes=5-6r )r� r7 Z'_get_start_and_end_bytes_from_range_strr �PARTIAL_CONTENTr: r< )r+ r rG r= r� r� r� r, r, r- �7_v1_MossoCloudFS_foo_bar_container_foo_bar_object_range� s �zJCloudFilesMockHttp._v1_MossoCloudFS_foo_bar_container_foo_bar_object_rangec C s* ddi}|� | j� tjd|tjtj fS )Nr� Z e2378cace8712661ce7beec3d9362ef6r� r9 rp r, r, r- � _v1_MossoCloudFS_py3_img_or_vid� s z2CloudFilesMockHttp._v1_MossoCloudFS_py3_img_or_vidc C s2 d}i }|� | j� d|d< tj||tjtj fS �Nr� �hash343hhash89h932439jsaa89r� �r& r: r r; r< ro rp r, r, r- �2_v1_MossoCloudFS_foo_bar_container_foo_test_upload� s zECloudFilesMockHttp._v1_MossoCloudFS_foo_bar_container_foo_test_uploadc C s: d}t |� t�| j�}d}d|d< tj||tjtj fS )NrR r� r� r� )r r& rl r: r r; r< ro )r+ r rG r= r� rw r, r, r- �2_v1_MossoCloudFS_speci_40l_name_m_40obj_E2_82_ACct� s zECloudFilesMockHttp._v1_MossoCloudFS_speci_40l_name_m_40obj_E2_82_ACctc C s2 d}i }|� | j� d|d< tj||tjtj fS r� r� rp r, r, r- �(_v1_MossoCloudFS_foo_bar_container_empty� s z;CloudFilesMockHttp._v1_MossoCloudFS_foo_bar_container_emptyc C s2 d}i }|� | j� d|d< tj||tjtj fS )Nr� r� r� r� rp r, r, r- �?_v1_MossoCloudFS_foo_bar_container_foo_test_upload_INVALID_HASH� s �zRCloudFilesMockHttp._v1_MossoCloudFS_foo_bar_container_foo_test_upload_INVALID_HASHc C s t d�}tj|| jtjtj fS )N�d )r r ro r: r< rp r, r, r- �>_v1_MossoCloudFS_foo_bar_container_foo_bar_object_INVALID_SIZE� s �zQCloudFilesMockHttp._v1_MossoCloudFS_foo_bar_container_foo_bar_object_INVALID_SIZEc C s d}t j|| jt jt j fS )Nr� )r r� r: r< ro rp r, r, r- �;_v1_MossoCloudFS_foo_bar_container_foo_bar_object_NOT_FOUND� s �zNCloudFilesMockHttp._v1_MossoCloudFS_foo_bar_container_foo_bar_object_NOT_FOUNDc C sL t �� }|�d� |�� }i }|�| j� ||d< d}tj||tjtj fS )Ns 235r� r � �hashlib�md5r& rK r: r r; r< ro �r+ r rG r= r� Zhasher� hash_valuer, r, r- �7_v1_MossoCloudFS_foo_bar_container_foo_test_stream_data s �zJCloudFilesMockHttp._v1_MossoCloudFS_foo_bar_container_foo_test_stream_datac C sL t �� }|�d� |�� }i }|�| j� ||d< d}tj||tjtj fS )Ns 123456789r� r r� r� r, r, r- �<_v1_MossoCloudFS_foo_bar_container_foo_test_stream_data_seek s �zOCloudFilesMockHttp._v1_MossoCloudFS_foo_bar_container_foo_test_stream_data_seekc C s6 i }|� | j� d|d< td�}tj||tjtj fS )NZ 577ef1154f3240ad5b9b413aa7346a1er� r� )r& r: r r ro r< rp r, r, r- �;_v1_MossoCloudFS_foo_bar_container_foo_bar_object_NO_BUFFER% s �zNCloudFilesMockHttp._v1_MossoCloudFS_foo_bar_container_foo_bar_object_NO_BUFFERN)&r? r@ rA r rm r: rq rt ru 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! � sD r! �__main__)6r[ r� �os.pathr �sysr& �ior r� r r r r Zlibcloud.utils.filesr� Zlibcloud.utils.py3r r r r r r Zlibcloud.common.typesr Zlibcloud.storage.baser r r Zlibcloud.storage.typesr r r r r r Z#libcloud.storage.drivers.cloudfilesr Z libcloud.testr r r r Zlibcloud.test.file_fixturesr Zlibcloud.test.storage.baser ZTestCaser rh rj r! r? �exit�mainr, r, r, r- �<module> sZ | |
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка