📁 File Manager Pro
v10.0.2 | PHP: 8.1.34
Server: LiteSpeed
2026-06-28 19:41:28
📂
/
/
opt
/
imunify360
/
venv
/
lib
/
python3.11
/
site-packages
/
defence360agent
/
plugins
/
__pycache__
✏️
Editing: event_monitor.cpython-311.opt-1.pyc
� �j� � �� � 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)�Dict�List�Optional)�Core)� MessageType)� MessageSource)�%NativeFeatureManagementSettingsChange)�EventProcessorBase�UserConfigProcessor)�recurring_check�safe_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_task��selfs �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 �loop�sinks r � create_sourcezEventMonitor.create_source s� � � � ��� ��� � �� � � E�d� K� K�L�L�L� �� � � 3�D� 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� 4�5�5�5�5�5�5�5�5�5�5�5r �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)�unlink�FileNotFoundError� Exception�logger�warning)r' �es r �_rmfilezEventMonitor._rmfile, s~ � � B� �K�K�M�M�M�M�M�� � � � � �D�D�� B� B� B� �N�N�7��q� A� A� A� A� A� A� A� A� A����� B���s � � A� A� A�A�returnc �N � t j | � � � � � S r )�json�loads� 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)�username�hook�ts�fieldszhook file disappeared %sz hook file have broken json %s) �name�split�float� ValueErrorr, r- r � cPanelEvent�from_hook_eventr5 r* r2 �JSONDecodeError)r r' r8 r9 �ts1�ts2�_r: s r �_event_to_messagez EventMonitor._event_to_message9 s$ � � �+/�9�?�?�3�+?�+?� (�H�d�C��q��s�S�y�3��'�'�B�B��� � � � �N�N�H�$� O� O� O��4�4� ���� B� �*�:�:�!������t�,�,� ;� � � �� !� =� =� =� �N�N�5�t� <� <� <� <� <��#� B� B� B� �N�N�:�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_DIR�globrF r � is_enabled� add_messager+ r, �errorr/ �process_messages)r r' �message� processor�excs r r! z0EventMonitor._check_inbox_folder_generate_eventsO sR � � � ��� �(�(�-�-�l�;�;� #� #�D� #� �0�0��6�6���&�%)�%5� ;� ;� �!*�!5�!5�!7�!7�7�7�7�7�7�7� ;� %� 1� 1�'� :� :� :���� � E� E� E�� � � >��D�D�D�D�D�D�D�D����� E���� � � �T�"�"�"�"��� � �T�"�"�"�"���� �)� /� /�I��,�,�.�.� .� .� .� .� .� .� .� .� /� /s0 �AA>�=C�> B-�B(�#C�(B-�-C�C 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� �B�d� 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 �<module>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
💾 Save Changes
❌ Cancel