#include "Cleaner.h"
#include <memory>

namespace Cleaner {

static std::shared_ptr<bool> mAutoCleanTask  = std::make_shared<bool>(false);
static std::shared_ptr<bool> mCleanTaskCount = std::make_shared<bool>(false);
static std::shared_ptr<bool> mCleanTaskTPS   = std::make_shared<bool>(false);

bool auto_clean_triggerred = false;

void CleanTask() {
    auto&                config        = Cleaner::Entry::getInstance().getConfig();
    auto                 time          = config.Basic.Notice1;
    auto                 announce_time = config.Basic.Notice2;
    std::chrono::seconds time_1(time);
    std::chrono::seconds time_2(time - announce_time);
    if (config.Basic.ConsoleLog) {
        ll::io::LoggerRegistry::getInstance().getOrCreate("Cleaner")->info(
            tr("cleaner.output.count1", {S(time_1.count())})
        );
    }
    if (config.Basic.SendBroadcast) {
        Helper::broadcastMessage(tr("cleaner.output.count1", {S(time_1.count())}));
    }
    if (config.Basic.SendToast) {
        Helper::broadcastToast(tr("cleaner.output.count2", {S(announce_time)}));
    }
    ll::coro::keepThis([announce_time, &config, time_2]() -> ll::coro::CoroTask<> {
        co_await time_2;
        if (config.Basic.ConsoleLog) {
            ll::io::LoggerRegistry::getInstance().getOrCreate("Cleaner")->info(
                tr("cleaner.output.count2", {S(announce_time)})
            );
        }
        if (config.Basic.SendBroadcast) {
            Helper::broadcastMessage(tr("cleaner.output.count2", {S(announce_time)}));
        }
        if (config.Basic.SendToast) {
            Helper::broadcastToast(tr("cleaner.output.count2", {S(announce_time)}));
        }
        co_return;
    }).launch(ll::thread::ServerThreadExecutor::getDefault());
    ll::coro::keepThis([announce_time, &config, time_1]() -> ll::coro::CoroTask<> {
        co_await time_1;
        auto count = ExecuteClean();
        if (config.Basic.ConsoleLog) {
            ll::io::LoggerRegistry::getInstance().getOrCreate("Cleaner")->info(tr("cleaner.output.finish", {S(count)}));
        }
        if (config.Basic.SendBroadcast) {
            Helper::broadcastMessage(tr("cleaner.output.finish", {S(count)}));
        }
        if (config.Basic.SendToast) {
            Helper::broadcastToast(tr("cleaner.output.finish", {S(count)}));
        }
        auto_clean_triggerred = false;
        co_return;
    }).launch(ll::thread::ServerThreadExecutor::getDefault());
}

void AutoCleanTask(int seconds) {
    std::chrono::seconds time(seconds);
    *mAutoCleanTask = true;
    ll::coro::keepThis([time]() -> ll::coro::CoroTask<> {
        while (true) {
            co_await time;
            if (*mAutoCleanTask == false) co_return;
            CleanTask();
        }
        co_return;
    }).launch(ll::thread::ServerThreadExecutor::getDefault());
}

void CleanTaskCount(int max_entities) {
    auto& config     = Cleaner::Entry::getInstance().getConfig();
    *mCleanTaskCount = true;
    ll::coro::keepThis([max_entities, &config]() -> ll::coro::CoroTask<> {
        while (true) {
            co_await 10s;
            if (*mCleanTaskCount == false) co_return;
            auto count = CountEntities();
            if (auto_clean_triggerred == false) {
                if (count >= max_entities) {
                    auto_clean_triggerred = true;
                    if (config.Basic.ConsoleLog) {
                        ll::io::LoggerRegistry::getInstance().getOrCreate("Cleaner")->warn(
                            tr("cleaner.output.triggerAutoCleanCount", {S(count)})
                        );
                    }
                    if (config.Basic.SendBroadcast) {
                        Helper::broadcastMessage(tr("cleaner.output.triggerAutoCleanCount", {S(count)}));
                    }
                    if (config.Basic.SendToast) {
                        Helper::broadcastToast(tr("cleaner.output.triggerAutoCleanCount", {S(count)}));
                    }
                    CleanTask();
                }
            }
        }
        co_return;
    }).launch(ll::thread::ServerThreadExecutor::getDefault());
}

void CleanTaskTPS(float min_tps) {
    auto& config   = Cleaner::Entry::getInstance().getConfig();
    *mCleanTaskTPS = true;
    ll::coro::keepThis([min_tps, &config]() -> ll::coro::CoroTask<> {
        while (true) {
            co_await 10s;
            if (*mCleanTaskTPS == false) co_return;
            if (auto_clean_triggerred == false) {
                if (gmlib::GMLevel::getInstance()->getServerAverageTps() <= min_tps) {
                    auto_clean_triggerred = true;
                    auto mspt             = S(gmlib::GMLevel::getInstance()->getServerAverageTps());
                    if (config.Basic.ConsoleLog) {
                        ll::io::LoggerRegistry::getInstance().getOrCreate("Cleaner")->warn(
                            tr("cleaner.output.triggerAutoCleanTps", {mspt})
                        );
                    }
                    if (config.Basic.SendBroadcast) {
                        Helper::broadcastMessage(tr("cleaner.output.triggerAutoCleanTps", {mspt}));
                    }
                    if (config.Basic.SendToast) {
                        Helper::broadcastToast(tr("cleaner.output.triggerAutoCleanTps", {mspt}));
                    }
                    CleanTask();
                }
            }
        }
        co_return;
    }).launch(ll::thread::ServerThreadExecutor::getDefault());
}

void stopAllTasks() {
    if (!mCleanTaskCount) {
        *mCleanTaskTPS = false;
    }
    if (mCleanTaskCount) {
        *mCleanTaskCount = false;
    }
    if (mAutoCleanTask) {
        *mAutoCleanTask = false;
    }
}
} // namespace Cleaner