o

�2.a�@s*dd
lm
Z

ddlmZ
Gdd�d�ZdS)�)
�errors)
�utilsc@sPeZ
dZe�d
�
			ddd�
�
Zdd	�Zdd
d�
Ze�d�
		dd
d�
�
ZdS)�ExecApiMixin�	containerTF�Nc
Cs�|	d
u
rt�
|jd�rt�d�
�
t|t�rt�|�
}t|	t�r%tj�	|	�
}	|
||||||||	d�	}|
d
u
rEt�
|jd�rAt�d�
�
|
|d<|rL||d<nd|j
vrX|j
d|d<|�d	|
�}
|j|
|d
�}|�
|d�S)aC
        Sets up an exec instance in a running container.

        Args:
            container (str): Target container where exec instance will be
                created
            cmd (str or list): Command to be executed
            stdout (bool): Attach to stdout. Default: ``True``
            stderr (bool): Attach to stderr. Default: ``True``
            stdin (bool): Attach to stdin. Default: ``False``
            tty (bool): Allocate a pseudo-TTY. Default: False
            privileged (bool): Run as privileged.
            user (str): User to execute command as. Default: root
            environment (dict or list): A dictionary or a list of strings in
                the following format ``["PASSWORD=xxx"]`` or
                ``{"PASSWORD": "xxx"}``.
            workdir (str): Path to working directory for this exec session
            detach_keys (str): Override the key sequence for detaching
                a container. Format is a single character `[a-Z]`
                or `ctrl-<value>` where `<value>` is one of:
                `a-z`, `@`, `^`, `[`, `,` or `_`.
                ~/.docker/config.json is used by default.

        Returns:
            (dict): A dictionary with an exec ``Id`` key.

        Raises:
            :py:class:`docker.errors.APIError`
                If the server returns an error.
        Nz1.25z;Setting environment for exec is not supported in API < 1.25)	�	Container�User�
Privileged�Tty�AttachStdin�AttachStdout�AttachStderr�Cmd�Envz1.35z/workdir is not supported for API version < 1.35�
WorkingDir�
detachKeysz/containers/{0}/exec)
�dataT)r�
version_lt�_versionr�InvalidVersion�
isinstance�str�
split_command�dict�format_environment�_general_configs�_url�
_post_json�_result)�selfr�cmd�stdout�stderr�stdin�tty�
privileged�user�environment�workdir�detach_keysr�url�res�r,�5/usr/lib/python3/dist-packages/docker/api/exec_api.py�exec_creates>#

�












�


�






zExecApiMixin.exec_createcCs2t|
t
�r
|
�d
�
}
|�|�d|
��
}|�|d�S)aL

        Return low-level information about an exec command.

        Args:
            exec_id (str): ID of the exec instance

        Returns:
            (dict): Dictionary of values returned by the endpoint.

        Raises:
            :py:class:`docker.errors.APIError`
                If the server returns an error.
        �Idz/exec/{0}/jsonT)rr�get�_getrr)r�exec_idr+r,r,r-�exec_inspectPs




zExecApiMixin.exec_inspectcCsFt|
t
�r
|
�d
�
}
||d�}|�d|
�}|j||d�}|�|�

dS)z�
        Resize the tty session used by the specified exec command.

        Args:
            exec_id (str): ID of the exec instance
            height (int): Height of tty session
            width (int): Width of tty session
        r/)�
h�
wz/exec/{0}/resize)
�paramsN)rrr0r�_post�_raise_for_status)rr2�height�widthr6r*r+r,r,r-�exec_resizecs







zExecApiMixin.exec_resizer2c
Csd||d
�}|r	inddd�}|j|�
d|
�||dd�}	|r"|�|	�
S|r)|�|	�
S|j|	|||d�S)	a�
        Start a previously set up exec instance.

        Args:
            exec_id (str): ID of the exec instance
            detach (bool): If true, detach from the exec command.
                Default: False
            tty (bool): Allocate a pseudo-TTY. Default: False
            stream (bool): Stream response data. Default: False
            socket (bool): Return the connection socket to allow custom
                read/write operations.
            demux (bool): Return stdout and stderr separately

        Returns:

            (generator or str or tuple): If ``stream=True``, a generator
            yielding response chunks. If ``socket=True``, a socket object for
            the connection. A string containing response data otherwise. If
            ``demux=True``, a tuple with two elements of type byte: stdout and
            stderr.

        Raises:
            :py:class:`docker.errors.APIError`
                If the server returns an error.
        )r
�Detach�Upgrade�tcp)�
Connectionr=z/exec/{0}/startT)�headersr�stream)r$�demux)rrr�_get_raw_response_socket�_read_from_socket)
rr2�detachr$rA�socketrBrr@r+r,r,r-�
exec_startus$
�

�




�





zExecApiMixin.exec_start)	TTFFFrNNN)NN)FFFFF)	�__name__�
__module__�__qualname__r�check_resourcer.r3r;rGr,r,r,r-rs



�I


�rN)rrrrr,r,r,r-�<module>
s