From 4fa350964f086d63b2fdfc6b281a5debe73abdd3 Mon Sep 17 00:00:00 2001
From: hpkoh <53825802+hpkoh@users.noreply.github.com>
Date: Thu, 20 Oct 2022 00:32:42 +0800
Subject: [PATCH] [questions][feat] add question encounter crud (#343)

---
 .../questions-question-encounter-router.ts    | 135 ++++++++++++++++++
 apps/portal/src/types/questions.d.ts          |   6 +
 2 files changed, 141 insertions(+)
 create mode 100644 apps/portal/src/server/router/questions-question-encounter-router.ts

diff --git a/apps/portal/src/server/router/questions-question-encounter-router.ts b/apps/portal/src/server/router/questions-question-encounter-router.ts
new file mode 100644
index 00000000..2894fdf4
--- /dev/null
+++ b/apps/portal/src/server/router/questions-question-encounter-router.ts
@@ -0,0 +1,135 @@
+import { z } from 'zod';
+import { TRPCError } from '@trpc/server';
+
+import { createProtectedRouter } from './context';
+
+import type { AggregatedQuestionEncounter } from '~/types/questions';
+
+export const questionsQuestionEncounterRouter = createProtectedRouter()
+  .query('getAggregatedEncounters', {
+    input: z.object({
+      questionId: z.string(),
+    }),
+    async resolve({ ctx, input }) {
+      const questionEncountersData = await ctx.prisma.questionsQuestionEncounter.findMany({
+        include: {
+          company : true,
+        },
+        where: {
+          ...input,
+        },
+      });
+
+      const companyCounts: Record<string, number> = {};
+      const locationCounts: Record<string, number> = {};
+      const roleCounts:Record<string, number> = {};
+
+      for (let i = 0; i < questionEncountersData.length; i++) {
+        const encounter = questionEncountersData[i];
+
+        if (!(encounter.company!.name in companyCounts)) {
+            companyCounts[encounter.company!.name] = 1;
+        }
+        companyCounts[encounter.company!.name] += 1;
+
+        if (!(encounter.location in locationCounts)) {
+            locationCounts[encounter.location] = 1;
+        }
+        locationCounts[encounter.location] += 1;
+
+        if (!(encounter.role in roleCounts)) {
+            roleCounts[encounter.role] = 1;
+        }
+        roleCounts[encounter.role] += 1;
+
+      }
+
+      const questionEncounter:AggregatedQuestionEncounter = {
+        companyCounts,
+        locationCounts,
+        roleCounts,
+      }
+      return questionEncounter;
+    }
+  })
+  .mutation('create', {
+    input: z.object({
+      companyId: z.string(),
+      location: z.string(),
+      questionId: z.string(),
+      role: z.string(),
+      seenAt: z.date()
+    }),
+    async resolve({ ctx, input }) {
+      const userId = ctx.session?.user?.id;
+
+      return await ctx.prisma.questionsQuestionEncounter.create({
+        data: {
+          ...input,
+          userId,
+        },
+      });
+    },
+  })
+  .mutation('update', {
+    //
+    input: z.object({
+      companyId: z.string().optional(),
+      id: z.string(),
+      location: z.string().optional(),
+      role: z.string().optional(),
+      seenAt: z.date().optional(),
+    }),
+    async resolve({ ctx, input }) {
+      const userId = ctx.session?.user?.id;
+
+      const questionEncounterToUpdate = await ctx.prisma.questionsQuestionEncounter.findUnique({
+        where: {
+          id: input.id,
+        },
+      });
+
+      if (questionEncounterToUpdate?.id !== userId) {
+        throw new TRPCError({
+          code: 'UNAUTHORIZED',
+          message: 'User have no authorization to record.',
+        });
+      }
+
+      return await ctx.prisma.questionsQuestionEncounter.update({
+        data: {
+          ...input,
+        },
+        where: {
+          id: input.id,
+        },
+      });
+    },
+  })
+  .mutation('delete', {
+    input: z.object({
+      id: z.string(),
+    }),
+    async resolve({ ctx, input }) {
+      const userId = ctx.session?.user?.id;
+
+      const questionEncounterToDelete = await ctx.prisma.questionsQuestionEncounter.findUnique({
+        where: {
+          id: input.id,
+        },
+      });
+
+      if (questionEncounterToDelete?.id !== userId) {
+        throw new TRPCError({
+          code: 'UNAUTHORIZED',
+          message: 'User have no authorization to record.',
+        });
+      }
+
+      return await ctx.prisma.questionsQuestionEncounter.delete({
+        where: {
+          id: input.id,
+        },
+      });
+    },
+  });
\ No newline at end of file
diff --git a/apps/portal/src/types/questions.d.ts b/apps/portal/src/types/questions.d.ts
index 9ee7d6f0..521f3b8b 100644
--- a/apps/portal/src/types/questions.d.ts
+++ b/apps/portal/src/types/questions.d.ts
@@ -16,6 +16,12 @@ export type Question = {
   user: string;
 };
 
+export type AggregatedQuestionEncounter = {
+  companyCounts: Record<string, number>;
+  locationCounts: Record<string, number>;
+  roleCounts: Record<string, number>;
+}
+
 export type AnswerComment = {
   content: string;
   createdAt: Date;