# -*- encoding=utf-8 -*-
"""
# **********************************************************************************
# Copyright (c) Huawei Technologies Co., Ltd. 2020-2020. All rights reserved.
# [openeuler-jenkins] is licensed under the Mulan PSL v2.
# You can use this software according to the terms and conditions of the Mulan PSL v2.
# You may obtain a copy of Mulan PSL v2 at:
#          http://license.coscl.org.cn/MulanPSL2
# THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND,
# EITHER EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT,
# MERCHANTABILITY OR FIT FOR A PARTICULAR PURPOSE.
# See the Mulan PSL v2 for more details.
# Author: 
# Create: 2020-09-23
# Description: access control list base class
# **********************************************************************************
"""

import abc
import inspect
import logging
import os

from src.ac.framework.ac_result import SUCCESS, WARNING, FAILED

logger = logging.getLogger("ac")


class BaseCheck(object):
    """
    acl check base class
    """

    __metaclass__ = abc.ABCMeta

    def __init__(self, workspace, repo, conf=None):
        """

        :param repo:
        :param workspace:
        :param conf:
        """
        self._repo = repo
        self._workspace = workspace
        self._conf = conf

        self._work_dir = os.path.join(workspace, repo)

    @abc.abstractmethod
    def __call__(self, *args, **kwargs):
        raise NotImplementedError("subclasses must override __call__!")

    def start_check_with_order(self, *items):
        """
        按照items中顺序运行
        """
        result = SUCCESS
        for name in items:
            try:
                logger.debug("check %s", name)
                method = getattr(self, "check_{}".format(name))
                rs = method()
                logger.debug("%s -> %s", name, rs)
            except Exception as e:
                # 忽略代码错误
                logger.exception("internal error: %s", e)
                continue

            ignored = True if self._conf and name in self._conf.get("ignored", []) else False
            logger.debug("%s ignore: %s", name, ignored)

            if rs == SUCCESS:
                logger.info("check %s pass", name)
            elif rs == WARNING:
                logger.warning("check %s warning %s", name, " [ignored]" if ignored else "")
                if rs.details:
                    for d in rs.details:
                        logger.warning("  -> %s", d)
            elif rs == FAILED:
                logger.error("check %s fail %s", name, " [ignored]" if ignored else "")
                if rs.details:
                    for d in rs.details:
                        logger.error("  -> %s", d)
            else:
                # never here
                logger.exception("check %s exception %s", name, " [ignored]" if ignored else "")
                continue

            if not ignored:
                result += rs

        return result

    def start_check(self):
        """
        运行所有check_开头的函数
        """
        members = inspect.getmembers(self, inspect.ismethod)
        items = [member[0].replace("check_", "") for member in members if member[0].startswith("check_")]
        logger.info("check items: %s", items)

        return self.start_check_with_order(*items)

    def get_pr_changed_files(self):
        """
        通过 Gitcode API 获取本次 PR 的变更文件列表（仅文件名）。
        返回 None 表示无法获取（缺少参数或 API 失败）。
        """
        kwargs = getattr(self, '_kwargs', {})
        common_args = kwargs.get("common_args", {})
        pr_num = common_args.get("pr_num", "")
        owner = common_args.get("community", "")
        token = common_args.get("access_token", "")

        if not all([pr_num, owner, token]):
            return None

        from src.proxy.gitcode_proxy import GitcodeProxy
        gp = GitcodeProxy(owner, self._repo, token)
        pr_files = gp.get_pr_files(pr_num)
        if pr_files is None: 
            return None
        return [f.get("filename", "") for f in pr_files if f.get("filename")]