Merge pull request #190 from ReDI-School/feature/comments-endpoint

endpoint Comments

Author: savitha14june

backend/prisma/migrations/20250515115109_add_comments_table/migration.sql

@@ -0,0 +1,18 @@
+-- CreateTable
+CREATE TABLE "Comment" (
+    "id" SERIAL NOT NULL,
+    "userId" TEXT NOT NULL,
+    "createdAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "pinId" INTEGER NOT NULL,
+
+    CONSTRAINT "Comment_pkey" PRIMARY KEY ("id")
+);
+
+-- CreateIndex
+CREATE UNIQUE INDEX "Comment_userId_pinId_key" ON "Comment"("userId", "pinId");
+
+-- AddForeignKey
+ALTER TABLE "Comment" ADD CONSTRAINT "Comment_userId_fkey" FOREIGN KEY ("userId") REFERENCES "User"("id") ON DELETE RESTRICT ON UPDATE CASCADE;
+
+-- AddForeignKey
+ALTER TABLE "Comment" ADD CONSTRAINT "Comment_pinId_fkey" FOREIGN KEY ("pinId") REFERENCES "Pin"("id") ON DELETE RESTRICT ON UPDATE CASCADE;

backend/prisma/migrations/20250515115355_add_comments_table/migration.sql

@@ -0,0 +1,8 @@
+/*
+  Warnings:
+
+  - Added the required column `msg` to the `Comment` table without a default value. This is not possible if the table is not empty.
+
+*/
+-- AlterTable
+ALTER TABLE "Comment" ADD COLUMN     "msg" TEXT NOT NULL;

backend/prisma/migrations/20250515121716_add_comments_table/migration.sql

@@ -0,0 +1,10 @@
+/*
+  Warnings:
+
+  - You are about to drop the column `msg` on the `Comment` table. All the data in the column will be lost.
+  - Added the required column `content` to the `Comment` table without a default value. This is not possible if the table is not empty.
+
+*/
+-- AlterTable
+ALTER TABLE "Comment" DROP COLUMN "msg",
+ADD COLUMN     "content" TEXT NOT NULL;

backend/prisma/schema.prisma

@@ -40,22 +40,20 @@ model Pin {
   imageUrl    String
   description String?
   createdAt   DateTime @default(now())
-
   author   User   @relation(fields: [authorId], references: [id])
   authorId String
-
   reactions Reaction[]
   comments  Comment[]
 }
 
 model Comment {
-  id        Int      @id @default(autoincrement())
-  content   String
+  id        Int       @id @default(autoincrement())
+  user      User @relation(fields: [userId], references: [id])
+  userId    String
   createdAt DateTime @default(now())
+  pin       Pin  @relation(fields: [pinId], references: [id])
+  pinId     Int
+  content   String
 
-  user   User   @relation(fields: [userId], references: [id])
-  userId String
-
-  pin   Pin @relation(fields: [pinId], references: [id])
-  pinId Int
+  @@unique([userId, pinId]) // prevent duplicate Comments
 }

backend/src/controllers/commentsController.js

@@ -0,0 +1,77 @@
+import prisma from "../prisma/client.js";
+import {
+  BAD_REQUEST,
+  CREATED,
+  INTERNAL_SERVER_ERROR,
+  OK
+} from "../constants/http.js";
+
+export const getComments = async (req, res) => {
+  const { pinId } = req.query;
+  try {
+    if (!pinId) {
+      return res.status(BAD_REQUEST).json({ error: "pinId is required." });
+    }
+
+    const comments = await prisma.comment.findMany({
+      where: {
+        pinId: Number(pinId)
+      }
+    });
+
+    res.json({ comments });
+  } catch (err) {
+    res
+      .status(INTERNAL_SERVER_ERROR)
+      .json({ error: "Something went wrong in loading comments." });
+  }
+};
+
+export const addComment = async (req, res) => {
+  const { pinId, userId, content } = req.body;
+
+  // Validate required fields
+  if (!pinId || !userId) {
+    return res
+      .status(BAD_REQUEST)
+      .json({ error: "pinId and userId are required." });
+  }
+  if (!content) {
+    return res.status(BAD_REQUEST).json({ error: "Comment is empty." });
+  }
+
+  try {
+    // Create a comment
+    const comment = await prisma.comment.create({
+      data: {
+        userId: String(userId),
+        pinId: Number(pinId),
+        content: String(content)
+      }
+    });
+
+    res.status(CREATED).json({
+      message: "Comment added.",
+      comment
+    });
+  } catch (err) {
+    console.error("Add Comment Error:", err);
+    res.status(INTERNAL_SERVER_ERROR).json({ error: "Failed to add comment." });
+  }
+};
+
+export const deleteComment = async (req, res) => {
+  const { id } = req.body;
+  try {
+    await prisma.comment.delete({
+      where: {
+        id: Number(id)
+      }
+    });
+    res.status(OK).json({ message: "Comment removed." });
+  } catch (err) {
+    res
+      .status(INTERNAL_SERVER_ERROR)
+      .json({ error: "Failed to delete comment." });
+  }
+};

backend/src/index.js

@@ -5,6 +5,7 @@ import express from "express";
 import cors from "cors";
 import reactionsRoutes from "./routes/reactionsRoute.js";
 import userRoutes from "./routes/userRoute.js";
+import commentsRoutes from "./routes/commentsRoute.js";
 import { errorHandler } from "./middlewares/errorMiddleware.js";
 
 const app = express();
@@ -17,6 +18,7 @@ app.use(cors());
 // routes
 app.use("/api/reactions", reactionsRoutes);
 app.use("/api/user", userRoutes);
+app.use("/api/comments", commentsRoutes);
 
 // get
 app.get("/", (req, res) => {

backend/src/routes/commentsRoute.js

@@ -0,0 +1,13 @@
+import express from "express";
+const router = express.Router();
+import {
+  getComments,
+  addComment,
+  deleteComment
+} from "../controllers/commentsController.js";
+
+router.get("/", getComments);
+router.post("/", addComment);
+router.delete("/", deleteComment);
+
+export default router;