Website : rimsha.abasa.com
backdoor
Home
Console
Upload
information
Create File
Create Folder
About
Tools
:
/
proc
/
self
/
root
/
lib
/
python3
/
dist-packages
/
compose
/
__pycache__
/
Filename :
utils.cpython-310.pyc
back
Copy
o S �` � @ s2 d dl Z d dlZd dlZd dlZd dlZd dlmZ d dlm Z ddl m Z ddl mZ ddl m Z e�� Ze�e�Zdd � Zd5d d �Zdd d� fdd�Zdd� Zdd� Zdd� Zdd� Zdd� Zdd � Z d d � Z d d � Z d!d"� Z d#d$� Z d%d&� Z d'd(� Z!d)d*� Z"d+d� fd,d-�Z#d6d/d0�Z$d1d2d� fd3d4�Z%dS )7� N)�DockerException)� parse_bytes� )�StreamParseError)� MULTIPLIERS�� timeparsec c s, � | D ]}t |t�s|�dd�}|V qdS )z�Given a stream of bytes or text, if any of the items in the stream are bytes convert them to text. This function can be removed once docker-py returns text streams instead of byte streams. zutf-8�replaceN)� isinstance�str�decode)�stream�data� r �//usr/lib/python3/dist-packages/compose/utils.py�stream_as_text s � �r � c C s: | � t|��}|dkr d S | d |d � | |d d � fS )N���r )�findr )�buffer� separator�indexr r r � line_splitter s r c C � | S �Nr )�ar r r �<lambda>' � r c c s� � |pt }d}t| �D ]}||7 } ||�}|du rn|\}}|V qq |rHz||�V W dS tyG } z t�dt|� � t|��d}~ww dS )a Given a generator which yields strings and a splitter function, joins all input, splits on the separator and yields each chunk. Unlike string.split(), each chunk includes the trailing separator, except for the last one if none was found on the end of the input. � TNz?Compose tried decoding the following data chunk, but failed: %s)r r � Exception�log�error�reprr )r �splitter�decoder�bufferedr � buffer_split�item�er r r � split_buffer' s4 � ������r) c C sR | � � } zt�| �\}}| tjj�| |��� d� }||fW S ty( Y dS w )z�Attempt to parse a json object from a buffer. If there is at least one object, return it and the rest of the buffer, otherwise return None. N) �strip� json_decoder� raw_decode�jsonr$ � WHITESPACE�match�end� ValueError)r �objr �restr r r � json_splitterG s �r4 c C s t | ttj�S )z�Given a stream of text, return a stream of json objects. This handles streams which are inconsistently buffered (some entries may be newline delimited, and others are not). )r) r4 r+ r )r r r r � json_streamT s r5 c C s6 t j| dddd� d�}t�� }|�|�d�� |�� S )NT)�,�:c S s | � � S r )r" ��xr r r r ] s zjson_hash.<locals>.<lambda>)� sort_keys� separators�default�utf8)r- �dumps�hashlib�sha256�update�encode� hexdigest)r2 �dump�hr r r � json_hash\ s rF c C s t | d d �S )Ni ʚ;i� )�int)� time_nanor r r �microseconds_from_time_nanoc � rI c C s t | td �S )N�nano)rG r )� time_secondsr r r � nanoseconds_from_time_secondsg rJ rM c C s t | pd�S �Nr r ��valuer r r �parse_seconds_floatk s rQ c C s t | pd�}|d u r d S t|�S rN )r rM )rP �parsedr r r �parse_nanoseconds_into s rS c C s dd� | � � D �S )Nc S s& i | ]\}}|t |d ur|nd��qS rN )r )�.0�k�vr r r � <dictcomp>w s & z%build_string_dict.<locals>.<dictcomp>)�items)� source_dictr r r �build_string_dictv s rZ c C s. t | �dkrdS | d dv rd| fS t�| �S )Nr )r r )�.�\�/�~r )�len�ntpath� splitdrive)�pathr r r ra z s ra c C s zt | �W S ty Y d S w r )�sdk_parse_bytesr )�nr r r r � s �r c C s0 | s| S | d dkr| d dkr| dd� S | S )Nr �"r r r )�sr r r � unquote_path� s rg c C s@ t t�d��dd� } ztt| �� W q ty | Y S w )NT� � r )�hex�random� getrandbitsrG � truncate_idr1 )�valr r r �generate_random_id� s �ro c C s: d| v r| | � d�d d � } t| �dkr| d d� S | S )Nr7 r � )r r_ rO r r r rm � s rm c C r r r r8 r r r r � r c c s6 � t � }| D ]}||�}||vr|�|� |V qdS )zHList unique elements, preserving order. Remember all elements ever seen.N)�set�add)�iterable�key�seen�element� unique_keyr r r �unique_everseen� s � ��rx �# c C s$ t | �|kr| d |d � d S | S )Nri z...)r_ )rf � max_charsr r r �truncate_string� s r{ Fc C r r r r8 r r r r � r c s |s�s| S � �fdd�| D �S )a This function contains the logic of choosing which services to attach when doing docker-compose up. It may be used both with containers and services, and any other entities that map to service names - this mapping is provided by item_to_service_name.c s g | ] }� |��v r|�qS r r )rT r' ��item_to_service_name� service_namesr r � <listcomp>� s �z*filter_attached_for_up.<locals>.<listcomp>r )rX r~ �attach_dependenciesr} r r| r �filter_attached_for_up� s �r� )r )ry )&r? � json.decoderr- �loggingr` rk � docker.errorsr � docker.utilsr rc �errorsr r r � JSONDecoderr+ � getLogger�__name__r r r r) r4 r5 rF rI rM rQ rS rZ ra rg ro rm rx r{ r� r r r r �<module> sB �