From 395bd2916f1060d66d7beafebda68f3701329c6d Mon Sep 17 00:00:00 2001
From: hpkoh <hpkoh99@gmail.com>
Date: Sun, 9 Oct 2022 03:04:11 +0800
Subject: [PATCH] [questions][feat] add quesetion comment crud

---
 .../questions-question-comment-router.ts      | 149 ++++++++++++++++++
 apps/portal/src/types/questions-question.d.ts |   7 +
 2 files changed, 156 insertions(+)
 create mode 100644 apps/portal/src/server/router/questions-question-comment-router.ts

diff --git a/apps/portal/src/server/router/questions-question-comment-router.ts b/apps/portal/src/server/router/questions-question-comment-router.ts
new file mode 100644
index 00000000..70d67c38
--- /dev/null
+++ b/apps/portal/src/server/router/questions-question-comment-router.ts
@@ -0,0 +1,149 @@
+import { z } from 'zod';
+import {QuestionsVote } from '@prisma/client';
+import { TRPCError } from '@trpc/server';
+
+import { createProtectedRouter } from './context';
+
+import type { QuestionComment } from '~/types/questions-question';
+
+export const questionsQuestionCommentRouter = createProtectedRouter()
+  .query('getQuestionComments', {
+    input: z.object({
+      questionId: z.string(),
+    }),
+    async resolve({ ctx, input }) {
+      const questionCommentsData = await ctx.prisma.questionsQuestionComment.findMany({
+        include: {
+        _count: {
+          select: {
+            votes: true,
+          },
+        },
+        user: {
+          select: {
+            name: true,
+          },
+        },
+        votes: true,
+        },
+        orderBy: {
+          createdAt: 'desc',
+        },
+        where: {
+          ...input,
+        },
+    });
+    return questionCommentsData.map((data) => {
+      const votes:number = data.votes.reduce(
+        (previousValue:number, currentValue) => {
+          let result:number = previousValue;
+
+          switch(currentValue.vote) {
+          case QuestionsVote.NO_VOTE:
+            break;
+          case QuestionsVote.UPVOTE:
+            result += 1
+            break;
+          case QuestionsVote.DOWNVOTE:
+            result -= 1
+            break;
+          }
+          return result;
+        },
+        0
+        );
+
+      let userName = "";
+
+      if (data.user) {
+        userName = data.user.name!;
+      }
+
+
+      const question: QuestionComment = {
+        content: data.content,
+        createdAt: data.createdAt,
+        id: data.id,
+        numVotes: votes,
+        user: userName,
+      };
+      return question;
+    });
+    }
+  })
+  .mutation('create', {
+    input: z.object({
+      content: z.string(),
+      questionId: z.string(),
+    }),
+    async resolve({ ctx, input }) {
+      const userId = ctx.session?.user?.id;
+
+      return await ctx.prisma.questionsQuestionComment.create({
+        data: {
+          ...input,
+          userId,
+        },
+      });
+    },
+  })
+  .mutation('update', {
+    input: z.object({
+      content: z.string().optional(),
+      id: z.string(),
+    }),
+    async resolve({ ctx, input }) {
+      const userId = ctx.session?.user?.id;
+
+      const questionCommentToUpdate = await ctx.prisma.questionsQuestionComment.findUnique({
+        where: {
+          id: input.id,
+        },
+      });
+
+      if (questionCommentToUpdate?.id !== userId) {
+        throw new TRPCError({
+          code: 'UNAUTHORIZED',
+          message: 'User have no authorization to record.',
+          // Optional: pass the original error to retain stack trace
+        });
+      }
+
+      return await ctx.prisma.questionsQuestionComment.update({
+        data: {
+          ...input,
+          userId,
+        },
+        where: {
+          id: input.id,
+        },
+      });
+    },
+  })
+  .mutation('delete', {
+    input: z.object({
+      id: z.string(),
+    }),
+    async resolve({ ctx, input }) {
+      const userId = ctx.session?.user?.id;
+
+      const questionCommentToUpdate = await ctx.prisma.questionsQuestionComment.findUnique({
+        where: {
+          id: input.id,
+        },});
+
+      if (questionCommentToUpdate?.id !== userId) {
+        throw new TRPCError({
+          code: 'UNAUTHORIZED',
+          message: 'User have no authorization to record.',
+          // Optional: pass the original error to retain stack trace
+        });
+      }
+
+      return await ctx.prisma.questionsQuestionComment.delete({
+        where: {
+          id: input.id,
+        },
+      });
+    },
+  });
\ No newline at end of file
diff --git a/apps/portal/src/types/questions-question.d.ts b/apps/portal/src/types/questions-question.d.ts
index e69de29b..15ff11fd 100644
--- a/apps/portal/src/types/questions-question.d.ts
+++ b/apps/portal/src/types/questions-question.d.ts
@@ -0,0 +1,7 @@
+export type QuestionComment = {
+  content: string;
+  createdAt: Date;
+  id: string;
+  numVotes: number;
+  user: string;
+};
\ No newline at end of file