Updated http_server.cpp api/settings data #4782

Shadysoftdev · 2023-11-30T00:06:54Z

Shadysoftdev
Nov 30, 2023

I spent an hour or 2, not sure anymore dumping data into the http_server.cpp file, recompiled it and testing then making it easier to read, almost all of the main.lua besides the TRUST_ALTER_EGO messages gets pulled into the api/settings page now


/*
===========================================================================

Copyright (c) 2022 LandSandBoat Dev Teams

This program is free software: you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation, either version 3 of the License, or
(at your option) any later version.

This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
GNU General Public License for more details.

You should have received a copy of the GNU General Public License
along with this program.  If not, see http://www.gnu.org/licenses/

===========================================================================
*/

#include "http_server.h"

#include "common/logging.h"
#include "common/settings.h"
#include "common/sql.h"
#include "common/utils.h"

#include <nlohmann/json.hpp>
using json = nlohmann::json;

HTTPServer::HTTPServer()
{
    if (!settings::get<bool>("network.ENABLE_HTTP"))
    {
        return;
    }

    ts = std::make_unique<ts::task_system>(1);

    // NOTE: Everything registered in here happens off the main thread, so lock any global resources
    //     : you might be using.

    LockingUpdate();

    auto host = settings::get<std::string>("network.HTTP_HOST");
    auto port = settings::get<uint16>("network.HTTP_PORT");

    // clang-format off
    ts->schedule([this, host, port]()
    {
        m_httpServer.Get("/api", [&](httplib::Request const& req, httplib::Response& res)
        {
            res.set_content("Hello LSB API", "text/plain");
        });

        m_httpServer.Get("/api/sessions", [&](httplib::Request const& req, httplib::Response& res)
        {
            LockingUpdate();

            std::unique_lock<std::mutex> lock(m_updateBottleneck);
            json j;
            j = m_apiDataCache.activeSessionCount;
            res.set_content(j.dump(), "application/json");
        });

        m_httpServer.Get("/api/zones", [&](httplib::Request const& req, httplib::Response& res)
        {
            LockingUpdate();

            std::unique_lock<std::mutex> lock(m_updateBottleneck);
            json j = m_apiDataCache.zonePlayerCounts;
            res.set_content(j.dump(), "application/json");
        });

        m_httpServer.Get(R"(/api/zones/(\d+))", [&](httplib::Request const& req, httplib::Response& res)
        {
            auto maybeZoneId = req.matches[1].str();
            uint16 zoneId = std::strtol(maybeZoneId.c_str(), nullptr, 10);
            if (zoneId && zoneId < ZONEID::MAX_ZONEID)
            {
                LockingUpdate();

                std::unique_lock<std::mutex> lock(m_updateBottleneck);
                json j = m_apiDataCache.zonePlayerCounts[zoneId];
                res.set_content(j.dump(), "application/json");
            }
            else
            {
                res.status = 404;
            }
        });

        m_httpServer.Get("/api/settings", [&](httplib::Request const& req, httplib::Response& res)
        {
            // TODO: Cache these
            json j;
            j["SERVER_NAME"]                                    = settings::get<std::string>("main.SERVER_NAME");
            j["EXP_RATE"]                                       = settings::get<float>("main.EXP_RATE");
            j["ENABLE_TRUST_CASTING"]                           = settings::get<bool>("main.ENABLE_TRUST_CASTING");
            j["MAX_LEVEL"]                                      = settings::get<uint8>("main.MAX_LEVEL");
            j["ENABLE_COP"]                                     = settings::get<bool>("main.ENABLE_COP");
            j["ENABLE_TOAU"]                                    = settings::get<bool>("main.ENABLE_TOAU");
            j["ENABLE_WOTG"]                                    = settings::get<bool>("main.ENABLE_WOTG");
            j["ENABLE_ACP "]                                    = settings::get<bool>("main.ENABLE_ACP");
            j["ENABLE_AMK"]                                     = settings::get<bool>("main.ENABLE_AMK");
            j["ENABLE_ASA"]                                     = settings::get<bool>("main.ENABLE_ASA");
            j["ENABLE_ABYSSEA"]                                 = settings::get<bool>("main.ENABLE_ABYSSEA");
            j["ENABLE_SOA"]                                     = settings::get<bool>("main.ENABLE_SOA");
            j["ENABLE_ROV "]                                    = settings::get<bool>("main.ENABLE_ROV");
            j["ENABLE_VOIDWATCH"]                               = settings::get<bool>("main.ENABLE_VOIDWATCH");
            j["ENABLE_FIELD_MANUALS"]                           = settings::get<bool>("main.ENABLE_FIELD_MANUALS");
            j["ENABLE_GROUNDS_TOMES"]                           = settings::get<bool>("main.ENABLE_GROUNDS_TOMES");
            j["ENABLE_SURVIVAL_GUIDE"]                          = settings::get<bool>("main.ENABLE_SURVIVAL_GUIDE");
            j["REGIME_WAIT"]                                    = settings::get<bool>("main.REGIME_WAIT");
            j["FOV_REWARD_ALLIANCE"]                            = settings::get<bool>("main.FOV_REWARD_ALLIANCE");
            j["GOV_REWARD_ALLIANCE"]                            = settings::get<bool>("main.GOV_REWARD_ALLIANCE");
            j["ENABLE_DAILY_TALLY"]                             = settings::get<bool>("main.ENABLE_DAILY_TALLY");
            j["DAILY_TALLY_AMOUNT"]                             = settings::get<uint8>("main.DAILY_TALLY_AMOUNT");
            j["DAILY_TALLY_LIMIT"]                              = settings::get<uint16>("main.DAILY_TALLY_LIMIT");
            j["GOBBIE_BOX_MIN_AGE"]                             = settings::get<uint8>("main.GOBBIE_BOX_MIN_AGE");
            j["ENABLE_ROE"]                                     = settings::get<bool>("main.ENABLE_ROE");
            j["ENABLE_ROE_TIMED"]                               = settings::get<bool>("main.ENABLE_ROE_TIMED");
            j["ENABLE_EXCHANGE_LIMIT"]                          = settings::get<bool>("main.ENABLE_EXCHANGE_LIMIT");
            j["WEEKLY_EXCHANGE_LIMIT"]                          = settings::get<uint32>("main.WEEKLY_EXCHANGE_LIMIT");
            j["CAP_CURRENCY_ACCOLADES"]                         = settings::get<uint32>("main.CAP_CURRENCY_ACCOLADES");
            j["CAP_CURRENCY_BALLISTA"]                          = settings::get<uint8>("main.CAP_CURRENCY_BALLISTA");
            j["CAP_CURRENCY_SPARKS"]                            = settings::get<uint32>("main.CAP_CURRENCY_SPARKS");
            j["CAP_CURRENCY_VALOR"]                             = settings::get<uint16>("main.CAP_CURRENCY_VALOR");
            j["ENABLE_MAGIAN_TRIALS"]                           = settings::get<bool>("main.ENABLE_MAGIAN_TRIALS");
            j["ENABLE_VOIDWALKER"]                              = settings::get<bool>("main.ENABLE_VOIDWALKER");
            j["ENABLE_MONSTROSITY"]                             = settings::get<bool>("main.ENABLE_MONSTROSITY");
            j["MONSTROSITY_INFAMY_RATIO"]                       = settings::get<double>("main.MONSTROSITY_INFAMY_RATIO");
            j["MONSTROSITY_INFAMY_MESSAGING"]                   = settings::get<bool>("main.MONSTROSITY_INFAMY_MESSAGING");
            j["MONSTROSITY_TELEPORT_TO_FERETORY"]               = settings::get<bool>("main.MONSTROSITY_TELEPORT_TO_FERETORY");
            j["MONSTROSITY_TRIGGER_NPCS"]                       = settings::get<bool>("main.MONSTROSITY_TRIGGER_NPCS");
            j["MONSTROSITY_DONT_WIPE_BUFFS"]                    = settings::get<bool>("main.MONSTROSITY_DONT_WIPE_BUFFS");
            j["MONSTROSITY_PVP_MODE"]                           = settings::get<bool>("main.MONSTROSITY_PVP_MODE");
            j["MONSTROSITY_PVP_ZONE_BYPASS"]                    = settings::get<bool>("main.MONSTROSITY_PVP_ZONE_BYPASS");
            j["CASKET_DROP_RATE"]                               = settings::get<double>("main.CASKET_DROP_RATE");
            j["ABYSSEA_LIGHTS_DROP_RATE"]                       = settings::get<uint8>("main.ABYSSEA_LIGHTS_DROP_RATE");
            j["ABYSSEA_BONUSLIGHT_AMOUNT"]                      = settings::get<uint8>("main.ABYSSEA_BONUSLIGHT_AMOUNT");
            j["INITIAL_LEVEL_CAP"]                              = settings::get<uint8>("main.INITIAL_LEVEL_CAP");
            j["NORMAL_MOB_MAX_LEVEL_RANGE_MIN"]                 = settings::get<uint8>("main.NORMAL_MOB_MAX_LEVEL_RANGE_MIN");
            j["NORMAL_MOB_MAX_LEVEL_RANGE_MAX"]                 = settings::get<uint8>("main.NORMAL_MOB_MAX_LEVEL_RANGE_MAX");
            j["START_GIL"]                                      = settings::get<uint16>("main.START_GIL");
            j["START_INVENTORY"]                                = settings::get<uint8>("main.START_INVENTORY");
            j["NEW_CHARACTER_CUTSCENE"]                         = settings::get<bool>("main.NEW_CHARACTER_CUTSCENE");
            j["SUBJOB_QUEST_LEVEL"]                             = settings::get<uint8>("main.SUBJOB_QUEST_LEVEL");
            j["ADVANCED_JOB_LEVEL"]                             = settings::get<uint8>("main.ADVANCED_JOB_LEVEL");
            j["ALL_MAPS"]                                       = settings::get<bool>("main.ALL_MAPS");
            j["UNLOCK_OUTPOST_WARPS"]                           = settings::get<bool>("main.UNLOCK_OUTPOST_WARPS");
            j["SHOP_PRICE"]                                     = settings::get<float>("main.SHOP_PRICE");
            j["GIL_RATE"]                                       = settings::get<float>("main.GIL_RATE");
            j["BAYLD_RATE"]                                     = settings::get<float>("main.BAYLD_RATE");
            j["CAPACITY_RATE"]                                  = settings::get<float>("main.CAPACITY_RATE");
            j["BOOK_EXP_RATE"]                                  = settings::get<float>("main.BOOK_EXP_RATE");
            j["TABS_RATE"]                                      = settings::get<float>("main.TABS_RATE");
            j["ROE_EXP_RATE"]                                   = settings::get<float>("main.ROE_EXP_RATE");
            j["SPARKS_RATE"]                                    = settings::get<float>("main.SPARKS_RATE");
            j["CURE_POWER"]                                     = settings::get<float>("main.CURE_POWER");
            j["ELEMENTAL_POWER"]                                = settings::get<float>("main.ELEMENTAL_POWER");
            j["DIVINE_POWER"]                                   = settings::get<float>("main.DIVINE_POWER");
            j["NINJUTSU_POWER"]                                 = settings::get<float>("main.NINJUTSU_POWER");
            j["BLUE_POWER"]                                     = settings::get<float>("main.BLUE_POWER");
            j["DARK_POWER"]                                     = settings::get<float>("main.DARK_POWER");
            j["ITEM_POWER"]                                     = settings::get<float>("main.ITEM_POWER");
            j["WEAPON_SKILL_POWER"]                             = settings::get<float>("main.WEAPON_SKILL_POWER");
            j["USE_ADOULIN_WEAPON_SKILL_CHANGES"]               = settings::get<bool>("main.USE_ADOULIN_WEAPON_SKILL_CHANGES");
            j["DISABLE_PARTY_EXP_PENALTY"]                      = settings::get<bool>("main.DISABLE_PARTY_EXP_PENALTY");
            j["ENABLE_IMMUNOBREAK"]                             = settings::get<bool>("main.ENABLE_IMMUNOBREAK");
            j["ENABLE_TRUST_QUESTS"]                            = settings::get<bool>("main.ENABLE_TRUST_QUESTS");
            j["ENABLE_TRUST_CUSTOM_ENGAGEMENT"]                 = settings::get<bool>("main.ENABLE_TRUST_CUSTOM_ENGAGEMENT");
            j["ENABLE_TRUST_ALTER_EGO_EXTRAVAGANZA"]            = settings::get<bool>("main.ENABLE_TRUST_ALTER_EGO_EXTRAVAGANZA");
            j["ENABLE_TRUST_ALTER_EGO_EXTRAVAGANZA_ANNOUNCE"]   = settings::get<float>("main.ENABLE_TRUST_ALTER_EGO_EXTRAVAGANZA_ANNOUNCE");
            j["ENABLE_TRUST_ALTER_EGO_EXPO"]                    = settings::get<float>("main.ENABLE_TRUST_ALTER_EGO_EXPO");
            j["ENABLE_TRUST_ALTER_EGO_EXPO_ANNOUNCE"]           = settings::get<float>("main.ENABLE_TRUST_ALTER_EGO_EXPO_ANNOUNCE");
            j["HARVESTING_BREAK_CHANCE"]                        = settings::get<uint8>("main.HARVESTING_BREAK_CHANCE");
            j["EXCAVATION_BREAK_CHANCE"]                        = settings::get<uint8>("main.EXCAVATION_BREAK_CHANCE");
            j["LOGGING_BREAK_CHANCE"]                           = settings::get<uint8>("main.LOGGING_BREAK_CHANCE");
            j["MINING_BREAK_CHANCE"]                            = settings::get<uint8>("main.MINING_BREAK_CHANCE");
            j["HARVESTING_RATE"]                                = settings::get<uint8>("main.HARVESTING_RATE");
            j["EXCAVATION_RATE"]                                = settings::get<uint8>("main.EXCAVATION_RATE");
            j["LOGGING_RATE"]                                   = settings::get<uint8>("main.LOGGING_RATE");
            j["MINING_RATE"]                                    = settings::get<uint8>("main.MINING_RATE");
            j["DIGGING_RATE"]                                   = settings::get<uint8>("main.DIGGING_RATE");
            j["HEALING_TP_CHANGE"]                              = settings::get<uint8>("main.HEALING_TP_CHANGE");
            j["COFFER_MAX_ILLUSION_TIME"]                       = settings::get<uint16>("main.COFFER_MAX_ILLUSION_TIME");
            j["COFFER_MIN_ILLUSION_TIME"]                       = settings::get<uint16>("main.COFFER_MIN_ILLUSION_TIME");
            j["CHEST_MAX_ILLUSION_TIME"]                        = settings::get<uint16>("main.CHEST_MAX_ILLUSION_TIME");
            j["CHEST_MIN_ILLUSION_TIME"]                        = settings::get<uint16>("main.CHEST_MIN_ILLUSION_TIME");
            j["NM_LOTTERY_CHANCE"]                              = settings::get<float>("main.NM_LOTTERY_CHANCE");
            j["NM_LOTTERY_COOLDOWN"]                            = settings::get<float>("main.NM_LOTTERY_COOLDOWN");
            j["ENABLE_GARRISON"]                                = settings::get<bool>("main.ENABLE_GARRISON");
            j["GARRISON_LOCKOUT"]                               = settings::get<uint16>("main.GARRISON_LOCKOUT");
            j["GARRISON_TIME_LIMIT"]                            = settings::get<uint16>("main.GARRISON_TIME_LIMIT");
            j["GARRISON_ONCE_PER_WEEK"]                         = settings::get<bool>("main.GARRISON_ONCE_PER_WEEK");
            j["GARRISON_PARTY_LIMIT"]                           = settings::get<uint8>("main.GARRISON_PARTY_LIMIT");
            j["GARRISON_NATION_BYPASS"]                         = settings::get<bool>("main.GARRISON_NATION_BYPASS");
            j["GARRISON_RANK"]                                  = settings::get<uint8>("main.GARRISON_RANK");
            j["BETWEEN_2DYNA_WAIT_TIME"]                        = settings::get<float>("main.BETWEEN_2DYNA_WAIT_TIME");
            j["DYNA_MIDNIGHT_RESET"]                            = settings::get<bool>("main.DYNA_MIDNIGHT_RESET");
            j["DYNA_LEVEL_MIN"]                                 = settings::get<uint8>("main.DYNA_LEVEL_MIN");
            j["TIMELESS_HOURGLASS_COST"]                        = settings::get<uint16>("main.TIMELESS_HOURGLASS_COST");
            j["PRISMATIC_HOURGLASS_COST"]                       = settings::get<uint16>("main.PRISMATIC_HOURGLASS_COST");
            j["CURRENCY_EXCHANGE_RATE"]                         = settings::get<uint8>("main.CURRENCY_EXCHANGE_RATE");
            j["ENABLE_EXCHANGE_100S_TO_1S"]                     = settings::get<bool>("main.ENABLE_EXCHANGE_100S_TO_1S");
            j["RELIC_2ND_UPGRADE_WAIT_TIME"]                    = settings::get<uint16>("main.RELIC_2ND_UPGRADE_WAIT_TIME");
            j["RELIC_3RD_UPGRADE_WAIT_TIME"]                    = settings::get<uint16>("main.RELIC_3RD_UPGRADE_WAIT_TIME");
            j["FREE_COP_DYNAMIS"]                               = settings::get<bool>("main.FREE_COP_DYNAMIS");
            j["COSMO_CLEANSE_BASE_COST"]                        = settings::get<uint16>("main.COSMO_CLEANSE_BASE_COST");
            j["AF1_QUEST_LEVEL"]                                = settings::get<uint8>("main.AF1_QUEST_LEVEL");
            j["AF2_QUEST_LEVEL"]                                = settings::get<uint8>("main.AF2_QUEST_LEVEL");
            j["AF3_QUEST_LEVEL"]                                = settings::get<uint8>("main.AF3_QUEST_LEVEL");
            j["OLDSCHOOL_G1"]                                   = settings::get<bool>("main.OLDSCHOOL_G1");
            j["OLDSCHOOL_G2"]                                   = settings::get<bool>("main.OLDSCHOOL_G2");
            j["FRIGICITE_TIME"]                                 = settings::get<uint8>("main.FRIGICITE_TIME");
            j["ASSAULT_MINIMUM"]                                = settings::get<uint8>("main.ASSAULT_MINIMUM");
            j["DIA_OVERWRITE"]                                  = settings::get<bool>("main.DIA_OVERWRITE");
            j["BIO_OVERWRITE"]                                  = settings::get<bool>("main.BIO_OVERWRITE");
            j["STONESKIN_CAP"]                                  = settings::get<uint16>("main.STONESKIN_CAP");
            j["BLINK_SHADOWS"]                                  = settings::get<uint8>("main.BLINK_SHADOWS");
            j["SPIKE_EFFECT_DURATION"]                          = settings::get<uint16>("main.SPIKE_EFFECT_DURATION");
            j["ELEMENTAL_DEBUFF_DURATION"]                      = settings::get<uint16>("main.ELEMENTAL_DEBUFF_DURATION");
            j["AQUAVEIL_COUNTER"]                               = settings::get<uint8>("main.AQUAVEIL_COUNTER");
            j["ABSORB_SPELL_AMOUNT"]                            = settings::get<uint8>("main.ABSORB_SPELL_AMOUNT");
            j["ABSORB_SPELL_TICK"]                              = settings::get<uint8>("main.ABSORB_SPELL_TICK");
            j["SNEAK_INVIS_DURATION_MULTIPLIER"]                = settings::get<uint8>("main.SNEAK_INVIS_DURATION_MULTIPLIER");
            j["USE_OLD_CURE_FORMULA"]                           = settings::get<bool>("main.USE_OLD_CURE_FORMULA");
            j["USE_OLD_MAGIC_DAMAGE"]                           = settings::get<bool>("main.USE_OLD_MAGIC_DAMAGE");
            j["EXPLORER_MOOGLE_LV"]                             = settings::get<uint8>("main.EXPLORER_MOOGLE_LV");
            j["HALLOWEEN_2005"]                                 = settings::get<bool>("main.HALLOWEEN_2005");
            j["HALLOWEEN_YEAR_ROUND"]                           = settings::get<bool>("main.HALLOWEEN_YEAR_ROUND");
            j["ENABLE_LOGIN_CAMPAIGN"]                          = settings::get<bool>("main.ENABLE_LOGIN_CAMPAIGN");
            j["RUNIC_DISK_SAVE"]                                = settings::get<bool>("main.RUNIC_DISK_SAVE");
            j["ENABLE_NYZUL_CASKETS"]                           = settings::get<bool>("main.ENABLE_NYZUL_CASKETS");
            j["ENABLE_VIGIL_DROPS"]                             = settings::get<bool>("main.ENABLE_VIGIL_DROPS");
            j["ACTIVATE_LAMP_TIME"]                             = settings::get<uint16>("main.ACTIVATE_LAMP_TIME");
            j["ENABLE_CHOCOBO_RAISING"]                         = settings::get<bool>("main.ENABLE_CHOCOBO_RAISING");
            j["DEBUG_CHOCOBO_RAISING"]                          = settings::get<bool>("main.DEBUG_CHOCOBO_RAISING");
            j["CHOCOBO_RAISING_STAT_POS_MULTIPLIER"]            = settings::get<float>("main.CHOCOBO_RAISING_STAT_POS_MULTIPLIER");
            j["CHOCOBO_RAISING_STAT_NEG_MULTIPLIER"]            = settings::get<float>("main.CHOCOBO_RAISING_STAT_NEG_MULTIPLIER");
            j["CHOCOBO_RAISING_GIL_MULTIPLIER"]                 = settings::get<float>("main.CHOCOBO_RAISING_GIL_MULTIPLIER");
            j["CHOCOBO_RAISING_DISABLE_RETIREMENT"]             = settings::get<bool>("main.CHOCOBO_RAISING_DISABLE_RETIREMENT");
            j["CHOCOBO_RAISING_STAT_GROWTH_CAP"]                = settings::get<uint16>("main.CHOCOBO_RAISING_STAT_GROWTH_CAP");
            j["RIVERNE_PORTERS"]                                = settings::get<uint8>("main.RIVERNE_PORTERS");
            j["LANTERNS_STAY_LIT"]                              = settings::get<uint16>("main.LANTERNS_STAY_LIT");
            j["ENABLE_COP_ZONE_CAP"]                            = settings::get<bool>("main.ENABLE_COP_ZONE_CAP");
            j["ALLOW_MULTIPLE_EXP_RINGS"]                       = settings::get<bool>("main.ALLOW_MULTIPLE_EXP_RINGS");
            j["BYPASS_EXP_RING_ONE_PER_WEEK"]                   = settings::get<bool>("main.BYPASS_EXP_RING_ONE_PER_WEEK");
            j["NUMBER_OF_DM_EARRINGS"]                          = settings::get<uint8>("main.NUMBER_OF_DM_EARRINGS");
            j["HOMEPOINT_TELEPORT"]                             = settings::get<bool>("main.HOMEPOINT_TELEPORT");
            j["DIG_ABUNDANCE_BONUS"]                            = settings::get<uint8>("main.DIG_ABUNDANCE_BONUS");
            j["DIG_FATIGUE"]                                    = settings::get<bool>("main.DIG_FATIGUE");
            j["DIG_GRANT_BURROW"]                               = settings::get<bool>("main.DIG_GRANT_BURROW");
            j["DIG_GRANT_BORE"]                                 = settings::get<bool>("main.DIG_GRANT_BORE");
            j["ENM_COOLDOWN"]                                   = settings::get<uint8>("main.ENM_COOLDOWN");
            j["FORCE_SPAWN_QM_RESET_TIME"]                      = settings::get<uint8>("main.FORCE_SPAWN_QM_RESET_TIME");
            j["EQUIP_FROM_OTHER_CONTAINERS"]                    = settings::get<float>("main.EQUIP_FROM_OTHER_CONTAINERS");
            j["REGIME_REWARD_THRESHOLD"]                        = settings::get<uint8>("main.REGIME_REWARD_THRESHOLD");
            j["DISABLE_INACTIVITY_WATCHDOG"]                    = settings::get<bool>("main.DISABLE_INACTIVITY_WATCHDOG");
            j["INACTIVITY_WATCHDOG_PERIOD"]                     = settings::get<uint16>("main.INACTIVITY_WATCHDOG_PERIOD");
            res.set_content(j.dump(4), "application/json");
        });

        m_httpServer.set_error_handler([](httplib::Request const& /*req*/, httplib::Response& res)
        {
            auto str = fmt::format("<p>Error Status: <span style='color:red;'>{} ({})</span></p>", res.status, httplib::detail::status_message(res.status));
            res.set_content(str, "text/html");
        });

        m_httpServer.set_logger([](httplib::Request const& req, httplib::Response const& res)
        {
            // https://developer.mozilla.org/en-US/docs/Web/HTTP/Status
            if (res.status >= 500)
            {
                ShowError(fmt::format("Server Error: {} ({})", res.status, httplib::detail::status_message(res.status)));
                return;
            }
            else if (res.status >= 400)
            {
                ShowError(fmt::format("Client Error: {} ({})", res.status, httplib::detail::status_message(res.status)));
                return;
            }
        });

        ShowInfo(fmt::format("Starting HTTP Server on http://{}:{}/api", host, port));
        m_httpServer.listen(host, port);
    });
    // clang-format on
}

HTTPServer::~HTTPServer()
{
    m_httpServer.stop();
}

void HTTPServer::LockingUpdate()
{
    std::unique_lock<std::mutex> lock(m_updateBottleneck);

    auto now = server_clock::now();
    if (now > (m_lastUpdate.load() + 60s))
    {
        ShowInfo("API data is stale. Updating...");

        auto sql  = std::make_unique<SqlConnection>();
        auto data = APIDataCache{};

        // Total active sessions
        {
            auto ret = sql->Query("SELECT COUNT(*) FROM accounts_sessions;");
            if (ret != SQL_ERROR && sql->NumRows() && sql->NextRow() == SQL_SUCCESS)
            {
                data.activeSessionCount = sql->GetUIntData(0);
            }
        }

        // Chars per zone
        {
            auto ret = sql->Query("SELECT chars.pos_zone, COUNT(*) AS `count` "
                                  "FROM chars "
                                  "LEFT JOIN accounts_sessions "
                                  "ON chars.charid = accounts_sessions.charid "
                                  "GROUP BY pos_zone;");
            if (ret != SQL_ERROR && sql->NumRows())
            {
                while (sql->NextRow() == SQL_SUCCESS)
                {
                    auto zoneId = sql->GetUIntData(0);
                    auto count  = sql->GetUIntData(1);

                    data.zonePlayerCounts[zoneId] = count;
                }
            }
        }

        m_apiDataCache = data;
        m_lastUpdate.store(now);
    }
}

Shadysoftdev · 2023-12-01T16:13:17Z

Shadysoftdev
Dec 1, 2023
Author

or into a map structure

/*
===========================================================================

Copyright (c) 2022 LandSandBoat Dev Teams

This program is free software: you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation, either version 3 of the License, or
(at your option) any later version.

This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
GNU General Public License for more details.

You should have received a copy of the GNU General Public License
along with this program.  If not, see http://www.gnu.org/licenses/

===========================================================================
*/

#include "http_server.h"

#include "common/logging.h"
#include "common/settings.h"
#include "common/sql.h"
#include "common/utils.h"

#include <nlohmann/json.hpp>
using json = nlohmann::json;

HTTPServer::HTTPServer()
{
    if (!settings::get<bool>("network.ENABLE_HTTP"))
    {
        return;
    }

    ts = std::make_unique<ts::task_system>(1);

    // NOTE: Everything registered in here happens off the main thread, so lock any global resources
    //     : you might be using.

    LockingUpdate();

    auto host = settings::get<std::string>("network.HTTP_HOST");
    auto port = settings::get<uint16>("network.HTTP_PORT");

    // clang-format off
    ts->schedule([this, host, port]()
    {
        m_httpServer.Get("/api", [&](httplib::Request const& req, httplib::Response& res)
        {
            res.set_content("Hello Squanchy API", "text/plain");
        });

        m_httpServer.Get("/api/sessions", [&](httplib::Request const& req, httplib::Response& res)
        {
            LockingUpdate();

            std::unique_lock<std::mutex> lock(m_updateBottleneck);
            json j;
            j = m_apiDataCache.activeSessionCount;
            res.set_content(j.dump(), "application/json");
        });

        m_httpServer.Get("/api/zones", [&](httplib::Request const& req, httplib::Response& res)
        {
            LockingUpdate();

            std::unique_lock<std::mutex> lock(m_updateBottleneck);
            json j = m_apiDataCache.zonePlayerCounts;
            res.set_content(j.dump(), "application/json");
        });

        m_httpServer.Get(R"(/api/zones/(\d+))", [&](httplib::Request const& req, httplib::Response& res)
        {
            auto maybeZoneId = req.matches[1].str();
            uint16 zoneId = std::strtol(maybeZoneId.c_str(), nullptr, 10);
            if (zoneId && zoneId < ZONEID::MAX_ZONEID)
            {
                LockingUpdate();

                std::unique_lock<std::mutex> lock(m_updateBottleneck);
                json j = m_apiDataCache.zonePlayerCounts[zoneId];
                res.set_content(j.dump(), "application/json");
            }
            else
            {
                res.status = 404;
            }
        });

        std::map<std::string, std::function<json()>> settingsMap = {
        {"SERVER_NAME",                                  []() { return settings::get<std::string>("main.SERVER_NAME"); } },
        {"SERVER_MESSAGE",                               []() { return settings::get<std::string>("main.SERVER_MESSAGE"); } },
        {"RESTRICT_CONTENT",                             []() { return settings::get<uint8>("main.RESTRICT_CONTENT"); } },
        {"ENABLE_COP",                                   []() { return settings::get<bool>("main.ENABLE_COP"); } },
        {"ENABLE_TOAU",                                  []() { return settings::get<bool>("main.ENABLE_TOAU"); } },
        {"ENABLE_WOTG",                                  []() { return settings::get<bool>("main.ENABLE_WOTG"); } },
        {"ENABLE_ACP",                                   []() { return settings::get<bool>("main.ENABLE_ACP"); } },
        {"ENABLE_AMK",                                   []() { return settings::get<bool>("main.ENABLE_AMK"); } },
        {"ENABLE_ASA",                                   []() { return settings::get<bool>("main.ENABLE_ASA"); } },
        {"ENABLE_ABYSSEA",                               []() { return settings::get<bool>("main.ENABLE_ABYSSEA"); } },
        {"ENABLE_SOA",                                   []() { return settings::get<bool>("main.ENABLE_SOA"); } },
        {"ENABLE_ROV",                                   []() { return settings::get<bool>("main.ENABLE_ROV"); } },
        {"ENABLE_VOIDWATCH",                             []() { return settings::get<bool>("main.ENABLE_VOIDWATCH"); } },
        {"ENABLE_FIELD_MANUALS",                         []() { return settings::get<bool>("main.ENABLE_FIELD_MANUALS"); } },
        {"ENABLE_GROUNDS_TOMES",                         []() { return settings::get<bool>("main.ENABLE_GROUNDS_TOMES"); } },
        {"ENABLE_SURVIVAL_GUIDE",                        []() { return settings::get<bool>("main.ENABLE_SURVIVAL_GUIDE"); } },
        {"REGIME_WAIT",                                  []() { return settings::get<uint8>("main.REGIME_WAIT"); } },
        {"FOV_REWARD_ALLIANCE",                          []() { return settings::get<uint8>("main.FOV_REWARD_ALLIANCE"); } },
        {"GOV_REWARD_ALLIANCE",                          []() { return settings::get<uint8>("main.GOV_REWARD_ALLIANCE"); } },
        {"ENABLE_DAILY_TALLY",                           []() { return settings::get<bool>("main.ENABLE_DAILY_TALLY"); } },
        {"DAILY_TALLY_AMOUNT",                           []() { return settings::get<uint8>("main.DAILY_TALLY_AMOUNT"); } },
        {"DAILY_TALLY_LIMIT",                            []() { return settings::get<uint16>("main.DAILY_TALLY_LIMIT"); } },
        {"GOBBIE_BOX_MIN_AGE",                           []() { return settings::get<uint8>("main.GOBBIE_BOX_MIN_AGE"); } },
        {"ENABLE_ROE",                                   []() { return settings::get<bool>("main.ENABLE_ROE"); } },
        {"ENABLE_ROE_TIMED",                             []() { return settings::get<bool>("main.ENABLE_ROE_TIMED"); } },
        {"ENABLE_EXCHANGE_LIMIT",                        []() { return settings::get<bool>("main.ENABLE_EXCHANGE_LIMIT"); } },
        {"WEEKLY_EXCHANGE_LIMIT",                        []() { return settings::get<uint32>("main.WEEKLY_EXCHANGE_LIMIT"); } },
        {"CAP_CURRENCY_ACCOLADES",                       []() { return settings::get<uint32>("main.CAP_CURRENCY_ACCOLADES"); } },
        {"CAP_CURRENCY_BALLISTA",                        []() { return settings::get<uint16>("main.CAP_CURRENCY_BALLISTA"); } },
        {"CAP_CURRENCY_SPARKS",                          []() { return settings::get<uint32>("main.CAP_CURRENCY_SPARKS"); } },
        {"CAP_CURRENCY_VALOR",                           []() { return settings::get<uint16>("main.CAP_CURRENCY_VALOR"); } },
        {"ENABLE_MAGIAN_TRIALS",                         []() { return settings::get<bool>("main.ENABLE_MAGIAN_TRIALS"); } },
        {"ENABLE_VOIDWALKER",                            []() { return settings::get<bool>("main.ENABLE_VOIDWALKER"); } },
        {"ENABLE_MONSTROSITY",                           []() { return settings::get<bool>("main.ENABLE_MONSTROSITY"); } },
        {"MONSTROSITY_INFAMY_RATIO",                     []() { return settings::get<double>("main.MONSTROSITY_INFAMY_RATIO"); } },
        {"MONSTROSITY_INFAMY_MESSAGING",                 []() { return settings::get<uint8>("main.MONSTROSITY_INFAMY_MESSAGING"); } },
        {"MONSTROSITY_TELEPORT_TO_FERETORY",             []() { return settings::get<uint8>("main.MONSTROSITY_TELEPORT_TO_FERETORY"); } },
        {"MONSTROSITY_TRIGGER_NPCS",                     []() { return settings::get<uint8>("main.MONSTROSITY_TRIGGER_NPCS"); } },
        {"MONSTROSITY_DONT_WIPE_BUFFS",                  []() { return settings::get<uint8>("main.MONSTROSITY_DONT_WIPE_BUFFS"); } },
        {"MONSTROSITY_PVP_MODE",                         []() { return settings::get<uint8>("main.MONSTROSITY_PVP_MODE"); } },
        {"MONSTROSITY_PVP_ZONE_BYPASS",                  []() { return settings::get<uint8>("main.MONSTROSITY_PVP_ZONE_BYPASS"); } },
        {"CASKET_DROP_RATE",                             []() { return settings::get<double>("main.CASKET_DROP_RATE"); } },
        {"ABYSSEA_LIGHTS_DROP_RATE",                     []() { return settings::get<uint8>("main.ABYSSEA_LIGHTS_DROP_RATE"); } },
        {"ABYSSEA_BONUSLIGHT_AMOUNT",                    []() { return settings::get<uint8>("main.ABYSSEA_BONUSLIGHT_AMOUNT"); } },
        {"INITIAL_LEVEL_CAP",                            []() { return settings::get<uint8>("main.INITIAL_LEVEL_CAP"); } },
        {"MAX_LEVEL",                                    []() { return settings::get<uint8>("main.MAX_LEVEL"); } },
        {"NORMAL_MOB_MAX_LEVEL_RANGE_MIN",               []() { return settings::get<uint8>("main.NORMAL_MOB_MAX_LEVEL_RANGE_MIN"); } },
        {"NORMAL_MOB_MAX_LEVEL_RANGE_MAX",               []() { return settings::get<uint8>("main.NORMAL_MOB_MAX_LEVEL_RANGE_MAX"); } },
        {"START_GIL",                                    []() { return settings::get<uint32>("main.START_GIL"); } },
        {"START_INVENTORY",                              []() { return settings::get<uint8>("main.START_INVENTORY"); } },
        {"NEW_CHARACTER_CUTSCENE",                       []() { return settings::get<uint8>("main.NEW_CHARACTER_CUTSCENE"); } },
        {"SUBJOB_QUEST_LEVEL",                           []() { return settings::get<uint8>("main.SUBJOB_QUEST_LEVEL"); } },
        {"ADVANCED_JOB_LEVEL",                           []() { return settings::get<uint8>("main.ADVANCED_JOB_LEVEL"); } },
        {"ALL_MAPS",                                     []() { return settings::get<uint8>("main.ALL_MAPS"); } },
        {"UNLOCK_OUTPOST_WARPS",                         []() { return settings::get<uint8>("main.UNLOCK_OUTPOST_WARPS"); } },
        {"SHOP_PRICE",                                   []() { return settings::get<float>("main.SHOP_PRICE"); } },
        {"GIL_RATE",                                     []() { return settings::get<float>("main.GIL_RATE"); } },
        {"BAYLD_RATE",                                   []() { return settings::get<float>("main.BAYLD_RATE"); } },
        {"EXP_RATE",                                     []() { return settings::get<float>("main.EXP_RATE"); } },
        {"CAPACITY_RATE",                                []() { return settings::get<float>("main.CAPACITY_RATE"); } },
        {"BOOK_EXP_RATE",                                []() { return settings::get<float>("main.BOOK_EXP_RATE"); } },
        {"TABS_RATE",                                    []() { return settings::get<float>("main.TABS_RATE"); } },
        {"ROE_EXP_RATE",                                 []() { return settings::get<float>("main.ROE_EXP_RATE"); } },
        {"SPARKS_RATE",                                  []() { return settings::get<float>("main.SPARKS_RATE"); } },
        {"CURE_POWER",                                   []() { return settings::get<float>("main.CURE_POWER"); } },
        {"ELEMENTAL_POWER",                              []() { return settings::get<float>("main.ELEMENTAL_POWER"); } },
        {"DIVINE_POWER",                                 []() { return settings::get<float>("main.DIVINE_POWER"); } },
        {"NINJUTSU_POWER",                               []() { return settings::get<float>("main.NINJUTSU_POWER"); } },
        {"BLUE_POWER",                                   []() { return settings::get<float>("main.BLUE_POWER"); } },
        {"DARK_POWER",                                   []() { return settings::get<float>("main.DARK_POWER"); } },
        {"ITEM_POWER",                                   []() { return settings::get<float>("main.ITEM_POWER"); } },
        {"WEAPON_SKILL_POWER",                           []() { return settings::get<float>("main.WEAPON_SKILL_POWER"); } },
        {"USE_ADOULIN_WEAPON_SKILL_CHANGES",             []() { return settings::get<bool>("main.USE_ADOULIN_WEAPON_SKILL_CHANGES"); } },
        {"DISABLE_PARTY_EXP_PENALTY",                    []() { return settings::get<bool>("main.DISABLE_PARTY_EXP_PENALTY"); } },
        {"ENABLE_IMMUNOBREAK",                           []() { return settings::get<bool>("main.ENABLE_IMMUNOBREAK"); } },
        {"ENABLE_TRUST_CASTING",                         []() { return settings::get<bool>("main.ENABLE_TRUST_CASTING"); } },
        {"ENABLE_TRUST_QUESTS",                          []() { return settings::get<bool>("main.ENABLE_TRUST_QUESTS"); } },
        {"ENABLE_TRUST_CUSTOM_ENGAGEMENT",               []() { return settings::get<bool>("main.ENABLE_TRUST_CUSTOM_ENGAGEMENT"); } },
        {"ENABLE_TRUST_ALTER_EGO_EXTRAVAGANZA",          []() { return settings::get<bool>("main.ENABLE_TRUST_ALTER_EGO_EXTRAVAGANZA"); } },
        {"ENABLE_TRUST_ALTER_EGO_EXTRAVAGANZA_ANNOUNCE", []() { return settings::get<bool>("main.ENABLE_TRUST_ALTER_EGO_EXTRAVAGANZA_ANNOUNCE"); } },
        {"ENABLE_TRUST_ALTER_EGO_EXPO",                  []() { return settings::get<bool>("main.ENABLE_TRUST_ALTER_EGO_EXPO"); } },
        {"ENABLE_TRUST_ALTER_EGO_EXPO_ANNOUNCE",         []() { return settings::get<bool>("main.ENABLE_TRUST_ALTER_EGO_EXPO_ANNOUNCE"); } },
        {"HARVESTING_BREAK_CHANCE",                      []() { return settings::get<uint8>("main.HARVESTING_BREAK_CHANCE"); } },
        {"EXCAVATION_BREAK_CHANCE",                      []() { return settings::get<uint8>("main.EXCAVATION_BREAK_CHANCE"); } },
        {"LOGGING_BREAK_CHANCE",                         []() { return settings::get<uint8>("main.LOGGING_BREAK_CHANCE"); } },
        {"MINING_BREAK_CHANCE",                          []() { return settings::get<uint8>("main.MINING_BREAK_CHANCE"); } },
        {"HARVESTING_RATE",                              []() { return settings::get<uint8>("main.HARVESTING_RATE"); } },
        {"EXCAVATION_RATE",                              []() { return settings::get<uint8>("main.EXCAVATION_RATE"); } },
        {"LOGGING_RATE",                                 []() { return settings::get<uint8>("main.LOGGING_RATE"); } },
        {"MINING_RATE",                                  []() { return settings::get<uint8>("main.MINING_RATE"); } },
        {"DIGGING_RATE",                                 []() { return settings::get<uint8>("main.DIGGING_RATE"); } },
        {"HEALING_TP_CHANGE",                            []() { return settings::get<uint8>("main.HEALING_TP_CHANGE"); } },
        {"COFFER_MAX_ILLUSION_TIME",                     []() { return settings::get<uint16>("main.COFFER_MAX_ILLUSION_TIME"); } },
        {"COFFER_MIN_ILLUSION_TIME",                     []() { return settings::get<uint16>("main.COFFER_MIN_ILLUSION_TIME"); } },
        {"CHEST_MAX_ILLUSION_TIME",                      []() { return settings::get<uint16>("main.CHEST_MAX_ILLUSION_TIME"); } },
        {"CHEST_MIN_ILLUSION_TIME",                      []() { return settings::get<uint16>("main.CHEST_MIN_ILLUSION_TIME"); } },
        {"NM_LOTTERY_CHANCE",                            []() { return settings::get<float>("main.NM_LOTTERY_CHANCE"); } },
        {"NM_LOTTERY_COOLDOWN",                          []() { return settings::get<float>("main.NM_LOTTERY_COOLDOWN"); } },
        {"ENABLE_GARRISON",                              []() { return settings::get<bool>("main.ENABLE_GARRISON"); } },
        {"GARRISON_LOCKOUT",                             []() { return settings::get<uint16>("main.GARRISON_LOCKOUT"); } },
        {"GARRISON_TIME_LIMIT",                          []() { return settings::get<uint16>("main.GARRISON_TIME_LIMIT"); } },
        {"GARRISON_ONCE_PER_WEEK",                       []() { return settings::get<bool>("main.GARRISON_ONCE_PER_WEEK"); } },
        {"GARRISON_PARTY_LIMIT",                         []() { return settings::get<uint8>("main.GARRISON_PARTY_LIMIT"); } },
        {"GARRISON_NATION_BYPASS",                       []() { return settings::get<bool>("main.GARRISON_NATION_BYPASS"); } },
        {"GARRISON_RANK",                                []() { return settings::get<uint8>("main.GARRISON_RANK"); } },
        {"BETWEEN_2DYNA_WAIT_TIME",                      []() { return settings::get<uint8>("main.BETWEEN_2DYNA_WAIT_TIME"); } },
        {"DYNA_MIDNIGHT_RESET",                          []() { return settings::get<bool>("main.DYNA_MIDNIGHT_RESET"); } },
        {"DYNA_LEVEL_MIN",                               []() { return settings::get<uint8>("main.DYNA_LEVEL_MIN"); } },
        {"TIMELESS_HOURGLASS_COST",                      []() { return settings::get<uint16>("main.TIMELESS_HOURGLASS_COST"); } },
        {"PRISMATIC_HOURGLASS_COST",                     []() { return settings::get<uint16>("main.PRISMATIC_HOURGLASS_COST"); } },
        {"CURRENCY_EXCHANGE_RATE",                       []() { return settings::get<uint8>("main.CURRENCY_EXCHANGE_RATE"); } },
        {"ENABLE_EXCHANGE_100S_TO_1S",                   []() { return settings::get<bool>("main.ENABLE_EXCHANGE_100S_TO_1S"); } },
        {"RELIC_2ND_UPGRADE_WAIT_TIME",                  []() { return settings::get<uint16>("main.RELIC_2ND_UPGRADE_WAIT_TIME"); } },
        {"RELIC_3RD_UPGRADE_WAIT_TIME",                  []() { return settings::get<uint16>("main.RELIC_3RD_UPGRADE_WAIT_TIME"); } },
        {"FREE_COP_DYNAMIS",                             []() { return settings::get<bool>("main.FREE_COP_DYNAMIS"); } },
        {"COSMO_CLEANSE_BASE_COST",                      []() { return settings::get<uint16>("main.COSMO_CLEANSE_BASE_COST"); } },
        {"AF1_QUEST_LEVEL",                              []() { return settings::get<uint8>("main.AF1_QUEST_LEVEL"); } },
        {"AF2_QUEST_LEVEL",                              []() { return settings::get<uint8>("main.AF2_QUEST_LEVEL"); } },
        {"AF3_QUEST_LEVEL",                              []() { return settings::get<uint8>("main.AF3_QUEST_LEVEL"); } },
        {"OLDSCHOOL_G1",                                 []() { return settings::get<bool>("main.OLDSCHOOL_G1"); } },
        {"OLDSCHOOL_G2",                                 []() { return settings::get<bool>("main.OLDSCHOOL_G2"); } },
        {"FRIGICITE_TIME",                               []() { return settings::get<uint8>("main.FRIGICITE_TIME"); } },
        {"ASSAULT_MINIMUM",                              []() { return settings::get<uint8>("main.ASSAULT_MINIMUM"); } },
        {"DIA_OVERWRITE",                                []() { return settings::get<uint8>("main.DIA_OVERWRITE"); } },
        {"BIO_OVERWRITE",                                []() { return settings::get<uint8>("main.BIO_OVERWRITE"); } },
        {"STONESKIN_CAP",                                []() { return settings::get<uint16>("main.STONESKIN_CAP"); } },
        {"BLINK_SHADOWS",                                []() { return settings::get<uint8>("main.BLINK_SHADOWS"); } },
        {"SPIKE_EFFECT_DURATION",                        []() { return settings::get<uint16>("main.SPIKE_EFFECT_DURATION"); } },
        {"ELEMENTAL_DEBUFF_DURATION",                    []() { return settings::get<uint8>("main.ELEMENTAL_DEBUFF_DURATION"); } },
        {"AQUAVEIL_COUNTER",                             []() { return settings::get<uint8>("main.AQUAVEIL_COUNTER"); } },
        {"ABSORB_SPELL_AMOUNT",                          []() { return settings::get<uint8>("main.ABSORB_SPELL_AMOUNT"); } },
        {"ABSORB_SPELL_TICK",                            []() { return settings::get<uint8>("main.ABSORB_SPELL_TICK"); } },
        {"SNEAK_INVIS_DURATION_MULTIPLIER",              []() { return settings::get<uint8>("main.SNEAK_INVIS_DURATION_MULTIPLIER"); } },
        {"USE_OLD_CURE_FORMULA",                         []() { return settings::get<bool>("main.USE_OLD_CURE_FORMULA"); } },
        {"USE_OLD_MAGIC_DAMAGE",                         []() { return settings::get<bool>("main.USE_OLD_MAGIC_DAMAGE"); } },
        {"EXPLORER_MOOGLE_LV",                           []() { return settings::get<uint8>("main.EXPLORER_MOOGLE_LV"); } },
        {"HALLOWEEN_2005",                               []() { return settings::get<uint8>("main.HALLOWEEN_2005"); } },
        {"HALLOWEEN_YEAR_ROUND",                         []() { return settings::get<uint8>("main.HALLOWEEN_YEAR_ROUND"); } },
        {"ENABLE_LOGIN_CAMPAIGN",                        []() { return settings::get<bool>("main.ENABLE_LOGIN_CAMPAIGN"); } },
        {"RUNIC_DISK_SAVE",                              []() { return settings::get<bool>("main.RUNIC_DISK_SAVE"); } },
        {"ENABLE_NYZUL_CASKETS",                         []() { return settings::get<bool>("main.ENABLE_NYZUL_CASKETS"); } },
        {"ENABLE_VIGIL_DROPS",                           []() { return settings::get<bool>("main.ENABLE_VIGIL_DROPS"); } },
        {"ACTIVATE_LAMP_TIME",                           []() { return settings::get<uint16>("main.ACTIVATE_LAMP_TIME"); } },
        {"ENABLE_CHOCOBO_RAISING",                       []() { return settings::get<bool>("main.ENABLE_CHOCOBO_RAISING"); } },
        {"DEBUG_CHOCOBO_RAISING",                        []() { return settings::get<bool>("main.DEBUG_CHOCOBO_RAISING"); } },
        {"CHOCOBO_RAISING_STAT_POS_MULTIPLIER",          []() { return settings::get<float>("main.CHOCOBO_RAISING_STAT_POS_MULTIPLIER"); } },
        {"CHOCOBO_RAISING_STAT_NEG_MULTIPLIER",          []() { return settings::get<float>("main.CHOCOBO_RAISING_STAT_NEG_MULTIPLIER"); } },
        {"CHOCOBO_RAISING_GIL_MULTIPLIER",               []() { return settings::get<float>("main.CHOCOBO_RAISING_GIL_MULTIPLIER"); } },
        {"CHOCOBO_RAISING_DISABLE_RETIREMENT",           []() { return settings::get<bool>("main.CHOCOBO_RAISING_DISABLE_RETIREMENT"); } },
        {"CHOCOBO_RAISING_STAT_GROWTH_CAP",              []() { return settings::get<uint16>("main.CHOCOBO_RAISING_STAT_GROWTH_CAP"); } },
        {"RIVERNE_PORTERS",                              []() { return settings::get<uint8>("main.RIVERNE_PORTERS"); } },
        {"LANTERNS_STAY_LIT",                            []() { return settings::get<uint16>("main.LANTERNS_STAY_LIT"); } },
        {"ENABLE_COP_ZONE_CAP",                          []() { return settings::get<bool>("main.ENABLE_COP_ZONE_CAP"); } },
        {"ALLOW_MULTIPLE_EXP_RINGS",                     []() { return settings::get<bool>("main.ALLOW_MULTIPLE_EXP_RINGS"); } },
        {"BYPASS_EXP_RING_ONE_PER_WEEK",                 []() { return settings::get<bool>("main.BYPASS_EXP_RING_ONE_PER_WEEK"); } },
        {"NUMBER_OF_DM_EARRINGS",                        []() { return settings::get<uint8>("main.NUMBER_OF_DM_EARRINGS"); } },
        {"HOMEPOINT_TELEPORT",                           []() { return settings::get<bool>("main.HOMEPOINT_TELEPORT"); } },
        {"DIG_ABUNDANCE_BONUS",                          []() { return settings::get<uint8>("main.DIG_ABUNDANCE_BONUS"); } },
        {"DIG_FATIGUE",                                  []() { return settings::get<bool>("main.DIG_FATIGUE"); } },
        {"DIG_GRANT_BURROW",                             []() { return settings::get<bool>("main.DIG_GRANT_BURROW"); } },
        {"DIG_GRANT_BORE",                               []() { return settings::get<bool>("main.DIG_GRANT_BORE"); } },
        {"ENM_COOLDOWN",                                 []() { return settings::get<uint8>("main.ENM_COOLDOWN"); } },
        {"FORCE_SPAWN_QM_RESET_TIME",                    []() { return settings::get<uint8>("main.FORCE_SPAWN_QM_RESET_TIME"); } },
        {"EQUIP_FROM_OTHER_CONTAINERS",                  []() { return settings::get<float>("main.EQUIP_FROM_OTHER_CONTAINERS"); } },
        {"REGIME_REWARD_THRESHOLD",                      []() { return settings::get<uint8>("main.REGIME_REWARD_THRESHOLD"); } },
        {"DISABLE_INACTIVITY_WATCHDOG",                  []() { return settings::get<bool>("main.DISABLE_INACTIVITY_WATCHDOG"); } },
        {"INACTIVITY_WATCHDOG_PERIOD",                   []() { return settings::get<uint16>("main.INACTIVITY_WATCHDOG_PERIOD"); } },

        };

        m_httpServer.Get("/api/settings", [&](httplib::Request const& req, httplib::Response& res)
        {
            json j;
            for (const auto& [key, func] : settingsMap) {
                j[key] = func();
            }
            res.set_content(j.dump(4), "application/json");
        });

        m_httpServer.set_error_handler([](httplib::Request const& /*req*/, httplib::Response& res)
        {
            auto str = fmt::format("<p>Error Status: <span style='color:red;'>{} ({})</span></p>", res.status, httplib::detail::status_message(res.status));
            res.set_content(str, "text/html");
        });

        m_httpServer.set_logger([](httplib::Request const& req, httplib::Response const& res)
        {
            // https://developer.mozilla.org/en-US/docs/Web/HTTP/Status
            if (res.status >= 500)
            {
                ShowError(fmt::format("Server Error: {} ({})", res.status, httplib::detail::status_message(res.status)));
                return;
            }
            else if (res.status >= 400)
            {
                ShowError(fmt::format("Client Error: {} ({})", res.status, httplib::detail::status_message(res.status)));
                return;
            }
        });

        ShowInfo(fmt::format("Starting HTTP Server on http://{}:{}/api", host, port));
        m_httpServer.listen(host, port);
    });
    // clang-format on
}

HTTPServer::~HTTPServer()
{
    m_httpServer.stop();
}

void HTTPServer::LockingUpdate()
{
    std::unique_lock<std::mutex> lock(m_updateBottleneck);

    auto now = server_clock::now();
    if (now > (m_lastUpdate.load() + 60s))
    {
        ShowInfo("API data is stale. Updating...");

        auto sql  = std::make_unique<SqlConnection>();
        auto data = APIDataCache{};

        // Total active sessions
        {
            auto ret = sql->Query("SELECT COUNT(*) FROM accounts_sessions;");
            if (ret != SQL_ERROR && sql->NumRows() && sql->NextRow() == SQL_SUCCESS)
            {
                data.activeSessionCount = sql->GetUIntData(0);
            }
        }

        // Chars per zone
        {
            auto ret = sql->Query("SELECT chars.pos_zone, COUNT(*) AS `count` "
                                  "FROM chars "
                                  "LEFT JOIN accounts_sessions "
                                  "ON chars.charid = accounts_sessions.charid "
                                  "GROUP BY pos_zone;");
            if (ret != SQL_ERROR && sql->NumRows())
            {
                while (sql->NextRow() == SQL_SUCCESS)
                {
                    auto zoneId = sql->GetUIntData(0);
                    auto count  = sql->GetUIntData(1);

                    data.zonePlayerCounts[zoneId] = count;
                }
            }
        }

        m_apiDataCache = data;
        m_lastUpdate.store(now);
    }
}

0 replies

Shadysoftdev · 2023-12-01T17:49:56Z

Shadysoftdev
Dec 1, 2023
Author

Created a Python script to extract the settings from the main.lua so if it is updated it will pull the new settings and create the http_server.cpp

0 replies

zach2good · 2023-12-10T12:36:28Z

zach2good
Dec 10, 2023
Maintainer

This approach won't safely scale over time. As new settings are added and old settings are removed, these hard-coded entries will rot. I'm also not keen to introduce a script to populate this, given that it's not a well-used or widely-known feature.

A better way of handling this (especially because settings are backed with std::variant is to use std::visit to be able to interrogate every setting and get the correct type out of it, and then publish into the JSON object that's going to be published.

https://en.cppreference.com/w/cpp/utility/variant/visit

The settings output JSON also needs to be cached.

2 replies

zach2good Dec 10, 2023
Maintainer

There's also the idea that only a specific subset of settings will want to be published. This was written to be an API that a central service will call out to to populate a global listing of private servers and what their features are. Not all settings are relevant or desirable to publish, so I'd probably go for populating everything with std::visit, and then strip out the more sensitive ones based on key. It's less important that the list of exceptions rots than the actual list of settings.

zach2good Dec 17, 2023
Maintainer

I've implemented this here: 4a92fa0

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Updated http_server.cpp api/settings data #4782

{{title}}

{{editor}}'s edit

{{editor}}'s edit

Replies: 3 comments 2 replies

{{title}}

{{title}}

{{editor}}'s edit

{{editor}}'s edit

{{title}}

{{title}}

{{title}}

Select a reply

Updated http_server.cpp api/settings data #4782

Shadysoftdev Nov 30, 2023

Replies: 3 comments · 2 replies

Shadysoftdev Dec 1, 2023 Author

Shadysoftdev Dec 1, 2023 Author

zach2good Dec 10, 2023 Maintainer

zach2good Dec 10, 2023 Maintainer

zach2good Dec 17, 2023 Maintainer

Shadysoftdev
Nov 30, 2023

Replies: 3 comments 2 replies

Shadysoftdev
Dec 1, 2023
Author

Shadysoftdev
Dec 1, 2023
Author

zach2good
Dec 10, 2023
Maintainer

zach2good Dec 10, 2023
Maintainer

zach2good Dec 17, 2023
Maintainer