Website : rimsha.abasa.com
backdoor
Home
Console
Upload
information
Create File
Create Folder
About
Tools
:
/
proc
/
self
/
root
/
lib
/
python3
/
dist-packages
/
docker
/
api
/
__pycache__
/
Filename :
client.cpython-310.pyc
back
Copy
o a_a�I � @ s� d dl Z d dlZd dlZd dlmZ d dlZd dlZd dlZddlm Z ddl m Z m Z m Z mZmZmZmZmZ ddlmZmZmZmZ ddlmZ ddlmZm Z 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 dl0m1Z1 d dl2m3Z3 d dl4m5Z5 d dl6m7Z7 d dl8m9Z9 d dl:m;Z; d dl<m=Z= d dl>m?Z? zddlm@Z@ W n eAy� Y nw zddlmBZB W n eAy� Y nw G d d � d ejCe*e+e-e/e1e3e5e7e9e;e=e?�ZDdS ) � N)�partial� )�auth)�DEFAULT_NUM_POOLS�DEFAULT_NUM_POOLS_SSH�DEFAULT_MAX_POOL_SIZE�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)�SSLHTTPAdapter�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 sj 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 | _nx|�d�r�ts�t d��z t |||| d �| _W n t y� t d��w | �d | j� d| _nK|�d�r�z t |||| |d�| _W n t y� t d��w | �d| j� | � d d � d| _n t!|t"�r�|�#| � n|r�t$|d�| _| �d | j� || _|d u �s t!|t%��r|�&� dk�r| �'� | _(n|| _(t!| j(t%��s$t d�)t*|�j+���t�,| j(t-��r3t.d�)t-���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)r7 r8 � shell_outz1Install paramiko package to enable ssh:// support�http+docker://ssh)r7 �autoz4Version parameter must be a string or None. Found {}z>API versions below {} are no longer supported by this library.)/�super�__init__r r0 r1 �headersr �load_general_configr. �get�KeyErrorr � from_dict�_proxy_configsr � load_configr- r5 r � parse_hostr �bool� startswithr r r �_custom_adapter�mount�_unmountr r* � NameErrorr+ � isinstancer �configure_clientr �str�lower�_retrieve_server_versionr/ �format�type�__name__� version_ltr r ) �selfr0 �versionr1 r6 � user_agent� num_poolsr5 �use_ssh_clientr8 � proxy_configr2 �� __class__� �3/usr/lib/python3/dist-packages/docker/api/client.pyr@ i s� � � � ���� � � � �� � �� � � ����zAPIClient.__init__c C sN z | j dd�d W S ty td�� ty& } ztd|� ���d }~ww )NF)� api_version� ApiVersionzAInvalid response from docker daemon: key "ApiVersion" is missing.z)Error while fetching server API version: )rY rD r � Exception)rX �er` r` ra rS � 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.r1 )� setdefaultr1 )rX �kwargsr` r` ra �_set_request_timeout� s z APIClient._set_request_timeoutc K � | j |fi | �|���S �N)�postrh �rX �urlrg r` r` ra �_post� � zAPIClient._postc K ri rj )rC rh rl r` r` ra �_get� ro zAPIClient._getc K ri rj )�putrh rl r` r` ra �_put� ro zAPIClient._putc K ri rj )�deleterh rl r` r` ra �_delete� ro zAPIClient._deletec O sz |D ]}t |t�std�|t|����qttjjdd�}t ||�}|� dd�r3d�| j | j |j|� �S | j � |j|� � �S )Nz+Expected a string but found {} ({}) insteadz/:)�safe� versioned_apiTz{}/v{}{}) rO rQ � ValueErrorrT rU r �urllib�parse�quote�maprC r0 r/ )rX �pathfmt�argsrg �arg�quote_fr` r` ra �_url� s �� �zAPIClient._urlc C s4 z|� � W dS tjjy } zt|��d}~ww )z1Raises stored :class:`APIError`, if one occurred.N)�raise_for_status�requests� exceptions� HTTPErrorr )rX �responsere r` r` ra �_raise_for_status s ��zAPIClient._raise_for_statusc C s2 |r|rJ �| � |� |r|�� S |r|jS |jS rj )r� �json�content�text)rX r� r� �binaryr` r` ra �_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 )NrA zapplication/jsonz Content-Type�data)rO �dict�iter�itemsrn r� �dumps)rX rm r� rg �data2�k�vr` r` ra � _post_json s �� zAPIClient._post_jsonc C s |pdddd�S )Nr )�stdout�stderr�streamr` )rX �overrider` r` ra �_attach_params* s �zAPIClient._attach_params� containerc C sR | � d|�}tjd|| �|�d�}|�� j}|�ddd�}|�ddd�}| �|�S ) Nz/containers/{0}/attach/ws�POST)�paramsr9 zws://r r: zwss://)r� r� �Requestr� �preparerm �replace� _create_websocket_connection)rX r� r� rm �req�full_urlr` r` ra �_attach_websocket1 s zAPIClient._attach_websocketc C s t �|�S rj )� websocket�create_connection)rX rm r` r` ra r� : 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= r: ) r� r0 �raw�_fp�fp�sockrJ �channel�_sock� _response�AttributeError)rX r� r� r` r` ra �_get_raw_response_socket= 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� )rX r� �decode�readerr� r` r` ra r� S 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) rX r� �buf� buf_length�walker�header�_�length�start�endr` r` ra �_multiplexed_buffer_helperh 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)rX r� �socketr� r� r� r� r` r` ra �#_multiplexed_response_stream_helperx 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)rX r� � chunk_sizer� r� r` r` ra �_stream_raw_result� s � z APIClient._stream_raw_resultc C sJ | � |�}t||�}|rdd� |D �}ndd� |D �}|r |S t||d�S )Nc s s � | ]}t |� V qd S rj )r )�.0�framer` r` ra � <genexpr>� � � z.APIClient._read_from_socket.<locals>.<genexpr>c s s � | ]\}}|V qd S rj r` )r� r� r� r` r` ra r� � r� )�demux)r� r r )rX r� r� �ttyr� r� �genr` r` ra �_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� )rX r� �sockets�sr1 r` r` ra r� � s �z!APIClient._disable_socket_timeoutc C s | � |�}|d d S )N�Config�Tty)�inspect_container)rX r� �contr` r` ra � _check_is_tty� s zAPIClient._check_is_ttyc C s | � ||| �|��S rj )�_get_result_ttyr� )rX r� r� �resr` r` ra � _get_result� s zAPIClient._get_resultc C sV |r|r | � |�S | j|dd�S | �|� d}|r | �|�S |�dd� | �|�D ��S )NTr� � c S s g | ]}|�qS r` r` )r� �xr` r` ra � <listcomp>� s z-APIClient._get_result_tty.<locals>.<listcomp>)r� r� r� r� �joinr� )rX r� r� �is_tty�sepr` r` ra r� � s � �zAPIClient._get_result_ttyc G s |D ]}| j �|� qd S rj )�adapters�pop)rX r} �protor` r` ra rM � s �zAPIClient._unmountc sH zt � �|�W S tjjy# } z| jr | jW Y d }~S |�d }~ww rj )r? � get_adapterr� r� � InvalidSchemarK )rX rm re r^ r` ra r� � s ��zAPIClient.get_adapterc C s | j S rj )r/ )rX r` r` ra rb � 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 )r5 N)r rG r5 r- )rX �dockercfg_pathr` r` ra � reload_config� s �zAPIClient.reload_config)FFrj )F)r T)TF)*rV � __module__� __qualname__�__doc__r� �Session� __attrs__r r r r@ rS rh r rn rp rr rt r� r� r� r� r� r r� r� r� r� r� r� r� r� r� r� r� r� rM r� �propertyrb r� � __classcell__r` r` r^ ra r, / sV &�k r, )Er� r� rx � functoolsr r� �requests.exceptionsr� � r � constantsr r r r r r r r �errorsr r r r r6 r � transportr r 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* � ImportErrorr+ r� r, r` r` r` ra �<module> sj ( � � �