z958 d dl Z d dlmZ d dlmZ d dlmZ d dlmZm Z m
Z
d dl m Z d dl
mZ d dlmZ d d lmZ d d
lmZmZ d d lmZmZ ee Z G d d
ee ZdS ) N)ABC) getLogger)Path)DictListOptional)Core) MessageType)
MessageSource)%NativeFeatureManagementSettingsChange)EventProcessorBaseUserConfigProcessor)recurring_checksafe_cancel_taskc e Zd Zej ZdZd Zd Zd Z e
de fd Z e
de de
fd Zdeej fd Z ed
d Zd S )
EventMonitorz *.*.*.*.jsonc > d | _ d | _ g | _ d | _ d S N)_loop_sink _processors_processing_taskselfs Z/opt/imunify360/venv/lib/python3.11/site-packages/defence360agent/plugins/event_monitor.py__init__zEventMonitor.__init__ s&
57 $ c $ K || _ || _ | j t | | j t | | j | | _ d S r ) r r r appendr r create_task#_check_inbox_folder_generate_eventsr )r loopsinks r
create_sourcezEventMonitor.create_source s
Ed K KLLL 3D 9 9::: $
6 6 4 4 6 6!
!
r c > K t | j d {V d S r )r r r s r shutdownzEventMonitor.shutdown) s/ t 455555555555r filec | d S # t $ r Y d S t $ r'}t d| | Y d }~d S d }~ww xY w)NzCouldn't remove file %s %s)unlinkFileNotFoundError Exceptionloggerwarning)r' es r _rmfilezEventMonitor._rmfile, s~ B KKMMMMM DD B B B NN7q A A A A A A A A A Bs
A A AAreturnc N t j | S r )jsonloads read_text)r' s r
_from_jsonzEventMonitor._from_json5 s z$..**+++r c |j d ^}}}}}t |dz |z }n,# t $ r t d| Y d S w xY w t j |||| | S # t $ r t d| Y n/t j $ r t d| Y nw xY wd S )N.z+hook-event-file detected with wrong name %s)usernamehooktsfieldszhook file disappeared %sz hook file have broken json %s)
namesplitfloat
ValueErrorr, r- r
cPanelEventfrom_hook_eventr5 r* r2 JSONDecodeError)r r' r8 r9 ts1ts2_r: s r _event_to_messagez EventMonitor._event_to_message9 s$ +/9??3+?+? (HdCqsSy3''BB NNH$ O O O44 B *::!t,, ;
! = = = NN5t < < < < <# B B B NN:D A A A A A B ts' 47 %A A $5B %C-)C-,C- c K t | j d D ]} | | }|9| j D ]1}| d {V r| | 2n2# t $ r%}t d| Y d }~nd }~ww xY w|
| # |
| w xY w| j D ] }| d {V d S )Nz
*.*.*.jsonz Failed to process %s hook event) r EVENT_DIRglobrF r
is_enabled add_messager+ r, errorr/ process_messages)r r' message processorexcs r r! z0EventMonitor._check_inbox_folder_generate_eventsO sR ((--l;;
#
#D
# 0066&%)%5 ; ; !*!5!5!7!7777777 ; % 1 1' : : :
E
E
E >DDDDDDDD
E T"""" T"""" ) / /I,,.. . . . . . . . . / /s0 AA>=C>
B-B(#C(B--CC N)__name__
__module__ __qualname__r INBOX_HOOKS_DIRrI PATTERNr r$ r& staticmethodr r/ r r5 r r
r@ rF r r! r r r r s $I G% % %
6 6 6 Bd B B B \B , ,$ , , , \,+2I)J , _R
/
/
/
/
/r r ) r2 abcr loggingr pathlibr typingr r r defence360agent.contracts.configr "defence360agent.contracts.messagesr
!defence360agent.contracts.pluginsr 1defence360agent.feature_management.plugins.nativer 7defence360agent.plugins.event_monitor_message_processorr
r defence360agent.utilsr r rR r, r rX r r rc sH ' ' ' ' ' ' ' ' ' ' 1 1 1 1 1 1 : : : : : : ; ; ; ; ; ; D C C C C C C C 8 G/ G/ G/ G/ G/=# G/ G/ G/ G/ G/r