Na}{

File Content: `resident_socket.py`

import asyncio
import json

from defence360agent.contracts.config import (
    GENERIC_SENSOR_SOCKET_PATH,
)


async def send_to_socket(msg, timeout=15, wait_for_response=True):
    result = b""

    try:
        reader, writer = await asyncio.open_unix_connection(
            path=GENERIC_SENSOR_SOCKET_PATH
        )
    except ConnectionRefusedError:
        return "Failed to send to socket, check your socket active"
    except FileNotFoundError:
        return "Failed to send to socket, socket file not found"
    except OSError as e:
        return f"OSError when connectiong to {GENERIC_SENSOR_SOCKET_PATH}: {e}"

    try:
        writer.write(json.dumps(msg).encode() + b"\n")
        await writer.drain()

        if not wait_for_response:
            return {}

        while True:
            data = await asyncio.wait_for(reader.read(8192), timeout=timeout)

            if not data:
                break

            result += data

            if b"\n" in data:
                break

        return json.loads(result.decode())

    except json.JSONDecodeError:
        return "Failed to decode json answer from a plugin"

    except (
        asyncio.TimeoutError,
        asyncio.IncompleteReadError,
        asyncio.CancelledError,
        BrokenPipeError,
        ConnectionResetError,
        OSError,
    ) as e:
        return (
            result.decode()
            if result
            else (
                "Failed to process operation with socket. Reason:"
                f" {type(e).__name__}"
            )
        )
    finally:
        writer.close()
        await writer.wait_closed()

Name	Size	Permission
__pycache__	---	0755
schema	---	0755
schema_responses	---	0755
__init__.py	0 bytes	0644
configuration_management.py	3199 bytes	0644
conflicts.py	3283 bytes	0644
control_panel.py	484 bytes	0644
countries.py	5804 bytes	0644
csf_imports.py	2690 bytes	0644
custom_lists.py	642 bytes	0644
disabled_rules.py	7584 bytes	0644
feature.py	1944 bytes	0644
health.py	343 bytes	0644
hosting_panel.py	2794 bytes	0644
incidents.py	1871 bytes	0644
kcarectl.py	824 bytes	0644
lists.py	31393 bytes	0644
malware.py	385 bytes	0644
middleware.py	1348 bytes	0644
proactive.py	7816 bytes	0644
remote_proxy.py	3043 bytes	0644
resident_socket.py	1624 bytes	0644
schema.py	1071 bytes	0644
smart_advice.py	1284 bytes	0644
smtp_blocking.py	1758 bytes	0644
unavailable_on_freemium.py	354 bytes	0644
uninstall_cleanup.py	1258 bytes	0644
validate.py	9558 bytes	0644
whitelist_rbl.py	409 bytes	0644
whitelisted_crawlers.py	1040 bytes	0644
whitelisted_domains.py	821 bytes	0644

File Content: resident_socket.py

File Content: `resident_socket.py`