X7ROOT File Manager
Current Path:
/opt/imunify360/venv/lib/python3.11/site-packages/defence360agent/plugins
opt
/
imunify360
/
venv
/
lib
/
python3.11
/
site-packages
/
defence360agent
/
plugins
/
??
..
??
__init__.py
(0 B)
??
__pycache__
??
accumulate.py
(3.63 KB)
??
analyst_cleanup_update.py
(5.53 KB)
??
backup_info_sender.py
(3.06 KB)
??
cagefs.py
(5.17 KB)
??
checkpoint.py
(1.23 KB)
??
client.py
(10.6 KB)
??
config_merger.py
(828 B)
??
config_watcher.py
(1.89 KB)
??
event_hook_executor.py
(777 B)
??
event_monitor.py
(3.32 KB)
??
event_monitor_message_processor.py
(6.33 KB)
??
files_recurring_update.py
(1.09 KB)
??
icontact_sender.py
(4.42 KB)
??
idle_time_out.py
(1.21 KB)
??
lve_utils_install.py
(1.58 KB)
??
myimunify.py
(1.98 KB)
??
ping.py
(536 B)
??
send_domain_list.py
(2.78 KB)
??
send_server_config.py
(10.96 KB)
Editing: config_merger.py
import logging from defence360agent.contracts.config import ConfigValidationError, Merger from defence360agent.contracts.messages import MessageType from defence360agent.contracts.plugins import MessageSink, expect logger = logging.getLogger(__name__) class ConfigMerger(MessageSink): PROCESSING_ORDER = MessageSink.ProcessingOrder.PRE_PROCESS_MESSAGE def __init__(self): self.loop = None async def create_sink(self, loop): self.loop = loop @expect(MessageType.ConfigUpdate) async def update_merged_config(self, message): try: Merger.update_merged_config() except ConfigValidationError as err: logger.error("Config is invalid. Will not update: %s", err) finally: if event := message.get("event"): event.set()
Upload File
Create Folder