Merge branch 'main' into leaderboard-topics

Author: RitamNandi

src/services/subscription/subscription-router.test.ts

@@ -254,3 +254,42 @@ describe("POST /subscription/send-email/single", () => {
         expect(mockSESV2Send).toHaveBeenCalledTimes(1);
     });
 });
+
+describe("GET /subscription/:mailingList", () => {
+    it("should return the list of subscribers for an existing mailing list", async () => {
+        const subscribers = [EMAIL_1, EMAIL_2];
+        await SupabaseDB.SUBSCRIPTIONS.insert({
+            mailingList: VALID_mailingList,
+            subscriptions: subscribers,
+        });
+
+        const response = await getAsAdmin(
+            `/subscription/${VALID_mailingList}`
+        ).expect(StatusCodes.OK);
+
+        expect(response.body).toEqual(expect.arrayContaining(subscribers));
+        expect(response.body.length).toBe(2);
+    });
+
+    it("should return a 404 Not Found for a non-existent mailing list", async () => {
+        const response = await getAsAdmin(
+            "/subscription/non-existent-list"
+        ).expect(StatusCodes.NOT_FOUND);
+
+        expect(response.body).toEqual({ error: "Mailing list not found." });
+    });
+
+    it("should return an empty array for a list that has no subscribers", async () => {
+        // Setup: Create a list with an empty subscriptions array
+        await SupabaseDB.SUBSCRIPTIONS.insert({
+            mailingList: VALID_mailingList,
+            subscriptions: [],
+        });
+
+        const response = await getAsAdmin(
+            `/subscription/${VALID_mailingList}`
+        ).expect(StatusCodes.OK);
+
+        expect(response.body).toEqual([]);
+    });
+});

src/services/subscription/subscription-router.ts

@@ -136,4 +136,28 @@ subscriptionRouter.post(
     }
 );
 
+// Get all the emails in a specific mailing list
+// Param: mailingList - the name of the mailing list to retrieve
+subscriptionRouter.get(
+    "/:mailingList",
+    RoleChecker([Role.Enum.ADMIN]),
+    async (req, res) => {
+        const { mailingList } = req.params;
+        const { data: list } = await SupabaseDB.SUBSCRIPTIONS.select(
+            "subscriptions"
+        )
+            .eq("mailingList", mailingList)
+            .maybeSingle()
+            .throwOnError();
+
+        if (!list) {
+            return res
+                .status(StatusCodes.NOT_FOUND)
+                .json({ error: "Mailing list not found." });
+        }
+
+        return res.status(StatusCodes.OK).json(list.subscriptions || []);
+    }
+);
+
 export default subscriptionRouter;