[
MAINHACK
]
Mail Test
BC
Config Scan
HOME
Create...
New File
New Folder
Viewing / Editing File: accumulate.py
File is not writable. Editing disabled.
import asyncio import collections import contextlib import os from logging import getLogger from defence360agent.contracts.messages import MessageType from defence360agent.contracts.plugins import ( MessageSink, MessageSource, expect, ) from defence360agent.utils import recurring_check logger = getLogger(__name__) class Accumulate(MessageSink, MessageSource): PROCESSING_ORDER = MessageSink.ProcessingOrder.POST_PROCESS_MESSAGE DEFAULT_AGGREGATE_TIMEOUT = int( os.environ.get("IMUNIFY360_AGGREGATE_MESSAGES_TIMEOUT", 60) ) def __init__(self, period=DEFAULT_AGGREGATE_TIMEOUT, **kwargs): super().__init__(**kwargs) self._period = period async def create_source(self, loop, sink): self._loop = loop self._sink = sink self._task = loop.create_task( recurring_check(self._period)(self._flush)() ) self._data = collections.defaultdict(list) async def create_sink(self, loop): self._loop = loop async def shutdown(self): if self._task is not None: self._task.cancel() with contextlib.suppress(asyncio.CancelledError): await self._task @expect(MessageType.Accumulatable) async def collect(self, message): list_type = message.LIST_CLASS if message.do_accumulate(): self._data[list_type].append(message) async def _flush(self): copy_data = self._data self._data = collections.defaultdict(list) for list_type, messages in copy_data.items(): try: # FIXME: remove this try..except block after we have forbidden # to create Accumulatable class without LIST_CLASS. await self._sink.process_message(list_type(items=messages)) except TypeError: logger.error("%s, %s", list_type, messages) raise
Save Changes
Cancel / Back
Close ×
Server Info
Hostname: server05.hostinghome.co.in
Server IP: 192.168.74.40
PHP Version: 7.4.33
Server Software: Apache
System: Linux server05.hostinghome.co.in 3.10.0-962.3.2.lve1.5.81.el7.x86_64 #1 SMP Wed May 31 10:36:47 UTC 2023 x86_64
HDD Total: 1.95 TB
HDD Free: 691.14 GB
Domains on IP: N/A (Requires external lookup)
System Features
Safe Mode:
Off
disable_functions:
None
allow_url_fopen:
On
allow_url_include:
Off
magic_quotes_gpc:
Off
register_globals:
Off
open_basedir:
None
cURL:
Enabled
ZipArchive:
Disabled
MySQLi:
Enabled
PDO:
Enabled
wget:
Yes
curl (cmd):
Yes
perl:
Yes
python:
Yes
gcc:
Yes
pkexec:
No
git:
Yes
User Info
Username: itsweb
User ID (UID): 1619
Group ID (GID): 1621
Script Owner UID: 1619
Current Dir Owner: N/A