File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/client/ssh/__pycache__/__init__.cpython-310.pyc
Back
o ;jF � @ s� d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddl Zddl Zddl Zddl Zddl Zddl!Zddl"Zddl#Zddl$Zddl%Zddl&Zddl'Zddl(Zddl)Zddl*Zddl+Zddl,Zddl-Zddl.m/Z/ ddl0m1Z1 ddl2m3Z3 ddl4m5Z5 ddl6m7Z7 zddl8Z8dZ9W n e:y� d Z9Y nw d Z;d Z<d e< d Z=d�>dd� dj?ej@jAjBd��Cd�D ��ZDejEjF�G� �sCejEjF�H� �sCe jI�>e jI�JeK�d�ZLe jI�MeL��s&eLd7 ZLejEjN�OeL�� ZPeP�Q� ZRW d � n 1 �s=w Y ndZRe�SeT�ZUG dd� de1�ZVG dd� d�ZWdd� ZXdd � ZYd d � ZZd d � Z[d!d"� Z\dS )#z Create ssh executor system � N)� LOG_LEVELS)�MultiprocessingStateMixin)�compile_template)�Process)�zmqTFz$/var/tmp/.%%USER%%_%%FQDNUUID%%_saltZA_edbc7885e4f9aac9b83b35999b68d015148caf467b78fa39c05f669c0ff89878z (?:^|\r?\n)z (?:\r?\n|$)� c C s g | ]}|� � �qS � )�strip)�.0�sr r �L/opt/saltstack/salt/lib/python3.10/site-packages/salt/client/ssh/__init__.py� <listcomp>� s ��r a� /bin/sh << 'EOF' set -e set -u DEBUG="{{DEBUG}}" if [ -n "$DEBUG" ] then set -x fi SET_PATH="{{SET_PATH}}" if [ -n "$SET_PATH" ] then export PATH={{SET_PATH}} fi SUDO="" if [ -n "{{SUDO}}" ] then SUDO="{{SUDO}} " fi SUDO_USER="{{SUDO_USER}}" if [ "$SUDO" ] && [ "$SUDO_USER" ] then SUDO="$SUDO -u $SUDO_USER" fi EX_PYTHON_INVALID={EX_THIN_PYTHON_INVALID} PYTHON_CMDS="python3 python27 python2.7 python26 python2.6 python2 python /usr/libexec/platform-python" for py_cmd in $PYTHON_CMDS do if command -v "$py_cmd" >/dev/null 2>&1 && "$py_cmd" -c "import sys; sys.exit(not (sys.version_info >= (2, 6)));" then py_cmd_path=`"$py_cmd" -c 'from __future__ import print_function;import sys; print(sys.executable);'` cmdpath=`command -v $py_cmd 2>/dev/null || which $py_cmd 2>/dev/null` if file $cmdpath | grep "shell script" > /dev/null then ex_vars="'PATH', 'LD_LIBRARY_PATH', 'MANPATH', \ 'XDG_DATA_DIRS', 'PKG_CONFIG_PATH'" export `$py_cmd -c \ "from __future__ import print_function; import sys; import os; map(sys.stdout.write, ['{{{{0}}}}={{{{1}}}} ' \ .format(x, os.environ[x]) for x in [$ex_vars]])"` exec $SUDO PATH=$PATH LD_LIBRARY_PATH=$LD_LIBRARY_PATH \ MANPATH=$MANPATH XDG_DATA_DIRS=$XDG_DATA_DIRS \ PKG_CONFIG_PATH=$PKG_CONFIG_PATH \ "$py_cmd_path" -c \ 'import base64; exec(base64.b64decode("""{{SSH_PY_CODE}}""").decode("utf-8"))' else exec $SUDO "$py_cmd_path" -c \ 'import base64; exec(base64.b64decode("""{{SSH_PY_CODE}}""").decode("utf-8"))' fi exit 0 else continue fi done echo "ERROR: Unable to locate appropriate python command" >&2 exit $EX_PYTHON_INVALID EOF)�EX_THIN_PYTHON_INVALIDzssh_py_shim.py�cc s� e Zd ZdZdZdd� Z� fdd�Z� fdd�Zed d � �Z d d � Z d d� Z dd� Z dd� Z dd� Zdd� Zd&dd�Zd'dd �Zd'd d �Zd(d d!�Zd"d#� Zd)d$d%�Z� ZS )*�SSHz( Create an SSH execution system z#__needs_updatec C sL t jdi| _tj�|d d�}tj�|�r&tr&tj j j d|d |dd�| _ nd | _ || _ | j d r6d| j d< tj j� d �sEtjjd d d ��t� | j d < | j d rU| j d nd| _| �� tj�| j | j �dd��| _| j�| j d | j�| _| js}| �� d| j v r�| j d �d�r�tj�tj�d��r�tj�d�}n%| j d �dtj�| j d d d d��}n| j �dtj�| j d d d��}|dkr�tj�|�s�z tjjj � |� W n t y� tj� d��w | j �dtj j!d �| j �d tj j!d �| j �d tj j!d �|| j �d tj j!d �| j �d tj j!d �| j �d tj j!d � | j �d!tj j!d! �| j �d"tj j!d" �| j �d#tj j!d# �| j �d$�| j �d%�d&� | _"| j �d'��rltj�d(d)t#�$� j%d d*� � ��| j"d+< d,| j d< tj&�'| j i �| _'| j �(d-d � tj)�*| j �| _+tj j,j-| j d. | j �d/�| j d | j �d0�d1�| _,t.| j+�| _/d S )2NT�sock_dirzmaster_event_pull.ipcZmasterF)�opts�listenZ regen_thin�ssh_wipe�ssh���zRNo ssh binary found in path -- ssh must be installed for salt-ssh to run. Exiting.)�code�msg� _ssh_versionZselected_target_option�glob�rosterZflat�tgt�__master_opts__�ssh_use_home_key� ~/.ssh/id_rsa�ssh_priv�pki_dir� salt-ssh.rsazagent-forwardinga' salt-ssh could not be run because it could not generate keys. You can probably resolve this by executing this script with increased permissions via sudo or by running as root. You could also use the '-c' option to supply a configuration directory that you have permissions to read and write to.�ssh_userZssh_port� ssh_passwdZssh_priv_passwdZ ssh_timeout�timeoutZssh_sudoZ ssh_sudo_userZssh_identities_onlyZssh_remote_port_forwards� ssh_options) �user�port�passwd�priv� priv_passwdr% �sudo� sudo_user�identities_only�remote_port_forwardsr& Z rand_thin_dirz/var/tmp�.� �thin_dir�TrueZ __fs_update�cachedirZthin_extra_modsZssh_ext_alternatives)Z extra_modsZ overwriteZ extended_cfg)0r �ROSTER_UPDATE_FLAG�_SSH__parsed_rosters�os�path�join�existsr �salt�utils�eventZ get_eventr �which� exceptionsZSaltSystemExit� ssh_version�tgt_type�_expand_targetr ZRoster�get�targets�_update_targets�isfile� expanduser�clientr �shellZgen_key�OSErrorZSaltClientError�configZDEFAULT_MASTER_OPTS�defaults�uuidZuuid4�hex�loader� returners�pop� fileclientZFSClient�fsclient�thinZgen_thin�mod_data�mods)�selfr Z pull_sockr* r r r �__init__� s� � � �� � ��� �� � � � � �� � � � � � �z SSH.__init__c s t � �|� | �|d � d S �Nr )�super� __setstate__rX �rW �state�� __class__r r r[ J s zSSH.__setstate__c s t � �� }| j|d< |S rY )rZ � __getstate__r r\ r^ r r r` O s zSSH.__getstate__c C s^ | j �d�s| j �dd�| j d< | j �dd�}d|v r$|�dd�\}}n| j �d�}||d�S )z� Method to determine the hostname and user when bypassing the roster and using ssh syntax (ex. root@localhost) Z ssh_cli_tgtr � �@� r# )�hostnamer' )r rC �split�rW rd r' r r r � parse_tgtT s z SSH.parse_tgtc C sT t j�| j�}|| jvr(t|t j�| ji �| jd | jd | jd �}|| j|< |S )zM Read roster filename as a key to the data. :return: ZrendererZrenderer_blacklistZrenderer_whitelist)r; r Zget_roster_filer r6 r rO Zrender)rW � roster_file� roster_datar r r � _get_rosterd s � zSSH._get_rosterc C s� | j d }t|t�r dS d|votjj�|�}|rk|du r dS | �� | jD ]F}| j| }t|t �sj|D ]5}z || � d�}W n t yL || }Y nw |||fv ri|| j d kr_|| j d< d| j| j < dS q4q&dS dS )zs Figures out if the target is a reachable host without wildcards, expands if any. :return: rd N�*�hostr F)rg � isinstance�listr; r< �network�is_reachable_hostrj r6 �boolrC �AttributeErrorr r5 )rW rd Zneeds_expansionZroster_filenameri �host_idZ roster_hostr r r rB u s8 � � ���zSSH._expand_targetc C s� | � � }t�|tj�r\| j| j rZtjj� |d��+}|� dj t � � tj�� �� | j�dd�| j�dd�| j�dd�d�� W d � n1 sGw Y t�d | j�dd�|� dS dS t�d |� dS ) z] Update default flat roster with the passed in information. :return: �azw# Automatically added by "{s_user}" at {s_time} {hostname}: host: {hostname} user: {user} passwd: {passwd} r ra r# r$ )Zs_userZs_timerd r' r) Nz+The host %s has been added to the roster %sz)Unable to update roster %s: access denied)rj r7 �access�W_OKr6 r5 r; r< �files�fopen�write�format�getpassZgetuser�datetime�utcnow� isoformatr rC �log�info�error)rW rh Z roster_fpr r r �_update_roster� s, �� � ��zSSH._update_rosterc C st | j d }| j d }|dkrd}tjj�|�r6|| jd< | j�dd�||d�| j|< | j�d�r8| �� d S d S d S ) zj Uptade targets in case hostname was directly passed without the roster. :return: rd r' rk ra r r$ )r) rl r' Zssh_update_rosterN) rg r; r< ro rp r rC rD r� rf r r r rE � s � �zSSH._update_targetsc C s� d| j v r | j d �d�r tj�tj�d��r tj�d�}n| j �dtj�| j d dd��}|� d�}tjj � |d ��}|� � � � d � d �W d � S 1 sQw Y d S ) z> Return the key string for the SSH public key r r r r r! r r" z.pub�rrc z rsa root@masterN) r rC r7 r8 rF rG r9 r; r< rw rx �readre )rW r* Zpub�fp_r r r � get_pubkey� s ��� $�zSSH.get_pubkeyc s� t || t�r | j�d�r&| j| }|�dd�s | jd r$| �||d� |S || �dd�� dg}� fdd �|D �}d � v rk|sk| j| }td �|�� td �}|� d �rW|S t � d�|d |��|d< | �||d�S |S )z> Deploy the SSH key if the minions don't auth Zssh_key_deployr) Fr$ �stderrra zfailed to upload filec s g | ] }� � |�r|�qS r )�count)r �x�r� r r r � � z"SSH.key_deploy.<locals>.<listcomp>�Permission deniedz[Permission denied for host {}, do you want to deploy the salt-ssh key? (password required):z[Y/n] )�n�NzPassword for {}@{}: r' T) rm �dictr rC rD �_key_deploy_run�printrz �input� startswithr{ )rW rl �ret�targetZ ignore_errZ check_err�deployr r� r � key_deploy� s, � �zSSH.key_deployTc C s d|� dd�| �� g}t| j||f| j| j| jd�|��}tjj � d�r-|j � � \}}}n|� � \}}}|r}|�d� t| j| jd |f| j| j| jd�|��}|�� \}}}ztjj�|�} || � d| �iW S ty| |rv||i Y S |d i Y S w tjjj|kr�||iS ||iS ) z) The ssh-copy-id routine zssh.set_auth_keyr' �root)rV rS rT z ssh-copy-idr) �argv�localz Bad Return)rC r� �Singler rV rS rT r; r< r8 r> rI Zcopy_id�runrQ � cmd_block�json� find_json� ExceptionrL � exitcodes�EX_OK) rW rl r� Zre_runr� �single�stdoutr� �retcode�datar r r r� � sV ���� ��� �zSSH._key_deploy_runFc C s\ t �|�}t||d |f| j| j| j|d�|��}d|ji}|�� \}} } zt| �} W n t t fy? t � d|| � d} Y nw zSt jj�|�} t| �dk r�d| v r�| d |d< z&| d d } zt| �} W n t t fy| t � d || � t| d�} Y nw W n tt fy� Y n w || | d �|d< W n ty� || | d �|d< Y nw |�|| f� d S ) zH Run the routine in a "Thread", put a dict on the queue r� )rV rS rT �mine�idz*Got an invalid retcode for host '%s': '%s'rc � r� r� r� z+Host '%s' reported an invalid retcode: '%s')r� r� r� N)�copy�deepcopyr� rV rS rT r� r� �int� TypeError� ValueErrorr �warningr; r< r� r� �len�max�KeyErrorr� �put) rW �quer rl r� r� r� r� r� r� r� r� Zremote_retcoder r r �handle_routine% sj ��� � ���� �� ��zSSH.handle_routinec c s� � t �� }i }t| j�}t� }t� }d} | js t�d� d S t|�| j� dd�k r�|s�zt |�}W n t y= d}Y qw | j D ]} | | j| vrT| j | | j| | < qAd| j| vrc|| j| d< | j| � d�r�t s�|�|� |�|� d} t�| � g d | d d |d �} || id fV q|| j|| j| |f} t| j| d �} | �� d| i||< qi }d}z |� d�\}}d|v r�|�|d � |d |d i|fV W n tjy� Y nw |D ]h}|| d �� �sD||v�r7z |� d�\}}d|v �r |�|d � |d |d i|fV q� tj�y Y nw ||v�r7d�|�}||d�}t�|� |d |d id fV || d �� |�|� q�|D ] }||v �rS|�|� �qGt|�t| j�k�rad S t|�| j� dd�k�swt| j�t|�k�r|t�d� q)ze Spin up the needed threads or processes and execute the subsequent routines FTz$No matching targets found in roster.Z ssh_max_procs� rl �winrmzTPlease contact sales@saltstack.com for access to the enterprise saltwinshell module.Nrc ra )Zfun_args�jid�returnr� �funr� )r� �args�threadr r� r� z>Target '{}' did not return any data, probably due to an error.)r� r� g�������?)�multiprocessing�Queue�iterrD �setr r� r� r rC �next� StopIterationrL � HAS_WINSHELL�add�debugr r� �start�queue�Empty�is_aliverz r9 rQ �time�sleep)rW r� r� ZrunningZ target_iterZreturnedZrets�initrl �defaultZlog_msgZno_retr� Zroutiner� r� r� r r r � handle_ssh\ s� � � � � �� �� �� � � ��� �zSSH.handle_sshNc c s� � d� | jd �}| j| |p| j�dd�d�}| jd }| j�dd�r)d }|}n|r/|d nd }|d d� }|| j| jd | jd ||d�}| jd dkrb| jd� | jd � ||| j�� d� n| jd� | jd � ||� | j|d�D ]Q\}} tt |��} | � || || |� | j r�tt |� � ��\} } t | t�r�d| i} d| vr�| | d< d| vr�|| d< || d< | j �| tjj �|d| gd�� |V qvdS )aJ Execute and yield returns as they come in, do not print to the display mine The Single objects will use mine_functions defined in the roster, pillar, or master config (they will be checked in that order) and will modify the argv with the arguments from mine_functions � {}.prep_jid�master_job_cacher� N�Z passed_jidr� � raw_shellF�ssh._rawr ra rc r r' �r� rA r r' r� �arg� local_cache� {}.save_load��minions)r� r� r� r� r� �job)rz r rP rC rA rD �keysr� r� r� � cache_jobr= �itemsrm �str� fire_eventr; r< �tagify) rW r� r� �fstrr� r� r� �job_loadr� �_rl �id_r� r r r �run_iter� sR � � �� ���z SSH.run_iterc C s( | j d�| jd � ||||d�� dS )z+ Cache the job information z {}.returnerr� )r� r� r� r� N)rP rz r )rW r� r� r� r� r r r r� � s �z SSH.cache_jobc C s | j �d�r@| �� i }| jD ]#}|�d�rqi ||< | j| D ]}| j| | d }||| |< q qtj�|d| j � t� � d� | j d �}| j | |pT| j �dd�d �}| j d }| j �d d �rhd }|} n|rn|d nd}|dd� } || j | j d | j d || d�} z5t |t�r�|�d�}| j d dkr�| j d� | j d � || | j�� d� n| j d� | j d � || � W n ty� } ztjd| j d | dd� W Y d} ~ nd} ~ ww | j �d�r�d |� �} t| � td t| � d � td� i } | j �d d�}d}| �� D ]�\}}tt|��}t |t��s t�d ||� d}t ||�}| � |||| |� | � ||�}t || t ��rR|| �d!��pEd�d"��rR|| d! ||< t || t ��sa||| i}n!d#|| v�rk|}n|| �d$| j �d d��}||| �d#i �i}| j �d%��r�| � |� n tj�||| j � | j!�r�tt|�"� ��\}}t |t#��r�d#|i}d&|v�r�||d&< d'|v�r�||d'< ||d< | j!�$|tj%j!�&|d(|gd)�� �q| j!du�r�| j!�'� | j �d%��r�tj�| || j � |�r t� tj(j)j*� dS dS )*zK Execute the overall routine, print results via outputters Z list_hosts�#rl �nestedr� r� r� Nr� r� r� Fr� r ra rc r r' r� �utf-8r� r� r� z(Could not save load with returner %s: %sT)�exc_info�verbosezExecuting job with jid �-r �outputz)Host '%s' returned an invalid retcode: %sr� zssh:r� �outZstaticr� r� r� r� )+r rC rj r6 r� r; r� Zdisplay_output�sys�exitrz rP rA rm �bytes�decoderD r� r� r r� r� r� r� r� r� r� r� r� r� r� r� �updater= r� r� r� r< r� ZdestroyrL r� Z EX_AGGREGATE)rW r� r� rh rs rd r� r� r� r� r� �excr ZsretZ outputterZ final_exitr� rl Zp_datar� r� r r r r� s� � � ������ � ��� �zSSH.run)T�F)FN)N)�__name__� __module__� __qualname__�__doc__r5 rX r[ r` �propertyrg rj rB r� rE r� r� r� r� r� r� r� r� � __classcell__r r r^ r r � s( t / 7 c<r c @ s� e Zd ZdZ d'dd�Zdd� Zd d � Zd d � Zd d� Zdd� Z dd� Z d(dd�Z dd� Z dd� Z d)dd �Zd*d d �Zd(d d �Zd!d"� Zd#d$� Zd%d&� ZdS )+r� z* Hold onto a single ssh execution N� Fc K s� || _ |�d�| _|�dd �| _|| _|| _| | _|�d�r"d| _n t| j�d��| _|�d�r6|d | _ n3| jrEt � | � |�d�| _ n$|rNt �d|�}nt �dd �}|�d t�tjtjj�� �jd d � �| _ | j | jd< || _| j| jd �| _|�d d �| _|�dd �| _| jr�tj � | j�| _ t |t �r�|g| _!n|| _!| �"� \| _#| _$| _%|| _&|�dd�| _'t | t(�r�| ni | _)|||||| | | | | j)|||||d�}ddd�| _*| j*�+|�di �� |d ur�| j*�+|� | j*�+tj �,| j d�| j&ddd�� tj-j.�/| j*�| _0|| _1| j1�+|� tj2�3|d | j�| _4tj5j6j7j8|fi |��| _7| j�r8| j7�9d�\}}}|�:� | _;|�r@|| _<d S tjj<�=|d �| _<d S ) N�mine_functions� cmd_umaskZ disable_wipeFr r2 Zssh_python_envz%%USER%%r� z %%FQDNUUID%%r1 )� master_optsrR �ssh_pre_flight�ssh_pre_flight_args�set_pathra )rl r' r( r) r* r+ r% r, �ttyrV r. r- r/ r� r& Tz salt-call.log)Z grains_cacheZlog_fileZssh_minion_optsZ running_data�/� )�root_dirr� r Zfileserver_list_cache_timez&powershell $ENV:PROCESSOR_ARCHITECTUREr4 )>r� rC r� r� r� r r �wiperq r2 � saltwinshellZ set_winvarsZ python_env�DEFAULT_THIN_DIR�replacerM Zuuid3Z NAMESPACE_DNSr; r< ro Zget_fqhostnamerN rS �contextr� r r7 r8 �basename� ssh_pre_filerm r� r� �_Single__arg_compsr� r� �kwargsr� r r� rV � minion_optsr� r9 Z serializersZyamlZ serialize� minion_configr� rO � ssh_wrapper�wfuncsrH r rI Z gen_shell�exec_cmdr �archrT Z thin_path) rW r r� r� rl r' r( r) r* r+ r% r, r rV rS rT r� r r. r- r/ r� r& r r2 r� r r� r r r rX s� �� �� �� (zSingle.__init__c C sV | j r| j d nd}tjjj| j dd� d| j�dg �d�}|d }|d }|||fS )z; Return the function name and the arg list r ra rc NF�no_parse)Z conditionr )r� r; r< r� Z parse_inputr rC )rW r� �parsedr� �kwsr r r Z __arg_comps� s � zSingle.__arg_compsc C s | j r|S d�dd� |D ��S )a Properly escape argument to protect special characters from shell interpretation. This avoids having to do tricky argument quoting. Effectively just escape all characters in the argument that are not alphanumeric! ra c S s$ g | ]}t �d |�rd| n|�qS )z\W�\)�re�match)r �charr r r r s $ z&Single._escape_arg.<locals>.<listcomp>)r� r9 )rW r� r r r � _escape_arg s zSingle._escape_argc C s� t �� �h}z t�| j|j� W n ty( } z W Y d}~W d � dS d}~ww dt�|j�j� �}t � d� | j � |j|�\}}}|dkrXt � d� |||fW d � S t � d� | j|| jd�W d � S 1 sow Y dS ) zK Run our pre_flight script before running any ssh commands N)ra z2Could not copy pre flight script to temporary pathrc r0 z'Copying the pre flight script to targetr z.Could not copy the pre flight script to targetz)Executing the pre flight script on target)� script_args)�tempfile�NamedTemporaryFile�shutil�copyfiler� �namerJ �pathlib�Pathr �tracerI �sendr� �execute_scriptr )rW Ztemp�errZ target_scriptr� r� r� r r r �run_ssh_pre_flight s( �� � �$�zSingle.run_ssh_pre_flightc C s* | j �d| j� ��\}}}|dkrdS dS )zC check if the thindir exists on the remote machine ztest -d r FT)rI r r2 )rW r� r� r� r r r �check_thin_dir, s zSingle.check_thin_dirc C s( | j �| jtj�| jd�� | �� dS )z" Deploy salt-thin z salt-thin.tgzT)rI r& rT r7 r8 r9 r2 � deploy_ext�rW r r r r� 5 s �z Single.deployc C s0 | j �d�r| j�| j d tj�| jd�� dS )z- Deploy the ext_mods tarball �filezsalt-ext_mods.tgzT)rV rC rI r& r7 r8 r9 r2 r, r r r r+ @ s �zSingle.deploy_extc s d } }}� j rI� j�dd�s � �� r t�d� j� n-tj� � j �s+t� d� j � n � � � \}}}|dkrBt� d� j � |||fS t�d� j � � j�d d�rgd � � fd d �� jD ��}� j�|�\}}}n� j� jv sp� jrw� �� \}}n� �� \}}}|||fS ) aC Execute the routine, the routine can be either: 1. Execute a raw shell command 2. Execute a wrapper func 3. Execute a remote Salt command If a (re)deploy is needed, then retry the operation after a deploy attempt Returns tuple of (stdout, stderr, retcode) NZssh_run_pre_flightFz=%s thin dir already exists. Not running ssh_pre_flight scriptz+The ssh_pre_flight script %s does not existr z&Error running ssh_pre_flight script %sz.Successfully ran the ssh_pre_flight script: %sr� � c s g | ]}� � |��qS r )r �r r� r, r r r o s z Single.run.<locals>.<listcomp>)r� r rC r* r r� r2 r7 r8 r: r� r) r r9 r� rI r r� r r� � run_wfuncr� )rW Zdeploy_attemptedr� r� r� �cmd_strr r, r r� K s6 ��� � z Single.runc C s~ d}d}t j�| jd d| j�}t j�|�st �|� t j�|d�}d}t j�|�s-d}nt�� t � |�j d }|| j� dd�krDd}| j� d �rLd}i }d | jv rX| jd }|s\d}|�rtt j jjj| j| jf| j| jd �| j��}|d � } d | v r�| d } t jj�d| i�} | | fS | jd | d< | jd | d< | jd | d< | jd | d< | jd | d< | jd | d< | jd | d< | jd | d< | j� dd�| d< | jd | d< d | jv r�| jd | d < d | jv r�| jd | d < n| jd | d < | j| d < d } |D ] } || | d | < q�d | jv �r$| jd D ]} | jd | | d | < �qi } | �| � | �| d � t j�| | d | d | � d!d"��}|�� }| | d |d#�}|�rtt jj � |d$��}|� t j �|�� W d � n 1 �sow Y |�s�|�r�t jj � |d%��}t j � |�}W d � n 1 �s�w Y |� d&i �}|� d �|d < |D ] } || |d | < �q�d | jv �r�| jd D ]} | jd | |d | < �q�|� d'�|d'< | j� d(d�|d(< t j jjj|| jf| j| jd �| j��}t j!�"||| j�| _#| j#|_#| j$�r�d}d}| j%}| j&�r | j%| j&v �r | j&| j% }n2|d' �r8| j%|d' � d)i �v �r8|d' d) | j% }n| j%| jd � d)i �v �rO| jd d) | j% }t'|t(��r^|�)d*|�}|}n,t'|t*��r�|dd� D ]}t'|t(��r�d*|v �r�|d* }|�)|�+|�� �qj|}n|}t'|t(��r�g | _,|| _-n t'|t*��r�|| _,i | _-z | j$�r�|| | j,i | j-��}n | j#| j% | j,i | j-��}W nI t.�y� } zd+| j%� d,|� �}t/j0|t1j2d-� d.} W Y d}~n(d}~w t3�y } zd/�4| j%|�}t/j0|t1j2d-� d.} W Y d}~nd}~ww t5| | j� dd ��} t'|t(��r0d|v �r0t jj�d|d i�} | | fS t jj�dd0|ii�} | | fS )1zV Execute a wrapper function Returns tuple of (json_data, '') FNr4 r� z ssh_data.pT�< Z cache_lifeZ refresh_cacheZ ssh_grains)rS r z test.opts_pkg�_errorr� r� � file_rootsZ pillar_rootsZ ext_pillarZextension_modules� module_dirsr r2 Z master_topsZextra_filerefsra r� r Zknown_hosts_file�_caller_cachedirr� r �grains�saltenv�base)r r7 �pillar�w+b�rbr r: r r� Z mine_functionz TypeError encountered executing z: )Zexc_info_on_loglevelrc z,An Exception occurred while executing {}: {}r� )6r7 r8 r9 r r� �isdir�makedirsrF r� �stat�st_mtimerC r; rH r �wrapperZFunctionWrapperrS r r� r< r� �dumpsr r� r: ZPillarZcompile_pillarrw rx ry �payload�loadrO r r r� r� r� rm r� rQ rn �indexr� r r� r r� �logging�DEBUGr� rz r� )rW Z data_cacher� �cdirZdatapZrefreshZ passed_timeZ conf_grainsZ pre_wrapperZopts_pkgr� r� ZgrainZpoptsr: Z pillar_datar� r rA Z mine_argsZ mine_fun_dataZmine_fun�item�resultr� r r r r0 z s. ��� �� � � ���� � ������zSingle.run_wfuncc C sD | j �d�r| j �d�rdtjjjj� d�nd}nd}| j d }d| jv r+| jd }n| jd }tjj � |d �\}}d}| j�d �sGd | jd < t d t | j�d d � krVd }dj | j t| j|d tjj| j�dd�| j| j| j|| jd� }t�d|�}t�|�d��� d�} | j s�t j |||p�d| t j d | j!d�} | S t"�#| �} | S )z, Prepare the command string r, r) z sudo -p '�'ra r- r6 r4 �sha1Z log_levelr� r� �1af OPTIONS.config = """ {config} """ OPTIONS.delimiter = '{delimeter}' OPTIONS.saltdir = '{saltdir}' OPTIONS.checksum = '{checksum}' OPTIONS.hashfunc = '{hashfunc}' OPTIONS.version = '{version}' OPTIONS.ext_mods = '{ext_mods}' OPTIONS.wipe = {wipe} OPTIONS.tty = {tty} OPTIONS.cmd_umask = {cmd_umask} OPTIONS.code_checksum = {code_checksum} ARGS = {arguments} �version) rK Z delimeterZsaltdirZchecksumZhashfuncrN �ext_modsr r r� Z code_checksumZ argumentsz#%%OPTSr� r )rG ZSUDOZ SUDO_USERZ SSH_PY_CODEZ HOST_PY_MAJORZSET_PATH)$r� rC r; rH r rI Z SUDO_PROMPTr r< rT �thin_sumr rz r �RSTRr2 rN � __version__rV r r r� r� � SSH_PY_SHIMr �base64� encodebytes�encoder� r� � SSH_SH_SHIMr� � version_infor r Zgen_shim) rW r, r- r4 Zthin_code_digestrP r� Zarg_strZpy_codeZ py_code_enc�cmdr r r �_cmd_strE sZ �� � � �zSingle._cmd_str�pyra c C s� d}|r t |ttf�st�t|��}d�d�dd� |D ���}|dkr.| j� d|� d��}n| j s@| j� d |� |� d |� ��}nt � | |�}| j sW| j� d |� |� d �� |S | j� d |� �� |S ) z< execute a script on the minion then delete ra z {}r. c S s g | ] }t �t|���qS r )�shlex�quoter� )r �elr r r r � r� z)Single.execute_script.<locals>.<listcomp>Zps1z "powershell �"z /bin/sh 'rK zrm 'zdel ) rm rn �tupler\ re r� rz r9 rI r r� r Z call_python)rW �script� extensionZpre_dirr r� r� r r r r' � s �zSingle.execute_scriptc C s� | j s | js | j�|�S tjddd��}|�tjj � |�� W d � n1 s(w Y dt � |j �j � �}| jr@t�| |�}| jj|j |dd�\}}}|dkr[t�d � |||fS zt�|j � W n tyl Y nw | j||d �}|S ) z� Run a shim command. If tty is enabled, we must scp the shim to the target system and execute it there r; F)�mode�deleteNr0 T)r> r z(Could not copy the shim script to target)ra rb )r r� rI r r r ry r; r< � stringutils�to_bytesr# r$ r" r Zget_target_shim_filer& r r� r7 �removerJ r' ) rW r1 rb Z shim_tmp_fileZtarget_shim_filer� r� r� r� r r r �shim_cmd� s* � � �zSingle.shim_cmdc C s t | j�| _t�dd�dd� | jD ��� | �� }| �|�\}}}t�d| jd |� t�d| jd |� t�d| jd |� | � |||�}|r�|d kr�t � | � | �|�\}}}t � t|�rpt �t|d �d �� }t � t|�s_t � t|�r�t �t|d �d �� }t � t|�svn[|d kr�| �� | �|�\}}}t � t|�r�t � t|�s�d �|�||fS t � t|�r�t �t|d �d �� }t � t|�s�t � t|�r�t �t|d �d �� }t � t|�s�nd |� �||fS t � t|�r�t �t|d �d �� }t � t|�s�t � t|��rt � t|��rt �t|d �d �� }t � t|��sn�t �d|d �d �� }t�d||� d|k�r�|tjjjk�r�| �� | �|�\}}}t � t|��rTt � t|��ss| j�sdt�d|||� | �� S t � t|��sst�d|||� t � t|��r�t �t|d �d �� }t � t|��sz| j�r�d}nst � t|��r�t �t|d �d �� }t � t|��s�nYd|k�r| �� | �|�\}}}t � t|��r�t � t|��s�d|� �||fS t � t|��r�t �t|d �d �� }t � t|��s�t � t|��rt �t|d �d �� }t � t|��s�|||fS )aO Prepare the pre-check command to send to the subsystem 1. execute SHIM + command 2. check if SHIM returns a master request or if it completed 3. handle any master request 4. re-execute SHIM + command 5. split SHIM results from command results 6. return command results z3Performing shimmed, blocking command as follows: %sr. c S s g | ]}t |��qS r )r� r/ r r r r � s z$Single.cmd_block.<locals>.<listcomp>z STDOUT %s %srl z STDERR %s %szRETCODE %s: %s�.Python environment not found on Windows systemrc �Undefined SHIM statez2ERROR: Failure deploying thin, undefined state: {}zERROR: z\r?\nr z SHIM retcode(%s) and command: %sr� zJERROR: Failure deploying thin, retrying: STDOUT: %s STDERR: %s RETCODE: %sra rO z#ERROR: Failure deploying ext_mods: )� _convert_argsr� r r� r9 rZ rh r% r� �categorize_shim_errorsr Z deploy_pythonr �search�RSTR_REre r r� rz r; rL r� ZEX_THIN_DEPLOYr r� r� r+ )rW Zis_retryr1 r� r� r� r� Z shim_commandr r r r� � s� � � ���� � �� ��� ����� ��� zSingle.cmd_blockc C s t jj�|�}t jj�|�}t�t|�r |td kr d S t�t|�r$dS |�d�r+d S d}dt j j j fddft j j j fdd ft j j j fd d ft j j jfd d | fddd|�|�fdd|�|�fdd|�|�ft j j jfdd| fddg }|D ]}||d v s�t�|d |�r�|d S qvd S )Nr rj r� zFPermissions problem, target user may need to be root or use sudo: {0})r z5sudo: no tty present and no askpass program specifiedz+sudo expected a password, NOPASSWD requiredz Python interpreter is too oldz�Python version error. Recommendation(s) follow: - Install Python 3 on the target machine(s) - You can use ssh_pre_flight or raw shell (-r) to install Python 3zchecksum mismatchedz$The salt thin transfer was corruptedz scp not foundz/No scp binary. openssh-clients package requiredz*salt path .* exists but is not a directoryz5A necessary path for salt thin unexpectedly exists: )r z,sudo: sorry, you must have a tty to run sudoz"sudo is configured with requirettyr zFailed to open log filezPermission denied:.*/saltz&Failed to create directory path.*/saltzexists but is notz?An internal error occurred with the shim, please investigate: )r z)The system cannot find the path specifiedri )r zis not recognizedri r rc r� )r; r< re Z to_unicoder rm rn rQ r� rL r� r ZEX_THIN_CHECKSUMZEX_SCP_NOT_FOUND� EX_CANTCREATrz � EX_SOFTWARE) rW Z stdout_bytesZ stderr_bytesr� r� r� Zperm_error_fmt�errorsr� r r r rl ? s` � � � � �� ���: �z Single.categorize_shim_errorsc C � dS )z( Stub out check_refresh Nr )rW r� r� r r r � check_refresh� � zSingle.check_refreshc C rr )z; Module refresh is not needed, stub it out Nr r, r r r �module_refresh� rt zSingle.module_refresh)NNNNNr� FFNNNFNFNNFNr� )r[ ra N)r[ )r� r� r� r� rX r r r) r* r� r+ r� r0 rZ r' rh r� rl rs ru r r r r r� v sJ �x / L D $yT r� c C s� i }| D ]=}d}g }|D ]#}|dkr|| }n|dkr || }n|� d�r&q |�t|| �� q |rA||vr:g ||< || �|� q|S )z8 Create a list of file ref objects to reconcile r9 Z__env__r8 �__)r� �extend� salt_refs�append)�chunksZrefs�chunkr8 Zcrefsr] r r r �lowstate_file_refs� s$ �r| c C sX d}g }t | t�r| �|�r| gS t | t�r*| D ]}t |t�r)|�|�r)|�|� q|S )z5 Pull salt file references out of the states zsalt://)rm r� r� rn ry )r� �protor� �compr r r rx � s �rx c C s� g d�}i }| j }|D ]m}zRtjj|||�d�d�}|D ]A}tj�|�s%q |�t tjj ��r/q t� |�D ](}|� d�r\|�d�s\tj� ||�}tj�|�sNq4||vrVi ||< ||| |< q4q W q tyx } z t�d|| � W Y d} ~ q d} ~ ww z||�di �} | �� D ]o\} } | D ]h} tj�| �s�q�|D ]\}tj� | d |� ��}tj�|�s�q�z0t� |�D ](}|� d�r�|�d�s�tj� ||�}tj�|�s�q�||vr�i ||< ||| |< q�W q� ty� } z t�d || � W Y d} ~ q�d} ~ ww q�q�W n t�y } z t�d | � W Y d} ~ nd} ~ ww d }|D ] }t|| �� �D ]}tjj�|| | �}||7 }�q �q|�s7i S tjj�|�}t� |�� � }tj� | j d d|� d��}||d�}tj�|��ra|S | j d }tj�|��srt� |� t � |d�}tj� | j d d�}tjj!�"|d�� }|�#|� W d � n 1 �s�w Y |�$|d� |D ]}|| D ]}|�$|| | tj� ||�� �q��q�|�%� |S )z9 Generate the module arguments for the shim data )�modulesZstatesr7 Z renderersrP r )�tag)z.pyz.soz.pyxrv z0Failed to load %s modules from global loader: %sNr4 r� z Failed to scan directory %s: %sz*Failed to load modules from file_roots: %sra r4 z ext_mods.z.tgz)rN r- zw:gzz ext_mods.verzw+Z ext_version)&r r; rO Z _module_dirs�rstripr7 r8 r= r� r� ZSALT_BASE_PATH�listdir�endswithr9 rF r� r r� rC r� �sortedr� r< Z hashutilsZget_hashre rf �hashlibrL � hexdigestr> �tarfile�openrw rx ry r� �close)rS Z sync_refsr� r �refr5 Zmod_dirZfn_Zmod_pathr� r4 r8 �rootsr� Zver_baser{ �verZ ext_tar_pathrV Z cache_dirZtfpZverfiler� r r r rU � s� � ������ �� �� ������ ��� � � "�rU c C s� t jddgt jt jd��� } z5| d jddd�d �d�d }g }|D ]}z |�t|�� W q# ty> t|� Y W S w t|�W S t yM Y d S w ) z: Returns the version of the installed ssh command r z-V)r� r� rc � ,)�maxsplitr � _)r� r ) � subprocess�Popen�PIPE� communicatere ry r� r� r` � IndexError)r� Z version_parts�parts�partr r r r@ @ s$ �� � �r@ c C s\ g }| D ]'}t |t�r&t|�� �D ]}|dkrq|�|� d|| � �� qq|�|� q|S )z� Take a list of args, and convert any dicts inside the list to keyword args in the form of `key=value`, ready to be passed to salt-ssh Z __kwarg__�=)rm r� rn r� ry )r� Z convertedr� �keyr r r rk V s � rk )]r� rT �binasciir� r| r{ r� rF r� r7 r# r� r r\ r r� r� r� r r� rM Zsalt.client.ssh.shellr; Zsalt.client.ssh.wrapperZ salt.configZsalt.defaults.exitcodesZsalt.exceptionsZ salt.loaderZ salt.minionZ salt.outputZ salt.rosterZsalt.serializers.yamlZ salt.stateZsalt.utils.argsZsalt.utils.atomicfileZsalt.utils.eventZsalt.utils.filesZsalt.utils.hashutilsZsalt.utils.jsonZsalt.utils.networkZsalt.utils.pathZsalt.utils.platformZsalt.utils.stringutilsZsalt.utils.thinZsalt.utils.urlZsalt.utils.verifyZ salt._loggingr Zsalt._logging.mixinsr Z salt.templater Zsalt.utils.processr Zsalt.utils.zeromqr r r� � ImportErrorr rQ rn r9 rz rL r� r re rW r< �platformZ is_windowsZis_junosr8 �dirname�__file__Z shim_filer: rw rx Z ssh_py_shimr� rS � getLoggerr� r r r� r| rx rU r@ rk r r r r �<module> s� � -7�9��� B �� , 0x
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings