File: //usr/local/CyberPanel/lib64/python3.10/site-packages/docker/api/__pycache__/client.cpython-310.pyc
o
��h�K � @ s� d dl Z d dlZd dlZd dlmZ d dlZd dlZd dlZddlm Z ddl
m Z m Z m
Z
mZmZmZmZmZ ddlmZmZmZmZ ddlmZ ddlmZ dd l m Z m Z m Z m Z dd
l m!Z! dd l"m#Z# dd l$m%Z%m&Z&m'Z' d
dl(m)Z) d
dl m*Z* d
dl+m,Z, d
dl-m.Z. d
dl/m0Z0 d
dl1m2Z2 d
dl3m4Z4 d
dl5m6Z6 d
dl7m8Z8 d
dl9m:Z: d
dl;m<Z< d
dl=m>Z> zddlm?Z? W n e@y� Y nw zddlmAZA W n e@y� Y nw G d d � d ejBe)e*e,e.e0e2e4e6e8e:e<e>�ZCdS ) � N)�partial� )�auth)�DEFAULT_MAX_POOL_SIZE�DEFAULT_NUM_POOLS�DEFAULT_NUM_POOLS_SSH�DEFAULT_TIMEOUT_SECONDS�DEFAULT_USER_AGENT�IS_WINDOWS_PLATFORM�MINIMUM_DOCKER_API_VERSION�STREAM_HEADER_SIZE_BYTES)�DockerException�InvalidVersion�TLSParameterError�$create_api_error_from_http_exception)� TLSConfig)�UnixHTTPAdapter)�check_resource�config�update_headers�utils)� json_stream)� ProxyConfig)�consume_socket_output�
demux_adaptor� frames_iter� )�
BuildApiMixin)�ConfigApiMixin)�ContainerApiMixin)�DaemonApiMixin)� ExecApiMixin)�
ImageApiMixin)�NetworkApiMixin)�PluginApiMixin)�SecretApiMixin)�ServiceApiMixin)�
SwarmApiMixin)�VolumeApiMixin)�NpipeHTTPAdapter)�SSHHTTPAdapterc sR e Zd ZdZejjg d� Zddededdde f � fdd� Z
dd� Z d d
� Z e
d d � �Ze
d
d� �Ze
dd� �Ze
dd� �Zdd� Zdd� Zd@dd�Zdd� ZdAdd �Zed �dAd d ��Zd d!� Zd"d#� ZdBd$d%�Zd&d'� Z d(d)� Z dCd,d-�Z dDd.d/�Z d0d1� Z ed �d2d3� �Z!d4d5� Z"d6d7� Z#d8d9� Z$� fd:d;�Z%e&d<d=� �Z'dAd>d?�Z(� Z)S )E� APIClientaW
A low-level client for the Docker Engine API.
Example:
>>> import docker
>>> client = docker.APIClient(base_url='unix://var/run/docker.sock')
>>> client.version()
{u'ApiVersion': u'1.33',
u'Arch': u'amd64',
u'BuildTime': u'2017-11-19T18:46:37.000000000+00:00',
u'GitCommit': u'f4ffd2511c',
u'GoVersion': u'go1.9.2',
u'KernelVersion': u'4.14.3-1-ARCH',
u'MinAPIVersion': u'1.12',
u'Os': u'linux',
u'Version': u'17.10.0-ce'}
Args:
base_url (str): URL to the Docker server. For example,
``unix:///var/run/docker.sock`` or ``tcp://127.0.0.1:1234``.
version (str): The version of the API to use. Set to ``auto`` to
automatically detect the server's version. Default: ``1.35``
timeout (int): Default timeout for API calls, in seconds.
tls (bool or :py:class:`~docker.tls.TLSConfig`): Enable TLS. Pass
``True`` to enable it with default options, or pass a
:py:class:`~docker.tls.TLSConfig` object to use custom
configuration.
user_agent (str): Set a custom user agent for requests to the server.
credstore_env (dict): Override environment variables when calling the
credential store process.
use_ssh_client (bool): If set to `True`, an ssh connection is made
via shelling out to the ssh client. Ensure the ssh client is
installed and configured on the host.
max_pool_size (int): The maximum number of connections
to save in the pool.
)�
_auth_configs�_general_configs�_version�base_url�timeoutNFc
s� t � �� |r
|s
td��|| _|| _|| jd< t�� | _| j� di �}
z|
| } W n t
y9 |
� di �} Y nw t � | �| _
tj| j|d�| _|| _tj|tt|�d�}|�d�r_|p^tnt}|�d�r�t|||| d �| _| �d
| j� | � d d � d
| _n�|�d�r�ts�t d��z t |||| d �| _W n t y� } zt d�| �d } ~ ww | �d
| j� d| _nT|�d�r�z t |||| |d�| _W n t y� } zt d�| �d } ~ ww | �d| j� | � d d � d| _n t!|t"�r�|�#| � n|�rt$j%j&|d�| _| �d | j� || _|d u �st!|t'��r |�(� dk�r | �)� | _*n|| _*t!| j*t'��s3t dt+|�j,� ���t�-| j*t.��rCt/dt.� d���d S )Nz5If using TLS, the base_url argument must be provided.z
User-Agent�proxies�default)� config_dict�
credstore_env)�tlszssh://z http+unix://)�pool_connections�
max_pool_sizezhttp+docker://�http://�https://zhttp+docker://localhostznpipe://z2The npipe:// protocol is only supported on Windowsz4Install pypiwin32 package to enable npipe:// support�http+docker://localnpipe)r6 r7 � shell_outz1Install paramiko package to enable ssh:// support�http+docker://ssh)r6 �autoz2Version parameter must be a string or None. Found zAPI versions below z) are no longer supported by this library.)0�super�__init__r r/ r0 �headersr �load_general_configr- �get�KeyErrorr � from_dict�_proxy_configsr � load_configr, r4 r �
parse_hostr
�bool�
startswithr r r �_custom_adapter�mount�_unmountr
r) � NameErrorr* �
isinstancer �configure_client�requests�adapters� HTTPAdapter�str�lower�_retrieve_server_versionr. �type�__name__�
version_ltr r )
�selfr/ �versionr0 r5 �
user_agent� num_poolsr4 �use_ssh_clientr7 � proxy_configr1 �err�� __class__� �G/usr/local/CyberPanel/lib/python3.10/site-packages/docker/api/client.pyr? s s�
�
� �
����
�
� �����
�����
� � ��
��zAPIClient.__init__c
C s\ z | j dd�d W S ty } ztd�|�d }~w ty- } ztd|� ��|�d }~ww )NF)� api_version�
ApiVersionzAInvalid response from docker daemon: key "ApiVersion" is missing.z)Error while fetching server API version: )rZ rC r
� Exception)rY �ke�erb rb rc rU � s" �������z"APIClient._retrieve_server_versionc C s |� d| j� |S )zjPrepare the kwargs for an HTTP request by inserting the timeout
parameter, if not already present.r0 )�
setdefaultr0 )rY �kwargsrb rb rc �_set_request_timeout� s z APIClient._set_request_timeoutc K � | j |fi | �|���S �N)�postrk �rY �urlrj rb rb rc �_post� � zAPIClient._postc K rl rm )rB rk ro rb rb rc �_get� rr zAPIClient._getc K rl rm )�putrk ro rb rb rc �_put� rr zAPIClient._putc K rl rm )�deleterk ro rb rb rc �_delete� rr zAPIClient._deletec O s� |D ]}t |t�std|� dt|�� d���qttjjdd�}t||�}|j |� }|�
dd�r:| j � d| j � |� �S | j � |� �S ) Nz Expected a string but found z (z ) insteadz/:)�safe�
versioned_apiTz/v)
rN rS �
ValueErrorrV r �urllib�parse�quote�map�formatrB r/ r. )rY �pathfmt�argsrj �arg�quote_f�formatted_pathrb rb rc �_url s
��
zAPIClient._urlc
C s6 z|� � W dS tjjy } zt|�|�d}~ww )z1Raises stored :class:`APIError`, if one occurred.N)�raise_for_statusrP �
exceptions� HTTPErrorr )rY �responserh rb rb rc �_raise_for_status s
��zAPIClient._raise_for_statusc C s2 |r|rJ �| � |� |r|�� S |r|jS |jS rm )r� �json�content�text)rY r� r� �binaryrb rb rc �_result s
zAPIClient._resultc K s� i }|d ur t |t�r t|�� �D ] \}}|d ur |||< qn|d ur%|}d|vr-i |d< d|d d< | j|fdt�|�i|��S )Nr@ zapplication/jsonz Content-Type�data)rN �dict�iter�itemsrq r� �dumps)rY rp r� rj �data2�k�vrb rb rc �
_post_json! s �� zAPIClient._post_jsonc C s |pdddd�S )Nr )�stdout�stderr�streamrb )rY �overriderb rb rc �_attach_params1 s
�zAPIClient._attach_params� containerc C sR | � d|�}tjd|| �|�d�}|�� j}|�ddd�}|�ddd�}| �|�S ) Nz/containers/{0}/attach/ws�POST)�paramsr8 zws://r r9 zwss://)r� rP �Requestr� �preparerp �replace� _create_websocket_connection)rY r� r� rp �req�full_urlrb rb rc �_attach_websocket8 s
zAPIClient._attach_websocketc
C s8 z
dd l }|�|�W S ty } ztd�|�d }~ww )Nr z�The `websocket-client` library is required for using websocket connections. You can install the `docker` library with the [websocket] extra to install it.)� websocket�create_connection� ImportErrorr
)rY rp r� �ierb rb rc r� A s ����z&APIClient._create_websocket_connectionc C s~ | � |� | jdkr|jjjjj}n | j�d�r |jjjj}n|jjjj}| j�d�r.|j}z||_ W |S t
y> Y |S w )Nr: r< r9 ) r� r/ �raw�_fp�fp�sockrI �channel�_sock� _response�AttributeError)rY r� r� rb rb rc �_get_raw_response_socketM s
��z"APIClient._get_raw_response_socketc c s� � |j jjr;|rt| �|d��E dH dS |j }|js9|�d�}|s$dS |jjr1||�|jj�7 }|V |jrdS dS | j||d�V dS )z?Generator for data coming from a chunked-encoded HTTP response.FNr )r� ) r� r� �chunkedr �_stream_helper�closed�read�
chunk_leftr� )rY r� �decode�readerr� rb rb rc r� c s �
� zAPIClient._stream_helperc
c sr � | j |dd�}t|�}d} || tk rdS |||t � }t�d|�\}}|t }|| } | }||| � V q)zMA generator of multiplexed data blocks read from a buffered
response.T�r� r �>BxxxLN)r� �lenr �struct� unpack_from)
rY r� �buf�
buf_length�walker�header�_�length�start�endrb rb rc �_multiplexed_buffer_helperx s � �z$APIClient._multiplexed_buffer_helperc c s^ � | � |�}| �|� |j�t�}|sdS t�d|�\}}|s!q |j�|�}|s+dS |V q )zMA generator of multiplexed data blocks coming from a response
stream.Tr� N)r� �_disable_socket_timeoutr� r� r r� �unpack)rY r� �socketr� r� r� r� rb rb rc �#_multiplexed_response_stream_helper� s �
�z-APIClient._multiplexed_response_stream_helperr Tc c s6 � | � |� | �|�}| �|� |�||�E dH dS )z< Stream result for TTY-enabled container and raw binary dataN)r� r� r� � iter_content)rY r� �
chunk_sizer� r� rb rb rc �_stream_raw_result� s
�
z APIClient._stream_raw_resultc C s` | � |�}t||�}|rdd� |D �}ndd� |D �}|r |S z t||d�W |�� S |�� w )z�Consume all data from the socket, close the response and return the
data. If stream=True, then a generator is returned instead and the
caller is responsible for closing the response.
c s s � | ]}t |� V qd S rm )r )�.0�framerb rb rc � <genexpr>� � � z.APIClient._read_from_socket.<locals>.<genexpr>c s s � | ]\}}|V qd S rm rb )r� r� r� rb rb rc r� � r� )�demux)r� r r �close)rY r� r� �ttyr� r� �genrb rb rc �_read_from_socket� s
zAPIClient._read_from_socketc C s\ |t |dd�g}|D ]!}t|d�sq
d}t|d�r |�� }|du s%|dkr&q
|�d� q
dS )a Depending on the combination of python version and whether we're
connecting over http or https, we might need to access _sock, which
may or may not exist; or we may need to just settimeout on socket
itself, which also may or may not have settimeout on it. To avoid
missing the correct one, we try both.
We also do not want to set the timeout if it is already disabled, as
you run the risk of changing a socket that was non-blocking to
blocking, for example when using gevent.
r� N�
settimeout����
gettimeoutg )�getattr�hasattrr� r� )rY r� �sockets�sr0 rb rb rc r� � s
�z!APIClient._disable_socket_timeoutc C s | � |�}|d d S )N�Config�Tty)�inspect_container)rY r� �contrb rb rc �
_check_is_tty� s
zAPIClient._check_is_ttyc C s | � ||| �|��S rm )�_get_result_ttyr� )rY r� r� �resrb rb rc � _get_result� s zAPIClient._get_resultc C sP |r|r | � |�S | j|dd�S | �|� d}|r | �|�S |�t| �|���S )NTr� � )r� r� r� r� �join�listr� )rY r� r� �is_tty�seprb rb rc r� � s �
�zAPIClient._get_result_ttyc G s |D ]}| j �|� qd S rm )rQ �pop)rY r� �protorb rb rc rL � s �zAPIClient._unmountc
sH zt � �|�W S tjjy# } z| jr | jW Y d }~S |�d }~ww rm )r> � get_adapterrP r� �
InvalidSchemarJ )rY rp rh r` rb rc r� � s ��zAPIClient.get_adapterc C s | j S rm )r. )rY rb rb rc rd s zAPIClient.api_versionc C s t j|| jd�| _dS )a.
Force a reload of the auth configuration
Args:
dockercfg_path (str): Use a custom path for the Docker config file
(default ``$HOME/.docker/config.json`` if present,
otherwise ``$HOME/.dockercfg``)
Returns:
None
)r4 N)r rF r4 r, )rY �dockercfg_pathrb rb rc �
reload_config s �zAPIClient.reload_config)FFrm )F)r T)TF)*rW �
__module__� __qualname__�__doc__rP �Session� __attrs__r r r r? rU rk r rq rs ru rw r� r� r� r� r� r r� r� r� r� r� r� r� r� r� r� r� r� rL r� �propertyrd r� �
__classcell__rb rb r` rc r+ 9 sV &�j
r+ )Dr� r� r{ � functoolsr rP �requests.adapters�requests.exceptions� r � constantsr r r r r r
r r �errorsr
r r r r5 r � transportr r r r r �utils.json_streamr � utils.proxyr � utils.socketr r r �buildr r r� r �daemonr �exec_apir! �imager" �networkr# �pluginr$ �secretr% �servicer& �swarmr' �volumer( r) r� r* r� r+ rb rb rb rc �<module> sj (
� �
�