📁 File Manager Pro
v10.0.3 | PHP: 8.1.34
Server: Apache
2026-06-22 03:23:44
📂
/ (Root)
/
opt
/
alt
/
python37
/
lib
/
python3.7
/
site-packages
/
ssa
/
__pycache__
📍 /opt/alt/python37/lib/python3.7/site-packages/ssa/__pycache__
🔄 Refresh
✏️
Editing: manager.cpython-37.pyc
Read Only
B \�ed�5 � @ s� d Z ddlZddlZddlZddlZddlZddlZddlmZ ddl m Z ddl m Z ddl mZ ddlmZmZ dd lmZ dd lmZ dd lmZ dd lmZ dd lmZ G dd� d�Z dd�dd�Z dS )zA This module contains classes implementing SSA Manager behaviour � N)�contextmanager)�iglob)�is_cl_solo_edition)�Tuple� )�load_validated_parser�load_configuration)� flag_file)�SSAManagerError)� ssa_version)� AutoTracer)� DecisionMakerc @ s� e Zd ZdZdd� Zedd�dd��Zeed�dd ��Z ee d�d d ��Z ee d�d d ��Z e e d�dd�ZdAeejd�dd�Ze dd�dd�Zdd�dd�Zdd�dd�Zdd�d d �Zdd�d d �Zdd�d d!�Zeed"�d#d$�Zeee e f ef d�d%d&�Z e d'd(� �Z e e ed)d*�d+d,�Z d)d�d-d.�Z!eee e f ef d�d/d0�Z"d)d�d1d2�Z#d)d�d3d4�Z$d)d�d5d6�Z%ed�d7d8�Z&d)d�d9d:�Z'd)d�d;d<�Z(dd�d=d>�Z)d)d�d?d@�Z*d)S )B�Managerz SSA Manager class. c C sD t �d�| _d| _d| _d| _tddd� d�f| _tt t j f| _ d S ) N�managerz clos_ssa.ini)Zphp44Zphp51Zphp52Zphp53zphp\d+-imunifyz php-internal)z /opt/alt/php[0-9][0-9]/link/confz+/opt/cpanel/ea-php[0-9][0-9]/root/etc/php.dz$/opt/plesk/php/[0-9].[0-9]/etc/php.dz'/usr/local/php[0-9][0-9]/lib/php.conf.dzM/usr/share/cagefs/.cpanel.multiphp/opt/cpanel/ea-php[0-9][0-9]/root/etc/php.dzA/usr/share/cagefs-skeleton/usr/local/php[0-9][0-9]/lib/php.conf.dz./var/cagefs/*/*/etc/cl.php.d/alt-php[0-9][0-9]c S s t �| �d�d �S )N�/� )�pwd�getpwnam�split)�path� r �</opt/alt/python37/lib/python3.7/site-packages/ssa/manager.py�<lambda>5 � z"Manager.__init__.<locals>.<lambda>)r �user) �logging� getLogger�logger� ini_file_name� substrings_to_exclude_dir_paths�wildcard_ini_locations�dict�wildcard_ini_user_locations�OSError� ValueError� subprocess�SubprocessError�subprocess_errors)�selfr r r �__init__$ s zManager.__init__zjson str)�returnc O s* ddi}|� dd� |�� D �� t�|�S )z@ Form a success json response with given kwargs �result�successc S s i | ]\}}||�qS r r )�.0�k�vr r r � <dictcomp>A s z$Manager.response.<locals>.<dictcomp>)�update�items�json�dumps)�args�kwargsZ raw_responser r r �response; s zManager.responsec C s t j�t�S )z Is SSA enabled )�osr �isfiler )r( r r r �_enabledD s zManager._enabledc C s ddhS )zK Configuration settings required Request Processor restart �requests_duration� ignore_listr )r( r r r �_restart_required_settingsK s z"Manager._restart_required_settingsc C s dddddhS )N� correlation�correlation_coefficient�request_number�time�domains_numberr )r( r r r �solo_filtered_settingsR s z Manager.solo_filtered_settings)�settingsr* c C s | j �|�S )z� SSA Agent requires restart in case of changing these configuration: - requests_duration - ignore_list )r= � intersection)r( rD r r r �_restart_requiredW s zManager._restart_requiredF)�commandr* c C s y0t jdd|gdd|d�}| j�d|� d�� W n� t jk r� } zj| jjd|j� d|j� d |jpf|j � �|j|j|j|j d �d � t d|j� d|j� d |jp�|j � ���W d d }~X Y nZ | j k �r } z8| jjd |� d�dt |�id � t d |� d|� ���W d d }~X Y nX |S )z� Run /sbin/service utility to make given operation with SSA Agent service :command: command to invoke :check_retcode: whether to run with check or not :return: subprocess info about completed process z /sbin/servicez ssa-agentT)�capture_output�text�checkz ssa-agent z succeededz SSA Agent z failed with code z: )�cmd�retcode�stdout�stderr)�extraNzFailed to run z command for SSA Agent�errz for SSA Agent: ) r% �runr �info�CalledProcessError�errorrK � returncoderM rN r r' �str)r( rG � check_retcoder+ �er r r �run_service_utility_ s( 4$zManager.run_service_utility)r5 r* c C s� t � }|�|� y |�� W nH tk rd } z*| jjddt|�id� td|� ���W dd}~X Y nX | �|�r~| j ddd� | � � S ) z� Change SSA config and restart it. :args: dict to override current option values :return: JSON encoded result of the action z Failed to update SSA config filerP )rO z"Failed to update SSA config file: N�restartT)rW ) r �overrideZwrite_ssa_confr# r rT rV r rF rY r7 )r( r5 �configrX r r r � set_config| s zManager.set_configc s> t � }tdd�r2� fdd�|�� D �}� j|d�S � j|d�S )zV Get current SSA config. :return: JSON encoded current config T)�skip_jwt_checkc s i | ]\}}|� j kr||�qS r )rC )r- �key�value)r( r r r0 � s z&Manager.get_config.<locals>.<dictcomp>)r\ )r r r2 r7 )r( Z full_configZfiltered_configr )r( r � get_config� s zManager.get_configc C s | j r dnd}| j|d�S )zY Get current status of SSA. :return: JSON encoded current status �enabled�disabled)Z ssa_status)r: r7 )r( �statusr r r �get_ssa_status� s zManager.get_ssa_statusc C s2 | j rtddd��| �� | �� | �� | �� S )a� Enable SSA: - add clos_ssa extension for each PHP version on server - add clos_ssa extension into cagefs for each user and each ver - start SSA Agent (if it is not already started) - restart Apache (etc.) and FPM, reset CRIU images - create flag_file indicating that SSA is enabled successfully :return: JSON encoded current status zSSA is already enabled�warning)�flag)r: r � generate_inis�start_ssa_agent� create_flagr7 )r( r r r � enable_ssa� s zManager.enable_ssac C s2 | j stddd��| �� | �� | �� | �� S )a{ Disable SSA: - remove clos_ssa extension for each PHP version on server - remove clos_ssa extension from cagefs for each user and each ver - stop SSA Agent - restart Apache (etc.) and FPM, reset CRIU images - remove flag_file indicating that SSA is enabled :return: JSON encoded current status zSSA is already disabledrf )rg )r: r �remove_clos_inis�stop_ssa_agent� remove_flagr7 )r( r r r � disable_ssa� s zManager.disable_ssac C s> dd� t � �� D �}| j|t� | jr(dnd| �� t� �� d�S )z� Get SSA statistics. Includes: - config values - version - SSA status (enabled|disabled) - SSA Agent status (active|inactive) :return: JSON encoded current statistics c S s i | ]\}}t |��� |�qS r )rV �lower)r- r_ r` r r r r0 � s z%Manager.get_stats.<locals>.<dictcomp>rb rc )r\ �versionrd � agent_statusZ autotracing)r r2 r7 r r: �status_ssa_agentr � get_stats)r( Z_configr r r rt � s zManager.get_stats)�dir_pathr* c s � fdd�| j D �}|S )z6 Checking for substrings in a string. c s g | ]}t �|� �r|�qS r )�re�search)r- Z substring)ru r r � <listcomp>� s z+Manager.unused_dir_path.<locals>.<listcomp>)r )r( ru �resr )ru r �unused_dir_path� s zManager.unused_dir_pathc c s� x6| j D ],}x&t|�D ]}| �|�r&qd|fV qW qW xp| jD ]f}x`t|d �D ]P}| �|�rbqRy|d |�}W n | j�d|� wRY qRX |j|jf|fV qRW q@W dS )z� Generator of existing paths (matching known wildcard locations) for additional ini files Returns tuple of (uid, gid) and path. )r r r r zhUnable to get information about user owning %s directory (maybe he`s already terminated?), skip updatingN)r r rz r" r rR �pw_uid�pw_gid)r( �locationru Z pw_recordr r r �existing_paths� s zManager.existing_pathsc c s: z t �|� t �|� dV W dt �d� t �d� X dS )z� Dive into user context by dropping permissions to avoid most of the security issues. Does not cover cagefs case because it also requires nsenter, which is only available with execve() call in our system Nr )r8 �setegid�seteuid)r( �uid�gidr r r � _user_context� s zManager._user_contextN)r� r� �ini_pathr* c C sZ t j�|| j�}| �||��4 t|d�� }| j�d|� |�d� W dQ R X W dQ R X dS )zB Enable SSA extension for single ini_path (given) �wzGenerating %s file...zextension=clos_ssa.soN) r8 r �joinr r� �openr rR �write)r( r� r� r� r Zinir r r �generate_single_ini s zManager.generate_single_inic C sn | j �d� xP| �� D ]D\\}}}y| �|||� W q tk rX | j �d|� wY qX qW | j �d� dS )zj Place clos_ssa.ini into each existing Additional ini path, including cagefs ones z Generating clos_ssa.ini files...z>Unable to update file %s, possible permission misconfigurationz Finished!N)r rR r~ r� �PermissionError)r( r� r� r� r r r rh s zManager.generate_inisc c sV xP| � � D ]D\\}}}x6t�|�D ](}| j|kr2q"||ftj�||�fV q"W q W dS )z� Generator function searching for clos_ssa.ini files in all existing Additional ini paths Returns tuple of (uid, gid) and path. N)r~ r8 �listdirr r r� )r( r� r� r� �namer r r �find_clos_inis' s zManager.find_clos_inisc C sX | j �d� x:| �� D ].\\}}}| �||�� t�|� W dQ R X qW | j �d� dS )z8 Remove all gathered clos_ssa.ini files z Removing clos_ssa.ini files...Nz Finished!)r rR r� r� r8 �unlink)r( r� r� Zclos_inir r r rl 3 s zManager.remove_clos_inisc C s2 | � d�}|jr | j ddd� n| j ddd� dS )ze Start SSA Agent service or restart it if it is accidentally already running rd �startT)rW rZ N)rY rU )r( rr r r r ri = s zManager.start_ssa_agentc C s" | � d�}|js | j ddd� dS )z` Stop SSA Agent service or do nothing if it is accidentally not running rd �stopT)rW N)rY rU )r( rr r r r rm H s zManager.stop_ssa_agentc C s, y| j ddd� W n tk r& dS X dS )z: Get SSA Agent status: active or inactive rd T)rW �inactive�active)rY r )r( r r r rs Q s zManager.status_ssa_agentc C s. t td�� W dQ R X | j�dt� d�� dS )zE Create a flag file indicating successful enablement r� Nz Flag file z created)r� r r rR )r( r r r rj [ s zManager.create_flagc C sf y"t �t� | j�dt� d�� W n> tk r` } z | j�dt� dt|�� �� W dd}~X Y nX dS )z: Remove a flag file indicating enablement z Flag file z removedz removal failed: N)r8 r� r r rR r# rf rV )r( rX r r r rn c s zManager.remove_flagc C s t � �� }| jf |�S )zG Get last report. :return: JSON encoded report )r Zget_json_reportr7 )r( Zreportr r r � get_reportn s zManager.get_reportc C s | j r| �� dS )z@ Regenerates clos_ssa inis while SSA is enabled N)r: rh )r( r r r �regenerate_inisv s zManager.regenerate_inis)F)+�__name__� __module__� __qualname__�__doc__r) � staticmethodr7 �property�boolr: �setr= rC r! rF rV r% �CompletedProcessrY r] ra re rk ro rt �listrz r �intr~ r r� r� rh r� rl ri rm rs rj rn r� r� r r r r r s@ r zManager instance)r* c C s t � S )zk Factory function for appropriate manager initialization :return: appropriate manager instance )r r r r r �initialize_manager~ s r� ) r� r3 r r8 r rv r% � contextlibr �globr �clcommon.lib.cleditionr �typingr Z configurationr r �internal.constantsr �internal.exceptionsr �internal.utilsr Zmodules.autotracerr Zmodules.decision_makerr r r� r r r r �<module> s( a
💾 Save Changes
❌ Cancel