Dashboard
PHP:
8.2.30
OS:
Linux
User:
dh_nv8b2m
/
/
usr
/
local
/
lib
/
python3.10
/
dist-packages
/
ansible
/
utils
/
__pycache__
📤 Upload
📝 New File
📁 New Folder
Close
Editing: display.cpython-310.pyc
o O�h^} � @ s< d dl mZ zd dlZW n ey daY nw dad dlmZ d dlZd dl Z d dl Z d dl Z d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlmZ d dl m Z m Z d dl m Z! d dl"m#Z#m$Z$m%Z%m&Z& d d l'm(Z(m)Z) d d l*m+Z+ d d l,m-Z- d d l.m/Z0 d d l1m2Z2 d dl3m4Z4 ej5r�d dl6m7Z7 e�8d�Z9e j:�;e j<�=d��Z>e j?fe>j@_Ae jBe jCfe>jD_Ade �Ee jC�d d d ZFdaGdaHdDdd �ZIG d d � d ejJ�ZKG d d � d ejJ�ZLdZMeNe!d!��rOe!jOZPeP�rejP�QeP��re�RePejS��s e�RejP�TeP�ejS��rFejUePejVd"d#� e�Wd$�ZMejXjYD ]ZZeZ�[eKeNe!d%g ��� eZ�[eL� � �q0n e\d&eP ej]d'� e!j^ej_e!j`ejae!jbejVe!jcejae!jdej_e!jeejfe!jgejVe!jhejae!jiejVi Zjd(ZkdEd-d.�ZlejmfdFd2d3�ZndGd6d7�ZodHd=d>�ZpdId?d@�ZqG dAdB� dBe2dC�ZrdS )J� )� annotationsNFT��wraps)�unpack�pack)� constants)� AnsibleError�AnsibleAssertionError�AnsiblePromptInterrupt�AnsiblePromptNoninteractive)�to_bytes�to_text)� text_type)�stringc)�context)� Singleton)�wrap_var)� FinalQueue�P�c� � � � s [K�text�str�return�intc C s� t | t�s tdt| � ��zt�| t�}W n tjy! d}Y nw |dkr(|S d}d}| D ]1}|d7 }|dv rA|d8 }|d8 }q.zt� |�}W n tjyT d}Y nw |dkr[d}||7 }q.|dkrl|rlt d| ��|dkrr|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)r �width�counterr �w� r0 �@/usr/local/lib/python3.10/dist-packages/ansible/utils/display.py�get_text_widthL s< �� �r2 c @ s e Zd Zdd� Zdd� ZdS )�FilterBlackListc C s dd� |D �| _ d S )Nc S s g | ]}t �|��qS r0 )�logging�Filter)�.0�namer0 r0 r1 � <listcomp>� s z,FilterBlackList.__init__.<locals>.<listcomp>)� blacklist)�selfr9 r0 r0 r1 �__init__� s zFilterBlackList.__init__c s t � fdd�| jD �� S )Nc 3 s � | ]}|� � �V qd S �N)�filter�r6 �f��recordr0 r1 � <genexpr>� s � z)FilterBlackList.filter.<locals>.<genexpr>)�anyr9 �r: rA r0 r@ r1 r= � s zFilterBlackList.filterN)�__name__� __module__� __qualname__r; r= r0 r0 r0 r1 r3 s r3 c @ sD e Zd ZdZze�� ZW n ey de� � ZY nw 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)rH �username�userrD r0 r0 r1 r= � s zFilterUserInjector.filterN) rE rF rG �__doc__�getpass�getuserrJ �KeyError�os�getuidr= r0 r0 r0 r1 rH � s � rH �DEFAULT_LOG_PATHz=%(asctime)s p=%(process)d u=%(user)s n=%(name)s | %(message)s)�filename�level�format�ansible�DEFAULT_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/cowsay�tio�t.TextIO�lock�threading.RLockc C s. dd� }| j }||j|�|_||j|�|_d S )Nc s t � �� �fdd��}|S )Nc s6 �� � | i |��W d � S 1 sw Y d S r< r0 )�args�kwargs�r? r[ r0 r1 �locking_wrapper� s $�zL_synchronize_textiowrapper.<locals>._wrap_with_lock.<locals>.locking_wrapperr )r? r[ r` r0 r_ r1 �_wrap_with_lock� s z3_synchronize_textiowrapper.<locals>._wrap_with_lock)�buffer�write�flush)rY r[ ra rb r0 r0 r1 �_synchronize_textiowrapper� s re �fd�when�Nonec C s� t �| �}|tj t jt jB t jB t jB t jB @ |tj< |tj t j @ |tj < |tj t j t j B @ |tj < |tj t jB |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 r N)�termios� tcgetattr�tty�IFLAG�BRKINT�ICRNL�INPCK�ISTRIP�IXON�OFLAG�OPOST�CFLAG�CSIZE�PARENB�CS8�LFLAG�ECHO�ICANON�IEXTEN�ISIG�CC�VMIN�VTIME� tcsetattr)rf rg �moder0 r0 r1 �setraw� s 0 *r� �stdout� t.BinaryIOc C s | � dt � | � dt � d S )Ns [%s)rc � MOVE_TO_BOL� CLEAR_TO_EOL)r� r0 r0 r1 � clear_line� s r� �stdin_fd� stdout_fd�seconds�echo�boolc C sR t | � t�|�r t |� |r't�| �}|d tjB |d< t�| tj|� d S d S )N� )r� rP �isattyri rj ry r� �TCSANOW)r� r� r� r� � new_settingsr0 r0 r1 � setup_prompt� s �r� c C sP zt �� W n t jttjfy daY d S w t �d�p tat �d�p%t a d S )NF�cr�el) �curses� setupterm�errorr$ �io�UnsupportedOperation� HAS_CURSES�tigetstrr� r� r0 r0 r0 r1 r� � s �r� c @ s e Zd Zd|d}dd�Zd~d d �Zddd�Zd�dd�Zed�dd��Zed�dd��Z ed�dd��Z e d�d�d(d)��Z d�d�d,d-�Z d�d�d/d0�Z d�d�d1d2�Zd�d�d3d4�Zd�d�d5d6�Zd�d�d7d8�Zd�d�d9d:�Zd�d�d<d=�Zed�d�d>d?��Zed�d�d@dA��Ze ed�d�dBdC���Z d�d�dHdI�Ze d�d�dJdK��Zed�d�dMdN��Zed�dOdP��Zed�d�dRdS��Zed�d�dTdU��Z ed�d�dWdX��Z ed�d�dZd[��Z d�d�ddde�Z d�dfdg�Z d�d�dmdn�Z! d�d�dpdq�Z"e#d�dsdt��Z$e#d�dudv��Z%e#d�dxdy��Z&e#d�dzd{��Z'd S )��Displayr � verbosityr r rh c C s� d | _ t�� | _d | _|| _tjd u r|| _nt |tj�| _i | _ i | _ i | _ d | _ tj| _| �� | j rxz6tj| j dgtjtjd�}|�� \}}|jrNt�dd� |�� D �| _tjrjttj�rjttj�� | j�| _W n tyw d | _ Y nw | � � zt t j | j� t t j!| j� W n ty� } z| �"d|� �� W Y d }~nd }~ww t#�$d| j%� zt j j&dd� t j!j&dd� W n ty� } z| �"d|� �� W Y d }~nd }~ww d | _'d S ) Nz-l�r� �stderrc S s h | ]}t |��qS r0 )r )r6 r r0 r0 r1 � <setcomp>' s z#Display.__init__.<locals>.<setcomp>z/failed to patch stdout/stderr for fork-safety: �_replacing_warning_handler��errorszHfailed to reconfigure stdout/stderr with custom encoding error handler: F)(�_final_q� threading�RLock�_lock�columnsr� �C� LOG_VERBOSITY� log_verbosity�max� _deprecations�_warns�_errors�b_cowsay�ANSIBLE_COW_SELECTION�noncow�set_cowsay_info� subprocess�Popen�PIPE� communicate� returncode� Exception�split�cows_available�ANSIBLE_COW_ACCEPTLISTrC �set� intersection�_set_column_widthre �sysr� r� �warning�codecs�register_errorr� � reconfigure� setup_curses)r: r� �cmd�out�err�exr0 r0 r1 r; sV � � �� �� zDisplay.__init__� exception� UnicodeError�tuple[str | bytes, int]c C s | j ddd� d|jfS )Nz{Non UTF-8 encoded data replaced with "?" while displaying text to stdout/stderr, this is temporary and will become an errorz2.18)�version�?)� deprecated�end)r: r� r0 r0 r1 r� @ s � z"Display._replacing_warning_handler�queuer c C s t �� du r td��|| _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_context�parent_process� RuntimeErrorr� )r: r� r0 r0 r1 � set_queueI s zDisplay.set_queuec C s< t jrd S t jrt j| _d S tD ] }tj�|�r|| _qd S r< )r� �ANSIBLE_NOCOWS�ANSIBLE_COW_PATHr� � b_COW_PATHSrP �path�exists)r: � b_cow_pathr0 r0 r1 r� S s ��zDisplay.set_cowsay_info�func�+c.Callable[t.Concatenate[Display, P], None]�c.Callable[..., None]c s t � �d � fdd� �}|S ) Nr] �P.argsr^ �P.kwargsr rh c s8 | j r| j j� jg|�R i |��S � | g|�R i |��S r< )r� � send_displayrE )r: r] r^ �r� r0 r1 �wrapperb s z Display._proxy.<locals>.wrapper)r] r� r^ r� r rh r �r� r� r0 r� r1 �_proxy^ s zDisplay._proxyc s t � �d d � fdd � �}|S ) zQThis method ensures that debug is enabled before delegating to the proxy N�msgr �host� str | Noner rh c s t jsd S � | ||d�S )N)r� )r� � DEFAULT_DEBUG�r: r� r� r� r0 r1 r� r s z%Display._meets_debug.<locals>.wrapperr< �r� r r� r� r rh r r� r0 r� r1 � _meets_debugl s zDisplay._meets_debugc s t � �d d � fd d � �}|S )z�This method ensures the verbosity has been met before delegating to the proxy Currently this method is unused, and the logic is handled directly in ``verbose`` Nr� r r� r� �caplevelr r rh c s | j |kr � | |||d�S d S �N�r� r� )r� �r: r� r� r� r� r0 r1 r� � s z)Display._meets_verbosity.<locals>.wrapper�NN�r� r r� r� r� r r rh r r� r0 r� r1 �_meets_verbosityy s zDisplay._meets_verbosityNFTr� r �colorr� r� r� � screen_only�log_only�newlinec C s� t |t�std|jj� ���|}|sR|�d�}|r |dd� } n|} |r)t| |�} |s-|r1| d } |s7tj} ntj } | j � | � | � W d � n1 sMw Y t r^|s`| � ||� dS dS dS )zy Display a message to the user Note: msg *must* be a unicode string to prevent UnicodeError tracebacks. z"Display message must be str, not: � Nr )r# r r$ � __class__rE �endswithr r� r� r� r� rc �logger�_log) r: r� r� r� r� r� r� �nocolor� has_newline�msg2�fileobjr0 r0 r1 �display� s* ��zDisplay.displayr� � int | Nonec C sj t r1|d u s | j|kr3|�d�}tj}|r)zt| }W n ty( td| ��w t �||� d S d S d S )Nr� z%Invalid color supplied to display: %s) r� r� �lstripr4 �INFO�color_to_log_levelrO r �log)r: r� r� r� r� �lvlr0 r0 r1 r� � s ��z Display._logr� c C � | j ||dd�S )Nr r� ��verboser� r0 r0 r1 �v� � z Display.vc C r )Nr r� r r� r0 r0 r1 �vv� r z Display.vvc C r )Nr r� r r� r0 r0 r1 �vvv� r z Display.vvvc C r )Nr� r� r r� r0 r0 r1 �vvvv� r z Display.vvvvc C r )N� r� r r� r0 r0 r1 �vvvvv� r z Display.vvvvvc C r )N� r� r r� r0 r0 r1 �vvvvvv� r zDisplay.vvvvvvr c C sL | j |kr | j|||d� | j| j kr"| j|kr$| j|||d� d S d S d S r� )r� �_verbose_displayr� � _verbose_logr� r0 r0 r1 r � s �zDisplay.verbosec C sB t j}|d u r| j|t j|d� d S | jd||f t j|d� d S )N�r� r� �<%s> %s)r� �VERBOSE_TO_STDERRr � COLOR_VERBOSE)r: r� r� r� � to_stderrr0 r0 r1 r � s zDisplay._verbose_displayc C s( |d ur d||f }| � |tj|� d S )Nr )r� r� r r� r0 r0 r1 r � s zDisplay._verbose_logc C sV |d u r| j dt�� t�� |f tjd� d S | j dt�� t�� ||f tjd� d S )Nz %6d %0.5f: %s�r� z%6d %0.5f [%s]: %s)r rP �getpid�timer� � COLOR_DEBUGr� r0 r0 r1 �debug� s &(z Display.debugr� �removed�date�collection_namec C s� |� � }|r|d dvr|d7 }|dkrd}|r"d�|�}d}d}n d �|�}d }d }|r3d �|�} nd } |r=d�|�} n |rEd�|�} nd} d�dd� ||| | |fD ��} | S )z) used to print out a deprecation message.r )�!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 r< r0 r> r0 r0 r1 rB + s � z2Display.get_deprecation_message.<locals>.<genexpr>)�striprU �join) r: r� r� r r r! �header�removal_fragment� help_text� from_fragmentrg � message_textr0 r0 r1 �get_deprecation_message s, z Display.get_deprecation_messagec C s� |st jsd S | j|||||d�}|rt|��tj|| jdd�}d�|�d }|| jvr>| j |� � t j dd� d| j|< d S d S )N)r� r r r! F)�drop_whitespacer� Tr r ) r� �DEPRECATION_WARNINGSr- r �textwrap�wrapr� r' r� r r& �COLOR_DEPRECATE)r: r� r� r r r! r, �wrappedr0 r0 r1 r� / s �zDisplay.deprecated� formattedc C s` |sd| }t �|| j�}d�|�d }nd| }|| jvr.| j|tjdd� d| j|< d S d S )Nz [WARNING]: %sr� z [WARNING]: %sTr r )r0 r1 r� r' r� r r� � COLOR_WARN)r: r� r4 �new_msgr3 r0 r0 r1 r� G s �zDisplay.warningc C s t jr | �|� d S d S r< )r� �SYSTEM_WARNINGSr� )r: r� r0 r0 r1 �system_warningU s �zDisplay.system_warning�cowsc C s� t |�}| jr |r z| �|� W dS ty | �d� Y nw |�� }z | jt|� }W n ty= | jt |� }Y nw |dkrDd}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 r� � banner_cowsay�OSErrorr� r& r� r2 r, �lenr )r: r� r� r9 �star_len�starsr0 r0 r1 �bannerZ s$ � �zDisplay.bannerc C s� d|v r|� dd�}|�d�r|d d� }| jddg}| jr9| j}|dkr-t�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 )�replacer� r� r� rC �choice�listr� �appendr r� r� r� r� r r )r: r� r� �runcmd�thecowr� r� r� r0 r0 r1 r; r s zDisplay.banner_cowsay� wrap_textc C s` |rd| }t �|| j�}d�|�d }nd| }|| jvr.| j|tjdd� d| j|< d S d S )Nz [ERROR]: %sr� z ERROR! %sTr r )r0 r1 r� r' r� r r� � COLOR_ERROR)r: r� rJ r6 r3 r0 r0 r1 r� � s �z Display.error�privatec C s |rt � | �S t| �S r< )rM �input)r� rL r0 r0 r1 �prompt� s zDisplay.prompt�varnamerN �encrypt�confirm� salt_size�salt�default�unsafec C s� d } t j�� rC| j} |r|d urd||f } n |r d| } nd| } |r= | | |�} | d| |�} | | kr6n| �d� q%n | | |�} nd } | �d� | sR|d urR|} |rbdd lm} || |||d �} t| d d �} | rnt | �} | S ) Nz %s [%s]: z%s: zinput for %s: Tzconfirm z&***** VALUES ENTERED DO NOT MATCH ****z/Not prompting as we are not in interactive moder )� do_encrypt)rR rS �surrogate_or_strictr� ) r� � __stdin__r� rN r r� �ansible.utils.encryptrV r r )r: rO rL rN rP rQ rR rS rT rU �result� do_promptr� �secondrV r0 r0 r1 � do_var_prompt� s: � zDisplay.do_var_promptc C sJ t �d�rtdt�dtjtddddd���d }nd}td|d �| _ d S )Nr �HHHHr �O ) rP r� r �fcntl�ioctlri � TIOCGWINSZr r� r� )r: �tty_sizer0 r0 r1 r� � s (zDisplay._set_column_widthr� �interrupt_input�c.Container[bytes] | None�complete_input�bytesc C s$ | j rddlm} | j j|j|||||d� |j�� S tr&| js&t � d| _| j d u s;t � | j �r;t � � t �| j �kr?td��| �|� d}| j�? t�| j �}z-t| j | j|| � t�| jtj� | j| |||d�W t�| j tj|� W d � S t�| j tj|� w 1 s�w Y d S )Nr )�current_worker)� worker_idrN rL r� rd rf Tzstdin is not interactive� )r� r� rd rf ) r� � ansible.executor.process.workerrh � send_promptri � worker_queue�getr� r� r� � _stdin_fdrP r� �getpgrp� tcgetpgrpr r r� ri rj r� � _stdout_fd�tcflush�_stdin�TCIFLUSH�_read_non_blocking_stdinr� � TCSADRAIN) r: r� rL r� rd rf rh rZ �original_stdin_settingsr0 r0 r1 � prompt_until� s6 � � � �zDisplay.prompt_untilr� c C s | j rt�|d ur t�� }|d u r-zt�tjj�� �d tj }W n t y, d}Y nw zt�| j �d tj g}W n t yH ddg}Y nw d}|d u sXt�� | |k �r d } zBt �| j d� | d u r�|d u srt�� | |k r�| j�d�} t�tj� | d u r�|d u srt�� | |k srW t �| j d� | d u r�d} nt �| j d� | d u r�d} w |d u r�| |ks�|d ur�| �� |v r�t| j� td ��|d u r�| d v s�|d ur�| �� |v r�t| j� |S | |v r�t| j� |d d � }|r�| j�|� | j�� n|| 7 }|d u sXt�� | |k sX|S ) N� � � � rj Fr Tzuser interrupt)r � r )r� �NotImplementedErrorr ri rj r� �stdinrb �fileno�VINTRr� ro �VERASErP � set_blockingrt �read�sleepr� � DEFAULT_INTERNAL_POLL_INTERVAL�lowerr� �_stdoutr rc rd ) r: r� r� rd rf �start� interrupt�backspace_sequences� result_string� key_pressedr0 r0 r1 rv s` � � ����$ $ � �z Display._read_non_blocking_stdin�t.BinaryIO | Nonec C s* | j rt�ztjjW S ty Y d S w r< )r� r r� r� rb �AttributeError�r: r0 r0 r1 rt B s �zDisplay._stdinc C �& z| j �� W S ttfy Y d S w r< )rt r� � ValueErrorr� r� r0 r0 r1 ro K � �zDisplay._stdin_fdr� c C s | j rt�tjjS r< )r� r r� r� rb r� r0 r0 r1 r� R s zDisplay._stdoutc C r� r< )r� r� r� r� r� r0 r0 r1 rr X r� zDisplay._stdout_fd)r )r� r r rh )r� r� r r� )r� r r rh �r rh )r� r� r r� )r� r� r r� )NFFFT)r� r r� r� r� r� r� r� r� r� r� r� r rh r� )r� r r� r� r� r r< r� )Nr r� )NFNN) r� r r� r� r r� r r� r! r� r r ) r� r r� r� r r� r r� r! r� r rh )F)r� r r4 r� r rh )r� r r rh rI )r� r r� r� r9 r� r rh )r� r r� r� r rh )T)r� r rJ r� r rh )r� r rL r� r r )TNNFNNNF)rO r rL r� rN r� rP r� rQ r� rR r rS r� rT r� rU r� r r )FNNN) r� r rL r� r� r rd re rf re r rg ) r� r� r� r rd re rf re r rg )r r� )r r )r r� )(rE rF rG r; r� r� r� � staticmethodr� r� r� r r� r r r r r r r r r r r- r� r� r8 r@ r; r� rN r] r� ry rv �propertyrt ro r� rr r0 r0 r0 r1 r� s� 9 � ; �*� � 5 �; �6 r� )� metaclass)r r r r )rY rZ r[ r\ )rf r rg r r rh )r� r� r rh ) r� r r� r r� r r� r� r rh r� )s� __future__r r� � ImportErrorr� �collections.abc�abcr r� � ctypes.utilr) r` rM r� r4 rP rC r� r� ri r0 r� r rk �typing�t� functoolsr �structr r rV r r� �ansible.errorsr r r r �+ansible.module_utils.common.text.convertersr r �ansible.module_utils.sixr �ansible.utils.colorr � ansible.utils.multiprocessingr r� �ansible.utils.singletonr �ansible.utils.unsafe_proxyr � TYPE_CHECKING�#ansible.executor.task_queue_managerr � ParamSpecr �cdll� LoadLibrary�util� find_libraryr& �c_wcharr+ �argtypes� c_wchar_p�c_intr' �sizeofr( r� r� r2 r5 r3 rH r� �getattrrR r� r� �access�W_OK�dirname� basicConfigr � getLogger�root�handlers�handler� addFilter�printr� rK �ERRORr5 �WARNING�COLOR_OK� COLOR_SKIP�COLOR_UNREACHABLEr �DEBUG� COLOR_CHANGEDr2 r r r� re � TCSAFLUSHr� r� r� r� r� r0 r0 r0 r1 �<module> s� � 3 < � ��
Save
Cancel