Admin

name	type	size	perms	modified	actions
[parent directory]
__pycache__/	dir	-	0755	2026-09-01 07:52:26
__init__.py	file	0 B	0644	2026-09-01 07:52:26	edit
accumulate.py	file	3,599 B	0644	2026-09-01 07:52:26	edit
analyst_cleanup_update.py	file	5,662 B	0644	2026-09-01 07:52:26	edit
backup_info_sender.py	file	3,052 B	0644	2026-09-01 07:52:26	edit
cagefs.py	file	5,403 B	0644	2026-09-01 07:52:26	edit
checkpoint.py	file	1,257 B	0644	2026-09-01 07:52:26	edit
client.py	file	19,537 B	0644	2026-09-01 07:52:26	edit
config_merger.py	file	828 B	0644	2026-09-01 07:52:26	edit
config_watcher.py	file	1,934 B	0644	2026-09-01 07:52:26	edit
event_hook_executor.py	file	777 B	0644	2026-09-01 07:52:26	edit
event_monitor.py	file	3,306 B	0644	2026-09-01 07:52:27	edit
event_monitor_message_processor.py	file	7,023 B	0644	2026-09-01 07:52:27	edit
feature_flags.py	file	8,952 B	0644	2026-09-01 07:52:27	edit
files_recurring_update.py	file	1,121 B	0644	2026-09-01 07:52:27	edit
icontact_sender.py	file	4,529 B	0644	2026-09-01 07:52:27	edit
idle_time_out.py	file	1,239 B	0644	2026-09-01 07:52:27	edit
lve_utils_install.py	file	1,817 B	0644	2026-09-01 07:52:27	edit
myimunify.py	file	2,025 B	0644	2026-09-01 07:52:27	edit
ping.py	file	536 B	0644	2026-09-01 07:52:27	edit
send_domain_list.py	file	3,077 B	0644	2026-09-01 07:52:27	edit
send_server_config.py	file	11,511 B	0644	2026-09-01 07:52:27	edit
service_manager.py	file	2,175 B	0644	2026-09-01 07:52:27	edit
wordpress.py	file	36,283 B	0644	2026-09-01 07:52:27	edit

editing: idle_time_out.py

from logging import getLogger

from defence360agent.api import inactivity
from defence360agent.contracts.config import SimpleRpc
from defence360agent.contracts.plugins import MessageSink
from defence360agent.utils import clip, fail_agent_service, recurring_check

logger = getLogger(__name__)

class IdleTimeOutCheck(MessageSink):
    async def create_sink(self, loop):
        self._loop = loop
        if SimpleRpc.SOCKET_ACTIVATION:
            inactivity.track.reset_timer()
            self._task = loop.create_task(
                recurring_check(
                    period=clip(
                        SimpleRpc.INACTIVITY_TIMEOUT // 5, low=1, high=60
                    ),
                )(
                    self._check_timeout,
                )()
            )
        else:
            self._task = None

async def shutdown(self):
        if self._task:
            self._task.cancel()
            # CancelledError is handled by @recurring_check():
            await self._task

async def _check_timeout(self):
        logger.info("Periodical check %s ", inactivity.track)
        if inactivity.track.is_timeout():
            logger.warning("Shutting down due to inactivity.")
            fail_agent_service()

cancel