#include "inter.h"
#include "core-activation.h"
#include "core-init.h"
#include "msg.h"
#include "core-exception.h"

namespace aFuncore {
    Inter::Inter(Environment &env_)
            : out{}, in{}, env{env_}{
        status = inter_creat;

        activation = nullptr;

        status = inter_init;
        env++;
    }

    Inter::Inter(const Inter &base_inter)
            : out{}, in{}, env{base_inter.env}{
        status = inter_creat;

        activation = nullptr;

        for (auto &i: base_inter.literal)
            literal.push_back(i);

        status = inter_normal;
        env++;
    }

    Inter::~Inter(){
        env--;
    }

    /**
     * 使能 (激活解释器)
     */
    void Inter::enable(){
        if (status == inter_init) {
            env.protect->setProtect(true);
            status = inter_normal;
        }
    }

    /**
     * 运行代码（直接运行activation）
     * @return
     */
    bool Inter::runCode(){
        if (status == inter_stop)
            status = inter_normal;

        while (activation != nullptr) {
            if (isInterStop()) {
                while (activation != nullptr)
                    delete popActivation();
                return false;
            }

            const Code::ByteCode *code = nullptr;
            Activation::ActivationStatus as = activation->getCode(code);
            switch (as) {
                case Activation::as_end: {
                    delete popActivation();
                    break;
                }
                case Activation::as_run:
                    activation->runCode(code);
                    break;
                case Activation::as_end_run:
                    activation->endRun();
                    break;
                default:
                    errorLog(aFunCoreLogger, "Error activation status.");
                    activation->getDownStream().pushMessage("ERROR",
                                                            new ErrorMessage("RuntimeError", "Error activation status.", activation));
                    break;
            }
        }
        return true;
    }

    /**
     * 运行代码
     * @param code 代码
     * @return
     */
    bool Inter::runCode(const Code &code){
        if (activation != nullptr) {
            errorLog(aFunCoreLogger, "Run code with activation");
            return false;
        }

        new TopActivation(code, *this);
        return runCode();
    }

    /**
     * 函数调用
     * @param code 代码
     * @return
     */
    bool Inter::runCode(Object *func){
        if (activation != nullptr) {
            errorLog(aFunCoreLogger, "Run function with activation");
            return false;
        }

        auto func_obj = dynamic_cast<Function *>(func);
        if (func_obj == nullptr) {
            errorLog(aFunCoreLogger, "Run without function");
            return false;
        }

        new FuncActivation(func_obj, *this);
        return runCode();
    }

    /**
     * 检查字面量是否匹配
     * @param element 字面量
     * @return
     */
    bool Inter::checkLiteral(const std::string &element) const{
        if (literal.empty())
            return false;

        for (auto &i: literal) {
            try {
                if (i.rg.match(element) != 1)
                    continue;
                return true;
            } catch (aFuntool::RegexException &e) {
                continue;
            }
        }
        return false;
    }

    /**
     * 检查字面量正则匹配
     * @param element 字面量
     * @param literaler 函数
     * @param in_protect 是否保护空间
     * @return
     */
    bool Inter::checkLiteral(const std::string &element, std::string &literaler, bool &in_protect) const{
        if (literal.empty())
            return false;

        for (auto &i: literal) {
            try {
                if (i.rg.match(element) != 1)
                    continue;
                literaler = i.literaler;
                in_protect = i.in_protect;
                return true;
            } catch (aFuntool::RegexException &e) {
                continue;
            }
        }
        return false;
    }

    bool Inter::pushLiteral(const std::string &pattern, const std::string &literaler, bool in_protect){
        try {
            literal.push_front({aFuntool::Regex(pattern), pattern, literaler, in_protect});
        } catch (aFuntool::RegexException &e) {
            return false;
        }
        return true;
    }

    void Environment::gcThread() {
        while(true) {
            std::queue<Object *> del;
            std::queue<Object *> des;
            {
                std::unique_lock<std::mutex> mutex{lock};
                if (destruct)
                    break;
                Object::checkReachable(gc);
                Object::setReachable(gc, des, del);
            }
            Object::deleteUnreachable(del);
            Object::destructUnreachable(des, gc_inter);
            aFuntool::safeSleep(1);
        }

        Object::destructAll(gc, gc_inter); /* 不需要mutex锁 */
    }

    Environment::Environment(int argc, char **argv)
        : reference{0}, gc_inter{*(new Inter(*this))},
          protect{new ProtectVarSpace(*this)}, global{new VarSpace(*this)},
          global_varlist{new VarList(protect)}, destruct{false} {
        global_varlist->push(global);
        /* 生成 gc_inter 后, reference == 1 */

        envvar.setNumber("sys:gc-runtime", 2);
        envvar.setString("sys:prefix", "''");  // 引用，顺序执行
        envvar.setNumber("sys:exit-code", 0);
        envvar.setNumber("sys:argc", argc);
        envvar.setNumber("sys:error_std", 0);

        for (int i = 0; i < argc; i++) {
            char buf[20];
            snprintf(buf, 10, "sys:arg%d", i);
            envvar.setString(buf, argv[i]);
        }

        gc_thread = std::thread([this](){this->gcThread();});

        {  // 导入函数
            auto import = new ImportFunction(*this);
            protect->defineVar("import", import);
            import->delReference();
        }
    }

    Environment::~Environment() noexcept(false) {
        {   /* 使用互斥锁, 防止与gc线程出现不同步的情况 */
            std::unique_lock<std::mutex> mutex{lock};
            if (reference != 1)  // gc_inter 有一个引用
                throw EnvironmentDestructException();

            if (destruct)
                return;

            destruct = true;
        }

        gc_thread.join();
        delete &gc_inter;

        delete global_varlist;
        protect->delReference();
        global->delReference();

        Object::deleteAll(gc); /* 不需要mutex锁 */

        if (reference != 0)
            throw EnvironmentDestructException();
    }
}