feat: game reporting id, game replay command

Author: jacobtread

src/services/game/mod.rs

@@ -10,7 +10,8 @@ use crate::{
                 GameSetupContext, GameSetupResponse, GameState, GetGameDetails,
                 HostMigrateFinished, HostMigrateStart, JoinComplete, PlayerJoining,
                 PlayerNetConnectionStatus, PlayerRemoved, PlayerState, PlayerStateChange,
-                RemoveReason, SettingChange, SlotType, StateChange, UNSPECIFIED_TEAM_INDEX,
+                RemoveReason, ReportingIdChange, SettingChange, SlotType, StateChange,
+                UNSPECIFIED_TEAM_INDEX,
             },
             util::LOCALE_NZ,
             NetworkAddress,
@@ -252,6 +253,15 @@ impl Game {
         }
     }
 
+    /// Handle a "replay", game resetting its state back to pre-game
+    /// updates game reporting id
+    pub fn replay(&mut self) {
+        self.set_state(GameState::PreGame);
+
+        // TODO: Rotate game reporting ID to a new ID
+        self.set_game_reporting_id(18014398695176361);
+    }
+
     pub fn game_data(&self) -> RawBlaze {
         let data = GetGameDetails { game: self };
         data.into()
@@ -459,6 +469,21 @@ impl Game {
         ));
     }
 
+    pub fn set_game_reporting_id(&mut self, reporting_id: u64) {
+        self.reporting_id = reporting_id;
+
+        debug!("Updated game reporting id (Value: {:?})", &reporting_id);
+
+        self.notify_all(Packet::notify(
+            game_manager::COMPONENT,
+            game_manager::GAME_REPORTING_ID_CHANGE,
+            ReportingIdChange {
+                id: self.id,
+                grid: reporting_id,
+            },
+        ));
+    }
+
     pub fn set_settings(&mut self, settings: GameSettings) {
         self.settings = settings;
 

src/session/models/game_manager.rs

@@ -538,6 +538,17 @@ pub struct StateChange {
     pub state: GameState,
 }
 
+/// Message for a game reporting ID changing
+#[derive(TdfSerialize)]
+pub struct ReportingIdChange {
+    /// The ID of the game
+    #[tdf(tag = "GID")]
+    pub id: GameID,
+    /// The new game reporting ID
+    #[tdf(tag = "GRID")]
+    pub grid: u64,
+}
+
 /// Message for a game setting changing
 #[derive(TdfSerialize)]
 pub struct SettingChange {

src/session/routes/game_manager.rs

@@ -544,16 +544,14 @@ pub async fn handle_cancel_matchmaking(
 ///  "GID": 2,
 /// }
 /// ```
-#[allow(unused)]
 pub async fn handle_replay_game(
-    session: SessionLink,
-    SessionAuth(player): SessionAuth,
     Extension(games): Extension<Arc<Games>>,
-
     Blaze(ReplayGameRequest { game_id }): Blaze<ReplayGameRequest>,
 ) -> ServerResult<()> {
     let game_ref = games
         .get_by_id(game_id)
         .ok_or(GameManagerError::InvalidGameId)?;
+
+    game_ref.write().replay();
     Ok(())
 }

src/session/routes/mod.rs

@@ -56,6 +56,7 @@ pub fn router() -> BlazeRouterBuilder {
         builder.route(g::COMPONENT, g::CANCEL_MATCHMAKING,handle_cancel_matchmaking);
         builder.route(g::COMPONENT, g::GET_GAME_DATA_FROM_ID, handle_get_game_data);
         builder.route(g::COMPONENT, g::JOIN_GAME, handle_join_game);
+        builder.route(g::COMPONENT, g::REPLAY_GAME, handle_replay_game);
     }
 
     // Stats