File: //usr/local/CyberCP/plogical/__pycache__/processUtilities.cpython-310.pyc
o
��h~Y � @ sb d dl mZ d dlZd dlZd dlZd dlZd dlZd dl Z d dl
Z
d dl Z G dd� dej �Z
dS )� )�CyberCPLogFileWriterNc @ s6 e Zd ZdZdZdZdZdZdZdZ dZ
dZ dZ dZ
dZdZdZd Zd
d � Zd d
� Zedd� �Zedd� �Zedd� �Zedd� �Zed4dd��Zedd� �Zed d � �Zed d � �Z ed d!� �Z ed"d#� �Z ed5d$d%��Z ed6d&d'��Z ed7d(d)��Z!d*d+� Z"ed8d,d-��Z#ed.d/� �Z$ed0d1� �Z%ed2d3� �Z&dS )9�ProcessUtilitiesz/usr/local/CyberCP/debug� litespeed� r � � z /usr/local/lscpd/admin/comm.sock�unsetz /usr/local/lscp/conf/bind.confc C s t j�| � || _|| _d S �N)�multi�Thread�__init__�function� extraArgs)�selfr
r � r �//usr/local/CyberCP/plogical/processUtilities.pyr s
zProcessUtilities.__init__c
C sX z| j dkr
| �� W d S W d S ty+ } zt�t|�d � W Y d }~d S d }~ww )N�popenz [ApplicationInstaller.run])r
�
customPoen�
BaseException�logging� writeToFile�str)r �msgr r r �run! s
� ��zProcessUtilities.runc C s: dt j } t �| �}|�d�dkr|�d�d �d�S dS )Nzcat %s�*����:r �
�8090)r �portPath�outputExecutioner�find�split�rstrip)�command�portr r r �fetchCurrentPort( s
z!ProcessUtilities.fetchCurrentPortc
C s� g } z dd l }|�� D ]}|�� �tj�dkr | �|j� q W n ty; } zt �
t |�d � W Y d }~dS d }~ww t | �dkrD| S dS )Nr r z [getLitespeedProcessNumber])
�psutil� process_iter�namer! r �litespeedProcess�append�pidr r r r �len)�finalListOfProcessesr' �procr r r r �getLitespeedProcessNumber2 s$ ��
��� z*ProcessUtilities.getLitespeedProcessNumberc
C �| z t �� t jkr d} nd} t�| �}t�|�}|dkr W dS W dS tjy= } zt� t
|�d � W Y d }~d S d }~ww )Nzsystemctl restart lswsz$/usr/local/lsws/bin/lswsctrl restartr r z[restartLitespeed]� r � decideServer�OLS�shlexr" �
subprocess�call�CalledProcessErrorr r r �r$ �cmd�resr r r r �restartLitespeedF �
��z!ProcessUtilities.restartLitespeedc
C r1 )N�systemctl stop lswsz!/usr/local/lsws/bin/lswsctrl stopr r z[stopLitespeed]r2 r9 r r r �
stopLitespeedY r= z ProcessUtilities.stopLitespeedFNc
C sN znt tjd�}|d kr%|dkrtjt�| �||d�}n8tj| |||d�}n.| �d�dkr-n
| �d�dkr:d|| f } |dkrJtjt�| �||d�}n tj| |||d�}tj� t
j �ret �
| � d |� d
�� |d krlW d S W d S tjy� } zt �
d
t|� � W Y d }~d S d }~w ty� } zt �
dt|� � W Y d }~d S d }~ww )N�wF)�stdout�stderr)�shellrA rB �exportr �sudoz
sudo -u %s %s�
[Exit Code: �]r r z(%s. [ProcessUtilities.normalExecutioner]z-%s. [ProcessUtilities.normalExecutioner.Base])�open�os�devnullr6 r7 r5 r" r! �path�existsr � debugPathr r r8 r r )r$ rC �User�fr; r r r r �normalExecutionerl s6 ���z"ProcessUtilities.normalExecutionerc C sb z d} t �| � W n Y t �� }|dkr-|D ]}z
dt|� } t �| � W q Y qd S d S )Nr> r z
sudo kill -9 )r rP r0 r )r$ �pids�itemsr r r �
killLiteSpeed� s �z ProcessUtilities.killLiteSpeedc C s t j�d�r tjS tjS )Nz!/usr/local/lsws/bin/openlitespeed)rI rK rL r r4 �entr r r r r3 � s z ProcessUtilities.decideServerc s\ d} d}t j�d�rgtdd��P}|�� � d� v rXd� v r/dt_dt_dt_tj W d � S d� v r@dt_tj W d � S d � v rNtj W d � S tj
W d � S W d � n1 sbw Y t j�|�r�t|d��1}|�� � t � fd
d �d D ��r�t � fd
d �dD ��r�dt_tj W d � S W d � tj
S 1 s�w Y tj
S )Nz/etc/lsb-releasez/etc/redhat-releasez/etc/os-release�r�Ubuntuz24.04r z22.04z20.04c 3 � � | ]}|� v V qd S r r ��.0�x��contentr r � <genexpr>� � � z0ProcessUtilities.decideDistro.<locals>.<genexpr>)zCentOS Linux release 8zAlmaLinux release 8zRocky Linux release 8�Rocky Linux release 9�AlmaLinux release 9zCloudLinux release 9zCloudLinux release 8c 3 rW r r rX r[ r r r] � r^ )r` r_ )
rI rK rL rH �readr �
ubuntu22Check�
ubuntu24Check�
alma9check�ubuntu20�ubuntu�any�cent8)�
distroPath�distroPathAlmarO r r[ r � decideDistro� sH � � �� � �
�
�
z ProcessUtilities.decideDistroc C s> zd} t �| �}|�d�dkrW dS W dS ty Y dS w )Nzcat /etc/cgrules.confzNo suchr r r )r r r! r )r$ �outputr r r �containerCheck� s
�z ProcessUtilities.containerCheckc
C s� d} zt � t jt j�}|�tj� |dgW S tyW } z5| dkr3t�d� dt |�gW Y d }~S | d } t�dt |� d t | � d � t
� d
� W Y d }~nd }~ww q) Nr r �Noner zcFailed to connect to LSCPD socket, run 'systemctl restart lscpd' on command line to fix this issue.r z.Failed to connect to LSCPD UDS, error message:z
. Attempt z>, we will attempt again in 2 seconds. [setupUDSConnection:138]r ) �socket�AF_UNIX� SOCK_STREAM�connectr �server_addressr r r r �time�sleep)�count�sockr r r r �setupUDSConnection� s
"���z#ProcessUtilities.setupUDSConnectionc C s� d}d}d}||k r�zst �� }|d dkr||d7 }|d }||k rkt�d|� d|� d�� t�d� |dkrit�d � ztjg d
�d d d � t�d
� W n tyh } zt�dt |�� �� W Y d}~nd}~ww W qt�d|� �� d|� d|� �W S W n? ty� } z3|d7 }t |�}||k r�t�d|� d|� d|� �� t�d� W Y d}~qd|� d|� �W Y d}~S d}~ww �zj|du r�W dS |d }t j
dkr�t j �
d�t _
t j d= |dk�r | �d�dkr�n | �d�dkr�d| } t j�t j�r�t�| � |dk�r|�t j
| �d�� nJd t j
|| f } |�| �d�� n9| �d��r-| �dd d�} |dk�r;d t j
|| f } n d t j
||| f } t j�t j��rQt�| � |�| �d�� d } |�d!�}
t|
�dk�sm|
dk�rnn| |
7 } �q\z | jdd"d#�} W n t�y� } zt�d$t | � � d } W Y d} ~ nd} ~ ww |�� t j�t j��r&t| �dk�r�t�d%� | W S zO| d }
t�d&t| �� d't|
�� �� t |
t ��r�t |
�}nd(}| �t j
d ��|�r�d)| nd d ��|�r�d*| nd d �� � }t�d+|� d,|� d-�� W | W S t�y% } zt�d.t |�� �� W Y d}~| W S d}~ww | W S t�yJ } zt�t | �d/ � d0t | � W Y d} ~ S d} ~ ww )1a
Send command to lscpd with retry mechanism
:param command: Command to execute
:param user: User to run command as
:param dir: Directory to run command in
:param retries: Number of retry attempts if connection fails
r Nr r z)[sendCommand] Connection failed, attempt �/z. Retrying in 2 seconds...r z4[sendCommand] Attempting to restart lscpd service...)� systemctl�restart�lscpdT)�capture_output�textr z'[sendCommand] Failed to restart lscpd: z:[sendCommand] All connection attempts failed. Last error: z-1Connection failed after z attempts: z([sendCommand] Unexpected error, attempt z: z-1Error after z+-1Internal error: connection result is Noner �TOKENrD rE zsudo %s�utf-8z
%s-d %s %s� z
%s-u %s %sz%s-u %s -d %s %s� � �replace)�errorsz8Some data could not be decoded to str, error message: %su$ └─ Empty response from lscpdu └─ Response length: z
, last char: �unknownz-u %s z-d %s u └─ rF rG u$ └─ Failed to log exit code: z [hey:sendCommand]�0) r rx r r rt ru r6 r � Exceptionr �tokenrI �environ�getr! rK rL rM �sendall�encode�
startswithr� �recvr- �decoder �close�repr�
isinstance�ord�strip)r$ �user�dir�retries�attempt�
last_error�ret�erw �raw_data� currentData�datar � exit_char� exit_code�
clean_commandr r r � sendCommand� s�
��
��
���
�
>� ����z ProcessUtilities.sendCommandc
C s� z�t j�tj�rt�d| � d|� d|� �� t�� dkr2t j�tj�r(t�d� t� | ||� W dS t j�tj�r>t�d� t�
| |�}|rLt |�dkrVt�d | � W dS zH|d
}t |t
�ret|�}n t |t�rwt |�dkrt|d nd}n
tt�|�� d ��}t j�tj�r�t�d |� d
| � �� |dkr�W W dS W W dS ty� } zt�dt
|�� d
| � �� W Y d }~W dS d }~ww ty� } zt�t
|�d � W Y d }~dS d }~ww )Nz#[executioner] Called with command: z, user: z , shell: �rootz6[executioner] Running as root, using normalExecutionerr z3[executioner] Not root, using sendCommand via lscpdr z)Empty response from lscpd for command: %sr �hexzExit code from lscpd: � for command: zFailed to parse exit code: z [executioner])rI rK rL r rM r r �getpass�getuserrP r� r- r� r r� �bytes�int�codecsr� r� r )r$ r� rC r� �exitCoder� r r r r � executionert sH
����z ProcessUtilities.executionerc
C s �zlt �� dkr�tj�tj�rt�| � |d kr%| � d�s%d|� d| � �} tj
� � }d|d< d|d< d|d < |d ks>|d
krMt j
| d
t jt j|dd d �}nt j
t�| �t jt j|dd d
�}|r�|�� \}}|j} tj�tj�rxt�d| � d�� | dkr�d|fW S d|fW S |�� d }|j} tj�tj�r�t�d| � d�� |W S t| �tkr�d�| �} |�rbt�| |�}
|
r�t|
�dkr�t�d| � W dS zg|
d } tj�tj�r�t�dt| �� �� t| t�r�t | �} n t| t �r�t| �dkr�| d nd} n
t t � | � � d��} tj�tj��rt�d| � d| � �� | dk�r&d|
d d� fW W S d|
d d� fW W S t!�ya } z%t�dt| �� d| � �� dt|
�dk�rS|
d d� ndfW Y d } ~ W S d } ~ ww t�| ||�d d� W S t"�y� }
zt�t|
�d � W Y d }
~
d S d }
~
ww ) Nr� rE zsudo -u � zC.UTF-8�LC_ALL�LANGr� �PYTHONIOENCODINGTr� )rC rA rB �env�encodingr� )rA rB r� r� r� u └─ [Exit Code: rG r r z>Empty response from lscpd in outputExecutioner for command: %s)r r� r z.Raw exit code character in outputExecutioner: r� z'Parsed exit code in outputExecutioner: r� z0Failed to parse exit code in outputExecutioner: r� z[outputExecutioner:188])#r� r� rI rK rL r rM r r r� r� �copyr6 �Popen�PIPE�STDOUTr5 r" � communicate�
returncode�type�list�joinr� r- r� r� r r� r� r� r� r� r� r )r$ r� rC r� � retRequiredr� �prl �_r� r� r� r� r r r r r � st
0�� ��z"ProcessUtilities.outputExecutionerc
C s� z<t | jd �tkst | jd �tkr| jd }nd�| jd �}t�� dkr1tj|dd� W dS t �
|| jd � W dS t yX } zt �
t|�d � W Y d }~d S d }~ww ) Nr$ r� r� T)rC r� r z
[customPoen])r� r r r� r� r� r� r6 r7 r r� r r r )r r$ r r r r r � s $ � ��zProcessUtilities.customPoenc
C sf zi }| |d< ||d< t d|�}|�� W d S ty2 } zt�t|�d � W Y d }~d S d }~ww )Nr$ r� r z [popenExecutioner])r �startr r r r )r$ r� r �pur r r r �popenExecutioner s
��z!ProcessUtilities.popenExecutionerc C s2 d| |f }|� � D ] \}}|d||f }q
|S )Nz$/usr/local/CyberCP/bin/python %s %s z --%s %s)rR )rK � functionName�
parameters�execPath�key�valuer r r � BuildCommand s z ProcessUtilities.BuildCommandc
C s� dd l } d}z7| �|�}|jdkr5|�� }|D ]}|�d�dkr1d|�d�v r1|�d�}| W S qW d S td |j� W d S tyU } z td
|� W Y d }~d S d }~ww ) Nr z1https://api.github.com/repos/nodejs/node/releases�� �
prereleaseF�LTSr) �tag_namez&Failed to fetch releases. Status code:�An error occurred:)�requestsr� � status_code�json�printr� )r� �url�response�releases�release� lts_versionr� r r r �!fetch_latest_lts_version_for_node s(
������z2ProcessUtilities.fetch_latest_lts_version_for_nodec
C s� dd l } d}z(| �|�}|jdkr |�� }|d �d�W S t�d|j� �� td|j� W d S tyP } ztd|� t�dt|�� �� W Y d }~d S d }~ww ) Nr z;https://api.github.com/repos/PrestaShop/PrestaShop/releasesr� r� z'Failed to fetch releases. Status code: zH[fetch_latest_prestashop_version] Failed to fetch releases. Status code:r� z5[fetch_latest_prestashop_version] An error occurred: ) r� r� r� r� r r r� r� r )r� r� r� r� r� r r r � fetch_latest_prestashop_version, s
�
��z0ProcessUtilities.fetch_latest_prestashop_version)FN)NNr )NF)NNNNr )'�__name__�
__module__� __qualname__rM r* rT r4 �centosrh �cent9rf re rb rd rc rs r� r r r � staticmethodr& r0 r< r? rP rS r3 rk rm rx r� r� r r r� r� r� r� r r r r r sl
#
$
0 N
r )� plogical.CyberCPLogFileWriterr r r6 r5 rI ro � threadingr
rt r� r� r r r r r r �<module> s