feat: game reporting database tables and store game report

Author: jacobtread

Cargo.lock

@@ -82,7 +82,13 @@ rand = "0.9"
 [dependencies.sea-orm]
 version = "^1"
 default-features = false
-features = ["runtime-tokio-rustls", "macros", "with-chrono", "sqlx-sqlite"]
+features = [
+    "runtime-tokio-rustls",
+    "macros",
+    "with-chrono",
+    "with-json",
+    "sqlx-sqlite",
+]
 
 # SeaORM Migration 
 [dependencies.sea-orm-migration]

Cargo.toml

@@ -0,0 +1,78 @@
+use crate::{
+    database::DbResult,
+    utils::{
+        parsing::player_character::{PlayerCharacterPower, PlayerCharacterWeaponMod, WeaponId},
+        types::PlayerID,
+    },
+};
+use futures_util::future::BoxFuture;
+use sea_orm::{entity::prelude::*, ActiveValue::Set, FromJsonQueryResult};
+use serde::{Deserialize, Serialize};
+use std::collections::HashMap;
+
+pub type GameReportModel = Model;
+
+/// Structure for player data
+#[derive(Serialize, Clone, Debug, PartialEq, Eq, DeriveEntityModel)]
+#[sea_orm(table_name = "game_report")]
+pub struct Model {
+    /// Unique Identifier for the player data
+    #[sea_orm(primary_key, column_type = "Integer")]
+    pub id: i64,
+    pub data: GameReportData,
+    pub created_at: DateTimeUtc,
+    pub finished_at: DateTimeUtc,
+}
+
+#[derive(Clone, Debug, PartialEq, Eq, Serialize, Deserialize, FromJsonQueryResult)]
+pub struct GameReportData {
+    pub attributes: HashMap<String, String>,
+    pub players: Vec<GameReportPlayer>,
+    /// Randomness seed used by players
+    pub seed: u32,
+    /// Whether the extraction
+    pub extracted: bool,
+}
+
+#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
+pub struct GameReportPlayer {
+    /// ID of the player
+    pub player_id: PlayerID,
+
+    /// Player username
+    pub player_name: String,
+
+    /// Name of the player character kit the player was using
+    pub kit_name: Option<String>,
+
+    /// Player weapon list
+    pub weapons: Option<Vec<WeaponId>>,
+
+    /// Player weapon mods
+    pub weapon_mods: Option<Vec<PlayerCharacterWeaponMod>>,
+
+    /// Player power choices and levels
+    pub powers: Option<Vec<PlayerCharacterPower>>,
+}
+
+#[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]
+pub enum Relation {}
+
+impl ActiveModelBehavior for ActiveModel {}
+
+impl Model {
+    pub fn create(
+        db: &DatabaseConnection,
+        data: GameReportData,
+        created_at: DateTimeUtc,
+        finished_at: DateTimeUtc,
+    ) -> BoxFuture<'_, DbResult<Self>> {
+        ActiveModel {
+            data: Set(data),
+            created_at: Set(created_at),
+            finished_at: Set(finished_at),
+            ..Default::default()
+        }
+        .insert(db)
+    }
+}

src/database/entities/game_report.rs

@@ -1,4 +1,5 @@
 pub mod galaxy_at_war;
+pub mod game_report;
 pub mod leaderboard_data;
 pub mod player_data;
 pub mod players;

src/database/entities/mod.rs

@@ -0,0 +1,41 @@
+use sea_orm_migration::{prelude::*, schema::*};
+
+#[derive(DeriveMigrationName)]
+pub struct Migration;
+
+#[async_trait::async_trait]
+impl MigrationTrait for Migration {
+    async fn up(&self, manager: &SchemaManager) -> Result<(), DbErr> {
+        manager
+            .create_table(
+                Table::create()
+                    .table(GameReport::Table)
+                    .if_not_exists()
+                    .col(pk_auto(GameReport::Id))
+                    .col(json_binary(GameReport::Data))
+                    .col(date_time(GameReport::CreatedAt))
+                    .col(date_time(GameReport::FinishedAt))
+                    .to_owned(),
+            )
+            .await
+    }
+
+    async fn down(&self, manager: &SchemaManager) -> Result<(), DbErr> {
+        manager
+            .drop_table(Table::drop().table(GameReport::Table).to_owned())
+            .await
+    }
+}
+
+#[derive(DeriveIden)]
+enum GameReport {
+    Table,
+    /// Unique ID of the game report
+    Id,
+    /// The actual game report data
+    Data,
+    /// Timestamp of the game creation
+    CreatedAt,
+    /// Timestamp of the game finish
+    FinishedAt,
+}

src/database/migration/m20250312_083054_game_reports.rs

@@ -6,6 +6,7 @@ mod m20221222_174733_player_data;
 mod m20230913_185124_player_data_unique;
 mod m20231205_121139_leaderboard_data;
 mod m20240714_023535_add_player_timestamps;
+mod m20250312_083054_game_reports;
 
 pub struct Migrator;
 
@@ -19,6 +20,7 @@ impl MigratorTrait for Migrator {
             Box::new(m20230913_185124_player_data_unique::Migration),
             Box::new(m20231205_121139_leaderboard_data::Migration),
             Box::new(m20240714_023535_add_player_timestamps::Migration),
+            Box::new(m20250312_083054_game_reports::Migration),
         ]
     }
 }

src/database/migration/mod.rs

@@ -271,6 +271,9 @@ impl Game {
     pub fn replay(&mut self) {
         self.set_state(GameState::PreGame);
 
+        // Update game creation timestamp
+        self.created_at = Utc::now();
+
         // TODO: Rotate game reporting ID to a new ID
         self.set_game_reporting_id(18014398695176361);
     }