File: //usr/lib/python3/dist-packages/duplicity/backends/__pycache__/swiftbackend.cpython-310.pyc
o
��La)( � @ sr d dl mZ d dlZd dlZd dlmZ d dlmZ d dlmZ d dlm Z G dd� dej
j �Z ej
�
d e � dS )
� )�strN)�config)�log)�util)�BackendExceptionc @ sH e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dS )� SwiftBackendz
Backend for Swift
c
C s2 t jj�| |� zddlm} ddlm} ddlm} W n t y0 } zt
dt |� ��d }~ww || _ i }i }i }dt
jv rSdt
jv rSt
jd |d< t
jd |d < n<d
t
jvr\t
d ��d t
jvret
d
��dt
jvrnt
d��t
jd
|d< |d< t
jd |d< |d< t
jd |d< |d< dt
jv �r4t
jd |d< |d< t
jd dk�r3dt
jv r�|�dt
jd i� dt
jv r�|�d t
jd i� d t
jv r�|�d t
jd i� d t
jv r�|�d t
jd i� d!t
jv r�|�d"t
jd! i� d#t
jv �r|�d$t
jd# i� d%t
jv �r|�d&t
jd% i� d't
jv �r#|�d(t
jd' i� d)t
jv �r3|�d*t
jd) i� nd+|d< d!t
jv �rEt
jd! |d"< d)t
jv �rU|�d*t
jd) i� |�� D ] } || |d,| < �qY||d-< d.d/� |j�d0�D �}
|
�d�| _|
�r�d1d0�|
� | _nd2| _tj} d3} d }
zt�d4| � |d>i |��| _| j� | j�}
W nB |�y� } zt�d5|j j t |�f � W Y d }~n'd }~w t �y� } zt� d5|j j t |�f tj!j"� W Y d }~nd }~ww |
d u �r3t�#d6| j � z| �rt$| | gg�nd }| jj%| j|d7� W nF t �y2 } zt� d8|j j t |�f tj!j"� W Y d }~n(d }~ww | �rO|
| �&� | k�rOt� d9| j|
| �&� | f � nt�d:|
� zt�d;| � ||d<�| _'| j'�(| j�}W n# |�y� } zt� d5|j j t |�f tj!j"� W Y d }~nd }~ww t�d=| � d S )?Nr )� SwiftService)�
Connection)�ClientExceptionzDSwift backend requires the python-swiftclient library.
Exception: %s�SWIFT_PREAUTHURL�SWIFT_PREAUTHTOKEN�
preauthurl� preauthtoken�SWIFT_USERNAMEz,SWIFT_USERNAME environment variable not set.�SWIFT_PASSWORDz,SWIFT_PASSWORD environment variable not set.�
SWIFT_AUTHURLz+SWIFT_AUTHURL environment variable not set.� os_username�user� os_password�key� os_auth_url�authurl�SWIFT_AUTHVERSION� auth_version�3�SWIFT_USER_DOMAIN_NAME�user_domain_name�SWIFT_USER_DOMAIN_ID�user_domain_id�SWIFT_PROJECT_DOMAIN_NAME�project_domain_name�SWIFT_PROJECT_DOMAIN_ID�project_domain_id�SWIFT_TENANTNAME� tenant_name�SWIFT_ENDPOINT_TYPE�
endpoint_type� SWIFT_USERID�user_id�SWIFT_TENANTID� tenant_id�SWIFT_REGIONNAME� region_name�1�os_�
os_optionsc S s g | ]}|d kr|�qS )� � )�.0�xr1 r1 �A/usr/lib/python3/dist-packages/duplicity/backends/swiftbackend.py�
<listcomp>p s z)SwiftBackend.__init__.<locals>.<listcomp>�/z%s/r0 zX-Storage-Policyz'Starting connection with arguments:'%s'zConnection failed: %s %szCreating container %s)�headersz Container creation failed: %s %sz>Container '%s' exists but its storage policy is '%s' not '%s'.z Container already created: %sz Starting Swiftservice: '%s'��optionszContainer stats: %sr1 ))� duplicity�backend�Backend�__init__�swiftclient.servicer � swiftclientr r
� ImportErrorr r �resp_exc�os�environ�update�keys�path�split�pop� container�join�prefixr �swift_storage_policyr �Debug�conn�head_container� __class__�__name__� Exception�
FatalError� ErrorCode�connection_failed�Info�dict�
put_container�lower�svc�stat)�self�
parsed_urlr r r
�e� conn_kwargsr/ � svc_optionsr � url_parts�policy�
policy_header�container_metadatar7 �container_statr1 r1 r4 r= # s� ���
� � �����
����� ����zSwiftBackend.__init__c C s& t || j�r|jdkrtjjS d S d S )Ni� )�
isinstancerA � http_statusr rT �backend_not_found)r\ � operationr^ r1 r1 r4 � _error_code� s
�zSwiftBackend._error_codec
C s� t �|j�}tjdkrQddlm} t�|�}|j tjkrQt
� d� | j j
| j||| jt �|� d�gdtjid�}dd� |D �}|D ] }|d sNt|d
��qBd S | jt �|� } t
� d || | jf � | jj| j| jt �|� t|d �d
� d S )Nr )�SwiftUploadObjectz Uploading Dynamic Large Object)� object_name� segment_sizer8 c S s g | ]
}d |d vr|�qS )rI �actionr1 �r2 �ar1 r1 r4 r5 � s z%SwiftBackend._put.<locals>.<listcomp>�success� tracebackz/Uploading '%s' to '%s' in remote container '%s'�rb)rI �obj�contents)r �fsdecode�namer �mp_segment_sizer> rk rB r[ �st_sizer rM rZ �uploadrI rK r rN �
put_object�open)
r\ � source_path�remote_filename�lprk �st�mp�uploadsrz �rpr1 r1 r4 �_put� s2
�� �
�zSwiftBackend._putc C sj | j j| j| jt�|� dd�\}}t|jd��}|D ]}|�|� qW d � d S 1 s.w Y d S )Ni )�resp_chunk_size�wb) rN �
get_objectrI rK r rv r| rw �write)r\ r~ �
local_pathr7 �body�f�chunkr1 r1 r4 �_get� s
� �"�zSwiftBackend._getc s, � j j� jd� jd�\}}� fdd�|D �S )NT)� full_listingrF c s" g | ]
}|d t � j�d� �qS )rw N)�lenrK )r2 �o�r\ r1 r4 r5 � s " z&SwiftBackend._list.<locals>.<listcomp>)rN �
get_containerrI rK )r\ r7 �objsr1 r� r4 �_list� s zSwiftBackend._listc C s, dd� | j �| j| jt�|� g�D �}d S )Nc S � g | ]}|�qS r1 r1 ro r1 r1 r4 r5 � � z(SwiftBackend._delete.<locals>.<listcomp>)rZ �deleterI rK r rv )r\ �filename�deletedr1 r1 r4 �_delete� s ,zSwiftBackend._deletec C s` dd� | j �| j| jt�|� g�D �d }dt|d d �i}t�dt�|�|d f � |S )Nc S r� r1 r1 ro r1 r1 r4 r5 � r� z'SwiftBackend._query.<locals>.<listcomp>r �sizer7 zcontent-lengthz Objectquery: '%s' has size %s.) rZ r[ rI rK r rv �intr rM )r\ r� �sobject�sobjr1 r1 r4 �_query� s , zSwiftBackend._queryN) rQ �
__module__� __qualname__�__doc__r= rj r� r� r� r� r� r1 r1 r1 r4 r s r �swift)�builtinsr rB �duplicity.backendr: r r r �duplicity.errorsr r; r< r �register_backendr1 r1 r1 r4 �<module> s <