Class LogServerManager

class/logsModel/logserverModel.py:550–836

class LogServerManager(object):
    _CONFIG_FILE = "{}/data/logserver_config.json".format(public.get_panel_path())
    _SOURCE_MAP = {
        "site": SiteLogSource,
        "syslog": SysLogSource,
    }
    _LOG_SERVER_MAP: Dict[str, BaseLogServer] = {
        "bt_log_server": BTLogServer,
    }

    def __init__(self):
        self._config: Optional[Dict[str, List[dict]]] = None
        self.last_server = None

    @property
    def config(self) -> Dict[str, List[dict]]:
        if self._config is not None:
            return self._config
        default_conf = {}
        try:
            self._config = json.loads(public.readFile(self._CONFIG_FILE))
        except (json.JSONDecodeError, TypeError):
            pass
        if isinstance(self._config, dict):
            return self._config

        self._config = default_conf
        return self._config

    def save_conf(self):
        if self._config:
            public.writeFile(self._CONFIG_FILE, json.dumps(self._config))

    def add_logserver(self, server_type: str, data: dict) -> Tuple[bool, str]:
        if server_type not in self._LOG_SERVER_MAP:
            return False, "不支持的日志服务系统"

        try:
            s = self._LOG_SERVER_MAP[server_type].new(data)
        except:
            return False, "配置信息错误"
        else:
            if isinstance(s, str):
                return False, s
            if s.check_exist(self) is True:
                return False, "该配置已存在，请勿重新添加"

        data["id"] = str(int(time.time()))
        data["server_type"] = server_type
        if "servers" not in self.config:
            self.config["servers"] = []

        self.config["servers"].append(data)
        self.save_conf()
        self.last_server = data
        return True, "配置添加成功"

    def modify_logserver(self, server_id: str, data: dict) -> Tuple[bool, str]: