File: //usr/lib/python3.9/site-packages/ansible/utils/__pycache__/display.cpython-39.pyc
a
�)g�K � @ s� d dl mZmZmZ eZd dlZd dlZd dl Z d dl
Z
d dl Z d dl Z d dl
Z
d dlZd dlZd dlZd dlZd dlmZmZ d dlmZ d dlmZ d dlmZm Z d dl m Z m Z d dl m!Z! d d l"m#Z# d d
l$m%Z& d d l'm(Z( d d l)m*Z* d d
l+m,Z, ej-�.ej/�0d��Z1ej2fe1j3_4ej5ej6fe1j7_4de�8ej6�d d d Z9dd� Z:G dd� de
j;�Z<G dd� de
j;�Z=dZ>e?ed��r,ej@ZAeA�r�e jA�BeA��r�e �CeAe jD��s�e �Ce jA�EeA�e jD��re
jFeAe
jGdd� e
�Hd�Z>e
jIjJD ](ZKeK�Le<e?ed g ��� eK�Le=� � �q�neMd eA ejNd � ejOe
jPejQe
jRejSe
jGejTe
jRejUe
jPejVe
jWejXe
jGejYe
jRejZe
jGi Z[d Z\d d!� Z]G d"d#� d#e(d$�Z^dS )%� )�absolute_import�division�print_functionN)�unpack�pack)�
TIOCGWINSZ)� constants)� AnsibleError�AnsibleAssertionError)�to_bytes�to_text)� text_type)�stringc)�context)� Singleton)�wrap_var��wraps�c� � � c C s� t | t�stdt| � ��zt�| t�}W n tjyB d}Y n0 |dkrP|S d}d}| D ]b}|d7 }|dv r�|d8 }|d8 }q\zt� |�}W n tjy� d}Y n0 |dkr�d}||7 }q\|dkr�|r�t
d| ��|dkr�|S dS )a3 Function that utilizes ``wcswidth`` or ``wcwidth`` to determine the
number of columns used to display a text string.
We try first with ``wcswidth``, and fallback to iterating each
character and using wcwidth individually, falling back to a value of 0
for non-printable wide characters.
z$get_text_width requires text, not %s���r r )��� �z3get_text_width could not calculate text width of %r) �
isinstancer
� TypeError�type�_LIBC�wcswidth�_MAX_INT�ctypes�
ArgumentError�wcwidth�EnvironmentError)�text�widthZcounterr �w� r* �9/usr/lib/python3.9/site-packages/ansible/utils/display.py�get_text_width8 s8
�r, c @ s e Zd Zdd� Zdd� ZdS )�FilterBlackListc C s dd� |D �| _ d S )Nc S s g | ]}t �|��qS r* )�logging�Filter)�.0�namer* r* r+ �
<listcomp>m � z,FilterBlackList.__init__.<locals>.<listcomp>)� blacklist)�selfr4 r* r* r+ �__init__l s zFilterBlackList.__init__c s t � fdd�| jD �� S )Nc 3 s | ]}|� � �V qd S �N)�filter�r0 �f��recordr* r+ � <genexpr>p r3 z)FilterBlackList.filter.<locals>.<genexpr>)�anyr4 �r5 r< r* r; r+ r8 o s zFilterBlackList.filterN)�__name__�
__module__� __qualname__r6 r8 r* r* r* r+ r- k s r- c @ sD e Zd ZdZz e�� ZW n ey6 de� � ZY n0 dd� Z
dS )�FilterUserInjectorz�
This is a filter which injects the current user as the 'user' attribute on each record. We need to add this filter
to all logger handlers so that 3rd party libraries won't print an exception due to user not being defined.
zuid=%sc C s t j|_dS )NT)rC �username�userr? r* r* r+ r8 s zFilterUserInjector.filterN) r@ rA rB �__doc__�getpassZgetuserrD �KeyError�os�getuidr8 r* r* r* r+ rC s s rC �DEFAULT_LOG_PATHz=%(asctime)s p=%(process)d u=%(user)s n=%(name)s | %(message)s)�filename�level�format�ansibleZDEFAULT_LOG_FILTERzM[WARNING]: log file at %s is not writeable and we cannot create it, aborting
)�file)s /usr/bin/cowsays /usr/games/cowsays /usr/local/bin/cowsays /opt/local/bin/cowsayc C s. dd� }| j }||j|�|_||j|�|_d S )Nc s t � �� �fdd��}|S )Nc s6 �� � | i |��W d � S 1 s(0 Y d S r7 r* )�args�kwargs�r: �lockr* r+ �locking_wrapper� s zL_synchronize_textiowrapper.<locals>._wrap_with_lock.<locals>.locking_wrapperr )r: rT rU r* rS r+ �_wrap_with_lock� s z3_synchronize_textiowrapper.<locals>._wrap_with_lock)�buffer�write�flush)ZtiorT rV rW r* r* r+ �_synchronize_textiowrapper� s rZ c @ s� e Zd Zd2dd�Zdd� Zdd� Zd3d d �Zd4d
d�Zd5dd�Zd6dd�Z d7dd�Z
d8dd�Z d9dd�Z d:dd�Z
d;d d �Zd<d d �Zd=d d!�Zd>d"d#�Zd$d%� Zd?d&d'�Zd@d(d)�ZdAd*d+�ZedBd,d-��ZdCd.d/�Zd0d1� ZdS )D�Displayr c
C s� d | _ t�� | _d | _|| _i | _i | _i | _d | _ t
j | _ | �
� | j r�zltj| j dgtjtjd�}|�� \}}|jr|t�dd� |�� D �| _t
jr�tt
j�r�tt
j��| j�| _W n ty� d| _ Y n0 | �� z tt j | j� tt j | j� W n6 t�y. } z | � d|� �� W Y d }~n
d }~0 0 z t j j dd� t j j dd� W n6 t�y� } z | � d |� �� W Y d }~n
d }~0 0 d S )
Nz-l��stdout�stderrc S s h | ] }t |��qS r* )r )r0 r r* r* r+ � <setcomp>� r3 z#Display.__init__.<locals>.<setcomp>Fz/failed to patch stdout/stderr for fork-safety: �replace��errorszDfailed to reconfigure stdout/stderr with the replace error handler: )!�_final_q� threading�RLock�_lock�columns� verbosity�
_deprecations�_warns�_errors�b_cowsay�CZANSIBLE_COW_SELECTION�noncow�set_cowsay_info�
subprocess�Popen�PIPE� communicate�
returncode� Exception�split�cows_availableZANSIBLE_COW_ACCEPTLISTr> �set� intersection�_set_column_widthrZ �sysr] r^ �warning� reconfigure)r5 rh �cmd�out�err�exr* r* r+ r6 � s@
&zDisplay.__init__c C s t �� du rtd��|| _dS )z�Set the _final_q on Display, so that we know to proxy display over the queue
instead of directly writing to stdout/stderr from forks
This is only needed in ansible.executor.process.worker:WorkerProcess._run
Nz%queue cannot be set in parent process)�multiprocessing_contextZparent_process� RuntimeErrorrc )r5 Zqueuer* r* r+ � set_queue� s zDisplay.set_queuec C s: t jr
d S t jrt j| _n tD ]}tj�|�r || _q d S r7 )rm ZANSIBLE_NOCOWSZANSIBLE_COW_PATHrl � b_COW_PATHSrI �path�exists)r5 Z
b_cow_pathr* r* r+ ro � s
zDisplay.set_cowsay_infoNFTc C s� | j r | j j||||||d�S |}|s�|�d�}|rB|dd� } n|} |rTt| |�} |s\|rd| d } |sptj}
ntj}
| j� |
�| � W d � n1 s�0 Y t r�|s�|�
d�} t j } |r�z t
| } W n ty� td| ��Y n0 t �| | � dS )zy Display a message to the user
Note: msg *must* be a unicode string to prevent UnicodeError tracebacks.
)�colorr^ � screen_only�log_only�newline�
Nr z%Invalid color supplied to display: %s)rc Z send_display�endswithr r{ r] r^ rf rX �logger�lstripr. �INFO�color_to_log_levelrH r
�log) r5 �msgr� r^ r� r� r� ZnocolorZ has_newlineZmsg2ZfileobjZlvlr* r* r+ �display s8 �
(
zDisplay.displayc C s | j ||dd�S )Nr ��host�caplevel��verbose�r5 r� r� r* r* r+ �vD s z Display.vc C s | j ||dd�S )Nr r� r� r� r* r* r+ �vvG s z
Display.vvc C s | j ||dd�S )Nr r� r� r� r* r* r+ �vvvJ s z Display.vvvc C s | j ||dd�S )N� r� r� r� r* r* r+ �vvvvM s z Display.vvvvc C s | j ||dd�S )N� r� r� r� r* r* r+ �vvvvvP s z
Display.vvvvvc C s | j ||dd�S )N� r� r� r� r* r* r+ �vvvvvvS s zDisplay.vvvvvvc C sZ t jrV|d u r2| jdt�� t�� |f t jd� n$| jdt�� t�� ||f t jd� d S )Nz
%6d %0.5f: %s�r� z%6d %0.5f [%s]: %s)rm Z
DEFAULT_DEBUGr� rI �getpid�time� COLOR_DEBUGr� r* r* r+ �debugV s $z
Display.debugr c C sJ t j}| j|krF|d u r,| j|t j|d� n| jd||f t j|d� d S )N�r� r^ z<%s> %s)rm ZVERBOSE_TO_STDERRrh r� �
COLOR_VERBOSE)r5 r� r� r� Z to_stderrr* r* r+ r� ] s
zDisplay.verbosec C s� |� � }|r |d dvr |d7 }|dkr,d}|rDd�|�}d}d}nd �|�}d
}d }|rfd �|�} nd
} |rzd�|�}
n|r�d�|�}
nd}
d�dd� ||| |
|fD ��} | S )z) used to print out a deprecation message.r )�!�?�.r� zansible.builtinz ansible-corez[DEPRECATED]: {0}zThis feature was removedz Please update your playbooks.z[DEPRECATION WARNING]: {0}z This feature will be removedzZDeprecation warnings can be disabled by setting deprecation_warnings=False in ansible.cfg.zfrom {0}� zin a release after {0}.zin version {0}.zin a future release.� c s s | ]}|r|V qd S r7 r* r9 r* r* r+ r= � r3 z2Display.get_deprecation_message.<locals>.<genexpr>)�striprN �join) r5 r� �version�removed�date�collection_name�headerZremoval_fragment� help_textZ
from_fragmentZwhen� message_textr* r* r+ �get_deprecation_messagef s,
z Display.get_deprecation_messagec C s| |st jsd S | j|||||d�}|r.t|��tj|| jdd�}d�|�d }|| jvrx| j |�
� t j dd� d| j|< d S )N)r� r� r� r� F)Zdrop_whitespacer� Tr� r ) rm ZDEPRECATION_WARNINGSr� r �textwrap�wraprg r� ri r� r� �COLOR_DEPRECATE)r5 r� r� r� r� r� r� �wrappedr* r* r+ �
deprecated� s
zDisplay.deprecatedc C s\ |s*d| }t �|| j�}d�|�d }nd| }|| jvrX| j|tjdd� d| j|< d S )Nz
[WARNING]: %sr� z
[WARNING]:
%sTr� r )r� r� rg r� rj r� rm �
COLOR_WARN)r5 r� � formatted�new_msgr� r* r* r+ r| � s
zDisplay.warningc C s t jr| �|� d S r7 )rm ZSYSTEM_WARNINGSr| )r5 r� r* r* r+ �system_warning� s zDisplay.system_warningc C s� t |�}| jr@|r@z| �|� W dS ty> | �d� Y n0 |�� }z| jt|� }W n tyz | jt |� }Y n0 |dkr�d}d| }| j
d||f |d� dS )zw
Prints a header-looking line with cowsay or stars with length depending on terminal width (3 minimum)
NzFsomebody cleverly deleted cowsay or something during the PB run. heh.r� �*z
%s %sr� ) r rl �
banner_cowsay�OSErrorr| r� rg r, r& �lenr� )r5 r� r� ZcowsZstar_lenZstarsr* r* r+ �banner� s
zDisplay.bannerc C s� d|v r*|� dd�}|�d�r*|d d� }| jddg}| jrr| j}|dkrZt�t| j��}|�d � |�t |�� |�t |�� t
j |t
j t
j d
�}|�
� \}}| jd t|� |d � d S )
Nz: [�[r� �]r s -Ws 60�randoms -fr\ z%s
r� )r` r� rl rn r� �choice�listrw �appendr rp rq rr rs r� r )r5 r� r� ZruncmdZthecowr~ r r� r* r* r+ r� � s
zDisplay.banner_cowsayc C s\ |r*d| }t �|| j�}d�|�d }nd| }|| jvrX| j|tjdd� d| j|< d S )Nz
[ERROR]: %sr� z ERROR! %sTr� r )r� r� rg r� rk r� rm � COLOR_ERROR)r5 r� Z wrap_textr� r� r* r* r+ �error� s
z
Display.errorc C s |rt � | �S t| �S d S r7 )rG �input)r� �privater* r* r+ �prompt� s
zDisplay.promptc
C s� d }
t j�� r�| j} |r.|d ur.d||f } n|r<d| } nd| } |rx| | |�}
| d| |�}
|
|
krjq�| �d� qHq�| | |�}
nd }
| �d� |
s�|d ur�|}
|r�ddlm} ||
|||�}
t|
d d
�}
| r�t |
�}
|
S ) Nz %s [%s]: z%s: zinput for %s: zconfirm z&***** VALUES ENTERED DO NOT MATCH ****z/Not prompting as we are not in interactive moder )�
do_encryptZsurrogate_or_strictra )
r{ � __stdin__�isattyr� r� r| Zansible.utils.encryptr� r r )r5 Zvarnamer� r� ZencryptZconfirmZ salt_sizeZsalt�defaultZunsafe�resultZ do_promptr� �secondr� r* r* r+ �
do_var_prompt� s4
zDisplay.do_var_promptc C sH t �d�r0tdt�dttddddd���d }nd}td|d �| _d S )Nr ZHHHHr �O ) rI r� r �fcntlZioctlr r �maxrg )r5 Ztty_sizer* r* r+ rz s
&zDisplay._set_column_width)r )NFFFT)N)N)N)N)N)N)N)Nr )NFNN)NFNN)F)NT)N)T)F)TNNFNNNN)r@ rA rB r6 r� ro r� r� r� r� r� r� r� r� r� r� r� r| r� r� r� r� � staticmethodr� r� rz r* r* r* r+ r[ � s.
1
B
#
+r[ )� metaclass)_Z
__future__r r r r Z
__metaclass__Z ctypes.utilr# r� rG r. rI r� rp r{ r� rd r� �structr r Ztermiosr rO r rm Zansible.errorsr r
Zansible.module_utils._textr r Zansible.module_utils.sixr
Zansible.utils.colorr Z ansible.utils.multiprocessingr r� Zansible.utils.singletonr Zansible.utils.unsafe_proxyr � functoolsr ZcdllZ LoadLibrary�utilZ find_libraryr Zc_wcharr% �argtypesZ c_wchar_pZc_intr! Zsizeofr" r, r/ r- rC r� �getattrrK r� r� �access�W_OK�dirnameZ basicConfigr� Z getLogger�root�handlersZhandlerZ addFilter�printr^ r� ZERRORr� ZWARNINGZCOLOR_OKZ
COLOR_SKIPZCOLOR_UNREACHABLEr� �DEBUGZ
COLOR_CHANGEDr� r� r� r� rZ r[ r* r* r* r+ �<module> sn 3 <
�
�