File: //usr/lib64/python3.9/site-packages/borg/crypto/__pycache__/file_integrity.cpython-39.opt-1.pyc
a
HZ�h� � @ s� d dl Z d dlZd dlZd dlZd dlmZ ddlmZ ddlm Z ddl
m Z e � ZG dd� d�Z G d d
� d
e �Z
G d d � d e
�ZG d
d� de
�ZejeejeiZG dd� de�ZG dd� de �ZG dd� de�ZdS )� N)�compare_digest� )�IntegrityError)�
create_logger)�StreamingXXH64c @ sT e Zd Zdd� Zdd� Zdd� Zejfdd�Zd d
� Z dd d
�Z
dd� Z dd� Z d S )�FileLikeWrapperc C s | j �� | S �N)�fd� __enter__��self� r
�@/usr/lib64/python3.9/site-packages/borg/crypto/file_integrity.pyr
s
zFileLikeWrapper.__enter__c C s | j �|||� d S r )r �__exit__�r �exc_type�exc_val�exc_tbr
r
r r s zFileLikeWrapper.__exit__c C s
| j �� S r )r �tellr r
r
r r s zFileLikeWrapper.tellc C s | j �||�S r )r �seek)r �offset�whencer
r
r r s zFileLikeWrapper.seekc C s | j �|�S r )r �write�r �datar
r
r r s zFileLikeWrapper.writeNc C s | j �|�S r )r �read)r �nr
r
r r s zFileLikeWrapper.readc C s | j �� d S r )r �flushr r
r
r r " s zFileLikeWrapper.flushc C s
| j �� S r )r �filenor r
r
r r % s zFileLikeWrapper.fileno)N)
�__name__�
__module__� __qualname__r
r r �io�SEEK_SETr r r r r r
r
r
r r s
r c sj e Zd ZdZdZdZdd� Z� fdd�Z� fdd�Zd� fd d
� Z d d � Z
e d
�dd�Z ddd�Z
� ZS )�FileHashingWrappera'
Wrapper for file-like objects that computes a hash on-the-fly while reading/writing.
WARNING: Seeks should only be used to query the size of the file, not
to skip data, because skipped data isn't read and not hashed into the digest.
Similarly skipping while writing to create sparse files is also not supported.
Data has to be read/written in a symmetric fashion, otherwise different
digests will be generated.
Note: When used as a context manager read/write operations outside the enclosed scope
are illegal.
Nc C s || _ || _| �� | _d S r )r �writing�FACTORY�hash)r �
backing_fdr r
r
r �__init__< s zFileHashingWrapper.__init__c s$ |d u r| � � t� �|||� d S r )� hash_length�superr r �� __class__r
r r A s zFileHashingWrapper.__exit__c s t � �|�}| j�|� |S )zI
Write *data* to backing file and update internal state.
)r+ r r' �update)r r r r, r
r r F s zFileHashingWrapper.writec s t � �|�}| j�|� |S )zf
Read *data* from backing file (*n* has the usual meaning) and update internal state.
)r+ r r' r. )r r r r, r
r r N s zFileHashingWrapper.readc C s
| j �� S )zn
Return current digest bytes as hex-string.
Note: this can be called multiple times.
)r' � hexdigestr r
r
r r/ V s z FileHashingWrapper.hexdigest�r c C s | j �|� d S r )r' r. r r
r
r r. ^ s zFileHashingWrapper.updateFc C s. |r| � dtj� | j�t| �� ��� � d S )Nr )r r" �SEEK_ENDr' r. �strr �encode)r � seek_to_endr
r
r r* a s z FileHashingWrapper.hash_length)N)F)r r r! �__doc__� ALGORITHMr& r) r r r r/ �bytesr. r* �
__classcell__r
r
r, r r$ ) s r$ c @ s e Zd ZdZejZdS )�SHA512FileHashingWrapperZSHA512N)r r r! r6 �hashlibZsha512r& r
r
r
r r9 h s r9 c @ s e Zd ZdZeZdS )�XXH64FileHashingWrapperZXXH64N)r r r! r6 r r& r
r
r
r r; m s r; c @ s e Zd ZdZdS )�FileIntegrityErrorz File failed integrity check: {}N)r r r! r5 r
r
r
r r< x s r< c @ s\ e Zd Zddd�Zdd� Zddd�Zeeed�d d
��Zdd d
�Z dd� Z
ed�dd�Z dS )�IntegrityCheckedFileNc
C s� || _ || _|rdnd}|p$t||�| _|d u | _i | _t}|sb| �||�}|rb|\} | _t| }|| j|d� | _ | _
| � |� d S )N�wb�rb)r( r ) �pathr% �open�file_fd� file_opened�digestsr; �load_integrity_data�SUPPORTED_ALGORITHMSr �hasher�
hash_filename)
r r@ r �filename� override_fd�integrity_data�modeZhash_clsZalgorithm_and_digests� algorithmr
r
r r) } s
z IntegrityCheckedFile.__init__c C s |d ur| � ||�S d S r )�parse_integrity_data�r r@ rK r
r
r rE � s z(IntegrityCheckedFile.load_integrity_datac C s> t j�|p| j�}| j�dt|� �� � | j�|�� � d S )N�%10d)�osr@ �basenamerG r. �lenr3 )r rI r
r
r rH � s z"IntegrityCheckedFile.hash_filename)r@ r c
C s� zHt �|�}|d }|tvr0t�d||� W d S |d }|d ||fW S tttfy� } z"t�d||� t|��W Y d }~n
d }~0 0 d S )NrM z3Cannot verify integrity of %s: Unknown algorithm %rrD �finalz)Could not parse integrity data for %s: %s) �json�loadsrF �logger�warning�
ValueError� TypeError�KeyErrorr< )�clsr@ r rK rM rD �er
r
r rN � s
z)IntegrityCheckedFile.parse_integrity_dataFc C s� | j s| jsd S | j�dt|� �� � | j�|�� � | jj|d� | j�� }| j rb|| j|< n$| jr�t| j� |d�|�s�t
| j ��d S )NrP )r4 � ) r% rD rG r. rS r3 r* r/ r �getr< r@ )r Zpartname�is_finalZdigestr
r
r � hash_part� s
z IntegrityCheckedFile.hash_partc C s� |d u}z6|s | j ddd� | j�|||� W | jrR| j�� n| jrP| j�� 0 |rZd S | jr~| �t� | jj
| j d��� n| j r�t �
d| j� d S )NrT T)r` )rM rD zVerified integrity of %s)ra rG r rC rB �closer% �store_integrity_datarU �dumpsr6 rD rW �debugr@ )r r r r � exceptionr
r
r r � s$ � � z IntegrityCheckedFile.__exit__r0 c C s
|| _ d S r )rK r r
r
r rc � s z)IntegrityCheckedFile.store_integrity_data)NNN)N)F) r r r! r) rE rH � classmethodr2 rN ra r rc r
r
r
r r= | s
r= c sL e Zd Zd
� fdd� Zdd� Zedd� �Zedd � �Ze d
�d d �Z
� Z S )� DetachedIntegrityCheckedFileNc sH t � �||||� |p tj�|�}tj�|�}| �tj�||��| _d S r ) r+ r) rQ r@ rR �dirname�integrity_file_path�join�output_integrity_file)r r@ r rI rJ Z
output_dirr, r
r r) � s z%DetachedIntegrityCheckedFile.__init__c C s | � | j�S r )�read_integrity_filer@ rO r
r
r rE � s z0DetachedIntegrityCheckedFile.load_integrity_datac C s | d S )Nz
.integrityr
)r@ r
r
r rj � s z0DetachedIntegrityCheckedFile.integrity_file_pathc
C s� zDt | �|���"}| �||�� �W d � W S 1 s80 Y W nV tyb t�d|� Y n: ty� } z"t�d||� t |��W Y d }~n
d }~0 0 d S )Nz No integrity file found for %sz(Could not read integrity file for %s: %s)
rA rj rN r �FileNotFoundErrorrW �info�OSErrorrX r< )r\ r@ r r] r
r
r rm � s 4 z0DetachedIntegrityCheckedFile.read_integrity_filer0 c C s: t | jd��}|�|� W d � n1 s,0 Y d S )N�w)rA rl r )r r r r
r
r rc � s z1DetachedIntegrityCheckedFile.store_integrity_data)NN) r r r! r) rE � staticmethodrj rg rm r2 rc r8 r
r
r, r rh � s
rh )r: r" rU rQ Zhmacr Zhelpersr rW r Zalgorithms.checksumsr r r$ r9 r; r6 rF r< r= rh r
r
r
r �<module> s$ ?�Z