File: //lib/python3.9/site-packages/ansible/plugins/action/__pycache__/pause.cpython-39.pyc
a
�)g:- �
@ sz d dl mZmZmZ eZd dlZd dlZd dlZd dl Z d dl
Z
d dl Z d dl m
Z
mZmZ d dlmZ d dlmZmZ d dlmZ d dlmZ d dlmZ e� ZzFd dl Z d dl Z ze � � d Z W n e j e!e j"fy� d
Z Y n0 W n e#y� d
Z Y n0 d Z$d Z%e �r.e �&d
��p e$Z$e �&d��p,e%Z%e j'fdd�Z(G dd� de)�Z*dd� Z+dd� Z,ddd�Z-G dd� de�Z.dS ) � )�absolute_import�division�print_functionN)�getpgrp�isatty� tcgetpgrp)� AnsibleError)�to_text� to_native)�boolean)�
ActionBase)�DisplayTF�
s [KZcr�elc C s� t �| �}|tj t jt jB t jB t jB t jB @ |tj< |tj t j
t j B @ |tj < |tj t j B |tj < |tj
t jt jB t jB t jB @ |tj
< d|tj t j< d|tj t j< t �| ||� dS )a Put terminal into a raw mode.
Copied from ``tty`` from CPython 3.11.0, and modified to not remove OPOST from OFLAG
OPOST is kept to prevent an issue with multi line prompts from being corrupted now that display
is proxied via the queue from forks. The problem is a race condition, in that we proxy the display
over the fork, but before it can be displayed, this plugin will have continued executing, potentially
setting stdout and stdin to raw which remove output post processing that commonly converts NL to CRLF
� r N)�termios� tcgetattr�ttyZIFLAGZBRKINTZICRNLZINPCKZISTRIPZIXONZCFLAGZCSIZEZPARENBZCS8ZLFLAG�ECHOZICANONZIEXTENZISIGZCCZVMINZVTIME� tcsetattr)�fdZwhen�mode� r �@/usr/lib/python3.9/site-packages/ansible/plugins/action/pause.py�setraw= s
0 *r c @ s e Zd ZdS )�AnsibleTimeoutExceededN)�__name__�
__module__� __qualname__r r r r r R s r c C s t �d S )N)r )Zsignum�framer r r �timeout_handlerV s r c C s | � dt � | � dt � d S )Ns [%s)�write� MOVE_TO_BOL� CLEAR_TO_EOL)�stdoutr r r �
clear_lineZ s r% c C s* | d u r dS t | �r"t� t| �kS dS d S )NF)r r r )r r r r �is_interactive_ s
r& c s. e Zd ZdZdZd� fdd� Zdd� Z� ZS ) � ActionModulezC pauses execution for a length or time, or until input is received TNc s4 |du rt � }tt| ��||�}~| jddd�dtidtiddid�dd �\}}d
}d}d}|d } d }
|�t d
dd d ddd| d�� | s�d}
|d r�d| j�� � � |d |
f }nd| j�� � � d|
f }|d
dur�|d
d }n|d dur�|d }d}t
�
� } t t j �
� �|d< d|d< d} d}
�zh�z�|du�r�|dk �rHd}t�tjt� t�|� t�d||
f � t�d�f |d �r�t�|� n
t�|� d} d}z&| jjj}tjj}|�� } |�� }W n ttf�y� d}Y n0 t| �}|�r�zt � | �d t j }W n t �y( d }Y n0 zt � | �d t j }W n t �y^ d d g}Y n0 t � | �}
t!| � t"|��r�t!|� |�s�| �r�t � | �}|d t j#B |d < t �$| t j%|� t �&|t j'� |�s |du �r�t�(d!� |du�r�t
�)|d � �q�z�|�*d�}||k�r"t+|� t,�|�s�|d"v �rBt+|� W �q�nT||v �r�|d dd#� |d< t+|� | �r||�-|d � |�.� n|d |7 < W nT t,�y� t�d� t�d$�f | �/|��r�t+|� Y �q�t+|� t0d%��Y n0 �q�W n t1�y Y n0 W d| |
fv�r4t"| ��r4t �$| t j2|
� t
�
� | }t t j �
� �|d&< t|�|d'< |d
k�rxt3|d( d)�}n
t3|d)�}d*||f |d+< n�d| |
fv�r�t"| ��r�t �$| t j2|
� t
�
� | }t t j �
� �|d&< t|�|d'< |d
k�r t3|d( d)�}n
t3|d)�}d*||f |d+< 0 t |d d,d-�|d< |S ).z run the pause action module N�boolT)�type�defaultr) �str)�echo�minutes�seconds�prompt))r- r. )Z
argument_specZmutually_exclusiver- r, � Fr )Zchanged�rc�stderrr$ �start�stop�deltar, z (output is hidden)r/ z
[%s]
%s%s:z,Press enter to continue, Ctrl+C to interrupt�< r. r3 � Z
user_inputr zPausing for %d seconds%sz<(ctrl+C then 'C' = continue early, ctrl+C then 'A' = abort)
� � � � � z>Not waiting for response to prompt as stdin is not interactive)r �
���z0Press 'C' to continue the play or 'A' to abort
zuser requested abort!r4 r5 g N@� zPaused for %s %sr$ Zsurrogate_or_strict)�errors)4�dict�superr' �runZvalidate_argument_spec�int�updateZ_taskZget_name�strip�timer �datetimeZnow�signal�SIGALRMr �alarm�displayZ _connectionZ
_new_stdin�buffer�sysr$ �fileno�
ValueError�AttributeErrorr& r r ZVINTR� ExceptionZVERASEr r r r ZTCSANOWZtcflushZTCIFLUSHZwarning�sleep�readr% �KeyboardInterruptr! �flush�_c_or_ar r Z TCSADRAIN�round)�self�tmpZ task_vars�resultZvalidation_resultZnew_module_argsZ
duration_unitr/ r. r, Z echo_promptr3 Zstdin_fdZ old_settingsZ stdout_fd�stdinr$ � interactiveZintrZ backspaceZ new_settings� key_pressedZduration�� __class__r r rC q s
��
�
�
zActionModule.runc C s0 |� d�}|�� dkrdS |�� dkr dS q d S )Nr � aF� cT)rT �lower)rY r\ r^ r r r rW 1 s
zActionModule._c_or_a)NN)r r r �__doc__ZBYPASS_HOST_LOOPrC rW �
__classcell__r r r_ r r' l s
Ar' )N)/Z
__future__r r r r) Z
__metaclass__rH rI rN r rG r �osr r r Zansible.errorsr Zansible.module_utils._textr r
Z)ansible.module_utils.parsing.convert_boolr Zansible.plugins.actionr Zansible.utils.displayr
rL Zcurses�ioZ setuptermZ
HAS_CURSES�error� TypeError�UnsupportedOperation� ImportErrorr" r# ZtigetstrZ TCSAFLUSHr rR r r r% r& r' r r r r �<module> sF