FM / plugins

/opt/imunify360/venv/versions/imunify-core-8.12.1-2/defence360agent/plugins/

/opt/imunify360/venv/versions/imunify-core-8.12.1-2/defence360agent/plugins

Name	Size	Mode	Actions
__pycache__/	-	0755	rm
accumulate.py	3599	0644	edit dl rm
analyst_cleanup_update.py	5662	0644	edit dl rm
backup_info_sender.py	3052	0644	edit dl rm
cagefs.py	5403	0644	edit dl rm
checkpoint.py	1257	0644	edit dl rm
client.py	19537	0644	edit dl rm
config_merger.py	828	0644	edit dl rm
config_watcher.py	1934	0644	edit dl rm
event_hook_executor.py	777	0644	edit dl rm
event_monitor.py	3306	0644	edit dl rm
event_monitor_message_processor.py	7023	0644	edit dl rm
feature_flags.py	8952	0644	edit dl rm
files_recurring_update.py	1121	0644	edit dl rm
icontact_sender.py	4529	0644	edit dl rm
idle_time_out.py	1239	0644	edit dl rm
lve_utils_install.py	1817	0644	edit dl rm
myimunify.py	2025	0644	edit dl rm
ping.py	536	0644	edit dl rm
send_domain_list.py	3077	0644	edit dl rm
send_server_config.py	11511	0644	edit dl rm
service_manager.py	2175	0644	edit dl rm
wordpress.py	36283	0644	edit dl rm
__init__.py	0	0644	edit dl rm

Edit: /opt/imunify360/venv/versions/imunify-core-8.12.1-2/defence360agent/plugins/config_watcher.py (1934B)

import time
from defence360agent.contracts import config
from defence360agent.contracts.messages import MessageType
from defence360agent.contracts.plugins import (
    MessageSink,
    MessageSource,
    expect,
)
from defence360agent.utils import recurring_check, Scope

POLLING_INTERVAL = config.int_from_envvar("READ_CONFIG_POLLING_INTERVAL", 30)

class ConfigWatcher(MessageSink, MessageSource):
    """Send ConfigUpdate message on [root's] config update.

The config update is detected by polling config file's
    modification time.

"""

SCOPE = Scope.AV

def __init__(self):
        self._config = config.ConfigFile()
        self._last_notify_time = 0
        self._sink = None
        self._task = None

async def create_sink(self, loop):
        "plugins.MessageSink method"

@expect(MessageType.ConfigUpdate)
    async def on_config_update_message(self, message):
        # update the time, to avoid sending duplicate ConfigUpdate
        # messages after the "config update" command
        self._last_notify_time = message["timestamp"]

async def create_source(self, loop, sink):
        self._sink = sink
        self._task = loop.create_task(self._check_config())

async def shutdown(self):
        if self._task is not None:
            t, self._task = self._task, None
            t.cancel()
            await t
        self._sink = None

@recurring_check(POLLING_INTERVAL)
    async def _check_config(self):
        if config.any_layer_modified_since(self._last_notify_time):
            # notify about the update
            message = MessageType.ConfigUpdate(
                conf=self._config, timestamp=time.time()
            )
            await self._sink.process_message(message)
            # update the time here, in case ConfigUpdate might stuck
            # in the queue for longer than the polling interval
            self._last_notify_time = message["timestamp"]

cmd: