File: //proc/1233/cwd/usr/lib/python3/dist-packages/compose/__pycache__/progress_stream.cpython-310.pyc
o
S �`�
� @ sP d dl mZ G dd� de�Zdd� Zdd� Zdd � Zd
d � Zd d
� Zdd� Z dS )� )�utilsc @ s e Zd ZdS )�StreamOutputErrorN)�__name__�
__module__� __qualname__� r r �9/usr/lib/python3/dist-packages/compose/progress_stream.pyr s r c C sL z|� | � W d S ty% t|dd�}|� | j|dd��|�� Y d S w )N�encoding�ascii�replace)�errors)�write�UnicodeEncodeError�getattr�encode�decode)�s�streamr r r r �write_to_stream s �r c c s� � t |d�o |�� }|}i }d}t�| �D ]\}|V d|v p!d|v }|s/t|||� |�� q|s2q|�d�}|s:q||vrIt|�||< td|� t|�|| }tdd|f |� t|||� d|v rmtd d|f |� |�� qd S )
N�isattyr �progress�progressDetail�id�
z%c[%dA� z%c[%dB) �hasattrr r � json_stream�print_output_event�flush�get�lenr )�outputr � is_terminal�lines�diff�event�is_progress_event�image_idr r r �
stream_output s6 �
�r( c C sj d| v r t | d d ��d}|r d| vr tdd |� d}nd| v r$d S d | v r1td
| d |� d | v r>td | d |� d
| v rKtd| d
|� | �dd�}d| v rctd�|| d |�|� d S d| v r�| d }|�d�}d|v r�|r�t|d �t|� d }td�|||�|� d S td�||�|� d S d| v r�td�| d |�|� d S td�||�|� d S )N� errorDetail�message� r z%c[2K
r �
r �timez[%s] r z%s: �fromz
(from %s) �statusr z{} {}{}�total�current�d z{} ({:.1f}%){}z{}{}z{}{}
)r r r �format�float)r% r r" �
terminatorr/ �detailr0 �
percentager r r r 9 s6
r c C s> d }| D ]}|� d�}|rd|vrq|�dd�d �� }q|S )Nr/ �Digest�:� )r �split�strip)�events�digestr% r/ r r r �get_digest_from_pulla s
r? c C s, | D ]}|� di �� d�}|r| S qd S )N�auxr8 )r )r= r% r> r r r �get_digest_from_pushl s �rA c C sT | d � � }d| v r(| d }d|v r(d|v r(t|d �t|d � }d�||�}|S )Nr/ r r1 r0 z {} ({:.1%}))�lowerr4 r3 )r% r/ r6 r7 r r r � read_statust s rC N)
�composer � Exceptionr r r( r r? rA rC r r r r �<module> s )(