Insert multiplayer matches into the database after match ends

Author: Swan

db/multiplayer_game_matches.go

@@ -0,0 +1,47 @@
+package db
+
+import (
+	"example.com/Quaver/Z/common"
+	"example.com/Quaver/Z/objects"
+)
+
+type MultiplayerMatch struct {
+	Id              int
+	GameId          int                            `db:"game_id"`
+	TimePlayed      int64                          `db:"time_played"`
+	MapMd5          string                         `db:"map_md5"`
+	MapName         string                         `db:"map"`
+	HostId          int                            `db:"host_id"`
+	Ruleset         objects.MultiplayerGameRuleset `db:"ruleset"`
+	GameMode        common.Mode                    `db:"game_mode"`
+	GlobalModifiers common.Mods                    `db:"global_modifiers"`
+	FreeMod         objects.MultiplayerGameFreeMod `db:"free_mod_type"`
+	HealthType      objects.MultiplayerGameHealth  `db:"health_type"`
+	Lives           int                            `db:"lives"`
+	Aborted         bool                           `db:"aborted"`
+}
+
+// InsertIntoDatabase Inserts a multiplayer match into the database and returns the insert id of it.
+func (match *MultiplayerMatch) InsertIntoDatabase() error {
+	query := "INSERT INTO multiplayer_game_matches" +
+		"(game_id, time_played, map_md5, map, host_id, ruleset, game_mode, global_modifiers, free_mod_type, health_Type, lives, aborted) " +
+		"VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)"
+
+	result, err := SQL.Exec(query, match.GameId, match.TimePlayed, match.MapMd5, match.MapName, match.HostId, match.Ruleset, match.GameMode,
+		match.GlobalModifiers, match.FreeMod, match.HealthType, match.Lives, match.Aborted)
+
+	if err != nil {
+		match.Id = -1
+		return err
+	}
+
+	id, err := result.LastInsertId()
+
+	if err != nil {
+		match.Id = -1
+		return err
+	}
+
+	match.Id = int(id)
+	return nil
+}

multiplayer/game.go

@@ -319,16 +319,17 @@ func (game *Game) EndGame() {
 		return
 	}
 
+	game.clearCountdown()
+	game.clearReadyPlayers(false)
+	game.updatePlayerWinCount()
+	game.insertMatchIntoDatabase()
+	game.rotateHost()
+
 	game.Data.InProgress = false
 	game.playersInMatch = []int{}
 	game.playersScreenLoaded = []int{}
 	game.playersFinished = []int{}
 	game.playersSkipped = []int{}
-	game.clearCountdown()
-	game.clearReadyPlayers(false)
-	game.rotateHost()
-
-	game.updatePlayerWinCount()
 	game.playerScores = map[int]*scoring.ScoreProcessor{}
 
 	game.sendPacketToPlayers(packets.NewServerGameEnded())
@@ -778,6 +779,31 @@ func (game *Game) updatePlayerWinCount() {
 	}
 }
 
+// Inserts the current match + scores into the database.
+func (game *Game) insertMatchIntoDatabase() {
+	if len(game.playerScores) == 0 {
+		return
+	}
+
+	match := db.MultiplayerMatch{
+		GameId:          game.Data.Id,
+		TimePlayed:      time.Now().UnixMilli(),
+		MapMd5:          game.Data.MapMD5,
+		MapName:         game.Data.MapName,
+		HostId:          game.Data.HostId,
+		Ruleset:         game.Data.Ruleset,
+		GameMode:        game.Data.MapGameMode,
+		GlobalModifiers: game.Data.GlobalModifiers,
+		FreeMod:         game.Data.FreeModType,
+	}
+
+	err := match.InsertIntoDatabase()
+
+	if err != nil {
+		log.Printf("Failed to insert match from game #%v into database - %v\n", game.Data.Id, err)
+	}
+}
+
 // Clears and stops the countdown timer.
 func (game *Game) clearCountdown() {
 	if game.countdownTimer != nil {