Unit test cases for all functions

functions/create-room/package.json

@@ -5,6 +5,7 @@
     "main": "src/main.js",
     "type": "module",
     "scripts": {
+        "test": "jest",
         "start": "node src/main.js",
         "format": "prettier --write ."
     },
@@ -13,6 +14,8 @@
         "node-appwrite": "^17.0.0"
     },
     "devDependencies": {
+        "@jest/globals": "^30.2.0",
+        "jest": "^30.2.0",
         "prettier": "^3.0.0"
     }
-}
+}

functions/create-room/src/appwrite.js

@@ -1,27 +1,27 @@
-import { Client, Databases, ID } from "node-appwrite";
+const { Client, Databases, ID } = require("node-appwrite");
 
 class AppwriteService {
-    constructor() {
-        const client = new Client();
-        client
-            .setEndpoint(
-                process.env.APPWRITE_ENDPOINT ?? "https://cloud.appwrite.io/v1"
-            )
-            .setProject(process.env.APPWRITE_FUNCTION_PROJECT_ID)
-            .setKey(process.env.APPWRITE_API_KEY);
-        this.databases = new Databases(client);
-    }
+  constructor() {
+    const client = new Client();
+    client
+      .setEndpoint(
+        process.env.APPWRITE_ENDPOINT ?? "https://cloud.appwrite.io/v1"
+      )
+      .setProject(process.env.APPWRITE_FUNCTION_PROJECT_ID)
+      .setKey(process.env.APPWRITE_API_KEY);
+    this.databases = new Databases(client);
+  }
 
-    async createRoom(newRoomData) {
-        const newRoomDocRef = await this.databases.createDocument(
-            process.env.MASTER_DATABASE_ID,
-            process.env.ROOMS_COLLECTION_ID,
-            ID.unique(),
-            newRoomData
-        );
+  async createRoom(newRoomData) {
+    const newRoomDocRef = await this.databases.createDocument(
+      process.env.MASTER_DATABASE_ID,
+      process.env.ROOMS_COLLECTION_ID,
+      ID.unique(),
+      newRoomData
+    );
 
-        return newRoomDocRef.$id;
-    }
+    return newRoomDocRef.$id;
+  }
 }
 
-export default AppwriteService;
+module.exports = AppwriteService;

functions/create-room/src/appwrite.test.js

@@ -0,0 +1,40 @@
+const createDocumentMock = jest.fn().mockResolvedValue({ $id: "room-123" });
+
+jest.mock("node-appwrite", () => {
+  return {
+    Client: jest.fn().mockImplementation(() => ({
+      setEndpoint: jest.fn().mockReturnThis(),
+      setProject: jest.fn().mockReturnThis(),
+      setKey: jest.fn().mockReturnThis(),
+    })),
+    Databases: jest.fn().mockImplementation(() => ({
+      createDocument: createDocumentMock,
+    })),
+    ID: {
+      unique: jest.fn(() => "unique-id-123"),
+    },
+  };
+});
+
+const AppwriteService = require("./appwrite");
+
+describe("Testing AppwriteService", () => {
+  let service;
+
+  beforeEach(() => {
+    service = new AppwriteService();
+  });
+
+  test("should call createDocument with correct params", async () => {
+    const roomId = await service.createRoom({ name: "Test Room" });
+
+    expect(createDocumentMock).toHaveBeenCalledWith(
+      process.env.MASTER_DATABASE_ID,
+      process.env.ROOMS_COLLECTION_ID,
+      "unique-id-123",
+      { name: "Test Room" }
+    );
+
+    expect(roomId).toBe("room-123");
+  });
+});

functions/create-room/src/livekit.js

@@ -1,45 +1,44 @@
 import { AccessToken, RoomServiceClient } from "livekit-server-sdk";
 
 class LivekitService {
-    constructor() {
-        this.roomServiceClient = new RoomServiceClient(
-            `${process.env.LIVEKIT_HOST}`,
-            `${process.env.LIVEKIT_API_KEY}`,
-            `${process.env.LIVEKIT_API_SECRET}`
-        );
-    }
+  constructor() {
+    this.roomServiceClient = new RoomServiceClient(
+      `${process.env.LIVEKIT_HOST}`,
+      `${process.env.LIVEKIT_API_KEY}`,
+      `${process.env.LIVEKIT_API_SECRET}`
+    );
+  }
 
-    generateToken(roomName, participantUid, isRoomAdmin) {
-        const accessToken = new AccessToken(
-            `${process.env.LIVEKIT_API_KEY}`,
-            `${process.env.LIVEKIT_API_SECRET}`,
-            {
-                identity: participantUid,
-            }
-        );
+  generateToken(roomName, participantUid, isRoomAdmin) {
+    const accessToken = new AccessToken(
+      `${process.env.LIVEKIT_API_KEY}`,
+      `${process.env.LIVEKIT_API_SECRET}`,
+      {
+        identity: participantUid,
+      }
+    );
 
-        //adding permissions to the access token before converting to jwt
-        accessToken.addGrant({
-            room: roomName,
-            roomCreate: isRoomAdmin,
-            roomAdmin: isRoomAdmin,
-            roomJoin: true,
-            canPublish: true,
-            canPublishData: true,
-            canSubscribe: true,
-            roomList: true,
-        });
+    //adding permissions to the access token before converting to jwt
+    accessToken.addGrant({
+      room: roomName,
+      roomCreate: isRoomAdmin,
+      roomAdmin: isRoomAdmin,
+      roomJoin: true,
+      canPublish: true,
+      canPublishData: true,
+      canSubscribe: true,
+      roomList: true,
+    });
 
-        //Return the JWT
-        return accessToken.toJwt();
-    }
+    //Return the JWT
+    return accessToken.toJwt();
+  }
 
-    async createRoom(roomOptions) {
-        const newLivekitRoom =
-            await this.roomServiceClient.createRoom(roomOptions);
+  async createRoom(roomOptions) {
+    const newLivekitRoom = await this.roomServiceClient.createRoom(roomOptions);
 
-        return newLivekitRoom;
-    }
+    return newLivekitRoom;
+  }
 }
 
 export default LivekitService;

functions/create-room/src/main.js

@@ -3,64 +3,60 @@ import LivekitService from "./livekit.js";
 import { throwIfMissing } from "./utils.js";
 
 export default async ({ req, res, log, error }) => {
-    throwIfMissing(process.env, [
-        "APPWRITE_API_KEY",
-        "MASTER_DATABASE_ID",
-        "ROOMS_COLLECTION_ID",
-        "LIVEKIT_HOST",
-        "LIVEKIT_API_KEY",
-        "LIVEKIT_API_SECRET",
-        "LIVEKIT_SOCKET_URL",
-    ]);
-
-    const appwrite = new AppwriteService();
-    const livekit = new LivekitService();
-
-    try {
-        throwIfMissing(JSON.parse(req.body), ["name", "adminUid", "tags"]);
-    } catch (err) {
-        error(err.message);
-        return res.json({ msg: err.message }, 400);
-    }
-
-    try {
-        log(req);
-        const { name, description, adminUid, tags } = JSON.parse(req.body);
-
-        // create a new room on appwrite
-        const newRoomdata = {
-            name,
-            description,
-            adminUid,
-            tags,
-            totalParticipants: 1,
-        };
-        const appwriteRoomId = await appwrite.createRoom(newRoomdata);
-        log(appwriteRoomId);
-
-        // create a new livekit room
-        const livekitRoomOptions = {
-            name: appwriteRoomId, // using appwrite room doc id as livekit room name
-            emptyTimeout: 300, // timeout in seconds
-        };
-        const livekitRoom = await livekit.createRoom(livekitRoomOptions);
-        log(livekitRoom);
-
-        // Creating a token for the admin
-        const accessToken = livekit.generateToken(
-            appwriteRoomId,
-            adminUid,
-            true
-        );
-
-        return res.json({
-            msg: "Room created Successfully",
-            livekit_room: livekitRoom,
-            livekit_socket_url: `${process.env.LIVEKIT_SOCKET_URL}`,
-            access_token: accessToken,
-        });
-    } catch (e) {
-        error(String(e));
-        return res.json({ msg: "Room creation failed" }, 500);
-    }
+  throwIfMissing(process.env, [
+    "APPWRITE_API_KEY",
+    "MASTER_DATABASE_ID",
+    "ROOMS_COLLECTION_ID",
+    "LIVEKIT_HOST",
+    "LIVEKIT_API_KEY",
+    "LIVEKIT_API_SECRET",
+    "LIVEKIT_SOCKET_URL",
+  ]);
+
+  const appwrite = new AppwriteService();
+  const livekit = new LivekitService();
+
+  try {
+    throwIfMissing(JSON.parse(req.body), ["name", "adminUid", "tags"]);
+  } catch (err) {
+    error(err.message);
+    return res.json({ msg: err.message }, 400);
+  }
+
+  try {
+    log(req);
+    const { name, description, adminUid, tags } = JSON.parse(req.body);
+
+    // create a new room on appwrite
+    const newRoomdata = {
+      name,
+      description,
+      adminUid,
+      tags,
+      totalParticipants: 1,
+    };
+    const appwriteRoomId = await appwrite.createRoom(newRoomdata);
+    log(appwriteRoomId);
+
+    // create a new livekit room
+    const livekitRoomOptions = {
+      name: appwriteRoomId, // using appwrite room doc id as livekit room name
+      emptyTimeout: 300, // timeout in seconds
+    };
+    const livekitRoom = await livekit.createRoom(livekitRoomOptions);
+    log(livekitRoom);
+
+    // Creating a token for the admin
+    const accessToken = livekit.generateToken(appwriteRoomId, adminUid, true);
+
+    return res.json({
+      msg: "Room created Successfully",
+      livekit_room: livekitRoom,
+      livekit_socket_url: `${process.env.LIVEKIT_SOCKET_URL}`,
+      access_token: accessToken,
+    });
+  } catch (e) {
+    error(String(e));
+    return res.json({ msg: "Room creation failed" }, 500);
+  }
 };