From 8d7e824af95acfa595c606d5571e71b869739de2 Mon Sep 17 00:00:00 2001
From: Quildra <Quildra@gmail.com>
Date: Sun, 4 Feb 2024 12:28:40 +0000
Subject: [PATCH] Swap to loginId instead of game handle

---
 .../20240204112812-race-login-id.js           | 45 +++++++++++++++++++
 packages/bridge-server/models/racer.js        |  3 +-
 .../bridge-server/src/racers/racer.model.ts   |  3 ++
 .../src/racers/racers.service.ts              | 23 ++++++++--
 .../src/upload/upload.service.ts              | 10 +++--
 5 files changed, 75 insertions(+), 9 deletions(-)
 create mode 100644 packages/bridge-server/migrations/20240204112812-race-login-id.js

diff --git a/packages/bridge-server/migrations/20240204112812-race-login-id.js b/packages/bridge-server/migrations/20240204112812-race-login-id.js
new file mode 100644
index 0000000..c00bc07
--- /dev/null
+++ b/packages/bridge-server/migrations/20240204112812-race-login-id.js
@@ -0,0 +1,45 @@
+'use strict';
+
+/** @type {import('sequelize-cli').Migration} */
+module.exports = {
+  async up (queryInterface, Sequelize) {
+    /**
+     * Add altering commands here.
+     *
+     * Example:
+     * await queryInterface.createTable('users', { id: Sequelize.INTEGER });
+     */
+    const transaction = await queryInterface.sequelize.transaction();
+    try {
+      await queryInterface.addColumn(
+        'Racers',
+        'loginId',
+        {
+          type: Sequelize.STRING,
+        },
+        { transaction }
+      );
+      await transaction.commit();
+    } catch (err) {
+      await transaction.rollback();
+      throw err;
+    }
+  },
+
+  async down (queryInterface, Sequelize) {
+    /**
+     * Add reverting commands here.
+     *
+     * Example:
+     * await queryInterface.dropTable('users');
+     */
+    const transaction = await queryInterface.sequelize.transaction();
+    try {
+      await queryInterface.removeColumn('Racers', 'loginId', { transaction });
+      await transaction.commit();
+    } catch (err) {
+      await transaction.rollback();
+      throw err;
+    }
+  }
+};
diff --git a/packages/bridge-server/models/racer.js b/packages/bridge-server/models/racer.js
index 2c1d4ae..82541c3 100644
--- a/packages/bridge-server/models/racer.js
+++ b/packages/bridge-server/models/racer.js
@@ -16,7 +16,8 @@ module.exports = (sequelize, DataTypes) => {
   Racer.init({
     name: DataTypes.STRING,
     gameHandle: DataTypes.STRING,
-    userId: DataTypes.STRING
+    userId: DataTypes.STRING,
+    loginId: DataTypes.STRING,
   }, {
     sequelize,
     modelName: 'Racer',
diff --git a/packages/bridge-server/src/racers/racer.model.ts b/packages/bridge-server/src/racers/racer.model.ts
index b5e3cab..10337da 100644
--- a/packages/bridge-server/src/racers/racer.model.ts
+++ b/packages/bridge-server/src/racers/racer.model.ts
@@ -10,6 +10,9 @@ export class Racer extends Model {
     @Column
     gameHandle: string;
 
+    @Column
+    loginId: string;
+
     @HasMany(() => RaceResult)
     results: RaceResult[];
 
diff --git a/packages/bridge-server/src/racers/racers.service.ts b/packages/bridge-server/src/racers/racers.service.ts
index d76f073..c390762 100644
--- a/packages/bridge-server/src/racers/racers.service.ts
+++ b/packages/bridge-server/src/racers/racers.service.ts
@@ -12,16 +12,16 @@ export class RacersService {
     )
     {}
 
-    async findOne(gameHandle: string) {
-        return this.racerModel.findOne({ where: {gameHandle: gameHandle} });
+    async findOne(loginId: string) {
+        return this.racerModel.findOne({ where: {loginId: loginId} });
     }
 
-    async findOrCreate(gameHandle: string): Promise<Racer> {
+    async findOrCreate(loginId: string): Promise<Racer> {
         try {
             return this.sequelize.transaction( async t => {
                 return this.racerModel.findOrCreate({
                     where: {
-                        gameHandle: gameHandle
+                        loginId: loginId
                     },
                     transaction: t
                   }).then((value) => {
@@ -32,4 +32,19 @@ export class RacersService {
             console.log(error);
         }
     }
+
+    async updateGameHandle(loginId: string, newGameHandle: string) {
+        try {
+            await this.sequelize.transaction( async t => {
+                const transactionHost = { transaction: t };
+                let target_racer = await this.racerModel.findOne(
+                  { where: {loginId: loginId} }
+                );
+                target_racer.gameHandle = newGameHandle;
+                target_racer.save();
+            });
+          } catch (error) {
+      
+          }
+    }
 }
diff --git a/packages/bridge-server/src/upload/upload.service.ts b/packages/bridge-server/src/upload/upload.service.ts
index 7d1adb6..66b6a3c 100644
--- a/packages/bridge-server/src/upload/upload.service.ts
+++ b/packages/bridge-server/src/upload/upload.service.ts
@@ -39,7 +39,7 @@ export class UploadService {
         let replay = new gbxReplay();
         replay.parse(buff);
 
-        return await this.racersService.findOne(replay.gamerHandle);
+        return await this.racersService.findOne(replay.login);
     }
 
     async replayUploaded(file: Express.Multer.File, body: any) {
@@ -71,7 +71,11 @@ export class UploadService {
         let replay = new gbxReplay();
         replay.parse(buff);
 
-        let currentRacer = await this.racersService.findOrCreate(replay.gamerHandle);
+        let currentRacer = await this.racersService.findOrCreate(replay.login);
+
+        if(currentRacer.gameHandle != replay.gamerHandle) {
+            this.racersService.updateGameHandle(replay.login, replay.gamerHandle);
+        }
 
         let race = await this.racesService.findOneBySeasonAndMapUID(body.seasonId, replay.mapUID)
 
@@ -89,8 +93,6 @@ export class UploadService {
 
         if(body.fileTime < race.startDate.getTime()) {
             throw new NotAcceptableException('EarlyReplay', {cause: new Error(), description: 'Replay generated before the race started.'})
-            console.log("Race Too Soon!")
-            return;
         }
         
         await this.raceResultsService.create(race.id, currentRacer.id, replay.bestTime, file.path, file_hash);