also write platform_id and platform to db.

Author: Ughuuu

src/authentication/authentication_thread.cpp

@@ -38,8 +38,10 @@ void AuthenticationThread::run() {
                 // check if the user has a peer_id associated with the reconnection_token if db
                 // enabled
                 if (db.enabled) {
+                    user_data.platform_id = user_data.reconnection_token;
                     user_data.id = db.get_peer_or_insert(user_data.reconnection_token,
-                                                         user_data.game_id, user_data.id);
+                                                         user_data.game_id, user_data.id,
+                                                         user_data.platform_id, user_data.platform);
                 }
                 logger.debug_log("[WebSocketServer] upgraded anon user: ", user_data.game_id, " ",
                                  user_data.id);

src/database/database.cpp

@@ -81,6 +81,8 @@ void Database::connect_to_db() {
             "id TEXT NOT NULL, "
             "peer_id TEXT NOT NULL, "
             "name TEXT NOT NULL, "
+            "platform_id TEXT NOT NULL, "
+            "platform TEXT NOT NULL, "
             "game_id TEXT NOT NULL, "
             "timestamp TIMESTAMPTZ DEFAULT NOW(), "
             "PRIMARY KEY (id, game_id),"
@@ -155,11 +157,6 @@ void Database::set_user_data(const std::string& game_id, const std::string& peer
         }
     }
 
-    if (name.empty()) {
-        std::cerr << "Name is required for user data" << std::endl;
-        return;
-    }
-
     pqxx::work txn(*connection);
 
     // Only update existing row
@@ -225,7 +222,9 @@ std::tuple<int64_t, int, std::string, std::string> Database::leaderboard_get_use
     return {score, rank, timestamp, name};
 }
 std::string Database::get_peer_or_insert(const std::string& reconnection_token,
-                                         const std::string& game_id, const std::string& peer_id) {
+                                         const std::string& game_id, const std::string& peer_id,
+                                         const std::string platform_id,
+                                         const std::string& platform) {
     ensure_connection();
     pqxx::work txn(*connection);
 
@@ -241,8 +240,9 @@ std::string Database::get_peer_or_insert(const std::string& reconnection_token,
     }
 
     // Not found, insert new peer
-    txn.exec(pqxx::zview("INSERT INTO peers (id, peer_id, name, game_id) VALUES ($1, $2, $3, $4);"),
-             pqxx::params(reconnection_token, peer_id, "", game_id));
+    txn.exec(pqxx::zview("INSERT INTO peers (id, peer_id, name, game_id, platform_id, platform) "
+                         "VALUES ($1, $2, $3, $4, $5, $6);"),
+             pqxx::params(reconnection_token, peer_id, "", game_id, platform_id, platform));
     txn.commit();
     return peer_id;
 }

src/database/database.h

@@ -19,7 +19,8 @@ class Database {
     void leaderboard_set_score(const std::string& leaderboard_id, const std::string& game_id,
                                const std::string& user_id, int64_t score, std::string& mode);
     std::string get_peer_or_insert(const std::string& reconnection_token,
-                                   const std::string& game_id, const std::string& peer_id);
+                                   const std::string& game_id, const std::string& peer_id,
+                                   const std::string platform_id, const std::string& platform);
     void set_user_data(const std::string& game_id, const std::string& peer_id,
                        const boost::container::flat_map<std::string, AnyElement>& user_data);
     std::vector<std::tuple<std::string, int64_t, std::string>> leaderboard_get_top(