feat: add match map pause notifications for admins and tournament org… (#101)

Co-authored-by: Flegma <Flegma@users.noreply.github.com>

Author: Flegma

hasura/enums/notification-types.sql

@@ -4,6 +4,7 @@ INSERT INTO e_notification_types ("value", "description") VALUES
     ('GameNodeStatus', 'GameNodeStatus'),
     ('NameChangeRequest', 'NameChangeRequest'),
     ('DedicatedServerStatus', 'DedicatedServerStatus'),
-    ('DedicatedServerRconStatus', 'DedicatedServerRconStatus')
+    ('DedicatedServerRconStatus', 'DedicatedServerRconStatus'),
+    ('MatchStatusChange', 'Match Status Change Notification')
 ON CONFLICT("value") DO UPDATE
     SET "description" = EXCLUDED."description";

hasura/metadata/databases/default/tables/public_tournaments.yaml

@@ -109,6 +109,7 @@ insert_permissions:
         organizer_steam_id: x-hasura-user-id
       columns:
         - description
+        - discord_notifications_enabled
         - match_options_id
         - name
         - start
@@ -143,6 +144,7 @@ insert_permissions:
         organizer_steam_id: x-hasura-user-id
       columns:
         - description
+        - discord_notifications_enabled
         - match_options_id
         - name
         - start
@@ -176,6 +178,7 @@ insert_permissions:
         organizer_steam_id: x-hasura-user-id
       columns:
         - description
+        - discord_notifications_enabled
         - match_options_id
         - name
         - start
@@ -211,6 +214,7 @@ insert_permissions:
         organizer_steam_id: x-hasura-user-id
       columns:
         - description
+        - discord_notifications_enabled
         - match_options_id
         - name
         - start
@@ -242,6 +246,7 @@ insert_permissions:
         organizer_steam_id: x-hasura-user-id
       columns:
         - description
+        - discord_notifications_enabled
         - match_options_id
         - name
         - start
@@ -274,6 +279,7 @@ insert_permissions:
         organizer_steam_id: x-hasura-user-id
       columns:
         - description
+        - discord_notifications_enabled
         - match_options_id
         - name
         - start
@@ -284,6 +290,7 @@ select_permissions:
       columns:
         - created_at
         - description
+        - discord_notifications_enabled
         - id
         - match_options_id
         - name
@@ -310,6 +317,7 @@ select_permissions:
       columns:
         - created_at
         - description
+        - discord_notifications_enabled
         - id
         - match_options_id
         - name
@@ -339,6 +347,7 @@ update_permissions:
     permission:
       columns:
         - description
+        - discord_notifications_enabled
         - name
         - start
         - status

hasura/migrations/default/1771700000000_add_match_status_notifications/down.sql

@@ -0,0 +1,6 @@
+-- Remove per-tournament Discord override column
+ALTER TABLE "public"."tournaments"
+DROP COLUMN IF EXISTS "discord_notifications_enabled";
+
+-- Remove MatchStatusChange from notification types
+DELETE FROM e_notification_types WHERE "value" = 'MatchStatusChange';

hasura/migrations/default/1771700000000_add_match_status_notifications/up.sql

@@ -0,0 +1,8 @@
+-- Add MatchStatusChange to notification types
+INSERT INTO e_notification_types ("value", "description") VALUES
+    ('MatchStatusChange', 'Match Status Change Notification')
+ON CONFLICT("value") DO UPDATE SET "description" = EXCLUDED."description";
+
+-- Add per-tournament Discord override column
+ALTER TABLE "public"."tournaments"
+ADD COLUMN IF NOT EXISTS "discord_notifications_enabled" boolean DEFAULT NULL;

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

@@ -3,6 +3,7 @@ import { GameServerQueues } from "../enums/GameServerQueues";
 import { HasuraService } from "../../hasura/hasura.service";
 import { UseQueue } from "../../utilities/QueueProcessors";
 import { NotificationsService } from "../../notifications/notifications.service";
+import { DISCORD_COLORS } from "../../notifications/utilities/constants";
 
 @UseQueue("GameServerNode", GameServerQueues.PluginVersion)
 export class CheckServerPluginVersions extends WorkerHost {
@@ -101,6 +102,6 @@ export class CheckServerPluginVersions extends WorkerHost {
       message: `${servers_aggregate.aggregate.count} servers has out of date plugins.`,
       title: "Plugin Out of Date",
       role: "administrator",
-    });
+    }, undefined, DISCORD_COLORS.RED);
   }
 }

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

@@ -4,6 +4,7 @@ import { Job } from "bullmq";
 import { HasuraService } from "../../hasura/hasura.service";
 import { UseQueue } from "../../utilities/QueueProcessors";
 import { NotificationsService } from "../../notifications/notifications.service";
+import { DISCORD_COLORS } from "../../notifications/utilities/constants";
 
 @UseQueue("GameServerNode", GameServerQueues.NodeOffline)
 export class MarkDedicatedServerOffline extends WorkerHost {
@@ -44,6 +45,6 @@ export class MarkDedicatedServerOffline extends WorkerHost {
       title: "Dedicated Server Offline",
       role: "administrator",
       entity_id: job.data.serverId,
-    });
+    }, undefined, DISCORD_COLORS.RED);
   }
 }

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

@@ -4,6 +4,7 @@ import { Job } from "bullmq";
 import { HasuraService } from "../../hasura/hasura.service";
 import { UseQueue } from "../../utilities/QueueProcessors";
 import { NotificationsService } from "../../notifications/notifications.service";
+import { DISCORD_COLORS } from "../../notifications/utilities/constants";
 
 @UseQueue("GameServerNode", GameServerQueues.NodeOffline)
 export class MarkGameServerNodeOffline extends WorkerHost {
@@ -39,6 +40,6 @@ export class MarkGameServerNodeOffline extends WorkerHost {
       title: "Game Server Node Offline",
       role: "administrator",
       entity_id: job.data.node,
-    });
+    }, undefined, DISCORD_COLORS.RED);
   }
 }

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

@@ -3,6 +3,7 @@ import { GameServerQueues } from "../enums/GameServerQueues";
 import { Job } from "bullmq";
 import { UseQueue } from "../../utilities/QueueProcessors";
 import { NotificationsService } from "../../notifications/notifications.service";
+import { DISCORD_COLORS } from "../../notifications/utilities/constants";
 
 @UseQueue("GameServerNode", GameServerQueues.NodeOffline)
 export class MarkGameServerNodeOnline extends WorkerHost {
@@ -36,6 +37,6 @@ export class MarkGameServerNodeOnline extends WorkerHost {
       title: "Game Server Node Online",
       role: "administrator",
       entity_id: job.data.node,
-    });
+    }, undefined, DISCORD_COLORS.GREEN);
   }
 }

src/matches/events/MatchMapStatusEvent.ts

@@ -1,10 +1,25 @@
 import MatchEventProcessor from "./abstracts/MatchEventProcessor";
 import { e_match_map_status_enum } from "../../../generated";
+import { HasuraService } from "../../hasura/hasura.service";
+import { MatchAssistantService } from "../match-assistant/match-assistant.service";
+import { Logger } from "@nestjs/common";
+import { ChatService } from "../../chat/chat.service";
+import { NotificationsService } from "../../notifications/notifications.service";
 
 export default class MatchMapStatusEvent extends MatchEventProcessor<{
   status: e_match_map_status_enum;
   winning_lineup_id?: string;
 }> {
+  constructor(
+    logger: Logger,
+    hasura: HasuraService,
+    matchAssistant: MatchAssistantService,
+    chat: ChatService,
+    private readonly notifications: NotificationsService,
+  ) {
+    super(logger, hasura, matchAssistant, chat);
+  }
+
   public async process() {
     const { matches_by_pk: match } = await this.hasura.query({
       matches_by_pk: {
@@ -41,6 +56,10 @@ export default class MatchMapStatusEvent extends MatchEventProcessor<{
       },
     });
 
+    if (this.data.status === "Paused") {
+      void this.notifications.sendMatchMapPauseNotification(this.matchId);
+    }
+
     if (isFinished) {
       if (update_match_maps_by_pk.match.current_match_map_id !== null) {
         await this.matchAssistant.sendServerMatchId(this.matchId);

src/matches/matches.controller.ts

@@ -10,6 +10,7 @@ import { DiscordBotOverviewService } from "../discord-bot/discord-bot-overview/d
 import { DiscordBotMessagingService } from "../discord-bot/discord-bot-messaging/discord-bot-messaging.service";
 import { DiscordBotVoiceChannelsService } from "../discord-bot/discord-bot-voice-channels/discord-bot-voice-channels.service";
 import {
+  e_match_status_enum,
   match_map_veto_picks_set_input,
   matches_set_input,
   servers_set_input,
@@ -20,6 +21,7 @@ import { ConfigService } from "@nestjs/config";
 import { AppConfig } from "src/configs/types/AppConfig";
 import { PostgresService } from "src/postgres/postgres.service";
 import { NotificationsService } from "../notifications/notifications.service";
+import { DISCORD_COLORS } from "../notifications/utilities/constants";
 import { MatchmakeService } from "src/matchmaking/matchmake.service";
 import { InjectQueue } from "@nestjs/bullmq";
 import { Queue } from "bullmq";
@@ -307,6 +309,18 @@ export class MatchesController {
 
     const status = data.new.status;
 
+    if (
+      data.op === "UPDATE" &&
+      data.old.status !== data.new.status &&
+      data.new.status
+    ) {
+      void this.notifications.sendMatchStatusNotification(
+        matchId,
+        data.new.status as e_match_status_enum,
+        data.old.status as e_match_status_enum,
+      );
+    }
+
     if (data.op === "DELETE") {
       await this.chatService.removeLobby(ChatLobbyType.Match, matchId);
     }
@@ -682,7 +696,7 @@ export class MatchesController {
       title: "Match Assistanced Required",
       role: "match_organizer",
       entity_id: data.match_id,
-    });
+    }, undefined, DISCORD_COLORS.RED);
 
     return {
       success: true,