H:jd d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZmZ d dlm Z d dl
m Z d dl m
Z
d dlmZ d dlmZ d dl mZ d d lmZmZmZmZmZmZmZ d d
lm Z m Z d d l m Z m Z m!Z! d d l"m#Z# d d
l$m%Z%m&Z&m'Z'm(Z( d dl)m*Z+ d dl,m-Z- d dl.m/Z0 d dl1m2Z2 d dl3m4Z4 d dl5m6Z6 d dl7m8Z8m9Z9m:Z:m;Z;mm?Z? d dl@mAZAmBZBmCZCmDZDmEZE d dlFmGZG d dlHm/Z/ n# eI$ r d Z/Y nw xY wdZJdZKdZLd ZMd ZNd ZOd ZPd ZQd!ZR e+ ZSd"ZTd#geBz d$gz eAz eCz ZU ed%d&eVfd'eVfg ZW ed(d)eXfd*eXfd+eXfd,eXfd-eXfd.eXfg ZY ed/d0eeX fd1eeX fd2eeX fd3eeX fd4eYfd5eWfd6eWfd7eeZ fd8eeZ fd9eZfd:eeZ fg Z[ ed;d3eXfd1eXfde j] j^ j_ Z` G d? d@e4 ZadA ZbdS )B N)datetime timedelta)message_from_string)Header)
MIMEMultipart)MIMEText)reduce)groupby)DictIterableIteratorList
NamedTupleOptionalTuple)ALL PrettyTable)clemailclproccpapi) LIMIT_LVP_ID)adminscpinfoget_admin_localeget_user_login_url)get_admin_email)
MailHelper)get_notification)NameMap)LveStatsPlugin)dateutil)deserialize_lve_idgcd get_hostname merge_dictsserialize_lve_iduser_should_be_notifiedmempages_to_bytes)
FIELD_AVERAGE FIELD_FAULT FIELD_LIMITHistoryShowUnionget_lve_version)NotificationsHelperc d S N resellers /builddir/build/BUILDROOT/lve-stats-5.0.4-1.el8.x86_64/opt/cloudlinux/venv/lib/python3.11/site-packages/lvestats/plugins/generic/statsnotifier.pyr r ; s t en_USzadmin_notify.txtzadmin_notify.htmlzuser_notify.txtzuser_notify.htmlzreseller_faults_notify.txtzreseller_faults_notify.htmlzreseller_notify.txtzreseller_notify.htmlz"Hosting account resources exceededIDanyFNotifySettingsNOTIFY_MIN_FAULTSNOTIFY_INTERVALNotifyFaultsOptions
NOTIFY_CPU NOTIFY_IO NOTIFY_IOPS
NOTIFY_MEMORY NOTIFY_EP NOTIFY_NPROC
AdminSettings NOTIFY_ADMINNOTIFY_CUSTOMERS_ON_FAULTSNOTIFY_RESELLER_CUSTOMERS#NOTIFY_RESELLER_ON_CUSTOMERS_FAULTSNOTIFY_FAULTS_TYPESNOTIFY_OPTIONS_SELFNOTIFY_OPTIONS_CUSTOMERNOTIFY_FROM_EMAILREPORT_ADMIN_EMAILNOTIFY_SUBJECTNOTIFY_CHARSET_EMAILResellerSettings NOTIFY_RESELLER_ON_TOTAL_FAULTSc e Zd ZdS )StatsNotifierTemplateErrorN)__name__
__module__ __qualname__r2 r6 r5 rS rS s Dr6 rS c e Zd ZdZdZdZdZdZdZd Z d Z
dBd
Z d Z d Z
d
Zd Zd Zd Zd Zd Zd Zed Zed ZdCdZed Zd Zd Zd Z d Z d e d e d e e e f fd Z dCd!e!d"e d#e fd$Z"dCd!e!d"e d#e d e#fd%Z$d& Z%dCd!e!d"e d#e fd'Z&d( Z'd) Z(d* Z)d+ Z*d, Z+d- Z,d. Z-d/ Z.d0e d e/fd1Z0ed2 Z1d3 Z2d4 Z3dDd6Z4d7 Z5d8 Z6d9 Z7d: Z8d; Z9d< Z:d= Z;d> ZdA Z?dS )E
StatsNotifieri i z/usr/share/lve/emails/z/etc/cl.emails.d/r zlocale_defines.jsonc d | _ d | _ d| _ t j d | _ | t | _ t | _
i | _ t j
| _ t | _ t# t% j | _ n/# t$ j t* f$ r t# | _ Y nw xY wt- | _ d S )N
statsnotifier) server_id db_engine lve_versionlogging getLoggerlog_load_plugin_settingsr$ hostnamer _mail_helper_reseller_settings_cacher ProcLve _proc_lver _name_mapsetr resellers NotSupportedAttributeErrorr/ _notificationsselfs r5 __init__zStatsNotifier.__init__ s $_55 ""$$$$
&LL(*% )) # !2!2 3 3DNN"N3 # # # UUDNNN # 1 3 3s %C )C.-C.c | | _ | | _ | j j j }| j j j }t t ||t j
g | _ | | j
d| j j | j
d| j j | j
d| j j | j
d| j j | j
d| j j j | j
d| j j j | j
d| j j j | j
d| j j j | j
d | j j j | j
d
| j j j | j
d | j j j | j
d | j j j | j
d
| j j j | j
d| j j j | j
d| j j | j
d| j j | j
d| j j | j
d| j j | j
d| j d dS )z [Re]load all plugin settingszConfig: NOTIFY_ADMIN=%sz%Config: NOTIFY_CUSTOMERS_ON_FAULTS=%sz$Config: NOTIFY_RESELLER_CUSTOMERS=%sz.Config: NOTIFY_RESELLER_ON_CUSTOMERS_FAULTS=%szConfig: NOTIFY_CPU=%szConfig: NOTIFY_IO=%szConfig: NOTIFY_IOPS=%szConfig: NOTIFY_MEMORY=%szConfig: NOTIFY_EP=%szConfig: NOTIFY_NPROC=%sz(Config: NOTIFY_INTERVAL_ADMIN=%s secondsz"Config: NOTIFY_MIN_FAULTS_ADMIN=%sz'Config: NOTIFY_INTERVAL_USER=%s secondsz!Config: NOTIFY_MIN_FAULTS_USER=%sz Config: NOTIFY_FROM_EMAIL=%sz Config: REPORT_ADMIN_EMAIL=%szConfig: NOTIFY_SUBJECT=%sz Config: NOTIFY_CHARSET_EMAIL=%sz r? r@ rA rB rC r; rL rM rN rO mail_headers)ro notify_interval_adminnotify_interval_userss r5 rb z#StatsNotifier._load_plugin_settings s # 6 6 8 8 *.*L*L*N*N' !% 4 H X $ 4 L \ S#8:OQ^Qi"jkk
**,,,
/1E1RSSS
=t?S?nooo
R>lmmm
R>v
-t/C/W/bccc
,d.B.V.`aaa
.0D0X0deee
0$2F2Z2hiii
,d.B.V.`aaa
/1E1Y1fggg
68L8`8p
:D - - / / X #~ 9 9 ; ;
X
X $ 7 7 D D
( HNND $ $($>$>}$M$M!!#4#W8WWWWWW :#T%99 9 9 9 9 9 : :r6 c Z d } fd}t || S )z
We do not need resellers with disabled
NOTIFY_CUSTOMERS_ON_FAULTS notifications,
also we do not need those resellers,
whose customers were notified recently.
Let's remove such resellers from check-list.
Tr c f | \ }}|j o$j ||j j S r1 )rF rm users_need_notificationrK r< )reseller_notify_settingsr notify_optionsro s r5 _filter_by_enabled_notificationszWStatsNotifier._get_customers_options_filtered.._filter_by_enabled_notifications s? ,D )[.!< ATAlAl^ C SB B
r6 r filterro resellers_settingsr s ` r5 _get_customers_options_filteredz-StatsNotifier._get_customers_options_filtered sI " 9 9T 9 J J 68JKKKr6 c L d }t | | S )z
If some resellers have same settings
for notify we can send notifications to
their users using only one database request.
For that, we must group them by customers settings
c ( | \ }}|j |j fS r1 )rK rI )customers_notify_settings_r s r5 _group_by_customers_optionszQStatsNotifier._get_customers_options_grouped.._group_by_customers_options s "; Q!9>;]] ]r6 )r
r )ro r s r5 _get_customers_options_groupedz,StatsNotifier._get_customers_options_grouped s3 ^ ^ ^
t;;==?Z[[[r6 c V } fd}t || S )z
We do not need resellers with disabled notifications at all
also we do not need resellers that were notified recently.
Let's remove such resellers from check-list.
c f | \ }}|j o$j ||j j S r1 )rQ rm reseller_need_notificationrJ r< )reseller_notify_optionsr r ro s r5 r zWStatsNotifier._get_resellers_options_filtered.._filter_by_enabled_notifications s? ,C )[.!A dFYFtFt^ ? OG G
r6 r r s ` r5 _get_resellers_options_filteredz-StatsNotifier._get_resellers_options_filtered sD " 9 9 ; ; 68JKKKr6 c P | }d }t || S )z
If some resellers have same settings
for notifywe can send them notifications
using only one database request.
For that, we must group them by settings
c ( | \ }}|j |j fS r1 rJ rI )reseller_options_groupedr r s r5 _group_by_self_optionszLStatsNotifier._get_resellers_options_grouped.._group_by_self_options* s ": Q!5~7YY Yr6 )r r
ro r r s r5 _get_resellers_options_groupedz,StatsNotifier._get_resellers_options_grouped s< " A A C C Z Z Z
)+ABBBr6 c Z d } fd}t || S )z5Get resellers with enabled NOTIFY_ON_CUSTOMERS_FAULTSTr c f | \ }}|j o$j ||j j S r1 )rH rm r rJ r< )r r r ro s r5 r zgStatsNotifier._get_reseller_customers_faults_options_filtered.._filter_by_enabled_notifications6 s> ,> )[. B 'BB !C!S
r6 r r s ` r5 /_get_reseller_customers_faults_options_filteredz=StatsNotifier._get_reseller_customers_faults_options_filtered1 sI " 9 9T 9 J J 68JKKKr6 c P | }d }t || S )Nc ( | \ }}|j |j fS r1 r )reseller_customers_settingsr r s r5 r z]StatsNotifier._get_resellers_customers_faults_options_grouped.._group_by_self_optionsF s "= Q!5~7YY Yr6 )r r
r s r5 /_get_resellers_customers_faults_options_groupedz=StatsNotifier._get_resellers_customers_faults_options_groupedB s: ! Q Q S S Z Z Z
)+ABBBr6 c : d| j j pt i| _ d S )Nrr )rt rN DEFAULT_SUBJECTr{ rn s r5 ry z+StatsNotifier._prepare_default_mail_headersM s$
t+:Mo
r6 c < | dd | _ d S )Nr\ localhost)getr\ )ro configs r5
set_configzStatsNotifier.set_configS s K==r6 c H || _ t || j | _ d S r1 )r] r. r\ r^ )ro engines r5
set_db_enginezStatsNotifier.set_db_engineV s# *64>BBr6 c X t | S # t j $ r d| dcY S w xY w)Nzhttp:///)r r rk )domains r5 _get_panel_login_urlz"StatsNotifier._get_panel_login_urlZ sJ '%f-- -! ' ' '&V&&& & & & 's ))c \ t j | d d S )N.r )locale normalizesplit)
localenames r5 get_localeszStatsNotifier.get_localesb s(
++11#66q99r6 Nc t j }|t | z
}| | }|sg S t | j ||| j t d||| }| } g }
| D ]~} || d< | d |
D | d |
D |
| |
S )z2
Get statistics for given period;
)secondsr9 )r\ show_columnsorder_byby_fault thresholduidPERIODc B i | ] \ }}|d v |t | dz S )aVMemaPMemlVMemlPMem r( .0keyvals r5
z1StatsNotifier.get_users_fault.. sB S BBB *3//47BBBr6 c ( i | ]\ }}|d v ||dz S ))aIOlIOr r2 r s r5 r z1StatsNotifier.get_users_fault.. s. j j j83TW[iTiTic3$;TiTiTir6 ) r utcnowr _get_faults_keysr- r] r\
FIELDS_ALL proceed_dictupdateitemsappend) ro rx notify_min_faultsnotify_faults_typesuids period_to period_from by_fault_arg history_showusers_fault_data users_stats user_stats r5 get_users_faultz StatsNotifier.get_users_faultg s8
O%% )F";";";; ,,-@AA I' N n#!'
(4466 ) * *I"(Ih
$-OO$5$5
j jy?P?P j j j k k k y ) ) ) )r6 c
t j g d| j | j | j | j | j | j | j g }t | S )z
Get list of keys for 'by_faults';
If reseller_settings is not None, use admin settings;
Else - use reseller's settings;
)CPUfVMemFPMemFEPfNprocFIOfIOPSf) itertoolscompressr> rA rB rC r? r@ list)notify_types_optionsr s r5 r z StatsNotifier._get_faults_keys s^ !) G G G$/$2$2$.$1$.$0
L!!!r6 c # h K |D ]}t |d \ }}| j | |d< t j |d dd d }n!# t j j t f$ r Y yw xY w|d |d< | |d pd |d
< |V d S ) z<
Get information about reseller's accounts;
r8 LOGINmailr Fkeylssearch_sys_usersr TOMAIL enLOCALEN) r" rh r r r cpapiexceptionsrk
IndexErrorr )ro faults_data
reseller_datar r cp_userinfos r5 _get_resellers_dataz!StatsNotifier._get_resellers_data s
) M /
d0C D DNK%)^%<%<[%I%IM' "
#l=+AI[ns t t tuv w )6
C
'2!nM( #&*&6&6{1~7M&N&NM( # s #A!!A?>A?c g }|D ]g}t t |d \ }} t j | }|j |d< |j d d |d< n# t $ r Y ww xY w t j |d d d }n!# t t j j f$ r Y w xY w|d |d< |d |d
< |
|d pd |d
< |d |d< |d |d< | j |d< | |d |d< | |d |d< | | i|S )z<
Get information about end user's accounts;
r8 r ,r TONAME)r dnsr r4 r r r DOMAIN r r RESELLERHOSTNAME LOGIN_URLFROMMAIL)r" intpwdgetpwuidpw_namepw_gecosr KeyErrorr r r r rk r rc r _get_notify_from_mailr )ro fault_users_data
users_data user_datauser_idr
user_pwd_datar s r5 get_users_dataz StatsNotifier.get_users_data s
) ) )I+C $,@,@AAJGQ
# W 5 5
%2%: '"&3&<&B&B3&G&G&J (##
#l9W+=Ej k k klm n 5 BC
#.a.Ih "-a.Ih "&"2"2;q>3IT"J"JIh $/NIj ! %0NIj !$(MIj !%)%>%>{1~%N%NIk "$($>$>y?T$U$UIj ! i ( ( ( (s$ AA00
A=<A="B$$CCc | j j }|| j v ra t j |dd d d }n<# t
t j j f$ r | j d| Y nw xY w|S )z
If reseller is admin -> send email from admin's mail
If reseller is reseller -> send email from reseller's mail
)r Fr r z/can't obtain notify_from_mail for %s from cpapi)
rt rL rj r r r r rk ra exception)ro r4 from_mails r5 r z#StatsNotifier._get_notify_from_mail s (: t~ % %
` !LUZ [ [ [\] ^_` a 5 BC
`
`
`""#TV^_____
`s #; 6A43A4c | j j pt j }n# t j $ r d}Y nw xY w|s"t
}| j d| |S )z
Determine server admin email;
Priority:
1. report_admin_email from config
2. cpapi.get_admin_email()
3. DEFAULT_ADMIN_MAIL
NzQCan't obtain admin email from control panel. System admin email will be used '%s')rt rM r r rk DEFAULT_ADMIN_MAILra warning)ro emails r5 _detect_admin_emailz!StatsNotifier._detect_admin_email s} (;Vu?T?V?VEE! EEE &E H c
s " 66 locale_nametempl_filenamereturnc ` t j | j | }t j || }t j | r||fS t j | j | }|t j || fS )a
Detects path for specified file. Checks directories in order:
1. self.TEMPLATE_CUSTOM_DIR = '/etc/cl.emails.d/'
2. self.TEMPLATE_DIR = '/usr/share/lve/emails/'
:param locale_name: locale name to check
:param templ_filename: template filename (without path)
:return: Tuple: (file_dir, full_path_to_file)
)ospathjoinTEMPLATE_CUSTOM_DIRexists TEMPLATE_DIR)ro r+ r,
templates_dir
full_filenames r5 _detect_path_for_filez#StatsNotifier._detect_path_for_file s T%={KK
]NCC
7>>- ( ( 0 -/ / T%6 DD
bgll=. I IIIr6
templ_datatext_templ_namehtml_templ_namec
| dt }| || \ }}t j | r t j | s:t
j d||t | t | \ }}|rWt j || }t j | st
j d| d }nd }|}| | } | d |d |d< n# t $ r Y nw xY w t j |d \ }
} | d | } n# t $ r | } Y nw xY w|
d| |d< n# t $ r Y nw xY wd }
t j || \ }}|r&|}t j || \ }}
nr# t j j j t& f$ rO}t) d | d
d t j || d | |d }~ww xY w| d
| }|||
fS )Nr a" Unable to find templates for locale '%s': file '%s' does not exist. Statsnotifier will use default templates with locale %s. See https://docs.cloudlinux.com/cloudlinux_os_components/#customize-lve-stats2-notifications in order to find how to create localized template and hide this warning.a Unable to find optional HTML message template '%s'. Sending email with only TEXT part.You can safely ignore this message if you do not want to use HTML email templates.See https://docs.cloudlinux.com/cloudlinux_os_components/#customize-lve-stats2-notificationsr user_typer )r8 z#Can not generate message for user "r z
"; template "z ". Jinja2: NOTIFY_FROM_SUBJECT)r DEFAULT_LOCALEr7 r/ r0 r3 r_ rz r1 _load_locales_datar r! seconds_to_human_viewr ClEmailgenerate_mail_jinja2jinja2
exceptions
TemplateErrorIOErrorrS )ro r8 r9 r: r+ r5 text_templ_pathhtml_templ_path _templ_namelocale_definesnumber english_namelocalized_period_name html_bodysubject text_bodyr e s_subjects r5 generate_msg_bodyz StatsNotifier.generate_msg_body s nnX~>> )-)C)CKQ`)a)a&
w~~m,,
iBGNN?4S4S
i L\
.2-G-GXg-h-h *M?
# gll=/ J JO7>>/22
' s
$
#' "O% 00 ?? #1(#;J{(>z?\k(l(l%I @!(()=)RTghhoo$9 I "(()=)RTghhoo$9 I
..C JJx 7D4H4]^^ _ _ _ JJx 643G3\]] ^ ^ ^ ^!(()=)RTghhoo$9 I &i00C NN>+o4CWCl+o+o+o p p p NN6 ? ? ? G4+z*StatsNotifier.send_msg.. s <<z+StatsNotifier._has_fault.. s- <. s 999ifa6999r6 r )NNc g } D ]Y}g }D ]=\ }}t | |d }| | >| | Z| S )Nz---)rn r r )table_bdata
table_liner
user_data_keycell
table_columnsr s r5 gen_table_bodyz:StatsNotifier._generate_table_data..gen_table_body s| G"
+
+
(5 , ,$A} txx
u = =>>D %%d++++z****Nr6 =T)formatborderhrulesvrules)r r r> rw rA rB rC r? extendsumr^ r@ lenr horizontal_char
junction_charr mapadd_row
get_stringget_html_stringr )
ro r r additional_columnscolumnsr tables_table s_html_tabler s
` @r5 _generate_table_dataz"StatsNotifier._generate_table_data s- \[[
& /)+AB,.FG,.FG$&:;*,FG*,@A
%/WDOOFJ4W4W$2[twPZ7[7[$2[twPZ7[7[$.U4??5*3U3U$1[doohPZ6[6[$.U4??5*3U3U
$ S!3R 8 8999 a #/
ZDOOGZ4X4X
Z $$&=?W%XYYY99=999 z??a : G$$ # ! S 0 0
1
1222""$$ ,,DcZ],^^ $$r6 c t |d | D }| d | D |S )z
Extend keys in new mode register ('aCPU' => 'acpu'),
correct 'aVMem', 'aPMem', 'lVMem', 'lPMem'
for backward compatibility with old templates
c > i | ]\ }}| |S r2 )lower)r kvs r5 r z8StatsNotifier._prepare_template_data.. s& 1]1]1]41a!''))Q1]1]1]r6 c ( i | ]\ }}|d v ||dz S r r2 )r r vars r5 r z8StatsNotifier._prepare_template_data.. s- t t tcOsHsHsS#*HsHsHsr6 )r% r r )ro r templ_data_dicts r5 _prepare_template_dataz$StatsNotifier._prepare_template_data sk &i1]1]9??K\K\1]1]1]^^ t t_-B-B-D-D t t t
r6 c |D ]h}d|d< | d st j d 1| | }| |t
t idS )z
Send email to each user in 'users_data',
with given template path in 'templ_name'
:type users_data: collections.Iterable[dict]
:return: Nothing
customerr< r z,User %s has not set email, skip notificationr8 r9 r: N)r r_ r r ro
USER_TEMPLUSER_TEMPL_HTML)ro r r8 user_template_datas r5
_notify_userszStatsNotifier._notify_users s % J&0J{ # >>(++
LMMM!%! | j j rt | j j sd S | j | j j j sd S | j | j j j }| || j j j
| j j t | j
d }| | }|sd S | || j j \ }}|s | j d d S ||| j j | t) | |dd| j d }| |t0 t2 d S )
Nr rx r r r r z6During admin check, no users faults found. Skipping...
Administratoradmin) STATS
STATS_HTMLr r r r r r< r r T)rt rE ru rI rm admin_need_notificationrJ r< mark_admin_notifiedr r; r rg lve_id_listr" r ra r rL r r r* rc ro ADMIN_TEMPLADMIN_TEMPL_HTML)ro rx r r s_text_tabler admin_template_datas r5 _check_adminzStatsNotifier._check_admin s $1 c$:N:b6c6c F"::4;O;c;stt F //111%9I // " 2 F X $ 4 Hdn003344 0
((:J(KK
F%)%>%>z4K_Ks%t%t" l HNNS T T T F "& ,>&&'7'9'9::..00 %
*KYi
tr6 c t j |dd d }n)# t t t j j f$ r i cY S w xY w|d | |d pd |dS )Nr Fr r r r )r r RESELLER_USERNAME)r r rG r r rk r )ro reseller_loginpanel_user_datas r5 get_panel_reseller_dataz%StatsNotifier.get_panel_reseller_data
s #l>ASfk l l lmn oOO ! .
III &a(&&q'9'ATBB!/
s #AAc r
i }|D ]}| d }|r || j vr#||vrO| | }| d sRt |d g|d d| ||< v|| d |d g }| D ]|\ }
|
d< | | p| j }|
fd|D |j \ }} |sS|
d< |
d < | j
d
< |
}|S ) Nr r r r )USERSr r c 4 g | ]}|d d v |S )r r r2 )r ur s r5 rh z8StatsNotifier.prepare_resellers_data..1 s+ FFFq!G*W
*E*E*E*E*Er6 r r r ) r rj r r% r r r rv r rI rc ) ro r resellers_datar r r resultr r r r s @r5 prepare_resellers_dataz$StatsNotifier.prepare_resellers_data s # S SI &]]: 6 6N!
^4>%I%I ^33 $ < <^ L L
$((22 1< ( 1 2i>QRR!2 2~..
~.w7>>y?QRRRR$2$8$8$:$: ND *DM $ : :> J J mdNm )-)B)BFFFFJFFFHYHm* * &L,
(DM!-D #}D MM$
r6 c # K |D ]_}| d }|s| | }| d sEt d| j i|| V `dS )z
With enabled second-level of resellers's limits
we have information about reseller's faults;
Here we prepare information about such resellers;
:type resellers_data: collections.Iterable[dict]
:return: dict
r r r N)r r r% rc )ro r r r
panel_datas r5 _prepare_resellers_summary_dataz-StatsNotifier._prepare_resellers_summary_data; s ,
V
VM * . .w 7 7N!
55nEEJ >>(++
z4= 9=*UU U U U U
V
Vr6 r5 c N t j || j } t |d 5 }t j | cddd S # 1 swxY w Y n@# t $ r3}| j d|t | Y d}~nd}~ww xY wi S )z
Load locales data from specified directory (file /usr/share/lve/emails//locale_defines.json)
:param templates_dir: Directory name to search json file
:return: Dictionary loaded from JSON file
r\ )encodingNz/Can't read/parse email localization file %s: %s) r/ r0 r1 LOCALE_DEFINES_FILEopenjsonload Exceptionra r( rn )ro r5 locale_defines_file json_filerR s r5 r@ z StatsNotifier._load_locales_dataO s !gll=$:R S S m)G<<<
, y++
,
,
,
,
,
,
,
,
,
,
,
,
,
,
,
,
, m m m H NPcehijekek l l l l l l l l m s: A% A A% A A% A !A% %
B"/)B B"c # P K | D ] }| | p|||< |V !d S r1 )r ) data_listr r r s r5 add_default_dataz StatsNotifier.add_default_data_ sB D
,DIJJJJ r6 c ^ t }|d }|d }|d }|d } t j |d }t j |d }nT# t t f$ r@}| j }| j }| j dt | Y d}~nd}~ww xY w|d } t |d
|d |d |d
t |d |d |d |d |d |d t |d | t |d | | d pt | d pd| d pd| d pd }
|
S ) z
Read admin settings config (using shared code in
lve-utils) and map it into our namedtuple structure
:rtype: AdminSettings
faultsNotificationfaultsToInclude minimumNumberOfFaultsToNotifynotifyr rr z:Can't set interval to admin. Period value is incorrect: %sNr) notifyAdminnotifyCustomersnotifyResellersnotifyResellerCustomerscpuioiopsmemconcurrentConnectionsnprocr> r? r@ rA rB rC r; r< notifyFromEmailreportAdminMail
notifySubject
notifyCharsetzus-ascii) rE rF rH rG rI rJ rK rL rM rN rO )get_admin_notificationr! time_dict_to_seconds
ValueError TypeErrorDEFAULT_PERIODra r( rn rD r= r: r r' ) ro raw_datanotification_datafaults_to_include
min_to_notifyperiodsr| notify_interval_userrR email_settingssettingss r5 rs z StatsNotifier.get_admin_settingse s *++ $%9 : -.? @)*IJ
#H- c$,$A''BR$S$S !#+#@ #Q#Q I& c c c#'#6 $($7 ! H Y[^_`[a[a b b b b b b b b c +73 *=9'89J'K0ABS0T&78Q&R 3,U3+D1 -f 5 / 6+,CD .w 7
! ! ! !/"/"8J_! ! ! %3"/"7I]% % % - 0 01B C C YGY - 1 12C D D J)--o>>D"!/!3!3O!D!D!R
-
0 s 4A% %B666B11B6c t | j j | j j | j j | j j | j j | j j S )NrH rF rQ rI rJ rK )rP rt rH rG rI rJ rK rn s r5 ru z+StatsNotifier.get_default_reseller_settings sO 040D0h'+';'U,0,@,d $ 4 H $ 4 H$($8$P
r6 Tc |r|| j v r
| j | S t | }|rd|vr|r
d | j |< d S |d }|d }|d }|d } t j |d }t j |d } nU# t t
f$ rA}
| j } | j }| j d|t |
Y d }
~
nd }
~
ww xY wt |d |d |d
t |d |d |d
|d |d |d t |d | t |d | } |r
| | j |< | S )Nr r r r r4 r z@Can't set interval to reseller %s. Period value is incorrect: %snotifyResellerOnCustomersr notifyResellerr r r r r r r r r )
re r r! r r r r ra r( rn rP r= r: ) ro r4 use_cacher r r r r notify_interval_resellernotify_interval_customerrR ress r5 r z#StatsNotifier.get_reseller_settings s ;T%BBB0: :#H-- /x??
?:>-h7 F $%9 : -.? @)*IJ
#H- s'/'DWZEX'Y'Y $'/'DWZEX'Y'Y $ $I& s s s'+': $'+': $ H _aiknopkqkq r r r r r r r r s 0AB]0^'89J'K,=>N,O 3,U3+D1 -f 5 / 6+,CD .w 7
! ! ! !/"/
";Me! ! ! %3"/
";Me% % %#
* :69D )( 3
s 4B C$#7C C$c | | }|sdS | |dd }|D ]?}d|d< | d s | |t t
@dS )z
Decide and send mails to resellers as resellers (doesn't include
notification to reseller about it's personal account as a customer)
:return: Nothing
Nr Resellerr4 r< r r )r r r ro RESELLER_TEMPLRESELLER_TEMPL_HTML)ro users_data_resellerr
reseller_infos r5 _process_resellers_mailsz&StatsNotifier._process_resellers_mails s 445HII F ..~xTT + M)3M+ & $$X..
" "(.Zm
#
r6 c | | }| |dd }|D ] }d|d< | | dS )z
When second level of reseller limits is enabled
we collect summary info about reseller;
When total load makes fault, we notify reseller about it;
r r r4 r< N)r r _notify_reseller_summary_faults)ro r resellers_faults_datar
s r5 %_process_resellers_summary_info_mailsz3StatsNotifier._process_resellers_summary_info_mails sp !% D D^ T T $ 5 56KXWa b b 2 @ @M)3M+ & 0 0 ? ? ? ? @ @r6 c t | | }| |t t dS )z0Prepare data for reseller_faults_notify templater N)r ro RESELLER_FAULTS_TEMPLRESELLER_FAULTS_TEMPL_HTML)ro r
s r5 r
z-StatsNotifier._notify_reseller_summary_faults sG 33MBB
$6K]w
r6 c V |dd D ]s}|d }t |d }| j j o|}|| j v r%| | p| j }|j o|}|s| | st| | |dd dS )z
Decide and send mails to customers(including resellers personal account
notification as a customer)
:return: Nothing
Nr r r Customer) r' rt rF rj r rv remover r )ro r user_info
account_owneruser_notification_enabled do_notifyr s r5 _process_users_mailsz"StatsNotifier._process_users_mails s $AAA
I %j 1M(? '@R(S(S % ,GeLeI ..$($>$>}$M$M$pQUQp! - H fMf
!!),,,
400XzRRSSSSSr6 c # K D ]c\ \ }}}d |D } j | t fd|D g } ||| V ddS )z
Find all customers that might cause faults
from /proc/lve/list, get additional data from
control panel and return it
c g | ]\ }}|S r2 r2 r r r s r5 rh z=StatsNotifier._iter_customers_faults_data.. !N!N!N.+q+!N!N!Nr6 c 3 f K | ]+}t j | V ,d S r1 )r rg r )r r ro s r5 rt z. s; ee;dn00==>>eeeeeer6 N)r rm mark_users_notifiedr )_StatsNotifier__get_customers_faults_data)ro notify_settingsr rj notified_resellersusers_to_checks ` r5 _iter_customers_faults_dataz)StatsNotifier._iter_customers_faults_data
s BFAdAdAfAf
i
i = 2_ 1I!N!NI!N!N!N 3 34F G G G !eeeeRdeeegi N 22>CVXghh h h h h
i
ir6 c x | |j |j || }| | }|S )Nr r )r r< r; r" )ro r$ r r" r r s r5 __get_customers_faults_dataz)StatsNotifier.__get_customers_faults_data! sP //"2 - ? 3 0
((:J(KK
r6 c ^ | D ]}| | d S r1 )r% r )ro r s r5 _check_userszStatsNotifier._check_users0 s> ::<< 2 2J % %j 1 1 1 1 2 2r6 c # K | D ]_\ \ }}}d |D }d |D }| |j |j || }| | }||fV `dS )z
Find all resellers that might cause faults
from /proc/lve/resellers, get additional data from
control panel and return it
c g | ]\ }}|S r2 r2 r s r5 rh z=StatsNotifier._iter_resellers_faults_data..= s J J Jnk1k J J Jr6 c 8 g | ]}t t | S r2 )r& r )r r s r5 rh z=StatsNotifier._iter_resellers_faults_data..? s$ !p!p!pR]"2<"M"M!p!p!pr6 r )r N)r r r< r; r )ro r" r rj resellers_uidsresellers_to_checkr r s r5 _iter_resellers_faults_dataz)StatsNotifier._iter_resellers_faults_data4 s BFAdAdAfAf 1 1 = 2_ 1I J J J J JN!p!pao!p!p!p ..&6"1"C$7' / K " 5 5+ 5 N NN .0 0 0 0 0 1 1r6 c # K | D ]e\ \ }}}d |D }g }|D ]/}| | j | 0| ||| }||fV fd S )Nc g | ]\ }}|S r2 r2 r s r5 rh zGStatsNotifier._iter_reseller_users_list_faults_data..Q r r6 )r r rg r r! )ro r" r rj r# r$ r customers_faultss r5 %_iter_reseller_users_list_faults_dataz3StatsNotifier._iter_reseller_users_list_faults_dataM s AEAuAuAwAw
7
7 = 2_ 1I!N!NI!N!N!N N 1
O
O %%dn&@&@&M&MNNNN # ? ?Pcet u u "$66 6 6 6 6
7
7r6 c f t }| D ]/\ }}| | | | 0| D ]/\ }}| | | | 0| j | d S r1 )ri r/ r r r3 r rm mark_resellers_notified)ro r# r reseller_idsr s r5 _check_resellersz StatsNotifier._check_resellers[ s UU,0,L,L,N,N 4 4 (NL
6 6~ F F F % %l 3 3 3 3(,(R(R(T(T 4 4 $J
) )* 5 5 5 % %l 3 3 3 3 334FGGGGGr6 c i | _ | j d | | | | j d S )NF)r )re rh
link_xml_noder) r7 r rm save_to_persistent_storage)ro lve_datas r5 executezStatsNotifier.executel sv )+% $$u$555 6688888r6 )Fr1 )T)@rT rU rV r rw r4 r2 r r rp rb r r r r r r r ry r r staticmethodr r r r r r" r r* rn r r7 dictrT r rd rl ro rw r r r r r r r r r@ r rs ru r r r r
r r% r! r) r/ r3 r7 r< r2 r6 r5 rX rX s5 !N J+L-L/4 4 4*(t (t (tT: : : :8L L L,\ \ \ L L L$C C C"L L L" C C C
> > >C C C ' ' \' : : \:* * * *X " " \"* &! ! !F *J Jc JeTWY\T\o J J J J$F/ F/D F/3 F/Y\ F/ F/ F/ F/P t c TW cp @x x x% %D %3 %Y\ % % % %= = =0% 0% 0%d $( ( (T
DV V V( \
- - -^
- - - -^ & @ @ @
T T T.i i i(
2 2 21 1 12 7 7 7 H H H"
9
9
9
9
9r6 rX c d}t | d }|r|d d }t }|t vr*| | p| }n| }|j S )z!
Gets parameter for user
rootr3 r r )r rX r r ru rs rF )rr default_resellerr4
stat_notifierr s r5 get_stats_notifier_parametersrC | s d-000H *#A;q>!OOMvxx'' / /0@ A A r]EpEpErEr !3355 ..r6 )cr r r r_ r/ r r r r) r email.headerr email.mime.multipartr email.mime.textr functoolsr r
typingr r r
r r r r prettytabler r clcommonr r r clcommon.clprocr clcommon.cpapir r r r clcommon.cpapi.plugins.universalr system_admin_emailclcommon.mail_helperr clconfig.lve_stats2_libr r lveapir lvestats.core.pluginr lvestats.lib.commonsr! lvestats.lib.commons.funcr" r# r$ r% r& r' lvestats.lib.commons.sizeutilr) lvestats.lib.lveinfolibr* r+ r, r- r. !lvestats.lib.notifications_helperr/ clconfig.lve_stats2_reseller_lib ImportErrorr? r r r r r r r r r' r r r r: boolr= rn rD rP rD rE rF rS rX rC r2 r6 r5 r[ s
( ( ( ( ( ( ( ( % % % % % % . . . . . . $ $ $ $ $ $ N N N N N N N N N N N N N N N N N N ( ( ( ( ( ( ( ( + + + + + + + + + + ( ( ( ( ( ( O O O O O O O O O O O O R R R R R R + + + + + + N N N N N N / / / / / / ) ) ) ) ) ) < ; ; ; ; ; n n n n n n n n n n n n n n A A A A A AAAAAAAA &
$4 : &, '')) 6Vk
!VH
,}
<{
J
c" C !j t d $ d
$ ( %x~6 $htn5 .? 34 / "N3 hsm, x}- 3 # /
" : .5 %t, *D1 34 / "N3
!:!H t9 t9 t9 t9 t9N t9 t9 t9n / / / / /s
C C C