zv
d dl Z d dlZd dlmZ d dlmZ d dlmZ d dlm Z d dl
m Z d dl m
Z
mZ d dlmZmZ d d lmZmZmZ ee Z e ed
Zd Z G d
de Z dS ) N) timedelta) getLogger)Union) MessageType)
MessageSource)get_current_backendget_last_backup_timestamp)
load_state
save_state)Scoperecurring_checksafe_cancel_task )hours c e Zd ZdZej Zd Zd Ze de
e e f de
fd Zdde
e e f fd Zd
Z ee d Z ed d
Zd ZdS )BackupInfoSenderz.Send user backup statistics to CH periodicallyc L K || _ || _ t j | _ | | _ | j | | _ | j |
| _ d S N) _loop_sinkasyncioEvent _send_eventload_last_send_timestamp_last_send_timestamp create_task _recurring_check_data_to_send _check_task_recurring_send_stat_send_stat_task)selfloopsinks _/opt/imunify360/venv/lib/python3.11/site-packages/defence360agent/plugins/backup_info_sender.py
create_sourcez BackupInfoSender.create_source s
"=??$($A$A$C$C! :11 . . 0 0
$z 5 5 % % ' '
c ~ K | j | j fD ]}t | d {V | d S r )r r! r save_last_send_timestamp)r" tasks r% shutdownzBackupInfoSender.shutdown' s[ %t';< ) )D"4(( ( ( ( ( ( ( ( ( %%'''''r' timestampreturnc F t | t t f o| dk S )Nr )
isinstanceintfloat)r, s r% is_valid_timestampz#BackupInfoSender.is_valid_timestamp, s )c5\22Dy1}Dr' Ntsc || j n|}| | s t d| d S t dd|i d S )NzInvalid timestamp: %sr last_send_timestamp)r r2 loggerwarningr )r" r3 r, s r% r) z)BackupInfoSender.save_last_send_timestamp0 s` 13D-- &&y11 NN2I > > > F%(=y'IJJJJJr' c t d d }| | s t d d}|S )Nr r5 z(Invalid timestamp loaded, resetting to 0r )r
getr2 r6 r7 )r" r, s r% r z)BackupInfoSender.load_last_send_timestamp7 sS 122667LMM &&y11 NNE F F FIr' c K t j | j z
t k r| j d S d S r )timer
SEND_INTERVALr set)r" s r% r z.BackupInfoSender._recurring_check_data_to_send> sC 9;;2 2m C C " " " " " D Cr' r c K | j d {V | d {V n2# t $ r%}t d| Y d }~nd }~ww xY wt
j | _ | j d S # t
j | _ | j w xY w)Nz!Failed to collect backup info: %s) r wait_send_server_config Exceptionr6 exceptionr; r clear)r" es r% r z%BackupInfoSender._recurring_send_statC s ##%%%%%%%%% %**,, , , , , , , , , E E E @! D D D D D D D D E )- D % " " $ $ $ $ $ )- D % " " $ $ $ $s, > B#
A-A(#B# (A--B# #3Cc K t j t t d {V }| j | d {V d S )N)backup_provider_typelast_backup_timestamp)r
BackupInfor r r process_message)r" confg_msgs r% r@ z$BackupInfoSender._send_server_configO sq *!4!6!6(A(C(C"C"C"C"C"C"C
j((33333333333r' r )__name__
__module__ __qualname____doc__r IM360SCOPEr& r+ staticmethodr r0 r1 boolr2 r) r r
RECURRING_CHECK_INTERVALr r r@ r' r% r r s 88 KE
( ( (
EeCJ&7 ED E E E \EK K5e+< K K K K _-..# # /.# _Q % % %4 4 4 4 4r' r ) r r; datetimer loggingr typingr "defence360agent.contracts.messagesr !defence360agent.contracts.pluginsr %defence360agent.subsys.backup_systemsr r 'defence360agent.subsys.persistent_stater
r defence360agent.utilsr r
r rK r6 r0
total_secondsr< rS r rT r' r% r^ sC : : : : : : ; ; ; ; ; ; K J J J J J J J J J J J J J J J J J 8 IIB'''557788
>4 >4 >4 >4 >4} >4 >4 >4 >4 >4r'