diff --git a/formulaire/pages/api/auth/[...nextauth].ts b/formulaire/pages/api/auth/[...nextauth].ts index bfd9d3884..522cbcc67 100644 --- a/formulaire/pages/api/auth/[...nextauth].ts +++ b/formulaire/pages/api/auth/[...nextauth].ts @@ -1,16 +1,14 @@ // @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; @@ -18,7 +16,7 @@ export const authOptions: NextAuthOptions = { }, 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) \ No newline at end of file +export default NextAuth(authOptions); diff --git a/formulaire/pages/api/demandeur/[id].tsx b/formulaire/pages/api/demandeur/[id].tsx index d314bdff5..840755225 100644 --- 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 index 0a6c7f4b9..134383c13 100644 --- 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,11 +50,9 @@ 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é" }); } @@ -63,13 +60,12 @@ const remove: NextApiHandler = async (req, res) => { 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 index b7096a185..0cf637cfb 100644 --- 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 index 2b64c2f79..0ed40eb17 100644 --- 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 index f82ae78b6..86364918b 100644 --- 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 index d1f756dd3..d450f0ea7 100644 --- 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" }); } }; diff --git a/formulaire/pages/api/piece/enfant/[id].tsx b/formulaire/pages/api/piece/enfant/[id].tsx index 3b6e2cd84..eb955f664 100644 --- a/formulaire/pages/api/piece/enfant/[id].tsx +++ b/formulaire/pages/api/piece/enfant/[id].tsx @@ -1,48 +1,43 @@ 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); - if (!session) { - res.status(401).end(); - return; - } - const { id: articleIdStr } = req.query; - if (typeof articleIdStr !== "string") { - res.status(404).send(`not a valid piece id`); - return; - } - - if (req.method == "DELETE") { - await remove(req, res); - } else { - res.status(405).end(); - return; - } + if (!session) { + res.status(401).end(); + return; + } + const { id: articleIdStr } = req.query; + if (typeof articleIdStr !== "string") { + res.status(404).send(`not a valid piece id`); + return; + } + + if (req.method == "DELETE") { + await remove(req, res); + } else { + res.status(405).end(); + return; + } }; function getId(req: NextApiRequest): number { - return Number(req.query.id as string); - } - + return Number(req.query.id as string); +} + const remove: NextApiHandler = async (req, res) => { - const prisma = new PrismaClient() try { const pieceId = getId(req); - const pieceDeleted = await prisma.pieceDossierEnfant.delete({ - where: { id: pieceId } - }) - await prisma?.$disconnect() + const pieceDeleted = await client.pieceDossierEnfant.delete({ + where: { id: pieceId }, + }); res.status(200).json({ pieceDeleted }); } catch (e: unknown) { - await prisma?.$disconnect() console.log(e); res.status(200).json({ message: "Piece non trouvée" }); } }; - export default handler; \ No newline at end of file +export default handler; diff --git a/formulaire/pages/api/remunerations/[id].tsx b/formulaire/pages/api/remunerations/[id].tsx index 0c87bc5c7..bc572b630 100644 --- a/formulaire/pages/api/remunerations/[id].tsx +++ b/formulaire/pages/api/remunerations/[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); @@ -19,11 +19,10 @@ const handler: NextApiHandler = async (req, res) => { }; const remove: NextApiHandler = async (req, res) => { - const prisma = new PrismaClient(); const remunerationId = Number(req.body as string); try { console.log("remunerationId: ", remunerationId); - await prisma.remuneration.delete({ + await client.remuneration.delete({ where: { id: remunerationId }, }); diff --git a/formulaire/pages/api/users/[email].tsx b/formulaire/pages/api/users/[email].tsx index a77661bec..b8f695449 100644 --- a/formulaire/pages/api/users/[email].tsx +++ b/formulaire/pages/api/users/[email].tsx @@ -1,5 +1,5 @@ import type { NextApiHandler } from "next"; -import { PrismaClient, User } from "@prisma/client"; +import { User } from "@prisma/client"; import { WORDING_MAILING } from "src/lib/helpers"; import type SMTPTransport from "nodemailer/lib/smtp-transport"; import type { Transporter } from "nodemailer"; @@ -7,7 +7,8 @@ import nodemailer from "nodemailer"; import fs from "fs"; import _ from "lodash"; 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,11 +25,10 @@ const handler: NextApiHandler = async (req, res) => { }; const getUserByEmail: NextApiHandler = async (req, res) => { - const prisma = new PrismaClient(); const userEmail = req.query.email as string; try { let user: User | null = null; - user = await prisma.user.findFirst({ + user = await client.user.findFirst({ where: { email: userEmail, }, @@ -38,9 +38,8 @@ const getUserByEmail: NextApiHandler = async (req, res) => { const data = { email: userEmail as string, }; - user = await prisma.user.create({ data }); + user = await client.user.create({ data }); } - await prisma?.$disconnect() //SEND EMAIL if (typeof req.body !== "string") { diff --git a/formulaire/pages/api/users/index.tsx b/formulaire/pages/api/users/index.tsx index b04894488..5f9e62cd5 100644 --- a/formulaire/pages/api/users/index.tsx +++ b/formulaire/pages/api/users/index.tsx @@ -1,8 +1,8 @@ import type { NextApiHandler, NextApiRequest } from "next"; -import { PrismaClient, User } from "@prisma/client"; import { number } from "zod"; 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); @@ -19,7 +19,6 @@ const handler: NextApiHandler = async (req, res) => { }; const getUserById: NextApiHandler = async (req, res) => { - const prisma = new PrismaClient(); let collaboratorIds: number[] | number = []; if (req.query.id) { @@ -32,17 +31,17 @@ const getUserById: NextApiHandler = async (req, res) => { } } try { - const users = await prisma.user.findMany({ + const users = await client.user.findMany({ where: { id: { in: collaboratorIds, }, }, }); - await prisma?.$disconnect() + await prisma?.$disconnect(); res.status(200).json(users); } catch (e: unknown) { - await prisma?.$disconnect() + await prisma?.$disconnect(); console.log(e); } };