File: //usr/lib/python3/dist-packages/duplicity/backends/__pycache__/b2backend.cpython-310.pyc
o
l��`C# � @ s� d dl mZ e�� d dlmZ d dlmZ d dlmZ d dlm Z d dlm
Z
d dlm Z d dl m
Z
mZ d d lZG d
d � d e�ZG d d
� d
ejj�Zej�de� d S )� )�standard_library)�object)�
quote_plus)�log)�progress)�util)�config)�BackendException�FatalBackendExceptionNc @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd S ) �B2ProgressListenerc C � d S �N� ��selfr r �>/usr/lib/python3/dist-packages/duplicity/backends/b2backend.py� __enter__) � z B2ProgressListener.__enter__c C s
|| _ d S r
)�total_byte_count)r r r r r �set_total_bytes, s
z"B2ProgressListener.set_total_bytesc C s t �|| j� d S r
)r �report_transferr )r �
byte_countr r r �bytes_completed/ s z"B2ProgressListener.bytes_completedc C r r
r r r r r �close2 r zB2ProgressListener.closec C r r
r )r �exc_type�exc_val�exc_tbr r r �__exit__5 r zB2ProgressListener.__exit__N)�__name__�
__module__� __qualname__r r r r r r r r r r ( s r c @ sH e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dS )� B2Backendz4
Backend for BackBlaze's B2 storage service
c C s, t jj�| |� zddlm} |�d�}dd� |D �| _W n g d�| _Y zddlm } ddlm
} dd l m } W n� t
y� z'ddlm } ddlm
} dd
lma dd lm } | jg d �k rhdd lma W nz t
y� z ddlm } ddlm
} dd
lma dd lm } dd lma W nP t
y� } zDd
t|dd
�v r�� z ddlm } ddlm
} dd
lma dd l m } dd l ma W n t
y� dt|dd�v rт t d��w W Y d}~nd}~ww Y nw Y nw ||� �| _ d| j _!|j"}| �#� } dd� |j$�%dd��d�D �| _&| j&�r| j&�'d�| _"| j&�'d�}
nt d��d�(dd� | j&D ��| _$| j �)d|| � zt*�+d| j$|
| j j,�-� f t*j.� W n t/�y` t*�+d| j$|
| j j,�0� f t*j.� Y nw z| j �1|
�| _2t*�+d t*j.� W dS |�y� zt*�+d t*j.� | j �3|
d �| _2W Y dS t4d ��w ) zA
Authorize to B2 api and set up needed variables
r )� __version__�.c S s g | ]}t |��qS r )�int��.0�xr r r �
<listcomp>I � z&B2Backend.__init__.<locals>.<listcomp>)r r r )�B2Api)�InMemoryAccountInfo)�NonExistentBucket)�DownloadDestLocalFile�� � r )�FileVersionInfoFactory�b2sdk�name�b2z5B2 backend requires B2 Python SDK (pip install b2sdk)N�B2c S s g | ]}|d kr|�qS )� r r% r r r r( u s �@�/zB2 requires a bucket namer6 c S s g | ]}|d �qS )r8 r )r& �url_partr r r r( } r) �
productionz<B2 Backend (path= %s, bucket= %s, recommended_part_size= %s)z8B2 Backend (path= %s, bucket= %s, minimum_part_size= %s)z Bucket foundz Bucket not found, creating one�
allPrivatezBucket cannot be created)5� duplicity�backend�Backend�__init__r2 r" �split�v_num�b2sdk.v2r* r+ �b2sdk.v2.exceptionr, � ImportError�b2sdk.v1r- �b2sdk.v1.exception�b2sdk.v1.file_versionr1 � b2sdk.api�b2sdk.account_info�b2sdk.download_dest�b2sdk.exception�b2sdk.file_version�getattr�b2.api�b2.account_info�b2.download_dest� b2.exception�b2.file_versionr �service�
parsed_url�hostname�username� get_password�path�replace� url_parts�pop�join�authorize_accountr �Log� account_info�get_recommended_part_size�INFO�AttributeError�get_minimum_part_size�get_bucket_by_name�bucket�
create_bucketr
) r rT �VERSION�v_splitr* r+ r, �e�
account_id� account_key� bucket_namer r r r? > s�
� � ������� �������zB2Backend.__init__c C s� t �d| jt�|� t�|j�f t j� | jg d�k r1| j� t
| jt�|� d�t |j�� dS | j� t
| jt�|� d��}|� |j� dS )z8
Download remote_filename to local_path
z
Get: %s -> %s)r/ � r r8 N)
r r^ rX r �fsdecoder3 ra rA re �download_file_by_namer r- �save_to)r �remote_filename�
local_path�dfr r r �_get� s
��� zB2Backend._getc C s^ t �dt�|j�| jt�|� f t j� | jjt�|j�t | jt�|� d�dt
� d� dS )z5
Copy source_path to remote_filename
z
Put: %s -> %sr8 zapplication/pgp-encrypted)� content_type�progress_listenerN) r r^ r rn r3 rX ra re �upload_local_filer r )r � source_pathrq r r r �_put� s ��
�zB2Backend._putc s � fdd�� j �� j�D �S )z-
List files on remote server
c s$ g | ]\}}|j t� j�d � �qS r
)� file_name�lenrX )r& �file_version_info� folder_namer r r r( � s �z#B2Backend._list.<locals>.<listcomp>)re �lsrX r r r r �_list� s
�zB2Backend._listc C s^ | j t�|� }t�d| tj� tjr | j� |� dS | �
t |d��}| j� |j
|j� dS )z4
Delete filename from remote server
z
Delete: %sr8 N)rX r rn r r^ ra r �
b2_hide_filesre � hide_file� file_infor �delete_file_version�id_rz )r �filename�
full_filenamer| r r r �_delete� s zB2Backend._deletec C s` t �d| j t�|� t j� | �t| jt�|� d��}d|dur-|jdur-t |j�iS diS )z+
Get size info of filename
z Query: %sr8 �sizeN���)
r r^ rX r rn ra r� r r� r$ )r r� r| r r r �_query� s ��zB2Backend._queryc C sh | j g d�kr
| j�|�S | jjj�| jj|d| j�}|d D ]}t� |�}|j
|kr/| S q t d��)Nr. r/ �fileszFile not found) rA re �get_file_info_by_name�api�session�list_file_namesr� rX r1 �from_api_responserz r )r r� �response�entryr| r r r r� � s
�zB2Backend.file_infoN) r r r �__doc__r? rt ry r r� r� r� r r r r r! 9 s S
r! r4 )�futurer �install_aliases�builtinsr � urllib.parser r< r r r r �duplicity.errorsr r
�duplicity.backendr r= r> r! �register_backendr r r r �<module> s