File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/inspectlib/__pycache__/collector.cpython-310.pyc
Back
o ;jKH � @ s8 d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl m Z d dl m Z m Z d dlmZmZmZmZmZ d dlmZ zd dlZW n eyS dZY nw e �e�ZG dd� de �Zdd � Z d d � Z ed k�re ej �d kr�e dej!d� e�"d� ej dd� \Z#Z$Z%e e#�r�e�"d� ze�&� d kr�e�"d � n W n e'y� Z( z e�"d� W Y dZ([(ndZ([(ww e�)� e�*d � z5e�&� Z+e+d kr�ej,j-�.ej/�0e#e j1�d��Z2e2�3e+� d�� W d � n1 s�w Y e�"d � W n e'�y Z( z e�"d� W Y dZ([(ndZ([(ww e e$e#e%� dS dS )� N)�CommandExecutionError)� EnvLoader�kiwiproc)� AllowedDir� IgnoredDir�Package�PackageCfgFile� PayloadFile)�InspectorSnapshotExceptionc @ s� e Zd ZdZg d�Zg d�Zg d�Zg d�Zd7dd�Zd d � Z d d � Z d8d d�Z dd� Z dd� Z dd� Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zd+d,� Zd9d.d/�Zd:d3d4�Z d;d5d6�Z dS )<� Inspectorz/etc/salt/minion)Z configuration�payload�all)�procZsysfsZdevtmpfsZtmpfszfuse.gvfs-fuse-daemon)ZautofsZcifs�nfsZnfs4) �/tmpz/var/tmpz /lost+foundz/var/runz /var/lib/rpmz /.snapshotsz/.zfsz/etc/sshz/rootz/homeNc C s t j| |||d� d S )N)�cachedir�piddir� pidfilename)r �__init__)�selfr r r � r �U/opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/inspectlib/collector.pyr > s �zInspector.__init__c C s | j jdd� | S )z6 Open new snapshot. :return: T��new��db�open�r r r r �create_snapshotC s zInspector.create_snapshotc C s | j �� | S )zF Open an existing, latest snapshot. :return: r r r r r �reuse_snapshotL s zInspector.reuse_snapshotc G s2 t j|gt|� t jt jt j|ptjd�j|d�S )z2 Call an external system command. )�stdout�stdin�stderr�env)�input)� subprocess�Popen�list�PIPE�STDOUT�os�environ� communicate)r Zcommandr$ r# �paramsr r r �_syscallU s ��zInspector._syscallc C s> | j �� �d�dkr| �� S | j �� �d�dv r | �� S t� S )zS Package scanner switcher between the platforms. :return: � os_family�Debian�ZSuseZredhat)� grains_core�os_data�get� _Inspector__get_cfg_pkgs_dpkg� _Inspector__get_cfg_pkgs_rpm�dictr r r r � _get_cfg_pkgsa s zInspector._get_cfg_pkgsc C s� t � }tjj�| �ddddd�d ��tj�D ]G}|� � }|s qt � ||< tjj�| �ddddd|�d ��tj�D ]}|� � }|sCq:|� � �dd�\}}|| � |� q:|| s^|� |� q|S ) zY Get packages with configuration files on Dpkg systems. :return: � dpkg-queryN�-Wf�${binary:Package}\nr z${Conffiles}\n� � ) r7 �salt�utils� stringutils�to_strr. �splitr* �linesep�stripr' �append�pop)r �data�pkg_nameZ pkg_cfg_itemZ pkg_cfg_fileZ pkg_cfg_sumr r r Z__get_cfg_pkgs_dpkgn s8 �� ���� �z Inspector.__get_cfg_pkgs_dpkgc C s� | � ddddddd�\}}t� }d}g }tjj�|�}|�tj�D ] }|� � }|s*q!|� d�s<|r7|r7|||< |}g }q!|� |� q!|rJ|rJ|||< |S )zG Get packages with configuration files on RPM systems. �rpmNz-qaz --configfilesz --queryformatz %{name}-%{version}-%{release}\n�/) r. r7 r> r? r@ rA rB r* rC rD � startswithrE )r �out�errrG rH � pkg_configs�liner r r Z__get_cfg_pkgs_rpm� s4 � z Inspector.__get_cfg_pkgs_rpmc C s t � }|�� D ]�\}}t� }t� }| j�� �d�dkr0tjj� | � dddd|�d �� t j �}n#| j�� �d�dv rStjj� | � dddd d d d d d|� d �� t j �}|D ],}|�� }|rp|�d�dk sp|� d�d �d�dk rqqU|� d�d }||v r�|�|� qU|r�|||< q|S )z� Filter out unchanged packages on the Debian or RPM systems. :param data: Structure {package-name -> [ file .. file1 ]} :return: Same structure as data, except only files that were changed. r/ r0 �dpkgNz--verifyr r1 rI z-Vz--nodepsz --nodigestz --nosignaturez --nomtimez --nolinktoz c r< �5���)r7 �itemsr' r2 r3 r4 r> r? r@ rA r. rB r* rC rD �findrE ) r rG Zf_datarH Z pkg_filesZcfgsZcfg_datarO Zcfg_filer r r �_get_changed_cfg_pkgs� sR ��� �� �* ��z Inspector._get_changed_cfg_pkgsc C sz d}d}|� � D ]2\}}t� }||_||_| j�|� |D ]}t� }||_||_||_| j�|� |d7 }q |d7 }qdS )zZ Save configuration packages. (NG) :param data: :return: r r= N) rS r �id�namer �storer Zpkgid�path) r rG Zpkg_idZ pkg_cfg_idrH rN ZpkgZ pkg_configZcfgr r r �_save_cfg_packages� s �z Inspector._save_cfg_packagesc C s� d}d|fd|fd|ffD ]@\}}|D ]9}t �|�}t� } || _|| _|| _|j| _|j| _ |j | _ |j | _ |j| _|j| _|j| _|d7 }| j�| � qq dS )z� Save payload (unmanaged files) :param files: :param directories: :param links: :return: r �f�d�lr= N)r* �statr rV rY �p_type�st_mode�mode�st_uid�uid�st_gid�gid�st_sizeZp_size�st_atime�atime�st_mtime�mtime�st_ctime�ctimer rX ) r �files� directories�links�idxr_ Zp_listZp_objZstatsr r r r � _save_payload� s, � ��zInspector._save_payloadc C sH | j �� �d�dkr| �� S | j �� �d�dv r | �� S t� t� t� fS )z> Build a in-memory data of all managed files. r/ r0 r1 )r2 r3 r4 �"_Inspector__get_managed_files_dpkg�!_Inspector__get_managed_files_rpmr' r r r r �_get_managed_files s z Inspector._get_managed_filesc C s� t � }t � }t � }tjj�| �ddddd�d ��tj�D ]N}|� � }|s&q tjj�| �dddd|�d ��tj�D ]0}|� � }|rF|dv rGq:tj � |�rS|� |� q:tj � |�r_|� |� q:tj �|�rj|� |� q:q t|�t|�t|�fS ) zZ Get a list of all system files, belonging to the Debian package manager. r9 Nr: r; r rP z-L)rJ z./�.)�setr> r? r@ rA r. rB r* rC rD rY �isdir�add�islink�isfile�sorted)r �dirsro rm rH Zresourcer r r Z__get_managed_files_dpkg" s8 ���� �� z"Inspector.__get_managed_files_dpkgc C s� t � }t � }t � }tjj�| �dddd�d ��tj�D ]A}|� � }|s%q |� dd��d�}|d d dkr>|� |d � q |d d d krN|� |d � q |d d d kr]|� |d � q t |�t |�t |�fS ) zZ Get a list of all system files, belonging to the RedHat package manager. rI Nz-qlavr � r< r\ rR r] �-) rv r> r? r@ rA r. rB r* rC rD �replacerx r{ )r r| ro rm rO r r r Z__get_managed_files_rpm? s( ���z!Inspector.__get_managed_files_rpmc G s t � }t � }t � }t�|tj�rt�|�D ]i}tj�||�}d}|D ] }|�t|��r.d}q"q"|r>tj� |�r>t�|tj�s?qt j j� |�rL|� |� qtj�|�rs|� |� | j|g|�R � \} } } |�| � |�| � |�| � qtj�|�r~|� |� qt|�t|�t|�fS )zW Walk implementation. Version in python 2.x and 3.x works differently. TF)r' r* �access�R_OK�listdirrY �joinrK �str�existsr> r? ry rE rw �_get_all_files�extendrz r{ ) r rY Zexcluderm r| ro �obj�validZex_objZf_objZd_objZl_objr r r r� W s4 � �zInspector._get_all_filesc C sT |\}}}|\}}}t tt|��|���t tt|��|���t tt|��|���fS )zK Get the intersection between all files and managed files. )r{ r' rv � difference) r ZmanagedZ system_allZm_filesZm_dirsZm_linksZs_filesZs_dirsZs_linksr r r �_get_unmanaged_filesv s �z Inspector._get_unmanaged_filesc C s t � }| j�t�D ]}tj�|j�r|�|j� q t � }|s4| j�t�D ]}tj�|j�r3|�|j� q$t � }t � }t � }dd� |pFt� d�D �D ]3}|d dkrVd|� �}||v s`tj� |�raqI| j |g|�R � \} } } |� | � |� | � |� | � qI| � | �� |||f�S )z" Scan the system. c S � g | ]}|r|�qS r r )�.0Zpthr r r � <listcomp>� � z+Inspector._scan_payload.<locals>.<listcomp>rJ r )r' r r4 r r* rY r� rE r r� ry r� r� r� rt ) r �allowed� allowed_dirZignored� ignored_dirZ all_filesZall_dirsZ all_linksZ entry_pathZe_filesZe_dirsZe_linksr r r � _scan_payload� s< � � ��zInspector._scan_payloadc K s4 | j jdd� t� }|t| j�O }tjj�� }|�� D ])\}}|| j v r1|D ] }|� |d � q&q|D ]}|d | j v rC|� |d � q3qt � }t t |��D ]}d} |D ] } |�| �r_d} nqT| rg|�|� qN|D ]} t� } | | _| j �| � qjdd� |�dd ��d �D �} | D ]}t� } || _| j �| � q�|S ) zJ Prepare full system scan by setting up the database etc. Tr Z mount_point�typeFc S r� r r )r� Zelmr r r r� � r� z0Inspector._prepare_full_scan.<locals>.<listcomp>�filter� �,)r r rv � IGNORE_PATHSr> r? ZfsutilsZ _get_mountsrS � IGNORE_MOUNTSrx �IGNORE_FS_TYPESr' r{ rK rE r rY rX r4 rB r )r �kwargsZ ignored_fsZmountsZdevicerG ZmptZ ignored_all�entryr� Ze_entryr� Zdir_objr� r� r r r �_prepare_full_scan� sF �� � � z Inspector._prepare_full_scanc C s. ddl m} ddlm} || j�|_|| _dS )z3 Initialize some Salt environment. r )� minion_config)�coreN)Z salt.configr� Z salt.grainsr� �DEFAULT_MINION_CONFIG_PATHZ__opts__r2 )r r� Zg_corer r r � _init_env� s zInspector._init_envc C s. | � � | �| �| �� �� | j| �� � dS )�0 Take a snapshot of the system. N)r� rZ rU r8 rq r� )r ra r r r �snapshot� s zInspector.snapshot� c K s~ || j vr td|� d���t| j�rtd��| jd i |�� tjdd|� �dtt j � | j�t j � | j �|gdtj tj d� d S ) r� zUnknown mode: '�'z Inspection already in progress.�nicer~ �pythonF)�checkr r" Nr )�MODEr �is_alive�pidfiler r� r% �run�__file__r* rY �dirname�dbfile�DEVNULL)r ra �priorityr� r r r �request_snapshot� s$ � �zInspector.request_snapshotFr �qcow2c C s& t t_ tjt|d�jdi |���d�S )zk Export description for Kiwi. :param local: :param path: :return: )Zgrains�formatZ somethingNr )Z__salt__r Z KiwiExporterZ __grains__�load�export)r � description�localrY r� r r r r� s ���zInspector.exportc C s& t du rd}t�|� t|��td��)zj Build an image using Kiwi. :param format: :param path: :return: NzXUnable to build the image due to the missing dependencies: Kiwi module is not available.z Build is not yet implemented)�kiwi�log�errorr )r r� rY �msgr r r �build s � zInspector.build)NNN)NN)r� )Fr r� )r� r ) �__name__� __module__� __qualname__r� r� r� r� r� r r r r. r8 r5 r6 rU rZ rq rt rr rs r� r� r� r� r� r� r� r� r� r r r r r + s8 !#*" &+ r c C s� z(t jj�| ��}t�t|�� �� �d� W d � W dS 1 s!w Y W dS t yM } zt� | tj �rBtj � | �rBt�| � W Y d}~dS d}~ww )z& Check if PID is still alive. r NTF)r> r? rm �fopenr* �kill�int�readrD � Exceptionr� �W_OKrY rz �unlink)r� �fp_�exr r r r� $ s �� ��r� c C s t | |��� �|� dS )z Main analyzer routine. N)r r r� )r� r� ra r r r �main2 s r� �__main__� z,This module is not intended to use directly!)�filer= �w� )4�loggingr* r% �sysZsalt.utils.filesr> Zsalt.utils.fsutilsZsalt.utils.pathZsalt.utils.stringutilsZsalt.exceptionsr Zsalt.modules.inspectlibr r Z salt.modules.inspectlib.entitiesr r r r r Z"salt.modules.inspectlib.exceptionsr r� � ImportError� getLoggerr� r� r r� r� �len�argv�printr" �exitr� r� ra �fork�OSErrorr� �setsid�umask�pidr? rm r� rY r� ZPID_FILEr� �writer r r r �<module> sv � | ��� � � ����
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings