Y_ d dl Z d dlZd dlZd dlZd dlZd dlmZ d dlZd dlZd dl m
Z
d dl m Z d dl
mZ d dlmZmZmZmZmZmZ d Zd Ze j d ed
efd Zd Zdd
Z d Z d Z d Z d Z d Z!ddZ"dS ) N)urlparse)cpapi)get_rhn_systemid_value)parse)CLICKHOUSE_WMT_ENDPOINT JWT_TOKENUNKNOWN_RHN_ID SERVICE_BIN
CHKCONFIG_BIN
SYSTEMCTL_BINc T t } t j t j k r d t j d D }nt j }|s| S t j }n&# t $ r t j d g }Y nw xY wt j dk r"t t j j _
|D ]X}||v rt j d| t j | D ]'\ }}| t# | (Y| S )Nc g | ]
}|d S )r ).0_cpinfos /builddir/build/BUILDROOT/cl-web-monitoring-tool-3.2.3-1.el9.cloudlinux.x86_64/opt/cloudlinux/venv/lib/python3.11/site-packages/wmt/common/utils.py
z get_domains..$ s LLLLLL )cplogin)keylsz%Cannot obtain list of suspended userscPanelz>>> ; ; ; 3c9:::;
q
AHHJJ
...
$ AHHJJ
...
$s >A 1BA*E
AF(c B i }| D ]}||v r| | || f||< |S Nr )d1d2resultkeys r intersectr\ m s;
F + + "99 S'2c7*F3K Mr c 6 t j d }t d D ]t} t j | ||d }| d S # t j $ r1}|}t j t d|z d Y d }~md }~ww xY w|)Nz(Error while sending report to ClickHouse < )jsonheaderstimeout )requestsRequestExceptionrangepostraise_for_statustimesleepmin)urlreportra erroriresponseerrs r send_reportrs u s %&P Q QE
1XX
}SvwPRSSSH % % ' ' '
EE ( ( ( (E Js162 ' ' ' ' ' ' ' ' ( s ,AB%'BBc t | }|j r'|j r d |j |j S | S )Nz{}://{})r schemenetlocformat)rm parseds r _strip_url_to_originry s?
c]]F
} > >
v}=== Jr c t t d 5 } | cd d d S # 1 swxY w Y d S # t t
t f$ r t j dt Y d S w xY w)Nrz Cannot read JWT token from %s) rF r readstripr= r9 UnicodeDecodeErrorr r% )rT s r _read_jwt_tokenr s
)S
!
! $Q6688>>## $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ W 0 1 7CCCtts3 A &A
A
AA AA 1B B c t d pt }| dd | d< | d }| dg D ]}t |d |d< | dg D ]}t |d |d< i }t
}|rd |z |d
< t t i | || d S ) N system_idzID- server_idsummary_report error_reportrm duration_reportzBearer
Authorization)ra ) r r replacepopgetry r rs r )rn
systemd_idsummaryentryra tokens r send_report_to_clickhouser s ' 44FJ$,,UB77F;jj)**GNB// : :+E%L99e -r22 : :+E%L99e G E 5#,u#4 ')>F)>g)>PPPPPPr c 8 |r>t j t | dgd t j t d| gd dS t j t dgd t j t d| gd t j t d| gd dS )z'
Enable cl_wmt_scanner service
startTcapture_outputz--addz
daemon-reloadenableN
subprocessrunr
r r daemon_nameis_cl6s r enable_wmt_daemonr s , [':&* , , , ,
w <&* , , , , , ,
7&* , , , ,
x=&* , , , ,
w <&* , , , , , ,r c |r>t j t | dgd t j t d| gd dS t j t d| gd t j t d| gd dS )z)
Disable WMT daemon
:return:
stopTr z--delkilldisableNr r s r disable_wmt_daemonr s
, [&9&* , , , ,
w <&* , , , , , ,
v{;&* , , , ,
y+>&* , , , , , ,r Tc N d}| r|dg}n|dg}t j |dd d S )Nz./usr/share/web-monitoring-tool/cron_control.pyz-iz-dT)r text)r r )status cron_toolcommands r manage_cronsr sB @I
$ d# d#N74d;;;;;;r rW )T)#
contextlibr rG r4 rj urllib.parser re r clcommonr clcommon.utilsr wmt.common.url_parserr wmt.common.constr r r r
r r r. rB contextmanagerstrrU r\ rs ry r r r r r r r r r s ! ! ! ! ! ! 1 1 1 1 1 1 ' ' ' ' ' ' 8 0 C c .
Q Q Q&, , ,,, , ,$< < < < <