Add pairing data validation check at connected event

Author: alexemanuelol

src/managers/rustPlusManager.ts

@@ -340,6 +340,7 @@ export class RustPlusInstance {
                     if (this.rustPlus.getAppResponseError(response) === rp.AppResponseError.NotFound) {
                         /* pairingData is no longer valid. */
                         if (pairingData && pairingData.valid) {
+                            log.warn(`${funcName} PairingData no longer valid for ${mainRequesterSteamId}.`, logParam);
                             pairingData.valid = false;
                             gim.updateGuildInstance(this.guildId);
                             await sendServerMessage(dm, this.guildId, this.serverId, this.connectionStatus);
@@ -375,6 +376,46 @@ export class RustPlusInstance {
         return true;
     }
 
+    public async validatePairingData() {
+        const funcName = `[RustPlusManager: validatePairingData]`
+        const logParam = { guildId: this.guildId, serverId: this.serverId, serverName: this.serverName };
+
+        log.info(`${funcName}`, logParam);
+
+        const gInstance = gim.getGuildInstance(this.guildId) as GuildInstance;
+        const pairingDataMap = gInstance.pairingDataMap[this.serverId];
+        for (const [steamId, pairingData] of Object.entries(pairingDataMap)) {
+            const rpInfo = await this.rustPlus.getInfoAsync(pairingData.steamId, pairingData.playerToken);
+            if (rp.isValidAppResponse(rpInfo, log)) {
+                if (!rp.isValidAppInfo(rpInfo.info, log)) {
+                    if (rp.isValidAppError(rpInfo.error, log)) {
+                        log.warn(`${funcName} SteamId: ${steamId}, AppError: ${rpInfo.error.error}`, logParam);
+                        if (this.rustPlus.getAppResponseError(rpInfo) === rp.AppResponseError.NotFound) {
+                            log.warn(`${funcName} PairingData no longer valid for ${steamId}.`, logParam);
+                            pairingData.valid = false;
+                        }
+                    }
+                    else {
+                        log.error(`${funcName} We got completely wrong response: ${JSON.stringify(rpInfo)}`, logParam);
+                    }
+                }
+                else {
+                    pairingData.valid = true;
+                }
+            }
+            else {
+                /* Error or rp.ConsumeTokensError */
+                if (rpInfo instanceof Error) {
+                    log.error(`${funcName} Error: ${rpInfo.message}`, logParam);
+                }
+                else {
+                    log.error(`${funcName} ConsumeTokensError: ${rpInfo}`, logParam);
+                }
+            }
+        }
+        gim.updateGuildInstance(this.guildId);
+    }
+
     public async setupSmartDevices() {
 
         // TODO! Go through all smart devices to get the status of them

src/rustPlusEvents/connected.ts

@@ -36,9 +36,11 @@ export async function execute(rpInstance: RustPlusInstance) {
 
     rpInstance.stopReconnectionTimer();
 
+    await rpInstance.validatePairingData();
+
     // TODO! Retrieve map to see if map wipe
 
-    rpInstance.setupSmartDevices();
+    await rpInstance.setupSmartDevices();
 
     rpInstance.startServerPollingHandler();