fix: use global prisma client in forms (#603)

* fix: use global prisma client in forms * fix
SocialGouv · Dec 12, 2023 · 0daee8b · 0daee8b
1 parent aa51d0d
commit 0daee8b
Show file tree

Hide file tree

Showing 11 changed files with 96 additions and 128 deletions.
diff --git a/formulaire/pages/api/auth/[...nextauth].ts b/formulaire/pages/api/auth/[...nextauth].ts
@@ -1,24 +1,22 @@
 // @ts-nocheck
 import { PrismaAdapter } from "@next-auth/prisma-adapter";
-import { PrismaClient } from "@prisma/client"
 import * as Sentry from "@sentry/nextjs";
 import NextAuth from "next-auth";
 import EmailAuthProvider from "next-auth/providers/email";
 import { sendVerificationRequest } from "../../../src/lib/emailAuth";
-import type { NextAuthOptions } from 'next-auth'
-
-const prisma = new PrismaClient();
+import type { NextAuthOptions } from "next-auth";
+import client from "src/lib/prismaClient";
 
 export const authOptions: NextAuthOptions = {
-  adapter: PrismaAdapter(prisma),
+  adapter: PrismaAdapter(client),
   callbacks: {
     session({ session, user }) {
       session.dbUser = user;
       return session;
     },
     async signIn({ user }) {
       if (typeof user.email !== "string") return false;
-      return true
+      return true;
     },
   },
   logger: {
@@ -48,4 +46,4 @@ export const authOptions: NextAuthOptions = {
   secret: process.env.NEXTAUTH_SECRET,
 };
 
-export default NextAuth(authOptions)
+export default NextAuth(authOptions);
diff --git a/formulaire/pages/api/demandeur/[id].tsx b/formulaire/pages/api/demandeur/[id].tsx
@@ -1,7 +1,7 @@
 import type { NextApiHandler, NextApiRequest } from "next";
-import { PrismaClient } from "@prisma/client";
 import { getServerSession } from "next-auth";
-import { authOptions }  from '../auth/[...nextauth]'
+import { authOptions } from "../auth/[...nextauth]";
+import client from "src/lib/prismaClient";
 
 const handler: NextApiHandler = async (req, res) => {
   const session = await getServerSession(req, res, authOptions);
@@ -27,10 +27,9 @@ function getId(req: NextApiRequest): number {
 }
 
 const get: NextApiHandler = async (req, res) => {
-  const prisma = new PrismaClient();
   const demandeurId = getId(req);
   try {
-    const demandeur = await prisma.demandeur.findFirst({
+    const demandeur = await client.demandeur.findFirst({
       where: {
         id: demandeurId,
       },
@@ -42,10 +41,9 @@ const get: NextApiHandler = async (req, res) => {
 };
 
 const remove: NextApiHandler = async (req, res) => {
-  const prisma = new PrismaClient();
   try {
     const demandeurId = getId(req);
-    await prisma.demandeur.delete({
+    await client.demandeur.delete({
       where: { id: demandeurId },
     });
 
@@ -60,11 +58,9 @@ const remove: NextApiHandler = async (req, res) => {
       }
       return r.json();
     });
-    await prisma?.$disconnect()
 
     res.status(200).json({ message: "Demandeur supprimé" });
   } catch (e: unknown) {
-    await prisma?.$disconnect()
     console.log(e);
     res.status(200).json({ message: "Demandeur non trouvé" });
   }

diff --git a/formulaire/pages/api/dossier/[id].tsx b/formulaire/pages/api/dossier/[id].tsx
@@ -1,12 +1,12 @@
 import type { NextApiHandler, NextApiRequest } from "next";
-import { PrismaClient } from "@prisma/client";
 import { generateToken } from "src/lib/utils";
 import { getServerSession } from "next-auth";
-import { authOptions }  from '../auth/[...nextauth]'
+import { authOptions } from "../auth/[...nextauth]";
+import client from "src/lib/prismaClient";
 
 const handler: NextApiHandler = async (req, res) => {
   const session = await getServerSession(req, res, authOptions);
-  console.log('session id', session)
+  console.log("session id", session);
   if (!session) {
     res.status(401).end();
     return;
@@ -33,10 +33,9 @@ function getId(req: NextApiRequest): number {
 }
 
 const remove: NextApiHandler = async (req, res) => {
-  const prisma = new PrismaClient();
   try {
     const dossierId = getId(req);
-    const dossierDeleted = await prisma.dossier.delete({
+    const dossierDeleted = await client.dossier.delete({
       where: { id: dossierId },
     });
 
@@ -51,25 +50,22 @@ const remove: NextApiHandler = async (req, res) => {
       }
       return r.json();
     });
-    await prisma?.$disconnect()
 
     res.status(200).json({ dossierDeleted });
   } catch (e: unknown) {
-    await prisma?.$disconnect()
     console.log(e);
     res.status(200).json({ message: "Dossier non trouvé" });
   }
 };
 
 const get: NextApiHandler = async (req, res) => {
   const session = await getServerSession(req, res, authOptions);
-  const prisma = new PrismaClient();
 
   var jwt = require("jsonwebtoken");
 
   try {
     const dossierId = getId(req);
-    const dossier = await prisma.dossier.findUnique({
+    const dossier = await client.dossier.findUnique({
       include: {
         user: true,
         enfants: {
@@ -91,7 +87,6 @@ const get: NextApiHandler = async (req, res) => {
       dossier?.userId === session?.dbUser.id ||
       dossier?.collaboratorIds.includes(session?.dbUser.id)
     ) {
-      await prisma?.$disconnect()
       res.status(200).json({
         dossier: dossier,
         docs: {
@@ -124,11 +119,9 @@ const get: NextApiHandler = async (req, res) => {
         },
       });
     } else {
-      await prisma?.$disconnect()
       res.status(401).json({ message: "Unauthorized" });
     }
   } catch (e: unknown) {
-    await prisma?.$disconnect()
     console.log(e);
     res.status(200).json({ message: "Dossier non trouvé" });
   }

diff --git a/formulaire/pages/api/dossier/duplicate/[id].tsx b/formulaire/pages/api/dossier/duplicate/[id].tsx
@@ -1,7 +1,8 @@
 import type { NextApiHandler, NextApiRequest } from "next";
-import { Dossier, PrismaClient, StatutDossier } from "@prisma/client";
+import { Dossier, StatutDossier } from "@prisma/client";
 import { getServerSession } from "next-auth";
-import { authOptions }  from '../../auth/[...nextauth]'
+import { authOptions } from "../../auth/[...nextauth]";
+import client from "src/lib/prismaClient";
 
 const handler: NextApiHandler = async (req, res) => {
   const session = await getServerSession(req, res, authOptions);
@@ -23,7 +24,6 @@ function getId(req: NextApiRequest): number {
 }
 
 const create: NextApiHandler = async (req, res) => {
-  const prisma = new PrismaClient();
   const dossier: Dossier = JSON.parse(req.body);
   const session = await getServerSession(req, res, authOptions);
 
@@ -48,7 +48,7 @@ const create: NextApiHandler = async (req, res) => {
   };
 
   try {
-    const dossier = await prisma.dossier.create({ data });
+    const dossier = await client.dossier.create({ data });
     res.status(200).json(dossier);
   } catch (e: unknown) {
     console.log(e);

diff --git a/formulaire/pages/api/enfants/[id].tsx b/formulaire/pages/api/enfants/[id].tsx
@@ -1,7 +1,7 @@
 import type { NextApiHandler, NextApiRequest } from "next";
-import { Enfant, PrismaClient } from "@prisma/client";
 import { getServerSession } from "next-auth";
-import { authOptions }  from '../auth/[...nextauth]'
+import { authOptions } from "../auth/[...nextauth]";
+import client from "src/lib/prismaClient";
 
 const handler: NextApiHandler = async (req, res) => {
   const session = await getServerSession(req, res, authOptions);
@@ -23,10 +23,9 @@ function getId(req: NextApiRequest): number {
 }
 
 const remove: NextApiHandler = async (req, res) => {
-  const prisma = new PrismaClient();
   try {
     const enfantId = getId(req);
-    const enfantDeleted = await prisma.enfant.delete({
+    const enfantDeleted = await client.enfant.delete({
       where: { id: enfantId },
     });
 
@@ -41,11 +40,9 @@ const remove: NextApiHandler = async (req, res) => {
       }
       return r.json();
     });
-    await prisma?.$disconnect()
 
     res.status(200).json({ message: fetching });
   } catch (e: unknown) {
-    await prisma?.$disconnect()
     console.log(e);
     res.status(200).json({ message: "Enfant non trouvé" });
   }

diff --git a/formulaire/pages/api/enfants/dossier/[id].tsx b/formulaire/pages/api/enfants/dossier/[id].tsx
@@ -1,7 +1,7 @@
 import type { NextApiHandler, NextApiRequest } from "next";
-import { Enfant, PrismaClient } from "@prisma/client";
 import { getServerSession } from "next-auth";
-import { authOptions }  from '../../auth/[...nextauth]'
+import { authOptions } from "../../auth/[...nextauth]";
+import client from "src/lib/prismaClient";
 
 const handler: NextApiHandler = async (req, res) => {
   const session = await getServerSession(req, res, authOptions);
@@ -24,46 +24,44 @@ function getId(req: NextApiRequest): number {
 
 const get: NextApiHandler = async (req, res) => {
   const session = await getServerSession(req, res, authOptions);
-  const prisma = new PrismaClient();
-  console.log('order : ', req.query.order)
+  console.log("order : ", req.query.order);
   try {
     const dossierId = getId(req);
-    const dossierConcerned = await prisma.dossier.findUnique({
-        where: {
-            id: dossierId
-        }
-    })
-    
+    const dossierConcerned = await client.dossier.findUnique({
+      where: {
+        id: dossierId,
+      },
+    });
+
     if (
-        dossierConcerned?.userId === session?.dbUser.id ||
-        dossierConcerned?.collaboratorIds.includes(session?.dbUser.id)
+      dossierConcerned?.userId === session?.dbUser.id ||
+      dossierConcerned?.collaboratorIds.includes(session?.dbUser.id)
     ) {
-      const enfantsByDossier = await prisma.enfant.findMany({
-          take: req.query.numberByPage ? Number(req.query.numberByPage) : 25,
-          skip: 25 * Number(req.query.page),
-          include: {
-            piecesDossier: true,
-            remuneration: true,
-            Comments: true
-          },
-          where: {
-            dossierId: dossierId
-          },
-          orderBy: { 
-            [req.query.termToOrder as string]: req.query.order as string
-          }
-      })
-      const countEnfants = await prisma.enfant.count({
-          where: {  
-            dossierId: dossierId
-          }
-        }
-      )
-      res.status(200).json({enfants: enfantsByDossier, count: countEnfants});
+      const enfantsByDossier = await client.enfant.findMany({
+        take: req.query.numberByPage ? Number(req.query.numberByPage) : 25,
+        skip: 25 * Number(req.query.page),
+        include: {
+          piecesDossier: true,
+          remuneration: true,
+          Comments: true,
+        },
+        where: {
+          dossierId: dossierId,
+        },
+        orderBy: {
+          [req.query.termToOrder as string]: req.query.order as string,
+        },
+      });
+      const countEnfants = await client.enfant.count({
+        where: {
+          dossierId: dossierId,
+        },
+      });
+      res.status(200).json({ enfants: enfantsByDossier, count: countEnfants });
     } else {
       res.status(401).json({ message: "Unauthorized" });
     }
-  } catch(e) {
+  } catch (e) {
     console.log(e);
   }
 };

diff --git a/formulaire/pages/api/piece/dossier/[id].tsx b/formulaire/pages/api/piece/dossier/[id].tsx
@@ -1,7 +1,7 @@
 import type { NextApiHandler, NextApiRequest } from "next";
-import { PrismaClient } from "@prisma/client";
 import { getServerSession } from "next-auth";
-import { authOptions }  from '../../auth/[...nextauth]'
+import { authOptions } from "../../auth/[...nextauth]";
+import client from "src/lib/prismaClient";
 
 const handler: NextApiHandler = async (req, res) => {
   const session = await getServerSession(req, res, authOptions);
@@ -32,34 +32,28 @@ function getId(req: NextApiRequest): number {
 }
 
 const get: NextApiHandler = async (req, res) => {
-  const prisma = new PrismaClient();
   const dossierId = getId(req);
   try {
-    const pieces = await prisma.pieceDossier.findMany({
+    const pieces = await client.pieceDossier.findMany({
       where: {
         dossierId: dossierId,
       },
     });
-    await prisma?.$disconnect()
     res.status(200).json(pieces);
   } catch (e: unknown) {
-    await prisma?.$disconnect()
     console.log(e);
   }
 };
 
 const remove: NextApiHandler = async (req, res) => {
-  const prisma = new PrismaClient();
   try {
     const pieceId = getId(req);
-    const dossierDeleted = await prisma.pieceDossier.delete({
+    const dossierDeleted = await client.pieceDossier.delete({
       where: { id: pieceId },
     });
-    await prisma?.$disconnect()
     res.status(200).json({ dossierDeleted });
   } catch (e: unknown) {
     console.log(e);
-    await prisma?.$disconnect()
     res.status(200).json({ message: "Piece non trouvée" });
   }
 };