bug: fix cvars not finishing

Author: lukepolo

src/rcon/rcon.service.ts

@@ -24,7 +24,6 @@ export class RconService {
 
   private connections: Record<string, RconClient> = {};
   private connectTimeouts: Record<string, NodeJS.Timeout> = {};
-  private activeOperations = new Set<string>();
 
   public async connect(serverId: string): Promise<RconClient | null> {
     if (this.connections[serverId]) {
@@ -179,9 +178,6 @@ export class RconService {
 
   private setupConnectionTimeout(serverId: string) {
     clearTimeout(this.connectTimeouts[serverId]);
-    if (this.activeOperations.has(serverId)) {
-      return;
-    }
     this.connectTimeouts[serverId] = setTimeout(async () => {
       await this.disconnect(serverId);
     }, this.CONNECTION_TIMEOUT);
@@ -258,13 +254,13 @@ export class RconService {
 
     this.logger.log(`generating cvars for build: ${buildId}`);
 
+    let rcon: RconClient | null = null;
     try {
-      const rcon = await this.connect(serverId);
+      rcon = await this.connect(serverId);
       if (!rcon) {
         throw Error(`unable to connect to server ${serverId}`);
       }
 
-      this.activeOperations.add(serverId);
       clearTimeout(this.connectTimeouts[serverId]);
       delete this.connectTimeouts[serverId];
 
@@ -282,16 +278,19 @@ export class RconService {
         description: string;
       }> = [];
 
-      try {
-        for (const prefix of prefixes) {
+      for (const prefix of prefixes) {
+        try {
           const parsedCvars = this.parseCvarList(
             await rcon.send(`Cvarlist ${prefix}`),
           );
           allCvars.push(...parsedCvars);
+        } catch (error) {
+          this.logger.error(
+            `unable to generate cvars for build: ${buildId} on prefix ${prefix}`,
+            error,
+          );
+          throw error;
         }
-      } finally {
-        this.activeOperations.delete(serverId);
-        this.setupConnectionTimeout(serverId);
       }
 
       await this.typeSenseService.resetCvars();
@@ -318,6 +317,7 @@ export class RconService {
       );
       await this.cache.put(failureCacheKey, true, 600);
     } finally {
+      await this.disconnect(serverId);
       await this.releaseCvarsLock(buildId);
     }
   }