Team meetings

backend/src/httpServer.ts

@@ -4,6 +4,7 @@ import usersRouter from "./routes/usersRoute";
 import authRouter from "./routes/authRoute";
 import chatRouter from "./routes/chatRoute";
 import { cleanUpData, importInitialData } from "./db";
+import roomRouter from "./routes/roomRoute";
 
 const { app } = servers;
 
@@ -15,3 +16,4 @@ importInitialData().then((res) => console.log(res));
 app.use("/users", usersRouter);
 app.use("/auth", authRouter);
 app.use("/chat", chatRouter);
+app.use("/room", roomRouter);

backend/src/routes/roomRoute.ts

@@ -0,0 +1,75 @@
+import { Router } from "express";
+import { isFriend } from "../users";
+import driver from "../driver/driver";
+const roomRouter = Router();
+
+roomRouter.get("/:userId", async (req, res) => {
+  try {
+    const userId = req.params.userId;
+    const session = driver.session();
+    const roomsQuery = await session.run(
+      `
+            MATCH (room:Room)-[:INVITED]-(u:User {id: $userId})
+            RETURN room
+        `,
+      { userId },
+    );
+    await session.close();
+    const rooms = roomsQuery.records
+      .map((record) => record.get("room").properties)
+      .map((record) => ({
+        ...record,
+        title: "Join meeting",
+      }));
+    return res.json({ status: "ok", rooms });
+  } catch (err) {
+    console.log("Error:", err);
+    return res.status(404).json({ status: "error", errors: err as object });
+  }
+});
+
+roomRouter.post("/", async (req, res) => {
+  try {
+    const newRoomProps = req.body;
+    const { roomId, from, to } = newRoomProps;
+    const session = driver.session();
+    const areFriends = await isFriend(session, from, to);
+    if (!areFriends) {
+      await session.close();
+      return res
+        .status(400)
+        .json({ status: "error", errors: { id: "no friends" } });
+    }
+    await session.run(`CREATE (r: Room $room)`, { room: newRoomProps });
+    await session.run(
+      `
+            MATCH (u:User {id: $userId})
+            MATCH (r:Room {roomId: $roomId})
+            CREATE (r)-[:INVITED]->(u)
+        `,
+      { userId: to, roomId },
+    );
+    await session.close();
+    return res.json({ status: "ok" });
+  } catch (err) {
+    console.log("Error:", err);
+    return res.status(404).json({ status: "error", errors: err as object });
+  }
+});
+
+roomRouter.delete("/:roomId", async (req, res) => {
+  try {
+    const roomId = req.params.roomId;
+    const session = driver.session();
+    await session.run(`MATCH (r:Room {roomId: $roomId}) DETACH DELETE r`, {
+      roomId,
+    });
+    await session.close();
+    return res.json({ status: "ok" });
+  } catch (err) {
+    console.log("Error:", err);
+    return res.status(404).json({ status: "error", errors: err as object });
+  }
+});
+
+export default roomRouter;

backend/src/routes/usersRoute.ts

@@ -234,6 +234,30 @@ usersRouter.get("/meetings/:userId", async (req: Request, res) => {
   }
 });
 
+usersRouter.get("/:userId/name", async (req, res) => {
+  try {
+    const userId = req.params.userId;
+    const session = driver.session();
+    const user = await userExists(session, { id: userId });
+    if (!user) {
+      return userNotFoundRes(res);
+    }
+    const userNameRequest = await session.run(
+      `MATCH (u:User {id: $userId}) return u`,
+      { userId },
+    );
+    await session.close();
+    const userData: User = userNameRequest.records.map((u) =>
+      filterUser(u.get("u").properties),
+    )[0];
+    const fullName = `${userData.first_name} ${userData.last_name}`;
+    return res.json({ status: "ok", fullName });
+  } catch (err) {
+    console.log("Error:", err);
+    return res.status(404).json({ status: "error", errors: err as object });
+  }
+});
+
 usersRouter.put("/meetings/:meetingId", async (req: Request, res) => {
   try {
     const session = driver.session();

backend/src/socketServer.ts

@@ -143,6 +143,34 @@ io.on("connection", async (socket: Socket) => {
     });
   });
 
+  socket.on("newRoom", async ({ roomId, from, to, userName }) => {
+    await socket.join(roomId);
+    const session = driver.session();
+    const userSockets = await getAllSockets(session, to);
+    userSockets.forEach((userSocket) => {
+      socket.to(userSocket.id).emit("newRoom", {
+        from,
+        roomId,
+        title: "Join room",
+        to,
+        userName,
+      });
+    });
+    await session.close();
+  });
+
+  socket.on("joinRoom", async ({ roomId, peerId, userId, fullName }) => {
+    await socket.join(roomId);
+    socket
+      .to(roomId)
+      .emit("userConnected", { peerId, userId, fullName, socketId: socket.id });
+  });
+
+  socket.on("leftRoom", async ({ userId, roomId }) => {
+    await socket.join(roomId);
+    socket.to(roomId).emit("leftRoom", userId);
+  });
+
   socket.on("disconnect", async (_reason) => {
     const session = driver.session();
     await leaveMeeting(session, userId);

compose.yml

@@ -22,6 +22,11 @@ services:
     ports:
       - 5173:80
 
+  peer-server:
+    build: ./peer-server
+    ports:
+      - 8000:8000
+
   backend:
     build: ./backend
     env_file: