Enroll in notifs for upgrading

src/services/leaderboard/leaderboard-router.ts

@@ -122,8 +122,10 @@ leaderboardRouter.post(
         const userIdsForPromotion =
             userIdsToPromote || leaderboard.map((entry) => entry.userId);
 
-        const entriesProcessed =
-            await promoteUsersToNextTier(userIdsForPromotion);
+        const entriesProcessed = await promoteUsersToNextTier(
+            userIdsForPromotion,
+            day
+        );
 
         const { submissionId, submittedAt } = await recordLeaderboardSubmission(
             day,

src/services/leaderboard/leaderboard-utils.ts

@@ -1,6 +1,7 @@
 import { SupabaseDB, TierType, IconColorType, supabase } from "../../database";
 import { LeaderboardEntry } from "./leaderboard-schema";
 import { getEventDayForDate } from "../attendee/attendee-utils";
+import { getFirebaseAdmin } from "../../firebase";
 
 function getDailyPointsForEventDay(
     attendee: {
@@ -190,7 +191,8 @@ export async function getGlobalLeaderboard(
  * @returns Promise<number> - Number of users actually promoted
  */
 export async function promoteUsersToNextTier(
-    userIds: string[]
+    userIds: string[],
+    day: string
 ): Promise<number> {
     if (!userIds || userIds.length === 0) {
         return 0;
@@ -205,6 +207,22 @@ export async function promoteUsersToNextTier(
         throw error;
     }
 
+    // Enroll every userId into a Firebase topic if they got promoted today
+
+    const { data: userDevices } = await SupabaseDB.NOTIFICATIONS.select(
+        "deviceId"
+    )
+        .in("userId", userIds)
+        .throwOnError();
+
+    if (userDevices && userDevices.length > 0) {
+        const deviceTokens = userDevices.map((device) => device.deviceId);
+        const topicName = `tier-promotion-${day.toLowerCase()}`;
+        await getFirebaseAdmin()
+            .messaging()
+            .subscribeToTopic(deviceTokens, topicName);
+    }
+
     return data || 0;
 }