Na}{

File Content: `ping.py`

from defence360agent.contracts.messages import MessageType
from defence360agent.contracts.plugins import (
    MessageSink,
    MessageSource,
    expect,
)


class SendPing(MessageSource, MessageSink):
    async def create_sink(self, loop):
        self._loop = loop

    async def create_source(self, loop, sink):
        self._loop = loop
        self._sink = sink

    @expect(MessageType.ServerConnected, MessageType.ServerReconnected)
    async def send_ping(self, _):
        await self._sink.process_message(MessageType.Ping())

Name	Size	Permission
__pycache__	---	0755
__init__.py	0 bytes	0644
accumulate.py	3615 bytes	0644
analyst_cleanup_update.py	5662 bytes	0644
backup_info_sender.py	3129 bytes	0644
checkpoint.py	1257 bytes	0644
client.py	9934 bytes	0644
config_merger.py	828 bytes	0644
config_watcher.py	1934 bytes	0644
event_hook_executor.py	777 bytes	0644
event_monitor.py	3404 bytes	0644
event_monitor_message_processor.py	6481 bytes	0644
files_recurring_update.py	1121 bytes	0644
icontact_sender.py	4461 bytes	0644
idle_time_out.py	1239 bytes	0644
lve_utils_install.py	1615 bytes	0644
myimunify.py	1977 bytes	0644
ping.py	536 bytes	0644
send_domain_list.py	2856 bytes	0644
send_server_config.py	10619 bytes	0644

File Content: ping.py

File Content: `ping.py`