HEX
Server: LiteSpeed
System: Linux atali.colombiahosting.com.co 5.14.0-570.12.1.el9_6.x86_64 #1 SMP PREEMPT_DYNAMIC Tue May 13 06:11:55 EDT 2025 x86_64
User: coopserp (1713)
PHP: 8.2.29
Disabled: dl,exec,passthru,proc_open,proc_close,shell_exec,memory_limit,system,popen,curl_multi_exec,show_source,symlink,link,leak,listen,diskfreespace,tmpfile,ignore_user_abord,highlight_file,source,show_source,fpaththru,virtual,posix_ctermid,posix_getcwd,posix_getegid,posix_geteuid,posix_getgid,posix_getgrgid,posix_getgrnam,posix_getgroups,posix_getlogin,posix_getpgid,posix_getpgrp,posix_getpid,posix,posix_getppid,posix_getpwnam,posix_getpwuid,posix_getrlimit,posix_getsid,posix_getuid,posix_isatty,posix_kill,posix_mkfifo,posix_setegid,posix_seteuid,posix_setgid,posix_setpgid,posix_setsid,posix_setid,posix_times,posix_ttyname,posix_uname,proc_get_status,proc_nice,proc_terminate
Upload Files
File: //opt/cloudlinux/venv/lib/python3.11/site-packages/cl_website_collector/feature_manager.py
# -*- coding: utf-8 -*-
#
# Copyright © Cloud Linux GmbH & Cloud Linux Software, Inc 2010-2024 All Rights Reserved
#
# Licensed under CLOUD LINUX LICENSE AGREEMENT
# http://cloudlinux.com/docs/LICENSE.TXT
import os
from copy import deepcopy
import requests


class FeatureManagerApiException(Exception):
    pass



class FeatureManager:
    """
    Communicates with FeatureManager API to get feature settings based on server metadata
    """

    def __init__(self, app_logger):
        self.api_url = self.base_url() + "/feature_manager/feature_settings"
        self.app_logger = app_logger

    @staticmethod
    def base_url() -> str:
        base_url = "https://x-ray-advice.cloudlinux.com"
        if os.path.exists("/opt/cloudlinux/staging_mode"):
            base_url = "https://x-ray-staging.cloudlinux.com"
        return base_url


    def request(self, payload):
        response = requests.get(self.api_url, json=payload, timeout=20)
        self.app_logger.info(f"FeatureManager request to {self.api_url} "
                              f"with payload {payload} "
                              f"returned {response.status_code}")
        if response.status_code != 200:
            raise FeatureManagerApiException(f"FeatureManager API returned {response.status_code}")
        return response.json()

    def get_decision(self, server_metadata, reason):
        payload = deepcopy(server_metadata)
        payload["reason"] = reason
        return self.request(payload)