o n�nh^}�@s<ddlmZzddlZWneydaYnwdaddlmZddlZddl Z ddlZddlZddl Z ddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlmZddlmZmZddlm Z!ddl"m#Z#m$Z$m%Z%m&Z&dd l'm(Z(m)Z)dd l*m+Z+ddl,m-Z-ddl.m/Z0dd l1m2Z2ddl3m4Z4ej5r�ddl6m7Z7e�8d�Z9e j:�;e j<�=d��Z>e j?fe>j@_Ae jBe jCfe>jD_Ade �Ee jC�dddZFdaGdaHdDdd�ZIGdd�dejJ�ZKGdd �d ejJ�ZLdZMeNe!d!��rOe!jOZPeP�rejP�QeP��re�RePejS��se�RejP�TeP�ejS��rFejUePejVd"d#�e�Wd$�ZMejXjYD]ZZeZ�[eKeNe!d%g��eZ�[eL��q0n e\d&ePej]d'�e!j^ej_e!j`ejae!jbejVe!jcejae!jdej_e!jeejfe!jgejVe!jhejae!jiejVi Zjd(ZkdEd-d.�ZlejmfdFd2d3�ZndGd6d7�ZodHd=d>�ZpdId?d@�ZqGdAdB�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 Cs�t|t�s tdt|��zt�|t�}Wntjy!d}Ynw|dkr(|Sd}d}|D]1}|d7}|dvrA|d8}|d8}q.zt� |�}WntjyTd}Ynw|dkr[d}||7}q.|dkrl|rlt d|��|dkrr|SdS)a3Function 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��rr)��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_widthLs< �� r2c@seZdZdd�Zdd�ZdS)�FilterBlackListcCsdd�|D�|_dS)NcSsg|]}t�|��qSr0)�logging�Filter)�.0�namer0r0r1� �sz,FilterBlackList.__init__..)� blacklist)�selfr9r0r0r1�__init__�szFilterBlackList.__init__cst�fdd�|jD��S)Nc3s�|]}|��VqdS�N)�filter�r6�f��recordr0r1� �s�z)FilterBlackList.filter..)�anyr9�r:rAr0r@r1r=�szFilterBlackList.filterN)�__name__� __module__�__qualname__r;r=r0r0r0r1r3sr3c@sDeZdZdZze��ZWneyde� �ZYnwdd�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=%scCstj|_dS�NT)rH�username�userrDr0r0r1r=�szFilterUserInjector.filterN)rErFrG�__doc__�getpass�getuserrJ�KeyError�os�getuidr=r0r0r0r1rH�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.RLockcCs.dd�}|j}||j|�|_||j|�|_dS)Ncst��fdd��}|S)Ncs6��|i|��Wd�S1swYdSr<r0)�args�kwargs�r?r[r0r1�locking_wrapper�s$�zL_synchronize_textiowrapper.._wrap_with_lock..locking_wrapperr)r?r[r`r0r_r1�_wrap_with_lock�sz3_synchronize_textiowrapper.._wrap_with_lock)�buffer�write�flush)rYr[rarbr0r0r1�_synchronize_textiowrapper�sre�fd�when�NonecCs�t�|�}|tjtjtjBtjBtjBtjB@|tj<|tj tj @|tj <|tjtjtj B@|tj<|tjtjB|tj<|tjtjtjBtjBtjB@|tj<d|tjtj<d|tjtj<t�|||�dS)aPut 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 rrN)�termios� tcgetattr�tty�IFLAG�BRKINT�ICRNL�INPCK�ISTRIP�IXON�OFLAG�OPOST�CFLAG�CSIZE�PARENB�CS8�LFLAG�ECHO�ICANON�IEXTEN�ISIG�CC�VMIN�VTIME� tcsetattr)rfrg�moder0r0r1�setraw�s 0*r��stdout� t.BinaryIOcCs |�dt�|�dt�dS)Ns[%s)rc�MOVE_TO_BOL�CLEAR_TO_EOL)r�r0r0r1� clear_line�sr��stdin_fd� stdout_fd�seconds�echo�boolcCsRt|�t�|�r t|�|r't�|�}|dtjB|d<t�|tj|�dSdS)N�)r�rP�isattyrirjryr��TCSANOW)r�r�r�r��new_settingsr0r0r1�setup_prompt�s �r�c CsPzt��WntjttjfydaYdSwt�d�ptat�d�p%t a dS)NF�cr�el) �curses� setupterm�errorr$�io�UnsupportedOperation� HAS_CURSES�tigetstrr�r�r0r0r0r1r��s �r�c@seZdZd|d}dd�Zd~dd�Zddd�Zd�dd�Zed�dd��Zed�dd��Z ed�dd��Z e d�d�d(d)��Zd�d�d,d-�Zd�d�d/d0�Z d�d�d1d2�Zd�d�d3d4�Zd�d�d5d6�Zd�d�d7d8�Zd�d�d9d:�Zd�d�dd?��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��Zed�d�dWdX��Zed�d�dZd[��Z d�d�ddde�Zd�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'dS)��Displayr� verbosityrrrhc Cs�d|_t��|_d|_||_tjdur||_nt |tj�|_i|_ i|_i|_d|_ tj|_|��|j rxz6tj|j dgtjtjd�}|��\}}|jrNt�dd�|��D�|_tjrjttj�rjttj��|j�|_Wntywd|_ Ynw|��zttj |j�ttj!|j�Wnty�}z|�"d|��WYd}~nd}~wwt#�$d|j%�ztj j&dd�tj!j&dd�Wnty�}z|�"d|��WYd}~nd}~wwd |_'dS) Nz-l�r��stderrcSsh|]}t|��qSr0)r )r6rr0r0r1� 'sz#Display.__init__..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�exr0r0r1r;sV � �� zDisplay.__init__� exception�UnicodeError�tuple[str | bytes, int]cCs|jddd�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�r0r0r1r�@s � z"Display._replacing_warning_handler�queuercCst��dur 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�r0r0r1� set_queueIs zDisplay.set_queuecCs<tjrdStjrtj|_dStD]}tj�|�r||_qdSr<)r��ANSIBLE_NOCOWS�ANSIBLE_COW_PATHr��b_COW_PATHSrP�path�exists)r:� b_cow_pathr0r0r1r�Ss��zDisplay.set_cowsay_info�func�+c.Callable[t.Concatenate[Display, P], None]�c.Callable[..., None]cst��d �fdd��}|S) Nr]�P.argsr^�P.kwargsrrhcs8|jr|jj�jg|�Ri|��S�|g|�Ri|��Sr<)r��send_displayrE)r:r]r^�r�r0r1�wrapperbszDisplay._proxy..wrapper)r]r�r^r�rrhr�r�r�r0r�r1�_proxy^szDisplay._proxycst��d d�fdd � �}|S)zQThis method ensures that debug is enabled before delegating to the proxy N�msgr�host� str | NonerrhcstjsdS�|||d�S)N)r�)r�� DEFAULT_DEBUG�r:r�r�r�r0r1r�rsz%Display._meets_debug..wrapperr<�r�rr�r�rrhrr�r0r�r1�_meets_debuglszDisplay._meets_debugcst��dd �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�rr�r��caplevelrrrhcs|j|kr �||||d�SdS�N�r�r�)r��r:r�r�r�r�r0r1r��s z)Display._meets_verbosity..wrapper�NN�r�rr�r�r�rrrhrr�r0r�r1�_meets_verbosityyszDisplay._meets_verbosityNFTr�r�colorr�r�r��screen_only�log_only�newlinecCs�t|t�std|jj��|}|sR|�d�}|r |dd�} n|} |r)t| |�} |s-|r1| d} |s7tj} ntj } |j � | �| �Wd�n1sMwYtr^|s`|� ||�dSdSdS)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#rr$� __class__rE�endswithrr�r�r�r�rc�logger�_log)r:r�r�r�r�r�r��nocolor�has_newline�msg2�fileobjr0r0r1�display�s* ��zDisplay.displayr�� int | NonecCsjtr1|dus|j|kr3|�d�}tj}|r)zt|}Wn ty(td|��wt�||�dSdSdS)Nr�z%Invalid color supplied to display: %s) r�r��lstripr4�INFO�color_to_log_levelrOr �log)r:r�r�r�r��lvlr0r0r1r��s ��zDisplay._logr�cC�|j||dd�S)Nrr��verboser�r0r0r1�v��z Display.vcCr)Nrr�rr�r0r0r1�vv�rz Display.vvcCr)Nrr�rr�r0r0r1�vvv�rzDisplay.vvvcCr)Nr�r�rr�r0r0r1�vvvv�rzDisplay.vvvvcCr)N�r�rr�r0r0r1�vvvvv�rz Display.vvvvvcCr)N�r�rr�r0r0r1�vvvvvv�rzDisplay.vvvvvvrcCsL|j|kr |j|||d�|j|jkr"|j|kr$|j|||d�dSdSdSr�)r��_verbose_displayr��_verbose_logr�r0r0r1r �s �zDisplay.verbosecCsBtj}|dur|j|tj|d�dS|jd||ftj|d�dS)N�r�r��<%s> %s)r��VERBOSE_TO_STDERRr� COLOR_VERBOSE)r:r�r�r�� to_stderrr0r0r1r�szDisplay._verbose_displaycCs(|dur d||f}|�|tj|�dS)Nr)r�r�rr�r0r0r1r�szDisplay._verbose_logcCsV|dur|jdt��t��|ftjd�dS|jdt��t��||ftjd�dS)Nz %6d %0.5f: %s�r�z%6d %0.5f [%s]: %s)rrP�getpid�timer��COLOR_DEBUGr�r0r0r1�debug�s&(z Display.debugr��removed�date�collection_namecCs�|��}|r|ddvr|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.builtinzansible-corez[DEPRECATED]: {0}zThis feature was removedzPlease update your playbooks.z[DEPRECATION WARNING]: {0}zThis 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.� css�|]}|r|VqdSr<r0r>r0r0r1rB+s�z2Display.get_deprecation_message..)�striprU�join)r:r�r�rr r!�header�removal_fragment� help_text� from_fragmentrg�message_textr0r0r1�get_deprecation_messages, zDisplay.get_deprecation_messagecCs�|stjsdS|j|||||d�}|rt|��tj||jdd�}d�|�d}||jvr>|j |� �tjdd�d|j|<dSdS)N)r�rr r!F)�drop_whitespacer�Trr)r��DEPRECATION_WARNINGSr-r�textwrap�wrapr�r'r�rr&�COLOR_DEPRECATE)r:r�r�rr r!r,�wrappedr0r0r1r�/s �zDisplay.deprecated� formattedcCs`|sd|}t�||j�}d�|�d}nd|}||jvr.|j|tjdd�d|j|<dSdS)Nz [WARNING]: %sr�z [WARNING]: %sTrr)r0r1r�r'r�rr�� COLOR_WARN)r:r�r4�new_msgr3r0r0r1r�Gs �zDisplay.warningcCstjr |�|�dSdSr<)r��SYSTEM_WARNINGSr�)r:r�r0r0r1�system_warningUs�zDisplay.system_warning�cowscCs�t|�}|jr |r z|�|�WdSty|�d�Ynw|��}z |jt|�}Wnty=|jt |�}Ynw|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�r2r,�lenr)r:r�r�r9�star_len�starsr0r0r1�bannerZs$ ��zDisplay.bannercCs�d|vr|�dd�}|�d�r|dd�}|jddg}|jr9|j}|dkr-t�t|j��}|�d �|�t |��|�t |��t j|t jt jd �}|� �\}}|jdt|�|d�dS) Nz: [�[r$�]rs-Ws60�randoms-fr�z%s r)�replacer�r�r�rC�choice�listr��appendrr�r�r�r�rr )r:r�r��runcmd�thecowr�r�r�r0r0r1r;rs zDisplay.banner_cowsay� wrap_textcCs`|rd|}t�||j�}d�|�d}nd|}||jvr.|j|tjdd�d|j|<dSdS)Nz [ERROR]: %sr�z ERROR! %sTrr)r0r1r�r'r�rr��COLOR_ERROR)r:r�rJr6r3r0r0r1r��s �z Display.error�privatecCs|rt�|�St|�Sr<)rM�input)r�rLr0r0r1�prompt�s zDisplay.prompt�varnamerN�encrypt�confirm� salt_size�salt�default�unsafec Cs�d} tj��rC|j}|r|durd||f}n|rd|}nd|}|r= |||�} |d||�} | | kr6n|�d�q%n |||�} nd} |�d�| sR|durR|} |rbdd lm}|| |||d �} t| dd�} | 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)rRrS�surrogate_or_strictr�) r�� __stdin__r�rNrr��ansible.utils.encryptrVr r)r:rOrLrNrPrQrRrSrTrU�result� do_promptr��secondrVr0r0r1� do_var_prompt�s: � zDisplay.do_var_promptcCsJt�d�rtdt�dtjtddddd��d}nd}td|d�|_ dS)Nr�HHHHr�O) rPr�r�fcntl�ioctlri� TIOCGWINSZrr�r�)r:�tty_sizer0r0r1r��s (zDisplay._set_column_widthr��interrupt_input�c.Container[bytes] | None�complete_input�bytesc Cs$|jrddlm}|jj|j|||||d�|j��Str&|js&t �d|_|j dus;t�|j �r;t� �t�|j �kr?td��|�|�d}|j�?t�|j �}z-t|j |j||�t�|jtj�|j||||d�Wt�|j tj|�Wd�St�|j tj|�w1s�wYdS)Nr)�current_worker)� worker_idrNrLr�rdrfTzstdin is not interactive�)r�r�rdrf)r��ansible.executor.process.workerrh�send_promptri�worker_queue�getr�r�r�� _stdin_fdrPr��getpgrp� tcgetpgrprrr�rirjr�� _stdout_fd�tcflush�_stdin�TCIFLUSH�_read_non_blocking_stdinr�� TCSADRAIN) r:r�rLr�rdrfrhrZ�original_stdin_settingsr0r0r1�prompt_until�s6 � � � �zDisplay.prompt_untilr�c Cs|jrt�|dur t��}|dur-zt�tjj��dtj }Wnt y,d}Ynwzt�|j�dtjg}Wn t yHddg}Ynwd}|dusXt��||k�r d} zBt �|jd�| dur�|dusrt��||kr�|j�d�} t�tj�| dur�|dusrt��||ksrWt �|jd�| dur�d} nt �|jd�| dur�d} w|dur�| |ks�|dur�| ��|vr�t|j�td ��|dur�| d vs�|dur�| ��|vr�t|j� |S| |vr�t|j�|dd�}|r�|j�|�|j��n|| 7}|dusXt��||ksX|S)N��rjFrTzuser interrupt)r� r)r��NotImplementedErrorrrirjr��stdinrb�fileno�VINTRr�ro�VERASErP�set_blockingrt�read�sleepr��DEFAULT_INTERNAL_POLL_INTERVAL�lowerr��_stdoutr rcrd) r:r�r�rdrf�start� interrupt�backspace_sequences� result_string�key_pressedr0r0r1rvs` �� $ $ � �z Display._read_non_blocking_stdin�t.BinaryIO | NonecCs*|jrt�ztjjWStyYdSwr<)r�rr�r�rb�AttributeError�r:r0r0r1rtBs �zDisplay._stdinc C�&z|j��WSttfyYdSwr<)rtr�� ValueErrorr�r�r0r0r1roK� �zDisplay._stdin_fdr�cCs|jrt�tjjSr<)r�rr�r�rbr�r0r0r1r�RszDisplay._stdoutc Cr�r<)r�r�r�r�r�r0r0r1rrXr�zDisplay._stdout_fd)r)r�rrrh)r�r�rr�)r�rrrh�rrh)r�r�rr�)r�r�rr�)NFFFT)r�rr�r�r�r�r�r�r�r�r�r�rrhr�)r�rr�r�r�rr<r�)Nrr�)NFNN)r�rr�r�rr�r r�r!r�rr)r�rr�r�rr�r r�r!r�rrh)F)r�rr4r�rrh)r�rrrhrI)r�rr�r�r9r�rrh)r�rr�r�rrh)T)r�rrJr�rrh)r�rrLr�rr)TNNFNNNF)rOrrLr�rNr�rPr�rQr�rRrrSr�rTr�rUr�rr)FNNN)r�rrLr�r�rrdrerfrerrg) r�r�r�rrdrerfrerrg)rr�)rr)rr�)(rErFrGr;r�r�r��staticmethodr�r�r�rr�r rr rrrr rrrr-r�r�r8r@r;r�rNr]r�ryrv�propertyrtror�rrr0r0r0r1r�s� 9 �; �*� � 5 �;�6r�)� metaclass)rrrr)rYrZr[r\)rfrrgrrrh)r�r�rrh) r�rr�rr�rr�r�rrhr�)s� __future__rr��ImportErrorr��collections.abc�abcrr��ctypes.utilr)r`rMr�r4rPrCr�r�rir0r�rrk�typing�t� functoolsr�structrrrVrr��ansible.errorsrr r r�+ansible.module_utils.common.text.convertersrr �ansible.module_utils.sixr�ansible.utils.colorr�ansible.utils.multiprocessingrr��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�r2r5r3rHr��getattrrRr�r��access�W_OK�dirname�basicConfigr� getLogger�root�handlers�handler� addFilter�printr�rK�ERRORr5�WARNING�COLOR_OK� COLOR_SKIP�COLOR_UNREACHABLEr�DEBUG� COLOR_CHANGEDr2rrr�re� TCSAFLUSHr�r�r�r�r�r0r0r0r1�s�� 3< � ��