create GET /discord-members API (#56)

* create GET /discord-members API

* write tests

* fixed rsa key issue with new kew pair

* remove console log

* fix formatting

* address comments

Author: bhtibrewal

src/controllers/getMembersInServer.ts

@@ -0,0 +1,30 @@
+import { IRequest } from "itty-router";
+import jwt from "@tsndr/cloudflare-worker-jwt";
+import * as response from "../constants/responses";
+import { env } from "../typeDefinitions/default.types";
+import JSONResponse from "../utils/JsonResponse";
+import { User } from "../typeDefinitions/user.types";
+import { getMembersInServer } from "../utils/getMembersInServer";
+
+export const getMembersInServerHandler = async (
+  request: IRequest,
+  env: env
+) => {
+  const authHeader = request.headers.get("Authorization");
+
+  if (!authHeader) {
+    return new JSONResponse(response.BAD_SIGNATURE);
+  }
+  try {
+    const authToken = authHeader.split(" ")[1];
+    await jwt.verify(authToken, env.RDS_SERVERLESS_PUBLIC_KEY, {
+      algorithm: "RS256",
+    });
+
+    const users = (await getMembersInServer(env)) as User[];
+
+    return new JSONResponse(users);
+  } catch (err) {
+    return new JSONResponse(response.BAD_SIGNATURE);
+  }
+};

src/index.ts

@@ -6,6 +6,7 @@ import { env } from "./typeDefinitions/default.types";
 import { discordMessageRequest } from "./typeDefinitions/discordMessage.types";
 import JSONResponse from "./utils/JsonResponse";
 import { verifyBot } from "./utils/verifyBot";
+import { getMembersInServerHandler } from "./controllers/getMembersInServer";
 
 const router = Router();
 
@@ -15,6 +16,8 @@ router.get("/", async () => {
   });
 });
 
+router.get("/discord-members", getMembersInServerHandler);
+
 router.post("/", async (request, env) => {
   const message: discordMessageRequest = await request.json();
   if (message.type === InteractionType.PING) {

src/typeDefinitions/user.types.d.ts

@@ -0,0 +1,23 @@
+export interface User {
+  avatar: null | string;
+  communication_disabled_until: null | string;
+  flags: 0;
+  is_pending: boolean;
+  joined_at: string; //ISO8601 timestamp
+  nick: null | string;
+  pending: boolean;
+  premium_since: null | string;
+  roles: string[];
+  user: {
+    id: string;
+    username: string;
+    global_name: string;
+    display_name: string;
+    avatar: string; // avatar hash
+    discriminator: string; //4-digit discord-tag
+    public_flags: integer;
+    avatar_decoration: null;
+  };
+  mute: boolean;
+  deaf: boolean;
+}

src/utils/getMembersInServer.ts

@@ -0,0 +1,19 @@
+import * as response from "../constants/responses";
+import { env } from "../typeDefinitions/default.types";
+import { DISCORD_BASE_URL } from "../constants/urls";
+
+export const getMembersInServer = async (env: env) => {
+  try {
+    const MEMBERS_URL = `${DISCORD_BASE_URL}/guilds/${env.DISCORD_GUILD_ID}/members?limit=1000`;
+    const response = await fetch(MEMBERS_URL, {
+      method: "GET",
+      headers: {
+        "Content-Type": "application/json",
+        Authorization: `Bot ${env.DISCORD_TOKEN}`,
+      },
+    });
+    return response.json();
+  } catch (err) {
+    return response.BAD_SIGNATURE;
+  }
+};

tests/unit/getMembersInServer.test.ts

@@ -0,0 +1,35 @@
+import { DISCORD_BASE_URL } from "../../src/constants/urls";
+import JSONResponse from "../../src/utils/JsonResponse";
+import { getMembersInServer } from "../../src/utils/getMembersInServer";
+
+describe("getMembersInServer", () => {
+  const mockEnv = {
+    BOT_PUBLIC_KEY: "xyz",
+    DISCORD_GUILD_ID: "123",
+    DISCORD_TOKEN: "abc",
+  };
+  test("returns JSON response with members on success", async () => {
+    const expectedResponse = [{ id: "1234", name: "John Doe" }];
+
+    jest
+      .spyOn(global, "fetch")
+      .mockImplementation(() =>
+        Promise.resolve(new JSONResponse(expectedResponse))
+      );
+
+    const response = await getMembersInServer(mockEnv);
+
+    expect(global.fetch).toHaveBeenCalledWith(
+      `${DISCORD_BASE_URL}/guilds/${mockEnv.DISCORD_GUILD_ID}/members?limit=1000`,
+      {
+        method: "GET",
+        headers: {
+          "Content-Type": "application/json",
+          Authorization: `Bot ${mockEnv.DISCORD_TOKEN}`,
+        },
+      }
+    );
+
+    expect(response).toEqual(expectedResponse);
+  });
+});