feature: cloudflare worker to download demos

Author: lukepolo

hasura/functions/match/maps/match_map_demo_download_url.sql

@@ -3,9 +3,26 @@ RETURNS text
 LANGUAGE plpgsql STABLE
 AS $$
 DECLARE
-    download_url text;
+    worker_url text;
+    filenames text[];
+    demos_domain text;
 BEGIN
-    download_url := CONCAT('demos/', match_map.match_id, '/map/', match_map.id);
-    RETURN download_url;
+    SELECT value INTO worker_url 
+    FROM settings 
+    WHERE name = 'cloudflare_worker_url';
+
+    IF worker_url IS NOT NULL THEN
+        SELECT array_agg(file) INTO filenames 
+        FROM match_map_demos 
+        WHERE match_map_id = match_map.id;
+    
+        RETURN CONCAT(worker_url, '/demos?matchId=', match_map.match_id, '&mapId=', match_map.id, '&files=', array_to_string(filenames, ','));
+    END IF;
+
+    SELECT value INTO demos_domain
+    FROM settings
+    WHERE name = 'demos_domain';
+
+    RETURN CONCAT(demos_domain, '/demos/', match_map.match_id, '/map/', match_map.id);
 END;
 $$;

src/game-server-node/jobs/MarkGameServerNodeOffline.ts

@@ -33,6 +33,10 @@ export class MarkGameServerNodeOffline extends WorkerHost {
       },
     });
 
+    if (process.env.DEV) {
+      return;
+    }
+
     this.notifications.send("GameNodeStatus", {
       message: `Game Server Node (${update_game_server_nodes_by_pk.label || job.data.node}) is Offline.`,
       title: "Game Server Node Offline",

src/game-server-node/jobs/MarkGameServerOffline.ts

@@ -38,6 +38,10 @@ export class MarkGameServerOffline extends WorkerHost {
       return;
     }
 
+    if (process.env.DEV) {
+      return;
+    }
+
     this.notifications.send("DedicatedServerStatus", {
       message: `Dedicated Server (${update_servers_by_pk.label || job.data.serverId}) is Offline.`,
       title: "Dedicated Server Offline",

src/hasura/hasura.service.ts

@@ -15,17 +15,20 @@ import fs from "fs";
 import path from "path";
 import crypto from "crypto";
 import { PostgresService } from "../postgres/postgres.service";
+import { AppConfig } from "../configs/types/AppConfig";
 
 @Injectable()
 export class HasuraService {
   private config: HasuraConfig;
+  private appConfig: AppConfig;
 
   constructor(
     protected readonly logger: Logger,
     protected readonly cache: CacheService,
     protected readonly configService: ConfigService,
     protected readonly postgresService: PostgresService,
   ) {
+    this.appConfig = configService.get<AppConfig>("app");
     this.config = configService.get<HasuraConfig>("hasura");
   }
 
@@ -108,6 +111,15 @@ export class HasuraService {
     await this.apply(path.resolve("./hasura/functions"));
     await this.apply(path.resolve("./hasura/views"));
     await this.apply(path.resolve("./hasura/triggers"));
+
+    await this.updateSettings();
+  }
+
+  private async updateSettings() {
+    await this.postgresService.query(
+      "insert into settings (name, value) values ('demos_domain', $1) on conflict (name) do update set value = $1",
+      [this.appConfig.demosDomain],
+    );
   }
 
   private async applyMigrations(path: string): Promise<number> {