db.cpp

/*
	Game server for Alien Front Online.
    Copyright (C) 2025  Flyinghead

    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 <https://www.gnu.org/licenses/>.
*/
#include "db.h"
#include "log.h"
#include <dcserver/database.hpp>
#include <stdexcept>

static std::string dbPath;

void setDatabasePath(const std::string& databasePath)
{
	::dbPath = databasePath;
	Database db(dbPath);
}

std::string getTop10Scores()
{
	try {
		Database db(dbPath);
		Statement stmt(db, "SELECT SCORE, PLAYER_NAME, ARCADE_NAME, CITY, STATE FROM RANKING ORDER BY SCORE DESC LIMIT 10");
		std::string scores;
		while (stmt.step())
		{
			if (!scores.empty())
				scores += '&';
			scores += stmt.getStringColumn(0) 			// score
					+ ':' + stmt.getStringColumn(1)		// player name
					+ ':' + stmt.getStringColumn(2)		// arcade name
					+ ':' + stmt.getStringColumn(3)		// city
					+ ':' + stmt.getStringColumn(4);	// state
		}
		return scores;
	} catch (const std::runtime_error& e) {
		ERROR_LOG("getUserRecord: %s", e.what());
	}
	return {};
}

void registerNewDcScore(int score, const std::string& player)
{
	registerNewScore(score, player, "Dreamcast", "Dreamcast", "");
}

void registerNewScore(int score, const std::string& player, const std::string& arcade, const std::string& city, const std::string& state)
{
	if (score == 0 || player.empty())
		return;
	Database db;
	try {
		db.open(dbPath);
		Statement stmt(db, "UPDATE RANKING SET SCORE = MAX(SCORE, ?), DATE = strftime('%s') WHERE PLAYER_NAME = ? AND ARCADE_NAME = ? AND CITY = ? AND STATE = ?");
		stmt.bind(1, score);
		stmt.bind(2, player);
		stmt.bind(3, arcade);
		stmt.bind(4, city);
		stmt.bind(5, state);
		stmt.step();
		if (stmt.changedRows() > 0)
			return;
	} catch (const std::runtime_error& e) {
		ERROR_LOG("registerNewScore UPDATE: %s", e.what());
	}
	try {
		Statement stmt(db, "INSERT INTO RANKING (SCORE, PLAYER_NAME, ARCADE_NAME, CITY, STATE, DATE) VALUES (?, ?, ?, ?, ?, strftime('%s'))");
		stmt.bind(1, score);
		stmt.bind(2, player);
		stmt.bind(3, arcade);
		stmt.bind(4, city);
		stmt.bind(5, state);
		stmt.step();

	} catch (const std::runtime_error& e) {
		ERROR_LOG("registerNewScore INSERT: %s", e.what());
	}
}