24 #include <boost/asio/post.hpp> 30 #define ERR_UH LOG_STREAM(err, log_mp_user_handler) 31 #define WRN_UH LOG_STREAM(warn, log_mp_user_handler) 32 #define LOG_UH LOG_STREAM(info, log_mp_user_handler) 33 #define DBG_UH LOG_STREAM(debug, log_mp_user_handler) 36 const int USER_INACTIVE = 1;
37 const int USER_IGNORE = 2;
42 , db_users_table_(c[
"db_users_table"].str())
43 , db_extra_table_(c[
"db_extra_table"].str())
47 mp_mod_group_ = std::stoi(c[
"mp_mod_group"].str());
49 ERR_UH <<
"Failed to convert the mp_mod_group value of '" << c[
"mp_mod_group"].str() <<
"' into an int! Defaulting to " << mp_mod_group_ <<
".";
56 std::string hash = get_hashed_password_from_db(name);
59 return password == hash;
61 ERR_UH <<
"Invalid hash for user '" << name <<
"'";
64 }
catch (
const error&
e) {
65 ERR_UH <<
"Could not retrieve hash for user '" << name <<
"' :" << e.message;
80 hash = get_hashed_password_from_db(name);
81 }
catch (
const error&
e) {
82 ERR_UH <<
"Could not retrieve hash for user '" << name <<
"' :" << e.message;
87 return hash.substr(0,12);
93 ERR_UH <<
"Error getting salt from hash of user '" << name <<
"': " << err.
what();
102 conn_.write_user_int(
"user_lastvisit", name, static_cast<int>(std::time(
nullptr)));
106 return conn_.user_exists(name);
110 return conn_.get_forum_id(name);
114 int user_type = conn_.get_user_int(
db_users_table_,
"user_type", name);
115 return user_type != USER_INACTIVE && user_type != USER_IGNORE;
122 return conn_.get_user_int(
db_extra_table_,
"user_is_moderator", name) == 1 || (mp_mod_group_ != 0 && conn_.is_user_in_group(name, mp_mod_group_));
129 conn_.write_user_int(
"user_is_moderator", name, is_moderator);
140 LOG_UH <<
"User '" << name <<
"' ip " << addr <<
" banned by IP address";
143 LOG_UH <<
"User '" << name <<
"' uid " << b.
get_user_id() <<
" banned by uid";
146 LOG_UH <<
"User '" << name <<
"' email " << b.
get_email() <<
" banned by email address";
149 ERR_UH <<
"Invalid ban type '" << b.
get_ban_type() <<
"' returned for user '" << name <<
"'";
156 throw error(
"No user with the name '" + name +
"' exists.");
159 std::time_t reg_date = get_registrationdate(name);
160 std::time_t ll_date = get_lastlogin(name);
162 std::string reg_string = ctime(®_date);
163 std::string ll_string;
166 ll_string = ctime(&ll_date);
168 ll_string =
"Never\n";
171 std::stringstream
info;
172 info <<
"Name: " << name <<
"\n" 173 <<
"Registered: " << reg_string
174 <<
"Last login: " << ll_string;
175 if(!user_is_active(name)) {
176 info <<
"This account is currently inactive.\n";
191 return conn_.update_addon_download_count(instance_version,
id, version);
195 return std::time_t(conn_.get_user_int(
db_extra_table_,
"user_lastvisit", user));
199 return std::time_t(conn_.get_user_int(
db_users_table_,
"user_regdate", user));
203 return conn_.get_uuid();
207 return conn_.get_tournaments();
211 boost::asio::post([
this, &s, player, player_id, offset, &io_service] {
212 boost::asio::post(io_service, [player, &s, doc = conn_.get_game_history(player_id, offset)]{
218 void fuh::db_insert_game_info(
const std::string& uuid,
int game_id,
const std::string& version,
const std::string& name,
int reload,
int observers,
int is_public,
int has_password){
219 conn_.insert_game_info(uuid, game_id, version, name, reload, observers, is_public, has_password);
223 conn_.update_game_end(uuid, game_id, replay_location);
226 void fuh::db_insert_game_player_info(
const std::string& uuid,
int game_id,
const std::string& username,
int side_number,
int is_host,
const std::string& faction,
const std::string& version,
const std::string& source,
const std::string& current_user){
227 conn_.insert_game_player_info(uuid, game_id, username, side_number, is_host, faction, version, source, current_user);
230 unsigned long long fuh::db_insert_game_content_info(
const std::string& uuid,
int game_id,
const std::string&
type,
const std::string& name,
const std::string&
id,
const std::string& addon_id,
const std::string& addon_version){
231 return conn_.insert_game_content_info(uuid, game_id, type, name,
id, addon_id, addon_version);
235 conn_.set_oos_flag(uuid, game_id);
239 boost::asio::post([
this, limit, &io_service] {
240 ERR_UH <<
"async test query starts!";
241 int i = conn_.async_test_query(limit);
242 boost::asio::post(io_service, [i]{ ERR_UH <<
"async test query output: " <<
i; });
247 return conn_.topic_id_exists(topic_id);
250 void fuh::db_insert_addon_info(
const std::string& instance_version,
const std::string&
id,
const std::string& name,
const std::string& type,
const std::string& version,
bool forum_auth,
int topic_id,
const std::string uploader) {
251 conn_.insert_addon_info(instance_version,
id, name, type, version, forum_auth, topic_id, uploader);
254 unsigned long long fuh::db_insert_login(
const std::string& username,
const std::string& ip,
const std::string& version) {
255 return conn_.insert_login(username, ip, version);
259 conn_.update_logout(login_id);
263 conn_.get_users_for_ip(ip, out);
267 conn_.get_ips_for_user(username, out);
271 return conn_.is_user_author(instance_version,
id, username, 1);
275 return conn_.is_user_author(instance_version,
id, username, 0);
279 conn_.delete_addon_authors(instance_version,
id);
282 void fuh::db_insert_addon_authors(
const std::string& instance_version,
const std::string&
id,
const std::string& primary_author,
const std::vector<std::string>& secondary_authors) {
283 conn_.insert_addon_author(instance_version,
id, primary_author, 1);
286 std::set<std::string> inserted_authors;
287 inserted_authors.emplace(primary_author);
289 for(
const std::string& secondary_author : secondary_authors) {
290 if(inserted_authors.count(secondary_author) == 0) {
291 inserted_authors.emplace(secondary_author);
292 conn_.insert_addon_author(instance_version,
id, secondary_author, 0);
298 return conn_.do_any_authors_exist(instance_version,
id);
301 #endif //HAVE_MYSQLPP
unsigned long long db_insert_login(const std::string &username, const std::string &ip, const std::string &version)
Inserts into the database for when a player logs in.
void db_update_addon_download_count(const std::string &instance_version, const std::string &id, const std::string &version)
Increments the download count for this add-on for the specific version.
static bool is_valid_prefix(const std::string &hash)
void user_logged_in(const std::string &name)
Sets the last login time to the current time.
std::time_t get_lastlogin(const std::string &user)
bool db_is_user_primary_author(const std::string &instance_version, const std::string &id, const std::string &username)
Checks whether the provided username is the primary author of the add-on.
std::string user_info(const std::string &name)
bool user_exists(const std::string &name)
player_connections::const_iterator player_iterator
void set_is_moderator(const std::string &name, const bool &is_moderator)
Sets or unsets whether the player should be considered a moderator in the extra table.
fuh(const config &c)
Reads wesnothd's config for the data needed to initialize this class and dbconn.
void async_get_and_send_game_history(boost::asio::io_service &io_service, wesnothd::server &s, wesnothd::player_iterator player, int player_id, int offset)
Runs an asynchronous query to fetch the user's game history data.
long get_forum_id(const std::string &name)
void db_insert_addon_info(const std::string &instance_version, const std::string &id, const std::string &name, const std::string &type, const std::string &version, bool forum_auth, int topic_id, const std::string uploader)
Inserts information about an uploaded add-on into the database.
static bool is_valid_hash(const std::string &hash)
ban_info user_is_banned(const std::string &name, const std::string &addr)
bool db_topic_id_exists(int topic_id)
Checks whether a forum thread with topic_id exists.
bool db_is_user_secondary_author(const std::string &instance_version, const std::string &id, const std::string &username)
Checks whether the provided username is a secondary author of the add-on.
const char * what() const noexcept
std::string get_tournaments()
void db_insert_addon_authors(const std::string &instance_version, const std::string &id, const std::string &primary_author, const std::vector< std::string > &secondary_authors)
Inserts rows for the primary and secondary authors for a particular addon and version.
bool db_do_any_authors_exist(const std::string &instance_version, const std::string &id)
Checks whether any author information exists for a particular addon and version, since if there's no ...
void db_set_oos_flag(const std::string &uuid, int game_id)
Sets the OOS flag in the database if wesnothd is told by a client it has detected an OOS error...
void send_to_player(player_iterator player, simple_wml::document &data)
unsigned long long db_insert_game_content_info(const std::string &uuid, int game_id, const std::string &type, const std::string &name, const std::string &id, const std::string &addon_id, const std::string &addon_version)
Inserts information about the content being played.
bool user_exists(const std::string &name)
bool user_is_active(const std::string &name)
static map_location::DIRECTION s
std::string password(const std::string &server, const std::string &login)
static bcrypt from_hash_string(const std::string &input)
std::time_t get_registrationdate(const std::string &user)
bool user_is_moderator(const std::string &name)
void db_update_logout(unsigned long long login_id)
Updates the database for when a player logs out.
void db_insert_game_info(const std::string &uuid, int game_id, const std::string &version, const std::string &name, int reload, int observers, int is_public, int has_password)
Inserts game related information.
std::string db_users_table_
The name of the table that contains forum user information.
std::string get_hashed_password_from_db(const std::string &user)
void get_users_for_ip(const std::string &ip, std::ostringstream *out)
Searches for all players that logged in using the ip address.
std::string get_salt() const
A config object defines a single node in a WML file, with access to child nodes.
std::string extract_salt(const std::string &name)
Needed because the hashing algorithm used by phpbb requires some info from the original hash to recre...
std::string get_user_email(const std::string &user)
void db_update_game_end(const std::string &uuid, int game_id, const std::string &replay_location)
Update the game related information when the game ends.
bool login(const std::string &name, const std::string &password)
Retrieves the player's hashed password from the phpbb forum database and checks if it matches the has...
void db_delete_addon_authors(const std::string &instance_version, const std::string &id)
Removes the authors information from addon_author for a particular addon and version.
void async_test_query(boost::asio::io_service &io_service, int limit)
A simple test query for running a query asynchronously.
void get_ips_for_user(const std::string &username, std::ostringstream *out)
Searches for all ip addresses used by the player.
void db_insert_game_player_info(const std::string &uuid, int game_id, const std::string &username, int side_number, int is_host, const std::string &faction, const std::string &version, const std::string &source, const std::string ¤t_user)
Inserts player information per side.
std::string db_extra_table_
The name of the table that contains additional user information.