File manager - Edit - /home/newsbmcs.com/public_html/static/img/logo/utils.tar
Back
fnmatch.py 0000644 00000006337 15027746032 0006555 0 ustar 00 """Filename matching with shell patterns. fnmatch(FILENAME, PATTERN) matches according to the local convention. fnmatchcase(FILENAME, PATTERN) always takes case in account. The functions operate by translating the pattern into a regular expression. They cache the compiled regular expressions for speed. The function translate(PATTERN) returns a regular expression corresponding to PATTERN. (It does not compile it.) """ import re __all__ = ["fnmatch", "fnmatchcase", "translate"] _cache = {} _MAXCACHE = 100 def _purge(): """Clear the pattern cache""" _cache.clear() def fnmatch(name, pat): """Test whether FILENAME matches PATTERN. Patterns are Unix shell style: * matches everything ? matches any single character [seq] matches any character in seq [!seq] matches any char not in seq An initial period in FILENAME is not special. Both FILENAME and PATTERN are first case-normalized if the operating system requires it. If you don't want this, use fnmatchcase(FILENAME, PATTERN). """ name = name.lower() pat = pat.lower() return fnmatchcase(name, pat) def fnmatchcase(name, pat): """Test whether FILENAME matches PATTERN, including case. This is a version of fnmatch() which doesn't case-normalize its arguments. """ try: re_pat = _cache[pat] except KeyError: res = translate(pat) if len(_cache) >= _MAXCACHE: _cache.clear() _cache[pat] = re_pat = re.compile(res) return re_pat.match(name) is not None def translate(pat): """Translate a shell PATTERN to a regular expression. There is no way to quote meta-characters. """ i, n = 0, len(pat) res = '^' while i < n: c = pat[i] i = i + 1 if c == '*': if i < n and pat[i] == '*': # is some flavor of "**" i = i + 1 # Treat **/ as ** so eat the "/" if i < n and pat[i] == '/': i = i + 1 if i >= n: # is "**EOF" - to align with .gitignore just accept all res = f"{res}.*" else: # is "**" # Note that this allows for any # of /'s (even 0) because # the .* will eat everything, even /'s res = f"{res}(.*/)?" else: # is "*" so map it to anything but "/" res = f"{res}[^/]*" elif c == '?': # "?" is any char except "/" res = f"{res}[^/]" elif c == '[': j = i if j < n and pat[j] == '!': j = j + 1 if j < n and pat[j] == ']': j = j + 1 while j < n and pat[j] != ']': j = j + 1 if j >= n: res = f"{res}\\[" else: stuff = pat[i:j].replace('\\', '\\\\') i = j + 1 if stuff[0] == '!': stuff = f"^{stuff[1:]}" elif stuff[0] == '^': stuff = f"\\{stuff}" res = f'{res}[{stuff}]' else: res = res + re.escape(c) return f"{res}$" socket.py 0000644 00000011721 15027746032 0006416 0 ustar 00 import errno import os import select import socket as pysocket import struct try: from ..transport import NpipeSocket except ImportError: NpipeSocket = type(None) STDOUT = 1 STDERR = 2 class SocketError(Exception): pass # NpipeSockets have their own error types # pywintypes.error: (109, 'ReadFile', 'The pipe has been ended.') NPIPE_ENDED = 109 def read(socket, n=4096): """ Reads at most n bytes from socket """ recoverable_errors = (errno.EINTR, errno.EDEADLK, errno.EWOULDBLOCK) if not isinstance(socket, NpipeSocket): if not hasattr(select, "poll"): # Limited to 1024 select.select([socket], [], []) else: poll = select.poll() poll.register(socket, select.POLLIN | select.POLLPRI) poll.poll() try: if hasattr(socket, 'recv'): return socket.recv(n) if isinstance(socket, pysocket.SocketIO): return socket.read(n) return os.read(socket.fileno(), n) except OSError as e: if e.errno not in recoverable_errors: raise except Exception as e: is_pipe_ended = (isinstance(socket, NpipeSocket) and len(e.args) > 0 and e.args[0] == NPIPE_ENDED) if is_pipe_ended: # npipes don't support duplex sockets, so we interpret # a PIPE_ENDED error as a close operation (0-length read). return '' raise def read_exactly(socket, n): """ Reads exactly n bytes from socket Raises SocketError if there isn't enough data """ data = b"" while len(data) < n: next_data = read(socket, n - len(data)) if not next_data: raise SocketError("Unexpected EOF") data += next_data return data def next_frame_header(socket): """ Returns the stream and size of the next frame of data waiting to be read from socket, according to the protocol defined here: https://docs.docker.com/engine/api/v1.24/#attach-to-a-container """ try: data = read_exactly(socket, 8) except SocketError: return (-1, -1) stream, actual = struct.unpack('>BxxxL', data) return (stream, actual) def frames_iter(socket, tty): """ Return a generator of frames read from socket. A frame is a tuple where the first item is the stream number and the second item is a chunk of data. If the tty setting is enabled, the streams are multiplexed into the stdout stream. """ if tty: return ((STDOUT, frame) for frame in frames_iter_tty(socket)) else: return frames_iter_no_tty(socket) def frames_iter_no_tty(socket): """ Returns a generator of data read from the socket when the tty setting is not enabled. """ while True: (stream, n) = next_frame_header(socket) if n < 0: break while n > 0: result = read(socket, n) if result is None: continue data_length = len(result) if data_length == 0: # We have reached EOF return n -= data_length yield (stream, result) def frames_iter_tty(socket): """ Return a generator of data read from the socket when the tty setting is enabled. """ while True: result = read(socket) if len(result) == 0: # We have reached EOF return yield result def consume_socket_output(frames, demux=False): """ Iterate through frames read from the socket and return the result. Args: demux (bool): If False, stdout and stderr are multiplexed, and the result is the concatenation of all the frames. If True, the streams are demultiplexed, and the result is a 2-tuple where each item is the concatenation of frames belonging to the same stream. """ if demux is False: # If the streams are multiplexed, the generator returns strings, that # we just need to concatenate. return b"".join(frames) # If the streams are demultiplexed, the generator yields tuples # (stdout, stderr) out = [None, None] for frame in frames: # It is guaranteed that for each frame, one and only one stream # is not None. assert frame != (None, None) if frame[0] is not None: if out[0] is None: out[0] = frame[0] else: out[0] += frame[0] else: if out[1] is None: out[1] = frame[1] else: out[1] += frame[1] return tuple(out) def demux_adaptor(stream_id, data): """ Utility to demultiplex stdout and stderr when reading frames from the socket. """ if stream_id == STDOUT: return (data, None) elif stream_id == STDERR: return (None, data) else: raise ValueError(f'{stream_id} is not a valid stream') proxy.py 0000644 00000004306 15027746032 0006310 0 ustar 00 from .utils import format_environment class ProxyConfig(dict): ''' Hold the client's proxy configuration ''' @property def http(self): return self.get('http') @property def https(self): return self.get('https') @property def ftp(self): return self.get('ftp') @property def no_proxy(self): return self.get('no_proxy') @staticmethod def from_dict(config): ''' Instantiate a new ProxyConfig from a dictionary that represents a client configuration, as described in `the documentation`_. .. _the documentation: https://docs.docker.com/network/proxy/#configure-the-docker-client ''' return ProxyConfig( http=config.get('httpProxy'), https=config.get('httpsProxy'), ftp=config.get('ftpProxy'), no_proxy=config.get('noProxy'), ) def get_environment(self): ''' Return a dictionary representing the environment variables used to set the proxy settings. ''' env = {} if self.http: env['http_proxy'] = env['HTTP_PROXY'] = self.http if self.https: env['https_proxy'] = env['HTTPS_PROXY'] = self.https if self.ftp: env['ftp_proxy'] = env['FTP_PROXY'] = self.ftp if self.no_proxy: env['no_proxy'] = env['NO_PROXY'] = self.no_proxy return env def inject_proxy_environment(self, environment): ''' Given a list of strings representing environment variables, prepend the environment variables corresponding to the proxy settings. ''' if not self: return environment proxy_env = format_environment(self.get_environment()) if not environment: return proxy_env # It is important to prepend our variables, because we want the # variables defined in "environment" to take precedence. return proxy_env + environment def __str__(self): return ( 'ProxyConfig(' f'http={self.http}, https={self.https}, ' f'ftp={self.ftp}, no_proxy={self.no_proxy}' ')' ) ports.py 0000644 00000005357 15027746032 0006305 0 ustar 00 import re PORT_SPEC = re.compile( "^" # Match full string "(" # External part r"(\[?(?P<host>[a-fA-F\d.:]+)\]?:)?" # Address r"(?P<ext>[\d]*)(-(?P<ext_end>[\d]+))?:" # External range ")?" r"(?P<int>[\d]+)(-(?P<int_end>[\d]+))?" # Internal range "(?P<proto>/(udp|tcp|sctp))?" # Protocol "$" # Match full string ) def add_port_mapping(port_bindings, internal_port, external): if internal_port in port_bindings: port_bindings[internal_port].append(external) else: port_bindings[internal_port] = [external] def add_port(port_bindings, internal_port_range, external_range): if external_range is None: for internal_port in internal_port_range: add_port_mapping(port_bindings, internal_port, None) else: ports = zip(internal_port_range, external_range) for internal_port, external_port in ports: add_port_mapping(port_bindings, internal_port, external_port) def build_port_bindings(ports): port_bindings = {} for port in ports: internal_port_range, external_range = split_port(port) add_port(port_bindings, internal_port_range, external_range) return port_bindings def _raise_invalid_port(port): raise ValueError('Invalid port "%s", should be ' '[[remote_ip:]remote_port[-remote_port]:]' 'port[/protocol]' % port) def port_range(start, end, proto, randomly_available_port=False): if not start: return start if not end: return [start + proto] if randomly_available_port: return [f"{start}-{end}{proto}"] return [str(port) + proto for port in range(int(start), int(end) + 1)] def split_port(port): if hasattr(port, 'legacy_repr'): # This is the worst hack, but it prevents a bug in Compose 1.14.0 # https://github.com/docker/docker-py/issues/1668 # TODO: remove once fixed in Compose stable port = port.legacy_repr() port = str(port) match = PORT_SPEC.match(port) if match is None: _raise_invalid_port(port) parts = match.groupdict() host = parts['host'] proto = parts['proto'] or '' internal = port_range(parts['int'], parts['int_end'], proto) external = port_range( parts['ext'], parts['ext_end'], '', len(internal) == 1) if host is None: if external is not None and len(internal) != len(external): raise ValueError('Port ranges don\'t match in length') return internal, external else: if not external: external = [None] * len(internal) elif len(internal) != len(external): raise ValueError('Port ranges don\'t match in length') return internal, [(host, ext_port) for ext_port in external] decorators.py 0000644 00000002724 15027746032 0007276 0 ustar 00 import functools from .. import errors from . import utils def check_resource(resource_name): def decorator(f): @functools.wraps(f) def wrapped(self, resource_id=None, *args, **kwargs): if resource_id is None and kwargs.get(resource_name): resource_id = kwargs.pop(resource_name) if isinstance(resource_id, dict): resource_id = resource_id.get('Id', resource_id.get('ID')) if not resource_id: raise errors.NullResource( 'Resource ID was not provided' ) return f(self, resource_id, *args, **kwargs) return wrapped return decorator def minimum_version(version): def decorator(f): @functools.wraps(f) def wrapper(self, *args, **kwargs): if utils.version_lt(self._version, version): raise errors.InvalidVersion( f'{f.__name__} is not available for version < {version}', ) return f(self, *args, **kwargs) return wrapper return decorator def update_headers(f): def inner(self, *args, **kwargs): if 'HttpHeaders' in self._general_configs: if not kwargs.get('headers'): kwargs['headers'] = self._general_configs['HttpHeaders'] else: kwargs['headers'].update(self._general_configs['HttpHeaders']) return f(self, *args, **kwargs) return inner __pycache__/decorators.cpython-310.pyc 0000644 00000003505 15027746032 0013633 0 ustar 00 o �h� � @ s< d dl Z ddlmZ ddlmZ dd� Zdd � Zd d � ZdS ) � N� )�errors� )�utilsc � � fdd�}|S )Nc s t �� �d� �fdd� �}|S )Nc s^ |d u r|� ��r|���}t|t�r |� d|� d��}|s#t�d��� | |g|�R i |��S )N�Id�IDz Resource ID was not provided)�get�pop� isinstance�dictr � NullResource)�self� resource_id�args�kwargs)�f� resource_name� �M/usr/local/CyberPanel/lib/python3.10/site-packages/docker/utils/decorators.py�wrapped s �z2check_resource.<locals>.decorator.<locals>.wrapped)N�� functools�wraps)r r �r �r r � decorator s z!check_resource.<locals>.decoratorr )r r r r r �check_resource s r c r )Nc s t �� �� �fdd��}|S )Nc s: t �| j��rt�� j� d�� ���� | g|�R i |��S )Nz is not available for version < )r � version_lt�_versionr �InvalidVersion�__name__�r r r )r �versionr r �wrapper s �z3minimum_version.<locals>.decorator.<locals>.wrapperr )r r$ �r# r r r s z"minimum_version.<locals>.decoratorr )r# r r r% r �minimum_version s r& c r )Nc sN d| j v r |�d�s| j d |d< n |d �| j d � � | g|�R i |��S )N� HttpHeaders�headers)�_general_configsr �updater" r r r �inner& s z update_headers.<locals>.innerr )r r+ r r r �update_headers% s r, )r � r r r r& r, r r r r �<module> s __pycache__/socket.cpython-310.pyc 0000644 00000010470 15027746032 0012755 0 ustar 00 o �h� � @ s� d dl Z d dlZd dlZd dlZd dlZzddlmZ W n ey) e d�ZY nw dZ dZ G dd� de �Z dZdd d �Zd d � Zd d� Zdd� Zdd� Zdd� Zddd�Zdd� ZdS ) � N� )� NpipeSocket� c @ s e Zd ZdS )� SocketErrorN)�__name__� __module__� __qualname__� r r �I/usr/local/CyberPanel/lib/python3.10/site-packages/docker/utils/socket.pyr s r �m � c C s t jt jt jf}t| t�s-ttd�st�| gg g � nt�� }|� | tj tj B � |�� z t| d�r9| � |�W S t| t j�rE| �|�W S t�| �� |�W S tyf } z |j |vr[� W Y d}~dS d}~w ty� } z t| t�ot|j�dko|jd tk}|r�W Y d}~dS � d}~ww )z+ Reads at most n bytes from socket �poll�recvNr � )�errno�EINTR�EDEADLK� EWOULDBLOCK� isinstancer �hasattr�selectr �register�POLLIN�POLLPRIr �pysocket�SocketIO�read�os�fileno�OSError� Exception�len�args� NPIPE_ENDED)�socket�n�recoverable_errorsr �e� is_pipe_endedr r r r s: �� � ���r c C sF d}t |�|k r!t| |t |� �}|std��||7 }t |�|k s|S )z] Reads exactly n bytes from socket Raises SocketError if there isn't enough data � zUnexpected EOF)r! r r )r$ r% �data� next_datar r r � read_exactly> s �r, c C s< zt | d�}W n ty Y dS w t�d|�\}}||fS )z� Returns the stream and size of the next frame of data waiting to be read from socket, according to the protocol defined here: https://docs.docker.com/engine/api/v1.24/#attach-to-a-container � )���r. z>BxxxL)r, r �struct�unpack)r$ r* �stream�actualr r r �next_frame_headerL s �r3 c C s |r dd� t | �D �S t| �S )z� Return a generator of frames read from socket. A frame is a tuple where the first item is the stream number and the second item is a chunk of data. If the tty setting is enabled, the streams are multiplexed into the stdout stream. c s s � | ]}t |fV qd S )N)�STDOUT)�.0�framer r r � <genexpr>e s � z frames_iter.<locals>.<genexpr>)�frames_iter_tty�frames_iter_no_tty)r$ �ttyr r r � frames_iter\ s r; c c sh � t | �\}}|dk rdS |dkr3t| |�}|du r qt|�}|dkr&dS ||8 }||fV |dksq)zc Returns a generator of data read from the socket when the tty setting is not enabled. Tr N)r3 r r! )r$ r1 r% �result� data_lengthr r r r9 j s � ��r9 c c s$ � t | �}t|�dkrdS |V q)z^ Return a generator of data read from the socket when the tty setting is enabled. Tr N)r r! )r$ r< r r r r8 s � �r8 Fc C s� |du r d� | �S ddg}| D ]=}|dksJ �|d dur5|d du r*|d |d< q|d |d 7 < q|d du rB|d |d< q|d |d 7 < qt|�S )a� Iterate through frames read from the socket and return the result. Args: demux (bool): If False, stdout and stderr are multiplexed, and the result is the concatenation of all the frames. If True, the streams are demultiplexed, and the result is a 2-tuple where each item is the concatenation of frames belonging to the same stream. Fr) N)NNr r )�join�tuple)�frames�demux�outr6 r r r �consume_socket_output� s rC c C s. | t kr|dfS | tkrd|fS t| � d���)z[ Utility to demultiplex stdout and stderr when reading frames from the socket. Nz is not a valid stream)r4 �STDERR� ValueError)� stream_idr* r r r � demux_adaptor� s rG )r )F)r r r r$ r r/ � transportr � ImportError�typer4 rD r r r# r r, r3 r; r9 r8 rC rG r r r r �<module> s, � $ % __pycache__/ports.cpython-310.pyc 0000644 00000004455 15027746032 0012642 0 ustar 00 o �h� � @ sH d dl Z e �d�Zdd� Zdd� Zdd� Zd d � Zdd d �Zdd� ZdS )� Nz�^((\[?(?P<host>[a-fA-F\d.:]+)\]?:)?(?P<ext>[\d]*)(-(?P<ext_end>[\d]+))?:)?(?P<int>[\d]+)(-(?P<int_end>[\d]+))?(?P<proto>/(udp|tcp|sctp))?$c C s( || v r | | � |� d S |g| |< d S �N)�append)� port_bindings� internal_port�external� r �H/usr/local/CyberPanel/lib/python3.10/site-packages/docker/utils/ports.py�add_port_mapping s r c C sJ |d u r|D ]}t | |d � qd S t||�}|D ] \}}t | ||� qd S r )r �zip)r �internal_port_range�external_ranger �ports� external_portr r r �add_port s � �r c C s* i }| D ]}t |�\}}t|||� q|S r )� split_portr )r r �portr r r r r �build_port_bindings s r c C s t d| ��)NzTInvalid port "%s", should be [[remote_ip:]remote_port[-remote_port]:]port[/protocol])� ValueError)r r r r �_raise_invalid_port( s �r Fc sR | s| S |s | � gS |r| � d|� � � �gS � fdd�t t| �t|�d �D �S )N�-c s g | ]}t |�� �qS r )�str)�.0r ��protor r � <listcomp>5 s z port_range.<locals>.<listcomp>� )�range�int)�start�endr �randomly_available_portr r r � port_range. s $r! c s� t | d�r | �� } t| �} t�| �}|d u rt| � |�� }|d � |d p'd}t|d |d |�}t|d |d dt|�d k�}� d u rY|d urUt|�t|�krUt d ��||fS |scd gt|� }n t|�t|�krot d ��|� fd d �|D �fS ) N� legacy_repr�hostr � r �int_end�ext�ext_endr z!Port ranges don't match in lengthc s g | ]}� |f�qS r r )r �ext_port�r# r r r S s z split_port.<locals>.<listcomp>) �hasattrr" r � PORT_SPEC�matchr � groupdictr! �lenr )r r, �partsr �internalr r r) r r 8 s, �r )F) �re�compiler+ r r r r r! r r r r r �<module> s � __pycache__/json_stream.cpython-310.pyc 0000644 00000004602 15027746032 0014011 0 ustar 00 o �h� � @ s\ d dl Z d dlZ ddlmZ e �� Zdd� Zdd� Zdd � Zdd d �Z dd d� fdd�Z dS )� N� )�StreamParseErrorc 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 we return text streams instead of byte streams. zutf-8�replaceN)� isinstance�str�decode)�stream�data� r �N/usr/local/CyberPanel/lib/python3.10/site-packages/docker/utils/json_stream.py�stream_as_text s � �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�json�decoder� WHITESPACE�match�end� ValueError)�buffer�obj�index�restr r r � json_splitter s �r 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). )� split_bufferr r r )r r r r � json_stream# s r � c C s: | � t|��}|dkr d S | d |d � | |d d � fS )N���� )�findr )r � separatorr r r r � line_splitter+ s r" c C s | S )Nr )�ar r r �<lambda>2 s r$ c c s� � |pt }d}t| �D ]}||7 } ||�}|du rn|\}}|V qq |r@z||�V W dS ty? } zt|�|�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. � TN)r" r � Exceptionr )r �splitterr �bufferedr � buffer_split�item�er r r r 2 s* � � ���r )r ) r � json.decoder�errorsr � JSONDecoderr r r r r" r r r r r �<module> s __pycache__/proxy.cpython-310.pyc 0000644 00000004762 15027746032 0012655 0 ustar 00 o �h� � @ s d dl mZ G dd� de�ZdS )� )�format_environmentc @ sd e Zd ZdZedd� �Zedd� �Zedd� �Zedd � �Ze d d � �Z d d � Z dd� Z dd� Z dS )� ProxyConfigz/ Hold the client's proxy configuration c C � | � d�S )N�http��get��self� r �H/usr/local/CyberPanel/lib/python3.10/site-packages/docker/utils/proxy.pyr � zProxyConfig.httpc C r )N�httpsr r r r r r r zProxyConfig.httpsc C r )N�ftpr r r r r r r zProxyConfig.ftpc C r )N�no_proxyr r r r r r r zProxyConfig.no_proxyc C s( t | �d�| �d�| �d�| �d�d�S )a Instantiate a new ProxyConfig from a dictionary that represents a client configuration, as described in `the documentation`_. .. _the documentation: https://docs.docker.com/network/proxy/#configure-the-docker-client � httpProxy� httpsProxy�ftpProxy�noProxy�r r r r )r r )�configr r r � from_dict s �zProxyConfig.from_dictc C sh i }| j r| j |d< |d< | jr| j |d< |d< | jr&| j |d< |d< | jr2| j |d< |d< |S ) zt Return a dictionary representing the environment variables used to set the proxy settings. � http_proxy� HTTP_PROXY� https_proxy� HTTPS_PROXY� ftp_proxy� FTP_PROXYr �NO_PROXYr )r �envr r r �get_environment( s zProxyConfig.get_environmentc C s$ | s|S t | �� �}|s|S || S )z� Given a list of strings representing environment variables, prepend the environment variables corresponding to the proxy settings. )r r )r � environment� proxy_envr r r �inject_proxy_environment8 s z$ProxyConfig.inject_proxy_environmentc C s& d| j � d| j� d| j� d| j� d� S )NzProxyConfig(http=z, https=z, ftp=z , no_proxy=�)r r r r r �__str__G s �����zProxyConfig.__str__N)�__name__� __module__� __qualname__�__doc__�propertyr r r r � staticmethodr r r" r$ r r r r r s r N)�utilsr �dictr r r r r �<module> s __pycache__/__init__.cpython-310.pyc 0000644 00000001762 15027746032 0013230 0 ustar 00 o �h� � @ s� d dl mZmZmZmZmZ d dlmZmZm Z d dl m Z m Z m Z mZmZmZmZmZmZmZmZmZmZmZmZmZmZm Z m Z m Z m Z m Z dS )� )�create_archive� exclude_paths� match_tag�mkbuildcontext�tar)�check_resource�minimum_version�update_headers)�compare_version�convert_filters�convert_port_bindings�convert_service_networks�convert_volume_binds�create_host_config�create_ipam_config�create_ipam_pool�datetime_to_timestamp�decode_json_header�format_environment�format_extra_hosts�kwargs_from_env�normalize_links� parse_bytes� parse_devices�parse_env_file� parse_host�parse_repository_tag� split_command� version_gte� version_ltN)!�buildr r r r r � decoratorsr r r �utilsr r r r r r r r r r r r r r r r r r r r r r � r# r# �K/usr/local/CyberPanel/lib/python3.10/site-packages/docker/utils/__init__.py�<module> s d __pycache__/utils.cpython-310.pyc 0000644 00000026160 15027746032 0012630 0 ustar 00 o �h,7 � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZmZ d dl m Z d dl m Z d dl mZmZ ddlmZ ddlmZmZmZmZ dd lmZ e�d d �Zd d � Zdd� Z dd� Z e dd�dd� �Z dd� Z dd� Z dd� Z!dd � Z"d d � Z#d d � Z$d!d"� Z%d#d$� Z&d>d&d'�Z'd(d)� Z(d?d*d+�Z)d,d-� Z*d.d/� Z+d0d1� Z,d2d3� Z-d4d5� Z.d6d7� Z/d8d9� Z0d@d:d;�Z1d<d=� Z2dS )A� N)�datetime�timezone)� lru_cache)� zip_longest)�urlparse� urlunparse� )�errors)� BYTE_UNITS�DEFAULT_HTTP_HOST� DEFAULT_NPIPE�DEFAULT_UNIX_SOCKET)� TLSConfig� URLComponentsz'scheme netloc url params query fragmentc O � t �d��)Nz[utils.create_ipam_pool has been removed. Please use a docker.types.IPAMPool object instead.�r �DeprecatedMethod��args�kwargs� r �H/usr/local/CyberPanel/lib/python3.10/site-packages/docker/utils/utils.py�create_ipam_pool � �r c O r )Nz_utils.create_ipam_config has been removed. Please use a docker.types.IPAMConfig object instead.r r r r r �create_ipam_config# r r c C s t �| �}|�d�}t�|�S )N�utf-8)�base64� b64decode�decode�json�loads)�header�datar r r �decode_json_header* s r# )�maxsizec C st | |krdS t dd� | �d�D ��}t dd� |�d�D ��}t||dd�D ]\}}||kr.q%||kr5 dS dS dS ) z�Compare docker versions >>> v1 = '1.9' >>> v2 = '1.10' >>> compare_version(v1, v2) 1 >>> compare_version(v2, v1) -1 >>> compare_version(v2, v2) 0 r c s � � | ]}t |�V qd S �N��int��.0�pr r r � <genexpr>@ � � z"compare_version.<locals>.<genexpr>�.c s r% r& r' r) r r r r, A r- )� fillvalue���� )�tuple�splitr )�v1�v2�s1�s2�c1�c2r r r �compare_version0 s r: c C s t | |�dkS )Nr )r: �r4 r5 r r r � version_ltM s r< c C s t | |� S r& )r< r; r r r � version_gteQ s r= c C s� ddd�}t | t�r2t| �dkr | d |d< | d |d< n7t | d t�r+| d |d< n)| d |d< n"t | t�rPd| v rL| d |d< d| v rK| d |d< nt| ��| |d< |d d u r`d|d< |S t|d �|d< |S )N� )�HostIp�HostPortr r1 r@ r r? )� isinstancer2 �len�str�dict� ValueError)�binding�resultr r r �_convert_port_bindingU s* � �rH c C sb i }t | �� �D ]&\}}t|�}d|vr|d7 }t|t�r'dd� |D �||< qt|�g||< q|S )N�/z/tcpc S s g | ]}t |��qS r )rH )r* rF r r r � <listcomp>x � z)convert_port_bindings.<locals>.<listcomp>)�iter�itemsrC rA �listrH )� port_bindingsrG �k�v�keyr r r �convert_port_bindingsq s rS c C s2 t | t�r| S g }| �� D ]�\}}t |t�r|�d�}t |t�r�d|v r/d|v r/td|����|d }t |t�r=|�d�}d|v rJ|d rGdnd}n d|v rS|d }nd}g d�}d|v rs|d |v rs|ro|� d |d � �}n|d }|�|� d |� d |� �� q t |t�r�|�d�}|�|� d |� d �� q |S ) Nr �ro�modez-Binding cannot contain both "ro" and "mode": �bind�rw)�rshared�shared�rslave�slave�rprivate�private� propagation�,�:z:rw)rA rN rM �bytesr rD rE �append)�bindsrG rP rQ rV rU �propagation_modesr r r �convert_volume_binds~ sB � � �re c C s� t | t�r| S t | t�stdt| �j� ���i }| D ]'}t |t�r3d|v r.|�dd�\}}n|}d}n tdt|�j� ���|||< q|S )Nz;Expected tmpfs value to be either a list or a dict, found: r` r1 r> z3Expected item in tmpfs list to be a string, found: )rA rD rN rE �type�__name__rC r3 )�tmpfsrG �mount�name�optionsr r r �convert_tmpfs_mounts� s, �� �� rl c C sH | s| S t | t�s td��g }| D ]}t |t�r d|i}|�|� q|S )Nz"networks parameter must be a list.�Target)rA rN � TypeErrorrC rb )�networksrG �nr r r �convert_service_networks� s rq c C sT | � dd�}t|�dkrt|�S | � dd�}t|�dkr&d|d vr&t|�S | d fS )N�@r1 r r` rI )�rsplitrB r2 )� repo_name�partsr r r �parse_repository_tag� s rv Fc C s | s|rt S | r| �� dkrtS | �� } t| �}|j}|r&tdd� |D ��r0td| � �d�}d}|dkr9t�d��|dksA|d krH|d k}d}n|d krNd }|d vrZt�d | � ���|dkri|jsit�d| � ���t|j |j |j |j g�r}t�d| � ���|j r�|dkr�t�d| � ���|j }|d kr�|jd ur�|j� d|� �}|j}|dv r�|jp�d}|dkr�|dkr�t�d| � ���d}|j� d|� �}|js�t� d|� �}|dkr�d|r�dnd� �}n|d kr�d }|dv r�|� d|� ��d�S tt|||dddd���d�S ) Nzunix://c s s � | ] }|t j� d �vV qdS )�+N)�string� ascii_letters)r* �xr r r r, � s � z parse_host.<locals>.<genexpr>z//�tcp�fdz fd protocol is not implemented�http�https� http+unix�unix)r{ r� �npipe�sshz Invalid bind address protocol: z Invalid bind address format: r� z@Invalid bind address format: no path allowed for this protocol: rI )r{ r� r z/Invalid bind address format: port is required: � r` �sr> )r r� z://)�scheme�netloc�url�params�query�fragment)r �stripr r r� �anyr �DockerExceptionr� r� r� r� �password�path�hostname�portr �rstripr r )�addr�is_win32�tls� parsed_url�protor� r� r� r r r � parse_host� s� �� ��� ���r� c C s� g }| D ]J}t |t�r|�|� qt |t�s t�dt|�� ���|�d�}|rN|d }t|�dkr6|d }n|}t|�dkrC|d }nd}|�|||d�� q|S )NzInvalid device type r` r r1 r �rwm)� PathOnHost�PathInContainer�CgroupPermissions) rA rD rb rC r r� rf r3 rB )�devices� device_list�device�device_mapping� path_on_host�path_in_container� permissionsr r r � parse_devicesD s2 � ��r� c C s� | st j} | �d�}| �d�pd }| �d�}|dkr d}n|d u}|p$|}i }|r-||d< |s1|S |s>t j�t j�d�d�}tt j�|d �t j�|d �ft j�|d �|d �|d < |S )N� DOCKER_HOST�DOCKER_CERT_PATH�DOCKER_TLS_VERIFYr> F�base_url�~z.dockerzcert.pemzkey.pemzca.pem)� client_cert�ca_cert�verifyr� )�os�environ�getr� �join� expanduserr )� environment�host� cert_path� tls_verify� enable_tlsr� r r r �kwargs_from_enva s0 � �r� c C s\ i }t | �� �D ] \}}t|t�r|rdnd}t|t�s |g}dd� |D �||< qt�|�S )N�true�falsec S s" g | ] }t |t�s t|�n|�qS r )rA rC )r* �itemr r r rJ � s ��z#convert_filters.<locals>.<listcomp>)rL rM rA �boolrN r �dumps)�filtersrG rP rQ r r r �convert_filters� s � r� c C s2 | � tj�tdddtjd� }|j|jd d S )z&Convert a datetime to a Unix timestampi� r1 )�tzinfo� i )� astimezoner �utcr �seconds�days)�dt�deltar r r �datetime_to_timestamp� s r� c C s t | ttf�r | S t| �dkrdS | dd� �� r1| d �� r1| d dks+| d dkr1| d d� } t}| d �� }|�� rB| }d}n| d d� }||�� v sR|�� ryzt|�}W n t yn } z t � d|� d��|�d }~ww t||| �} | S t � d| � d ���) Nr ���r0 �b�Bz/Failed converting the string value for memory (z) to an integer.z The specified value for memory (zW) should specify the units. The postfix should be one of the `b` `k` `m` `g` characters) rA r( �floatrB �isalphar �lower�isdigit�keysrE r r� )r� �units�suffix� digits_part�digits�ver r r � parse_bytes� s> ������ �r� c C s( t | t�r t| �� �} dd� t| �D �S )Nc S s& g | ]\}}|r|� d |� �n|�qS �r` r �r* rP rQ r r r rJ � s & z#normalize_links.<locals>.<listcomp>)rA rD rL rM �sorted)�linksr r r �normalize_links� s r� c C s� i }t | ��;}|D ]/}|d dkrq |�� }|sq |�dd�}t|�dkr.|\}}|||< q t�d| � d|� ���W d � |S 1 sDw Y |S ) ze Reads a line-separated environment file. The format of each line should be "key=value". r �#�=r1 r z!Invalid line in environment file z: N)�openr� r3 rB r r� )�env_filer� �f�line� parse_linerP rQ r r r �parse_env_file� s( �� ��r� c C s t �| �S r& )�shlexr3 )�commandr r r � split_command� s r� c s" dd� � � fdd�t | �� �D �S )Nc S s. |d u r| S t |t�r|�d�}| � d|� �S )Nr r� )rA ra r )rR �valuer r r � format_env� s z&format_environment.<locals>.format_envc s g | ]}� |� �qS r r )r* �var�r� r r rJ � rK z&format_environment.<locals>.<listcomp>)rL rM )r� r r� r �format_environment� s r� c C s8 |rdd� t t| �� ��D �S dd� t t| �� ��D �S )Nc S s g | ] \}}|� d |� ��qS )� r r� r r r rJ � � �z&format_extra_hosts.<locals>.<listcomp>c S s g | ] \}}|� d |� ��qS r� r r� r r r rJ � r� )r� rL rM )� extra_hosts�taskr r r �format_extra_hosts� s ��r� c O r )Nz_utils.create_host_config has been removed. Please use a docker.types.HostConfig object instead.r )�selfr r r r r �create_host_config r r� )FFr& )F)3r � collectionsr r� �os.pathr� rx r r � functoolsr � itertoolsr � urllib.parser r r> r � constantsr r r r r� r � namedtupler r r r# r: r< r= rH rS re rl rq rv r� r� r� r� r� r� r� r� r� r� r� r� r r r r �<module> sV � 6 [ &( __pycache__/fnmatch.cpython-310.pyc 0000644 00000005202 15027746032 0013102 0 ustar 00 o �h� � @ s@ d Z ddlZg d�Zi ZdZdd� Zdd� Zd d � Zd d � ZdS ) a� Filename matching with shell patterns. fnmatch(FILENAME, PATTERN) matches according to the local convention. fnmatchcase(FILENAME, PATTERN) always takes case in account. The functions operate by translating the pattern into a regular expression. They cache the compiled regular expressions for speed. The function translate(PATTERN) returns a regular expression corresponding to PATTERN. (It does not compile it.) � N)�fnmatch� fnmatchcase� translate�d c C s t �� dS )zClear the pattern cacheN)�_cache�clear� r r �J/usr/local/CyberPanel/lib/python3.10/site-packages/docker/utils/fnmatch.py�_purge s r c C s | � � } |� � }t| |�S )a� Test whether FILENAME matches PATTERN. Patterns are Unix shell style: * matches everything ? matches any single character [seq] matches any character in seq [!seq] matches any char not in seq An initial period in FILENAME is not special. Both FILENAME and PATTERN are first case-normalized if the operating system requires it. If you don't want this, use fnmatchcase(FILENAME, PATTERN). )�lowerr )�name�patr r r r s r c C s\ zt | }W n ty& t|�}tt �tkrt �� t�|� t |< }Y nw |�| �duS )z�Test whether FILENAME matches PATTERN, including case. This is a version of fnmatch() which doesn't case-normalize its arguments. N) r �KeyErrorr �len� _MAXCACHEr �re�compile�match)r r �re_pat�resr r r r / s �r c C s� dt | �}}d}||k r�| | }|d }|dkrK||k rE| | dkrE|d }||k r5| | dkr5|d }||kr?|� d�}n�|� d�}n�|� d�}n�|d krU|� d �}n}|d kr�|}||k ri| | d kri|d }||k rw| | d krw|d }||k r�| | d kr�|d }||k r�| | d ks�||kr�|� d�}n9| ||� �dd�}|d }|d d kr�d|dd� � �}n |d dkr�d|� �}|� d |� d �}n|t�|� }||k s |� d�S )zfTranslate a shell PATTERN to a regular expression. There is no way to quote meta-characters. r �^� �*�/z.*z(.*/)?z[^/]*�?z[^/]�[�!�]z\[�\z\\N�$)r �replacer �escape)r �i�nr �c�j�stuffr r r r ? sJ � � -r ) �__doc__r �__all__r r r r r r r r r r �<module> s __pycache__/build.cpython-310.pyc 0000644 00000015112 15027746032 0012562 0 ustar 00 o �hJ � @ s� d dl Z d dlZd dlZd dlZd dlZddlmZ ddlmZ er'e�d�ne�d�Z e�d�Z d e d e fd d �Z d#dd�Zd$dd�Zdd� Z d%dd�Zdd� Zdd� Zdd� Zd&d d �ZG d d � d �ZG d!d"� d"�ZdS )'� N� )�IS_WINDOWS_PLATFORM� )�fnmatchz/|\\�/zy^[a-z0-9]+((\.|_|__|-+)[a-z0-9]+)*(?::[0-9]+)?(/[a-z0-9]+((\.|_|__|-+)[a-z0-9]+)*)*(:[a-zA-Z0-9_][a-zA-Z0-9._-]{0,127})?$�tag�returnc C s t t�| ��S �N)�bool�_TAG�match)r � r �H/usr/local/CyberPanel/lib/python3.10/site-packages/docker/utils/build.py� match_tag s r Fc C sv t j�| �}|p g }|p d}g }|d d ur)d�|p dg|d g �}d|f|g}ttt|||d d��||||d�S )N)NNr � z .dockerignorer )� dockerfile)�files�root�fileobj�gzip� extra_files)�os�path�abspath�join�create_archive�sorted� exclude_paths)r �excluder r r r r �dockerignore_contentsr r r �tar s ���r c C s2 |du rd}|� d|� �� t|�}t|�| ��S )a Given a root directory path and a list of .dockerignore patterns, return an iterator of all paths (both regular files and directories) in the root directory that do *not* match any of the patterns. All paths returned are relative to the root. N� Dockerfile�!)�append�PatternMatcher�set�walk)r �patternsr �pmr r r r ) s r c C sT g }t �| �D ] \}}}|| D ]}t j�||�}|�|�| dd��d�� qq|S )N� r r )r r& r r r# �replace�lstrip)r r �dirname�dirnames�fnames�filename�longpathr r r �build_file_list: s ��r1 c C s� |pg }|s t �� }tj|rdnd|d�}|d u r t| �}dd� |D �}|D ]p}||v r-q&tj�| |�}|j||d�} | d u r@q&| j dk sJ| j dkrPt | j �| _ t rZ| j d @ d B | _ | � � r�z t|d ��} |�| | � W d � n1 suw Y W q& ty� } ztd |� ��| �d } ~ ww |�| d � q&|D ] \} } t�| �}| �d �}t|�|_|�|t�|�� q�|�� |�d� |S )Nzw:gz�w��moder c S s h | ]}|d �qS )r r )�.0�er r r � <setcomp>N � z!create_archive.<locals>.<setcomp>)�arcnamer l �� i� �I �rbz Can not read file in context: zutf-8)�tempfile�NamedTemporaryFile�tarfile�openr1 r r r � gettarinfo�mtime�intr r4 �isfile�addfile�OSError�TarInfo�encode�len�size�io�BytesIO�close�seek)r r r r r �t� extra_namesr � full_path�i�f�oe�name�contents�info�contents_encodedr r r r F sR ������ r c C s� t �� }tjd|d�}t| tj�rt�d�}td��t| tj �r2t�d�}t | � � �|_ | � d� n|j| dd�}|�|| � |�� |� d� |S )Nr2 r3 r! zCPlease use io.BytesIO to create in-memory Dockerfiles with Python 3r )r r9 )r< r= r> r? � isinstancerJ �StringIOrF � TypeErrorrK rH �getvaluerI rM r@ rD rL )r rR rN �dfinfor r r �mkbuildcontext{ s r] c C s dd� t �t| �D �S )Nc S s g | ] }|r|d kr|�qS )�.r )r5 �ptr r r � <listcomp>� s z split_path.<locals>.<listcomp>)�re�split�_SEP��pr r r � split_path� s rf c C s t r d�t| ��S | S )Nr )r r rf rd r r r �normalize_slashes� s rg Tc C s t |�}|�| �S r )r$ r& )r r' �defaultr( r r r r& � s r& c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )r$ c C s2 t tdd� dd� |D ���| _| j�td�� d S )Nc S s | j S r )�dirsrd r r r �<lambda>� s z)PatternMatcher.__init__.<locals>.<lambda>c S s g | ]}t |��qS r )�Pattern)r5 re r r r r` � r8 z+PatternMatcher.__init__.<locals>.<listcomp>z!.dockerignore)�list�filterr' r# rk )�selfr' r r r �__init__� s �zPatternMatcher.__init__c C s� d}t j�|�}t|�}| jD ]/}|j}|�|�}|s9|dkr9t|j�t|�kr9|�t jj � |d t|j�� ��}|r>| }q|S )NFr) ) r r r, rf r' � exclusionr rH ri �sepr )rn �filepath�matched� parent_path�parent_path_dirs�pattern�negativer r r r �matches� s ��zPatternMatcher.matchesc s � ��fdd�� � ��S )Nc 3 s� � t �| �D ]`}t j�t j�| ��|�}|�dt jj� ��r$|dd � }��|�}|s.|V t j��|�}t j�|�rAt j� |�rBq|r_d}�j D ]}|j sOqI|j �t |��r[d} nqI|r_q� |�E d H qd S )Nr^ r TF)r �listdirr r �relpath� startswithrq rx �isdir�islinkr' rp �cleaned_patternrg )� current_dirrR �fpathr �cur�skip�pat��rec_walkr rn r r r� � s8 �� ���z%PatternMatcher.walk.<locals>.rec_walkr )rn r r r� r r& � s !zPatternMatcher.walkN)�__name__� __module__� __qualname__ro rx r& r r r r r$ � s r$ c @ s( e Zd Zdd� Zedd� �Zdd� ZdS )rk c C s@ d| _ |�d�rd| _ |dd � }| �|�| _d�| j�| _d S )NFr" Tr r )rp r{ � normalizeri r r~ )rn � pattern_strr r r ro � s zPattern.__init__c C sf |� � }d}t|�}|t|�k r1|| dkr'||= |dkr&||d = |d8 }n|d7 }|t|�k s|S )Nr z..r )�striprf rH )�clsre rQ rb r r r r� � s � �zPattern.normalizec C s t t|�| j�S r )r rg r~ )rn rr r r r r s z Pattern.matchN)r� r� r� ro � classmethodr� r r r r r rk � s rk )NNNFr )NNFN)T)rJ r ra r> r< � constantsr r �compilerc r �strr r r r r1 r r] rf rg r& r$ rk r r r r �<module> s0 � �5 ? __pycache__/config.cpython-310.pyc 0000644 00000003433 15027746032 0012733 0 ustar 00 o �h� � @ sh d dl Z d dlZd dlZddlmZ ej�dd�ZdZe� e �Z ddd�Z d d � Z d d � Zdd d�ZdS )� N� )�IS_WINDOWS_PLATFORMz.dockerz config.jsonz .dockercfgc C s� t td | t� tj�t� t�tj�t� t�g��}t � dt |�� �� |D ]}tj� |�r8t � d|� �� | S q$t � d� d S )NzTrying paths: zFound file at path: zNo config file found) �list�filter� config_path_from_environment�os�path�join�home_dir�DOCKER_CONFIG_FILENAME� LEGACY_DOCKER_CONFIG_FILENAME�log�debug�repr�exists)� config_path�pathsr � r �I/usr/local/CyberPanel/lib/python3.10/site-packages/docker/utils/config.py�find_config_file s � � r c C s* t j�d�} | s d S t j�| t j�t��S )N� DOCKER_CONFIG)r �environ�getr r �basenamer )� config_dirr r r r ! s r c C s t r tj�dd�S tj�d�S )z� Get the user's home directory, using the same logic as the Docker Engine client - use %USERPROFILE% on Windows, $HOME/getuid on POSIX. � USERPROFILE� �~)r r r r r � expanduserr r r r r ( s r c C s� t | �}|si S z t|��}t�|�W d � W S 1 s w Y W n ttfy= } z t�|� W Y d }~nd }~ww t�d� i S )Nz4All parsing attempts failed - returning empty config)r �open�json�load�OSError� ValueErrorr r )r � config_file�f�er r r �load_general_config3 s &��� r' )N)r �loggingr � constantsr r r r r � getLogger�__name__r r r r r' r r r r �<module> s build.py 0000644 00000020112 15027746032 0006217 0 ustar 00 import io import os import re import tarfile import tempfile from ..constants import IS_WINDOWS_PLATFORM from .fnmatch import fnmatch _SEP = re.compile('/|\\\\') if IS_WINDOWS_PLATFORM else re.compile('/') _TAG = re.compile( r"^[a-z0-9]+((\.|_|__|-+)[a-z0-9]+)*" r"(?::[0-9]+)?(/[a-z0-9]+((\.|_|__|-+)[a-z0-9]+)*)*" r"(:[a-zA-Z0-9_][a-zA-Z0-9._-]{0,127})?$" ) def match_tag(tag: str) -> bool: return bool(_TAG.match(tag)) def tar(path, exclude=None, dockerfile=None, fileobj=None, gzip=False): root = os.path.abspath(path) exclude = exclude or [] dockerfile = dockerfile or (None, None) extra_files = [] if dockerfile[1] is not None: dockerignore_contents = '\n'.join( (exclude or ['.dockerignore']) + [dockerfile[0]] ) extra_files = [ ('.dockerignore', dockerignore_contents), dockerfile, ] return create_archive( files=sorted(exclude_paths(root, exclude, dockerfile=dockerfile[0])), root=root, fileobj=fileobj, gzip=gzip, extra_files=extra_files ) def exclude_paths(root, patterns, dockerfile=None): """ Given a root directory path and a list of .dockerignore patterns, return an iterator of all paths (both regular files and directories) in the root directory that do *not* match any of the patterns. All paths returned are relative to the root. """ if dockerfile is None: dockerfile = 'Dockerfile' patterns.append(f"!{dockerfile}") pm = PatternMatcher(patterns) return set(pm.walk(root)) def build_file_list(root): files = [] for dirname, dirnames, fnames in os.walk(root): for filename in fnames + dirnames: longpath = os.path.join(dirname, filename) files.append( longpath.replace(root, '', 1).lstrip('/') ) return files def create_archive(root, files=None, fileobj=None, gzip=False, extra_files=None): extra_files = extra_files or [] if not fileobj: fileobj = tempfile.NamedTemporaryFile() t = tarfile.open(mode='w:gz' if gzip else 'w', fileobj=fileobj) if files is None: files = build_file_list(root) extra_names = {e[0] for e in extra_files} for path in files: if path in extra_names: # Extra files override context files with the same name continue full_path = os.path.join(root, path) i = t.gettarinfo(full_path, arcname=path) if i is None: # This happens when we encounter a socket file. We can safely # ignore it and proceed. continue # Workaround https://bugs.python.org/issue32713 if i.mtime < 0 or i.mtime > 8**11 - 1: i.mtime = int(i.mtime) if IS_WINDOWS_PLATFORM: # Windows doesn't keep track of the execute bit, so we make files # and directories executable by default. i.mode = i.mode & 0o755 | 0o111 if i.isfile(): try: with open(full_path, 'rb') as f: t.addfile(i, f) except OSError as oe: raise OSError( f'Can not read file in context: {full_path}' ) from oe else: # Directories, FIFOs, symlinks... don't need to be read. t.addfile(i, None) for name, contents in extra_files: info = tarfile.TarInfo(name) contents_encoded = contents.encode('utf-8') info.size = len(contents_encoded) t.addfile(info, io.BytesIO(contents_encoded)) t.close() fileobj.seek(0) return fileobj def mkbuildcontext(dockerfile): f = tempfile.NamedTemporaryFile() t = tarfile.open(mode='w', fileobj=f) if isinstance(dockerfile, io.StringIO): dfinfo = tarfile.TarInfo('Dockerfile') raise TypeError('Please use io.BytesIO to create in-memory ' 'Dockerfiles with Python 3') elif isinstance(dockerfile, io.BytesIO): dfinfo = tarfile.TarInfo('Dockerfile') dfinfo.size = len(dockerfile.getvalue()) dockerfile.seek(0) else: dfinfo = t.gettarinfo(fileobj=dockerfile, arcname='Dockerfile') t.addfile(dfinfo, dockerfile) t.close() f.seek(0) return f def split_path(p): return [pt for pt in re.split(_SEP, p) if pt and pt != '.'] def normalize_slashes(p): if IS_WINDOWS_PLATFORM: return '/'.join(split_path(p)) return p def walk(root, patterns, default=True): pm = PatternMatcher(patterns) return pm.walk(root) # Heavily based on # https://github.com/moby/moby/blob/master/pkg/fileutils/fileutils.go class PatternMatcher: def __init__(self, patterns): self.patterns = list(filter( lambda p: p.dirs, [Pattern(p) for p in patterns] )) self.patterns.append(Pattern('!.dockerignore')) def matches(self, filepath): matched = False parent_path = os.path.dirname(filepath) parent_path_dirs = split_path(parent_path) for pattern in self.patterns: negative = pattern.exclusion match = pattern.match(filepath) if not match and parent_path != '': if len(pattern.dirs) <= len(parent_path_dirs): match = pattern.match( os.path.sep.join(parent_path_dirs[:len(pattern.dirs)]) ) if match: matched = not negative return matched def walk(self, root): def rec_walk(current_dir): for f in os.listdir(current_dir): fpath = os.path.join( os.path.relpath(current_dir, root), f ) if fpath.startswith(f".{os.path.sep}"): fpath = fpath[2:] match = self.matches(fpath) if not match: yield fpath cur = os.path.join(root, fpath) if not os.path.isdir(cur) or os.path.islink(cur): continue if match: # If we want to skip this file and it's a directory # then we should first check to see if there's an # excludes pattern (e.g. !dir/file) that starts with this # dir. If so then we can't skip this dir. skip = True for pat in self.patterns: if not pat.exclusion: continue if pat.cleaned_pattern.startswith( normalize_slashes(fpath)): skip = False break if skip: continue yield from rec_walk(cur) return rec_walk(root) class Pattern: def __init__(self, pattern_str): self.exclusion = False if pattern_str.startswith('!'): self.exclusion = True pattern_str = pattern_str[1:] self.dirs = self.normalize(pattern_str) self.cleaned_pattern = '/'.join(self.dirs) @classmethod def normalize(cls, p): # Remove trailing spaces p = p.strip() # Leading and trailing slashes are not relevant. Yes, # "foo.py/" must exclude the "foo.py" regular file. "." # components are not relevant either, even if the whole # pattern is only ".", as the Docker reference states: "For # historical reasons, the pattern . is ignored." # ".." component must be cleared with the potential previous # component, regardless of whether it exists: "A preprocessing # step [...] eliminates . and .. elements using Go's # filepath.". i = 0 split = split_path(p) while i < len(split): if split[i] == '..': del split[i] if i > 0: del split[i - 1] i -= 1 else: i += 1 return split def match(self, filepath): return fnmatch(normalize_slashes(filepath), self.cleaned_pattern) config.py 0000644 00000003274 15027746032 0006377 0 ustar 00 import json import logging import os from ..constants import IS_WINDOWS_PLATFORM DOCKER_CONFIG_FILENAME = os.path.join('.docker', 'config.json') LEGACY_DOCKER_CONFIG_FILENAME = '.dockercfg' log = logging.getLogger(__name__) def find_config_file(config_path=None): paths = list(filter(None, [ config_path, # 1 config_path_from_environment(), # 2 os.path.join(home_dir(), DOCKER_CONFIG_FILENAME), # 3 os.path.join(home_dir(), LEGACY_DOCKER_CONFIG_FILENAME), # 4 ])) log.debug(f"Trying paths: {repr(paths)}") for path in paths: if os.path.exists(path): log.debug(f"Found file at path: {path}") return path log.debug("No config file found") return None def config_path_from_environment(): config_dir = os.environ.get('DOCKER_CONFIG') if not config_dir: return None return os.path.join(config_dir, os.path.basename(DOCKER_CONFIG_FILENAME)) def home_dir(): """ Get the user's home directory, using the same logic as the Docker Engine client - use %USERPROFILE% on Windows, $HOME/getuid on POSIX. """ if IS_WINDOWS_PLATFORM: return os.environ.get('USERPROFILE', '') else: return os.path.expanduser('~') def load_general_config(config_path=None): config_file = find_config_file(config_path) if not config_file: return {} try: with open(config_file) as f: return json.load(f) except (OSError, ValueError) as e: # In the case of a legacy `.dockercfg` file, we won't # be able to load any JSON data. log.debug(e) log.debug("All parsing attempts failed - returning empty config") return {} json_stream.py 0000644 00000004210 15027746032 0007445 0 ustar 00 import json import json.decoder from ..errors import StreamParseError json_decoder = json.JSONDecoder() def stream_as_text(stream): """ 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 we return text streams instead of byte streams. """ for data in stream: if not isinstance(data, str): data = data.decode('utf-8', 'replace') yield data def json_splitter(buffer): """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. """ buffer = buffer.strip() try: obj, index = json_decoder.raw_decode(buffer) rest = buffer[json.decoder.WHITESPACE.match(buffer, index).end():] return obj, rest except ValueError: return None def json_stream(stream): """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). """ return split_buffer(stream, json_splitter, json_decoder.decode) def line_splitter(buffer, separator='\n'): index = buffer.find(str(separator)) if index == -1: return None return buffer[:index + 1], buffer[index + 1:] def split_buffer(stream, splitter=None, decoder=lambda a: 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. """ splitter = splitter or line_splitter buffered = '' for data in stream_as_text(stream): buffered += data while True: buffer_split = splitter(buffered) if buffer_split is None: break item, buffered = buffer_split yield item if buffered: try: yield decoder(buffered) except Exception as e: raise StreamParseError(e) from e __init__.py 0000644 00000001230 15027746032 0006657 0 ustar 00 from .build import create_archive, exclude_paths, match_tag, mkbuildcontext, tar from .decorators import check_resource, minimum_version, update_headers from .utils import ( compare_version, convert_filters, convert_port_bindings, convert_service_networks, convert_volume_binds, create_host_config, create_ipam_config, create_ipam_pool, datetime_to_timestamp, decode_json_header, format_environment, format_extra_hosts, kwargs_from_env, normalize_links, parse_bytes, parse_devices, parse_env_file, parse_host, parse_repository_tag, split_command, version_gte, version_lt, ) utils.py 0000644 00000033454 15027746032 0006275 0 ustar 00 import base64 import collections import json import os import os.path import shlex import string from datetime import datetime, timezone from functools import lru_cache from itertools import zip_longest from urllib.parse import urlparse, urlunparse from .. import errors from ..constants import ( BYTE_UNITS, DEFAULT_HTTP_HOST, DEFAULT_NPIPE, DEFAULT_UNIX_SOCKET, ) from ..tls import TLSConfig URLComponents = collections.namedtuple( 'URLComponents', 'scheme netloc url params query fragment', ) def create_ipam_pool(*args, **kwargs): raise errors.DeprecatedMethod( 'utils.create_ipam_pool has been removed. Please use a ' 'docker.types.IPAMPool object instead.' ) def create_ipam_config(*args, **kwargs): raise errors.DeprecatedMethod( 'utils.create_ipam_config has been removed. Please use a ' 'docker.types.IPAMConfig object instead.' ) def decode_json_header(header): data = base64.b64decode(header) data = data.decode('utf-8') return json.loads(data) @lru_cache(maxsize=None) def compare_version(v1, v2): """Compare docker versions >>> v1 = '1.9' >>> v2 = '1.10' >>> compare_version(v1, v2) 1 >>> compare_version(v2, v1) -1 >>> compare_version(v2, v2) 0 """ if v1 == v2: return 0 # Split into `sys.version_info` like tuples. s1 = tuple(int(p) for p in v1.split('.')) s2 = tuple(int(p) for p in v2.split('.')) # Compare each component, padding with 0 if necessary. for c1, c2 in zip_longest(s1, s2, fillvalue=0): if c1 == c2: continue elif c1 > c2: return -1 else: return 1 return 0 def version_lt(v1, v2): return compare_version(v1, v2) > 0 def version_gte(v1, v2): return not version_lt(v1, v2) def _convert_port_binding(binding): result = {'HostIp': '', 'HostPort': ''} if isinstance(binding, tuple): if len(binding) == 2: result['HostPort'] = binding[1] result['HostIp'] = binding[0] elif isinstance(binding[0], str): result['HostIp'] = binding[0] else: result['HostPort'] = binding[0] elif isinstance(binding, dict): if 'HostPort' in binding: result['HostPort'] = binding['HostPort'] if 'HostIp' in binding: result['HostIp'] = binding['HostIp'] else: raise ValueError(binding) else: result['HostPort'] = binding if result['HostPort'] is None: result['HostPort'] = '' else: result['HostPort'] = str(result['HostPort']) return result def convert_port_bindings(port_bindings): result = {} for k, v in iter(port_bindings.items()): key = str(k) if '/' not in key: key += '/tcp' if isinstance(v, list): result[key] = [_convert_port_binding(binding) for binding in v] else: result[key] = [_convert_port_binding(v)] return result def convert_volume_binds(binds): if isinstance(binds, list): return binds result = [] for k, v in binds.items(): if isinstance(k, bytes): k = k.decode('utf-8') if isinstance(v, dict): if 'ro' in v and 'mode' in v: raise ValueError( f'Binding cannot contain both "ro" and "mode": {v!r}' ) bind = v['bind'] if isinstance(bind, bytes): bind = bind.decode('utf-8') if 'ro' in v: mode = 'ro' if v['ro'] else 'rw' elif 'mode' in v: mode = v['mode'] else: mode = 'rw' # NOTE: this is only relevant for Linux hosts # (doesn't apply in Docker Desktop) propagation_modes = [ 'rshared', 'shared', 'rslave', 'slave', 'rprivate', 'private', ] if 'propagation' in v and v['propagation'] in propagation_modes: if mode: mode = f"{mode},{v['propagation']}" else: mode = v['propagation'] result.append( f'{k}:{bind}:{mode}' ) else: if isinstance(v, bytes): v = v.decode('utf-8') result.append( f'{k}:{v}:rw' ) return result def convert_tmpfs_mounts(tmpfs): if isinstance(tmpfs, dict): return tmpfs if not isinstance(tmpfs, list): raise ValueError( 'Expected tmpfs value to be either a list or a dict, ' f'found: {type(tmpfs).__name__}' ) result = {} for mount in tmpfs: if isinstance(mount, str): if ":" in mount: name, options = mount.split(":", 1) else: name = mount options = "" else: raise ValueError( "Expected item in tmpfs list to be a string, " f"found: {type(mount).__name__}" ) result[name] = options return result def convert_service_networks(networks): if not networks: return networks if not isinstance(networks, list): raise TypeError('networks parameter must be a list.') result = [] for n in networks: if isinstance(n, str): n = {'Target': n} result.append(n) return result def parse_repository_tag(repo_name): parts = repo_name.rsplit('@', 1) if len(parts) == 2: return tuple(parts) parts = repo_name.rsplit(':', 1) if len(parts) == 2 and '/' not in parts[1]: return tuple(parts) return repo_name, None def parse_host(addr, is_win32=False, tls=False): # Sensible defaults if not addr and is_win32: return DEFAULT_NPIPE if not addr or addr.strip() == 'unix://': return DEFAULT_UNIX_SOCKET addr = addr.strip() parsed_url = urlparse(addr) proto = parsed_url.scheme if not proto or any(x not in f"{string.ascii_letters}+" for x in proto): # https://bugs.python.org/issue754016 parsed_url = urlparse(f"//{addr}", 'tcp') proto = 'tcp' if proto == 'fd': raise errors.DockerException('fd protocol is not implemented') # These protos are valid aliases for our library but not for the # official spec if proto == 'http' or proto == 'https': tls = proto == 'https' proto = 'tcp' elif proto == 'http+unix': proto = 'unix' if proto not in ('tcp', 'unix', 'npipe', 'ssh'): raise errors.DockerException( f"Invalid bind address protocol: {addr}" ) if proto == 'tcp' and not parsed_url.netloc: # "tcp://" is exceptionally disallowed by convention; # omitting a hostname for other protocols is fine raise errors.DockerException( f'Invalid bind address format: {addr}' ) if any([ parsed_url.params, parsed_url.query, parsed_url.fragment, parsed_url.password ]): raise errors.DockerException( f'Invalid bind address format: {addr}' ) if parsed_url.path and proto == 'ssh': raise errors.DockerException( f'Invalid bind address format: no path allowed for this protocol: {addr}' ) else: path = parsed_url.path if proto == 'unix' and parsed_url.hostname is not None: # For legacy reasons, we consider unix://path # to be valid and equivalent to unix:///path path = f"{parsed_url.hostname}/{path}" netloc = parsed_url.netloc if proto in ('tcp', 'ssh'): port = parsed_url.port or 0 if port <= 0: if proto != 'ssh': raise errors.DockerException( f'Invalid bind address format: port is required: {addr}' ) port = 22 netloc = f'{parsed_url.netloc}:{port}' if not parsed_url.hostname: netloc = f'{DEFAULT_HTTP_HOST}:{port}' # Rewrite schemes to fit library internals (requests adapters) if proto == 'tcp': proto = f"http{'s' if tls else ''}" elif proto == 'unix': proto = 'http+unix' if proto in ('http+unix', 'npipe'): return f"{proto}://{path}".rstrip('/') return urlunparse(URLComponents( scheme=proto, netloc=netloc, url=path, params='', query='', fragment='', )).rstrip('/') def parse_devices(devices): device_list = [] for device in devices: if isinstance(device, dict): device_list.append(device) continue if not isinstance(device, str): raise errors.DockerException( f'Invalid device type {type(device)}' ) device_mapping = device.split(':') if device_mapping: path_on_host = device_mapping[0] if len(device_mapping) > 1: path_in_container = device_mapping[1] else: path_in_container = path_on_host if len(device_mapping) > 2: permissions = device_mapping[2] else: permissions = 'rwm' device_list.append({ 'PathOnHost': path_on_host, 'PathInContainer': path_in_container, 'CgroupPermissions': permissions }) return device_list def kwargs_from_env(environment=None): if not environment: environment = os.environ host = environment.get('DOCKER_HOST') # empty string for cert path is the same as unset. cert_path = environment.get('DOCKER_CERT_PATH') or None # empty string for tls verify counts as "false". # Any value or 'unset' counts as true. tls_verify = environment.get('DOCKER_TLS_VERIFY') if tls_verify == '': tls_verify = False else: tls_verify = tls_verify is not None enable_tls = cert_path or tls_verify params = {} if host: params['base_url'] = host if not enable_tls: return params if not cert_path: cert_path = os.path.join(os.path.expanduser('~'), '.docker') params['tls'] = TLSConfig( client_cert=(os.path.join(cert_path, 'cert.pem'), os.path.join(cert_path, 'key.pem')), ca_cert=os.path.join(cert_path, 'ca.pem'), verify=tls_verify, ) return params def convert_filters(filters): result = {} for k, v in iter(filters.items()): if isinstance(v, bool): v = 'true' if v else 'false' if not isinstance(v, list): v = [v, ] result[k] = [ str(item) if not isinstance(item, str) else item for item in v ] return json.dumps(result) def datetime_to_timestamp(dt): """Convert a datetime to a Unix timestamp""" delta = dt.astimezone(timezone.utc) - datetime(1970, 1, 1, tzinfo=timezone.utc) return delta.seconds + delta.days * 24 * 3600 def parse_bytes(s): if isinstance(s, (int, float,)): return s if len(s) == 0: return 0 if s[-2:-1].isalpha() and s[-1].isalpha(): if s[-1] == "b" or s[-1] == "B": s = s[:-1] units = BYTE_UNITS suffix = s[-1].lower() # Check if the variable is a string representation of an int # without a units part. Assuming that the units are bytes. if suffix.isdigit(): digits_part = s suffix = 'b' else: digits_part = s[:-1] if suffix in units.keys() or suffix.isdigit(): try: digits = float(digits_part) except ValueError as ve: raise errors.DockerException( 'Failed converting the string value for memory ' f'({digits_part}) to an integer.' ) from ve # Reconvert to long for the final result s = int(digits * units[suffix]) else: raise errors.DockerException( f'The specified value for memory ({s}) should specify the units. ' 'The postfix should be one of the `b` `k` `m` `g` characters' ) return s def normalize_links(links): if isinstance(links, dict): links = iter(links.items()) return [f'{k}:{v}' if v else k for k, v in sorted(links)] def parse_env_file(env_file): """ Reads a line-separated environment file. The format of each line should be "key=value". """ environment = {} with open(env_file) as f: for line in f: if line[0] == '#': continue line = line.strip() if not line: continue parse_line = line.split('=', 1) if len(parse_line) == 2: k, v = parse_line environment[k] = v else: raise errors.DockerException( f'Invalid line in environment file {env_file}:\n{line}') return environment def split_command(command): return shlex.split(command) def format_environment(environment): def format_env(key, value): if value is None: return key if isinstance(value, bytes): value = value.decode('utf-8') return f'{key}={value}' return [format_env(*var) for var in iter(environment.items())] def format_extra_hosts(extra_hosts, task=False): # Use format dictated by Swarm API if container is part of a task if task: return [ f'{v} {k}' for k, v in sorted(iter(extra_hosts.items())) ] return [ f'{k}:{v}' for k, v in sorted(iter(extra_hosts.items())) ] def create_host_config(self, *args, **kwargs): raise errors.DeprecatedMethod( 'utils.create_host_config has been removed. Please use a ' 'docker.types.HostConfig object instead.' )
| ver. 1.4 |
Github
|
.
| PHP 8.2.28 | Generation time: 0.02 |
proxy
|
phpinfo
|
Settings