REDROOM

Navigation

Breadcrumbs

Create

Edit File Size: 1.37 KB

/proc/thread-self/root/opt/imunify360/venv/lib64/python3.11/site-packages/defence360agent/model/messages_to_send.py

Text Base64

from collections import namedtuple

from peewee import FloatField, BlobField

from defence360agent.model import instance, Model

class MessageToSend(Model):
    """
    Storage for messages to be sent to server
    while connection to server is not available
    """

class Meta:
        database = instance.db
        db_table = "messages_to_send_nr"

#: When the message was added to the queue to be sent to the server.
    timestamp = FloatField(null=False)
    #: The message itself.
    message = BlobField(null=False)
    MessageToSendT = namedtuple("MessageToSendT", "timestamp message")

@classmethod
    def get_oldest(cls, limit=1):
        old = cls.select().order_by(cls.timestamp).limit(limit)
        return old

@classmethod
    def delete_in(cls, query):
        q = cls.delete().where(cls.id.in_(query))
        return q.execute()

@classmethod
    def delete_old(cls, limit=1):
        old = cls.select().order_by(cls.timestamp).limit(limit)
        q = cls.delete().where(cls.id.in_(old))
        return q.execute()

@classmethod
    def insert_many(cls, rows, **kwargs) -> None:
        # sqlite may have internal limit of variables-per-query
        for i in range(0, len(rows), 100):
            data = [
                cls.MessageToSendT(*row)._asdict() for row in rows[i : i + 100]
            ]
            super().insert_many(data, **kwargs).execute()

Exit & Reset Text mode: syntax highlighting auto-detects file type.

Name	Size	Perms	Modified	Actions
__pycache__ DIR	-	drwxr-xr-x	2026-06-08 20:23:14	Edit Download recursive recursive
analyst_cleanup.py	3.40 KB	lrw-r--r--	2026-05-26 21:20:44	Edit Download recursive recursive
event_hook.py	1.74 KB	lrw-r--r--	2026-05-26 21:20:44	Edit Download recursive recursive
icontact.py	1.16 KB	lrw-r--r--	2026-05-26 21:20:44	Edit Download recursive recursive
infected_domain.py	4.24 KB	lrw-r--r--	2026-05-26 21:20:44	Edit Download recursive recursive
instance.py	537 B	lrw-r--r--	2026-05-26 21:20:44	Edit Download recursive recursive
messages_to_send.py	1.37 KB	lrw-r--r--	2026-05-26 21:20:44	Edit Download recursive recursive
simplification.py	5.01 KB	lrw-r--r--	2026-05-26 21:20:44	Edit Download recursive recursive
tls_check.py	2.23 KB	lrw-r--r--	2026-05-26 21:20:44	Edit Download recursive recursive
wordpress.py	1.66 KB	lrw-r--r--	2026-05-26 21:20:44	Edit Download recursive recursive
wordpress_incident.py	13.02 KB	lrw-r--r--	2026-05-26 21:20:44	Edit Download recursive recursive
wp_disabled_rule.py	13.21 KB	lrw-r--r--	2026-05-26 21:20:44	Edit Download recursive recursive
__init__.py	963 B	lrw-r--r--	2026-05-26 21:20:44	Edit Download recursive recursive

Directory Contents