OXIESEC PANEL

Name	Size	Modified	Perms
📁 ..	-	09/05/2025 09:34:06 AM	rwxr-xr-x
📄 __init__.py	928 bytes	08/21/2025 03:04:58 PM	rw-r--r--
📁 __pycache__	-	09/05/2025 10:05:18 AM	rwxr-xr-x
📄 billing.py	6.24 KB	08/21/2025 03:04:58 PM	rw-r--r--
📁 bin	-	09/05/2025 09:34:13 AM	rwxr-xr-x
📄 cl_wpos_exceptions.py	3.59 KB	08/21/2025 03:04:58 PM	rw-r--r--
📁 cli_versions	-	09/05/2025 09:34:13 AM	rwxr-xr-x
📄 constants.py	5.56 KB	08/21/2025 03:04:58 PM	rw-r--r--
📄 create_user_uid_dirs.py	754 bytes	08/21/2025 03:04:58 PM	rw-r--r--
📄 cron.py	2.14 KB	08/21/2025 03:04:58 PM	rw-r--r--
📄 daemon.py	37.12 KB	08/21/2025 03:04:58 PM	rw-r--r--
📄 daemon_base.py	2.84 KB	08/21/2025 03:04:58 PM	rw-r--r--
📄 daemon_config.py	621 bytes	08/21/2025 03:04:58 PM	rw-r--r--
📄 daemon_redis_lib.py	11.93 KB	08/21/2025 03:04:58 PM	rw-r--r--
📄 daemon_subscription_handler.py	6.44 KB	08/21/2025 03:04:58 PM	rw-r--r--
📄 data_collector_utils.py	9.42 KB	08/21/2025 03:04:58 PM	rw-r--r--
📁 feature_suites	-	09/05/2025 09:34:13 AM	rwxr-xr-x
📁 hooks	-	09/05/2025 09:34:13 AM	rwxr-xr-x
📄 logsetup.py	4.04 KB	08/21/2025 03:04:58 PM	rw-r--r--
📁 migrations	-	09/05/2025 09:34:13 AM	rwxr-xr-x
📁 object_cache	-	09/05/2025 09:34:13 AM	rwxr-xr-x
📁 optimization_features	-	09/05/2025 09:34:13 AM	rwxr-xr-x
📄 papi.py	9.87 KB	08/21/2025 03:04:58 PM	rw-r--r--
📄 parse.py	2.1 KB	08/21/2025 03:04:58 PM	rw-r--r--
📁 php	-	09/05/2025 09:34:13 AM	rwxr-xr-x
📄 redis_configuration_pid_file_cleaner.py	1.01 KB	08/21/2025 03:04:58 PM	rwxr-xr-x
📄 report_generator.py	21.18 KB	08/21/2025 03:04:58 PM	rw-r--r--
📄 scoped_cache.py	1.34 KB	08/21/2025 03:04:58 PM	rw-r--r--
📄 socket_utils.py	4.03 KB	08/21/2025 03:04:58 PM	rw-r--r--
📄 stats.py	12.02 KB	08/21/2025 03:04:58 PM	rw-r--r--
📁 user	-	09/05/2025 09:34:13 AM	rwxr-xr-x
📄 utils.py	53.91 KB	08/21/2025 03:04:58 PM	rw-r--r--
📄 whmcs_utils.py	9.36 KB	08/21/2025 03:04:58 PM	rw-r--r--
📄 wp_config.py	725 bytes	08/21/2025 03:04:58 PM	rw-r--r--
📄 wp_utils.py	16.33 KB	08/21/2025 03:04:58 PM	rw-r--r--
📄 wpos_admin.py	67.14 KB	08/21/2025 03:04:58 PM	rw-r--r--
📄 wpos_hooks.py	4.85 KB	08/21/2025 03:04:58 PM	rwxr-xr-x
📄 wpos_req_scanner.py	4.38 KB	08/21/2025 03:04:58 PM	rw-r--r--

Editing: socket_utils.py

#!/opt/cloudlinux/venv/bin/python3 -bb
# coding=utf-8
#
# Copyright © Cloud Linux GmbH & Cloud Linux Software, Inc 2010-2021 All Rights Reserved
#
# Licensed under CLOUD LINUX LICENSE AGREEMENT
# http://cloudlinux.com/docs/LICENCE.TXT
#

from __future__ import absolute_import

import json
import socket
import struct
import time
from typing import Optional

# uint32_t, big endian
_format = '>I'

# Socket read timeout, seconds
_WPOS_SOCKET_READ_TIMEOUT_SEC = 10

def get_uid_from_socket(sock_object: socket.socket) -> int:
    """
    Retrieve credentials from SO_PEERCRED option
    :param sock_object: Socket object
    :return: uid of user, which connects to this socket.
    """
    _format_string = '3I'
    creds = sock_object.getsockopt(socket.SOL_SOCKET, socket.SO_PEERCRED, struct.calcsize(_format_string))
    # creds contains _pid, _uid, _gid - 3 uint32_t numbers
    _, _uid, _ = struct.unpack(_format_string, creds)
    return _uid

def pack_data_for_socket(data_dict: dict) -> bytes:
    """
    Prefix message with a 4-byte length
    :param data_dict: Data dict for send
    :return: byte array for send to socket
    """
    msg_bytes = json.dumps(data_dict).encode('utf-8')
    # Output data format:
    # 4 bytes unsigned int, big-endian - data_len
    # data_len                         - data_bytes
    return struct.pack(_format, len(msg_bytes)) + msg_bytes

def _read_bytes_from_socket_with_timeout(sock_object: socket.socket, num_bytes: int,
                                         timeout_sec: int) -> Optional[bytes]:
    """
    Read amount data from socket
    :param sock_object: Socket object to read data from
    :param num_bytes: Bytes number to read
    :param timeout_sec: Read timeout, None - timeout expired, data not received
    """
    msg = bytes()
    for i in range(timeout_sec * 10):
        msg += sock_object.recv(num_bytes)
        if len(msg) == num_bytes:
            return msg
        time.sleep(0.1)
    return None

def read_unpack_response_from_socket_daemon(sock_object: socket.socket) -> Optional[dict]:
    """
    Read length-prefixed amount of data from socket
    :param sock_object: Socket object to read data
    :return: Data received from socket dictionary. None - socket data format error
    """
    # Socket Input data format:
    # 4 bytes unsigned int, big-endian - data_len
    # data_len                         - data_bytes
    # NOTE: Set non-blocking mode and set timeout to avoid socket.recv hanging if invalid data was sent to socket
    sock_object.setblocking(False)
    sock_object.settimeout(_WPOS_SOCKET_READ_TIMEOUT_SEC)
    # Get data length (4 bytes)
    raw_msglen = _read_bytes_from_socket_with_timeout(sock_object, 4, _WPOS_SOCKET_READ_TIMEOUT_SEC)
    if raw_msglen is None:
        return None
    msglen = struct.unpack(_format, raw_msglen)[0]
    msg = _read_bytes_from_socket_with_timeout(sock_object, msglen, _WPOS_SOCKET_READ_TIMEOUT_SEC)
    if msg is None:
        return None
    return json.loads(msg.decode('utf-8'))

def read_unpack_response_from_socket_client(sock_object: socket.socket) -> Optional[dict]:
    """
    Read length-prefixed amount of data from socket
    :param sock_object: Socket object to read data
    :return: Data received from socket dictionary. None - socket data format error
    """
    # Socket Input data format:
    # 4 bytes unsigned int, big-endian - data_len
    # data_len                         - data_bytes
    try:
        raw_msglen = sock_object.recv(4)
        msglen = struct.unpack(_format, raw_msglen)[0]
        msg = bytes()
        while len(msg) != msglen:
            msg += sock_object.recv(4096)
    except socket.timeout:
        return None
    return json.loads(msg.decode('utf-8'))

def send_dict_to_socket_connection_and_close(connection: socket.socket, data_to_send: dict):
    """
    Sends dictionary to socket connection and close it
    :param connection: Socket connection to send data
    :param data_to_send: Data dict to send
    """
    bytes_to_send = pack_data_for_socket(data_to_send)
    connection.sendall(bytes_to_send)
    connection.close()