Merge pull request #125 from Turing-Sandbox/SUMMA-16

SUMMA-16: CommentService Frontend implementation

Author: BengeeL

backend/src/app.ts

@@ -9,7 +9,6 @@ import path from "path";
 
 // Import routes
 import userRoutes from './modules/user/routes/user.routes';
-import commentRoutes from './modules/comment/routes/comment.routes';
 import contentRoutes from './modules/content/routes/content.routes';
 import subscriptionRoutes from './modules/subscription/routes/subscription.routes';
 import notificationRoutes from './modules/notification/routes/notification.routes';
@@ -53,7 +52,6 @@ app.get("/health", (req, res) => {
 
 // API routes
 app.use("/user", userRoutes);
-app.use("/comment", commentRoutes);
 app.use("/content", contentRoutes);
 app.use("/subscription", subscriptionRoutes);
 app.use("/notification", notificationRoutes);

backend/src/modules/comment/controllers/comment.controller.ts

@@ -0,0 +1,118 @@
+import {
+  createComment,
+  deleteComment,
+  deletePost,
+  getAllComments,
+  getComment,
+  updateComment,
+} from "../services/comment.service";
+import { ContentService } from "../services/content.service";
+import { Request, Response } from "express";
+import { getUser } from "../../user/services/user.service";
+
+export async function createCommentController(
+  req: Request,
+  res: Response
+): Promise<void> {
+  const { post_id } = req.params;
+  const { owner_id, text } = req.body;
+  try {
+    const response = await getUser(owner_id);
+    const creation = await createComment(
+      post_id,
+      owner_id,
+      text,
+      response?.username
+    );
+    res.status(201).json({ message: "Comment created successfully", creation });
+  } catch (error) {
+    console.log(error);
+    console.log(post_id, owner_id, text);
+    res.status(500).json({ error: error });
+  }
+}
+
+export async function getCommentByIdController(req: Request, res: Response) {
+  const { post_id, comment_id } = req.params;
+  try {
+    const comment = await getComment(post_id, comment_id);
+    console.log(comment);
+    if (comment) res.status(200).json(comment);
+    else res.status(404).json(null);
+  } catch (error) {
+    res.status(500).json({ error: "Failed to fetch comment" });
+    console.log(error);
+  }
+}
+
+export async function updateCommentController(req: Request, res: Response) {
+  const { post_id, comment_id, user_id } = req.params;
+  const comment = await getComment(post_id, comment_id);
+  if (comment?.owner_id == user_id) {
+    const updatedComment = req.body;
+    try {
+      await updateComment(post_id, comment_id, updatedComment);
+      res.status(200).json({ message: "Comment updated successfully" });
+    } catch (error) {
+      res.status(500).json({ error: "Failed to update comment" });
+      console.log(error);
+    }
+  } else {
+    res.status(401).json({ error: "You do not have permission to try this." });
+  }
+}
+
+export async function deleteCommentController(req: Request, res: Response) {
+  const { post_id, comment_id, user_id } = req.params;
+  const comment = await getComment(post_id, comment_id);
+  if (comment?.owner_id == user_id) {
+    try {
+      await deleteComment(post_id, comment_id);
+      res.status(200).json({ message: "Comment deleted successfully" });
+    } catch (error) {
+      res.status(500).json({ error: error });
+      console.log(error);
+    }
+  } else {
+    res.status(401).json({ error: "You do not have permission to try this." });
+  }
+}
+
+export async function deletePostController(req: Request, res: Response) {
+  const { post_id, user_id } = req.params;
+  const post = await ContentService.getContent(post_id);
+  const creator_id = post?.creatorUID;
+  if (creator_id == user_id) {
+    try {
+      await deletePost(post_id);
+      res
+        .status(200)
+        .json({ message: "Post (entire comment tree) deleted successfully" });
+    } catch (error) {
+      res.status(500).json({ error: error + " " + post_id });
+      console.log(error);
+    }
+  } else {
+    res.status(401).json({ error: "You do not have permission to try this." });
+  }
+}
+
+export async function getCommentsByPostController(
+  req: Request,
+  res: Response
+): Promise<void> {
+  const { post_id } = req.params;
+  try {
+    const comments = await getAllComments(post_id);
+
+    if (Object.keys(comments).length > 0) {
+      res.status(200).json(comments);
+    } else {
+      res.status(200).json(null);
+    }
+  } catch (error) {
+    console.error("Error fetching comments:", error);
+    res.status(500).json({ error: "Failed to fetch comments" });
+    console.log("GET ALL COMMENTS ERROR: ", error);
+  }
+}

backend/src/modules/comment/routes/comment.routes.ts

@@ -0,0 +1,46 @@
+import { Router } from "express";
+import {
+  updateCommentController,
+  createCommentController,
+  deleteCommentController,
+  getCommentsByPostController,
+  getCommentByIdController,
+} from "../controllers/comment.controller";
+import { authenticateToken } from "../../../shared/middleware/auth";
+
+const commentRouter = Router();
+
+// Post routes
+commentRouter.post(
+  "/:contentId/comment",
+  authenticateToken,
+  createCommentController
+);
+
+// Get routes
+commentRouter.get(
+  "/:contentId/comments",
+  authenticateToken,
+  getCommentsByPostController
+);
+commentRouter.get(
+  "/:contentId/comment/:commentId",
+  authenticateToken,
+  getCommentByIdController
+);
+
+// Put routes
+commentRouter.put(
+  "/:contentId/comment/:commentId",
+  authenticateToken,
+  updateCommentController
+);
+
+// Delete routes
+commentRouter.delete(
+  "/:contentId/comment/:commentId",
+  authenticateToken,
+  deleteCommentController
+);
+
+export default commentRouter;

backend/src/modules/content/controllers/comment.controller.ts

@@ -1,13 +1,17 @@
 import { Router } from "express";
 import { ContentController } from "../controllers/content.controller";
+import commentRouter from "./comment.routes";
 
 const contentRoutes = Router();
 
 contentRoutes.post("/", ContentController.createContent); // Create new content
 contentRoutes.post("/uploadThumbnail", ContentController.uploadThumbnail); // Upload thumbnail
 
 contentRoutes.get("/feed/trending", ContentController.getTrendingContent); // Get trending content
-contentRoutes.get("/feed/creators/:userId", ContentController.getRelatedContentCreators); // Get related content creators
+contentRoutes.get(
+  "/feed/creators/:userId",
+  ContentController.getRelatedContentCreators
+); // Get related content creators
 contentRoutes.get("/feed/:userId", ContentController.getPersonalizedContent); // Get personalized content
 contentRoutes.get("/related/:contentId", ContentController.getRelatedContent); // Get related content
 
@@ -49,4 +53,6 @@ contentRoutes.post(
   ContentController.unshareContent
 ); // Unshare content
 
+contentRoutes.use("/", commentRouter);
+
 export default contentRoutes;

…/modules/comment/models/comment.model.ts …/modules/content/models/comment.model.tsbackend/src/modules/comment/models/comment.model.ts renamed to backend/src/modules/content/models/comment.model.ts backend/src/modules/comment/models/comment.model.ts renamed to backend/src/modules/content/models/comment.model.ts

@@ -3,7 +3,7 @@ import { ref, get, set, remove, update, child, push } from "firebase/database";
 import { Comment } from "../models/comment.model";
 import { pushNotification } from "../../notification/services/notification.service";
 import { Notification } from "../../notification/models/notification.model";
-import { ContentService } from "../../content/services/content.service";
+import { ContentService } from "./content.service";
 
 export async function createComment(
   post_id: string,