refactor: utilizacao do prisma na rota de criar um evento

src/controller/event/eventController.ts

 /* eslint-disable @typescript-eslint/no-explicit-any */
-import {Request, Response} from 'express';
-import * as eventService from '../../services/event/eventService';
-import {EventRegistrationData} from '../../interfaces/eventInterface';
-import {logger} from "../../logger";
+import { Request, Response } from "express";
+import * as eventService from "../../services/event/eventService";
+import { EventRegistrationData } from "../../interfaces/eventInterface";
+import { logger } from "../../logger";
+import { Event } from "@prisma/client";
 
 export const createEvent = async (req: Request, res: Response) => {
-  const eventBody = {...req.body};
+  const eventBody = { ...req.body };
   try {
-
-    const eventData: EventRegistrationData = req.body;
+    const eventData: Event = req.body;
 
     const eventId = await eventService.createEvent(eventData);
     logger.info(`Event registered successfully. EventID: ${eventId}`);
     logger.info(`Request Body: ${JSON.stringify(req.body)}`);
 
-    res.json({message: "Event registered successfully", eventId});
+    res.json({ message: "Event registered successfully", eventId });
   } catch (error: any) {
     logger.error(
       `Ocorreu um erro na rota: ${error.message}, body: ${JSON.stringify(
@@ -24,24 +24,23 @@ export const createEvent = async (req: Request, res: Response) => {
         stack: error.stack,
       }
     );
-    res.status(400).json({error: error.message});
+    res.status(400).json({ error: error.message });
   }
-
 };
 
 export const linkUserToAEvent = async (req: Request, res: Response) => {
-
   try {
-    console.log(req.params);
     const event: EventRegistrationData = req.body;
 
-    const result = await eventService.linkUserToAEvent(event, req.headers.authorization);
+    const result = await eventService.linkUserToAEvent(
+      event,
+      req.headers.authorization
+    );
 
     logger.info(`User linked successfully. Result: ${JSON.stringify(result)}`);
 
-    res.status(200).json({message: 'User linked successfully', result});
+    res.status(200).json({ message: "User linked successfully", result });
   } catch (error: any) {
-
     logger.error(
       `Ocorreu um erro na rota: ${error.message}, body: ${JSON.stringify(
         req.body
@@ -50,13 +49,11 @@ export const linkUserToAEvent = async (req: Request, res: Response) => {
         stack: error.stack,
       }
     );
-    res.status(400).json({error: error.message});
+    res.status(400).json({ error: error.message });
   }
-
-}
+};
 
 export const updateEvent = async (req: Request, res: Response) => {
-
   try {
     const nEventID = parseInt(req.params.id);
     const eventData: Partial<EventRegistrationData> = req.body;
@@ -66,9 +63,8 @@ export const updateEvent = async (req: Request, res: Response) => {
     logger.info(`Event edited successfully. Result: ${JSON.stringify(result)}`);
     logger.info(`Request Body: ${JSON.stringify(req.body)}`);
 
-    res.json({message: 'Event updated successfully', result});
+    res.json({ message: "Event updated successfully", result });
   } catch (error: any) {
-
     logger.error(
       `Ocorreu um erro na rota: ${error.message}, body: ${JSON.stringify(
         req.body
@@ -77,20 +73,21 @@ export const updateEvent = async (req: Request, res: Response) => {
         stack: error.stack,
       }
     );
-    res.status(400).json({error: error.message});
+    res.status(400).json({ error: error.message });
   }
 };
 
 export const deleteEvent = async (req: Request, res: Response) => {
-
   try {
     const eventId = parseInt(req.params.id);
     const result = await eventService.deleteEvent(eventId);
 
-    logger.info(`Event removed successfully. Result: ${JSON.stringify(result)}`);
+    logger.info(
+      `Event removed successfully. Result: ${JSON.stringify(result)}`
+    );
     logger.info(`Request Body: ${JSON.stringify(req.body)}`);
 
-    res.json({message: 'Event removed successfully', result});
+    res.json({ message: "Event removed successfully", result });
   } catch (error: any) {
     logger.error(
       `Ocorreu um erro na rota: ${error.message}, body: ${JSON.stringify(
@@ -101,7 +98,7 @@ export const deleteEvent = async (req: Request, res: Response) => {
       }
     );
 
-    res.status(400).json({error: error.message});
+    res.status(400).json({ error: error.message });
   }
 };
 
@@ -124,22 +121,22 @@ export const listAllEvents = async (req: Request, res: Response) => {
         stack: error.stack,
       }
     );
-    res.status(400).json({error: error.message});
+    res.status(400).json({ error: error.message });
   }
 };
 
 export const listEventByID = async (req: Request, res: Response) => {
   try {
-
     const eventId = parseInt(req.params.id);
     const result = await eventService.listEventByID(eventId);
 
-    logger.info(`Listed event by ID successfully. Result: ${JSON.stringify(result)}`);
+    logger.info(
+      `Listed event by ID successfully. Result: ${JSON.stringify(result)}`
+    );
     logger.info(`Request Body: ${JSON.stringify(req.body)}`);
 
     res.json(result);
   } catch (error: any) {
-
     logger.error(
       `Ocorreu um erro na rota: ${error.message}, body: ${JSON.stringify(
         req.body
@@ -149,7 +146,7 @@ export const listEventByID = async (req: Request, res: Response) => {
       }
     );
 
-    res.status(400).json({error: error.message});
+    res.status(400).json({ error: error.message });
   }
 };
 
@@ -159,14 +156,19 @@ export const listEventByFilters = async (req: Request, res: Response) => {
     const nAuthorID = parseInt(req.query.nAuthorID as string);
     const dtStartTime = req.query.dtStartTime as string;
 
-    const result = await eventService.listEventsByFilters(nEventType, nAuthorID, dtStartTime);
+    const result = await eventService.listEventsByFilters(
+      nEventType,
+      nAuthorID,
+      dtStartTime
+    );
 
-    logger.info(`Listed event by ID successfully. Result: ${JSON.stringify(result)}`);
+    logger.info(
+      `Listed event by ID successfully. Result: ${JSON.stringify(result)}`
+    );
     logger.info(`Request Body: ${JSON.stringify(req.body)}`);
 
     res.json(result);
   } catch (error: any) {
-
     logger.error(
       `Ocorreu um erro na rota: ${error.message}, body: ${JSON.stringify(
         req.body
@@ -176,22 +178,22 @@ export const listEventByFilters = async (req: Request, res: Response) => {
       }
     );
 
-    res.status(400).json({error: error.message});
+    res.status(400).json({ error: error.message });
   }
 };
 
 export const AllEventsToPatient = async (req: Request, res: Response) => {
   try {
-
     const nPatientID = parseInt(req.params.id);
     const result = await eventService.AllEventsToPatient(nPatientID);
 
-    logger.info(`Listed event by ID successfully. Result: ${JSON.stringify(result)}`);
+    logger.info(
+      `Listed event by ID successfully. Result: ${JSON.stringify(result)}`
+    );
     logger.info(`Request Body: ${JSON.stringify(req.body)}`);
 
     res.json(result);
   } catch (error: any) {
-
     logger.error(
       `Ocorreu um erro na rota: ${error.message}, body: ${JSON.stringify(
         req.body
@@ -201,6 +203,6 @@ export const AllEventsToPatient = async (req: Request, res: Response) => {
       }
     );
 
-    res.status(400).json({error: error.message});
+    res.status(400).json({ error: error.message });
   }
 };

src/repository/event/eventRepository.ts

-import { query } from '../../../database/db';
-import { EventRegistrationData } from '../../interfaces/eventInterface';
+import { Event, PrismaClient } from "@prisma/client";
+import { query } from "../../../database/db";
+import { EventRegistrationData } from "../../interfaces/eventInterface";
+
+const prisma = new PrismaClient();
 
 export async function getTheLastFourEventsByUser(userId: number) {
   const queryText = `
@@ -15,13 +18,10 @@ export async function getTheLastFourEventsByUser(userId: number) {
 
   const values = [userId];
   const result = await query(queryText, values);
-  console.log(result.rows);
   return result.rows;
 }
 
-
 export async function linkUserToAEvent(eventId: number, userId: number) {
-
   const queryText = `
     UPDATE Events
     SET nPatientID = $1
@@ -31,39 +31,30 @@ export async function linkUserToAEvent(eventId: number, userId: number) {
   return !!result;
 }
 
-export const createEvent = async (eventData: EventRegistrationData) => {
-  const ontem = new Date();
-  ontem.setDate(ontem.getDate() - 1);
-
-  if (eventData.dtDate <= ontem) {
-    throw new Error('A data do evento deve ser maior que a data de ontem.');
-  }
-
-  if (eventData.dtEndTime <= eventData.dtStartTime) {
-    throw new Error('A hora de término deve ser posterior à hora de início.');
-  }
-
-  const queryText = `
-      INSERT INTO Events (nAuthorID, nEventType, dtDate, dtStartTime, dtEndTime, nStatus, bActive)
-      VALUES ($1, $2, $3, $4, $5, $6, $7)
-      RETURNING nEventID`;
-
-  const values = [
-    eventData.nAuthorID,
-    eventData.nEventType,
-    eventData.dtDate,
-    eventData.dtStartTime,
-    eventData.dtEndTime,
-    eventData.nStatus,
-    1
-  ];
+export const createEvent = async (eventData: Event) => {
+  const event = prisma.event.create({
+    data: {
+      ...eventData,
+      active: true,
+    },
+  });
 
-  const result = await query(queryText, values);
-  return result.rows[0].nEventID;
+  return event;
 };
 
-export const updateEvent = async (nEventID: number, eventData: Partial<EventRegistrationData>) => {
-  const { nPatientID, nEventType, strName, dtDate, dtStartTime, dtEndTime, nStatus } = eventData;
+export const updateEvent = async (
+  nEventID: number,
+  eventData: Partial<EventRegistrationData>
+) => {
+  const {
+    nPatientID,
+    nEventType,
+    strName,
+    dtDate,
+    dtStartTime,
+    dtEndTime,
+    nStatus,
+  } = eventData;
 
   const dataAtual = new Date();
   let index = 1;
@@ -110,7 +101,7 @@ export const updateEvent = async (nEventID: number, eventData: Partial<EventRegi
   }
 
   if (index === 1) {
-    throw new Error('No fields to update.');
+    throw new Error("No fields to update.");
   }
 
   values.push(nEventID);
@@ -136,7 +127,6 @@ export const updateEvent = async (nEventID: number, eventData: Partial<EventRegi
 };
 
 export const deleteEventById = async (nEventID: number) => {
-
   const values = [nEventID];
   const queryText = `
         UPDATE Events
@@ -210,8 +200,11 @@ export const listAll = async () => {
   return result.rows;
 };
 
-export const getEventsByFilters = async (nEventType: number, nAuthorID: number, dtStartTime: string): Promise<any[]> => {
-
+export const getEventsByFilters = async (
+  nEventType: number,
+  nAuthorID: number,
+  dtStartTime: string
+): Promise<any[]> => {
   const queryText = `
     SELECT
       nEventID,
@@ -247,8 +240,9 @@ export const getEventsByFilters = async (nEventType: number, nAuthorID: number,
   return result.rows;
 };
 
-export const getAllEventsToPatient = async (nPatientID: number): Promise<any[]> => {
-
+export const getAllEventsToPatient = async (
+  nPatientID: number
+): Promise<any[]> => {
   const queryText = `
     SELECT
       nEventID,
@@ -279,4 +273,4 @@ export const getAllEventsToPatient = async (nPatientID: number): Promise<any[]>
   const result = await query(queryText, values);
 
   return result.rows;
-};
+};
\ No newline at end of file

src/repository/user/userRepository.ts

@@ -16,33 +16,25 @@ export const getUserByEmail = async (email: string) => {
   return user;
 };
 
-export const getUserById = async (nUserID: number) => {
-  const queryText = `
-    SELECT
-      nUserID,
-      strEmail,
-      strPhone,
-      strRegion,
-      strLosingPhase,
-      strUsername,
-      bActive,
-      CASE
-        WHEN nUserType = 0 THEN 'ADMIN'
-        WHEN nUserType = 1 THEN 'USUARIO'
-        WHEN nUserType = 2 THEN 'PSICOLOGO'
-        WHEN nUserType = 3 THEN 'TERAPEUTA'
-        ELSE 'Desconhecido'
-      END AS nUserType,
-      dtCreated AT TIME ZONE 'UTC' AT TIME ZONE 'America/Sao_Paulo' AS dtCreated,
-      dtEnd AT TIME ZONE 'UTC' AT TIME ZONE 'America/Sao_Paulo' AS dtEnd,
-      dtUpdated AT TIME ZONE 'UTC' AT TIME ZONE 'America/Sao_Paulo' AS dtUpdated,
-      strChildrenName,
-      strGender
-    FROM Users
-    WHERE nUserID = $1`;
-  const values = [nUserID];
-  const result = await query(queryText, values);
-  return result.rows[0];
+export const getUserById = async (userId: number) => {
+  const user = await prisma.user.findFirst({
+    where: {
+      id: userId,
+      AND: [
+        {
+          OR: [
+            {
+              userType: 2,
+            },
+            {
+              userType: 3,
+            },
+          ],
+        },
+      ],
+    },
+  });
+  return user;
 };
 
 export const registerUser = async (userData: User) => {
@@ -233,7 +225,7 @@ export const login = async (email: string, password: string) => {
   }
 
   const userData = user.rows[0];
-  console.log(userData);
+
   if (userData.bactive !== true) {
     throw new Error(errorMessages.INACTIVE_USER);
   }

src/services/event/eventService.ts

-import * as eventRepository from '../../repository/event/eventRepository';
-import {EventRegistrationData} from '../../interfaces/eventInterface';
-import {errorMessages} from '../../../messages/errorMessages';
+import * as eventRepository from "../../repository/event/eventRepository";
+import { EventRegistrationData } from "../../interfaces/eventInterface";
+import { errorMessages } from "../../../messages/errorMessages";
 import getUserFromToken from "../token/tokenService";
-import * as userRepository from '../../repository/user/userRepository';
-import {getTheLastFourEventsByUser} from "../../repository/event/eventRepository";
-export async function linkUserToAEvent(event: EventRegistrationData, token: string) {
+import * as userRepository from "../../repository/user/userRepository";
+import { getTheLastFourEventsByUser } from "../../repository/event/eventRepository";
+import { Event } from "@prisma/client";
+export async function linkUserToAEvent(
+  event: EventRegistrationData,
+  token: string
+) {
   const userId = getUserFromToken(token);
 
   if (!event || !userId) {
     throw new Error(errorMessages.ID_NOT_FOUND);
   }
 
-  const lastFourEvents: Array<any> = Object.values(await getTheLastFourEventsByUser(userId));
+  const lastFourEvents: Array<any> = Object.values(
+    await getTheLastFourEventsByUser(userId)
+  );
   const idLastAuthor = lastFourEvents[0].nauthorid;
-  const length = lastFourEvents.filter((el) => el.nauthorid === idLastAuthor).length;
+  const length = lastFourEvents.filter(
+    (el) => el.nauthorid === idLastAuthor
+  ).length;
   console.log(idLastAuthor);
-  console.log(lastFourEvents)
-  console.log(length)
+  console.log(lastFourEvents);
+  console.log(length);
 
-  if(length < 3) {
-    if(lastFourEvents[0].nauthorid !== event.nAuthorID) {
+  if (length < 3) {
+    if (lastFourEvents[0].nauthorid !== event.nAuthorID) {
       throw new Error(errorMessages.EVENT_NOT_FOUND);
     }
   }
@@ -27,37 +35,38 @@ export async function linkUserToAEvent(event: EventRegistrationData, token: stri
   const result = await eventRepository.linkUserToAEvent(event.nEventID, userId);
   console.log(result);
   if (!result) {
-    throw new Error('O usuário já possui 4 eventos ativos com este profissional.');
+    throw new Error(
+      "O usuário já possui 4 eventos ativos com este profissional."
+    );
   }
   return result;
-
-
 }
 
-
-export const createEvent = async (eventData: EventRegistrationData) => {
-
+export const createEvent = async (eventData: Event) => {
   if (
-    !eventData.nAuthorID ||
-    !eventData.dtDate ||
-    !eventData.dtStartTime ||
-    !eventData.dtEndTime
+    !eventData.authorId ||
+    !eventData.date ||
+    !eventData.startTime ||
+    !eventData.endTime
   ) {
     throw new Error(errorMessages.MISSING_FIELDS);
   }
 
-  const validateAuthor = await userRepository.getUserById(eventData.nAuthorID);
+  const validateAuthor = await userRepository.getUserById(eventData.authorId);
   if (!validateAuthor) {
-    throw new Error('(nAuthorID) Somente Psicólogo/ Terapeuta podem criar agendamentos.');
+    throw new Error(
+      "(nAuthorID) Somente Psicólogo/ Terapeuta podem criar agendamentos."
+    );
   }
-  if (eventData.dtDate !== undefined) {
+  if (!eventData.date) {
     const dataAtual = new Date();
-    if (new Date(eventData.dtDate) < dataAtual) {
-      throw new Error('Não é possível alterar agendas para datas passadas.');
+    const dataEvento = new Date(eventData.date);
+    if (dataEvento < dataAtual) {
+      throw new Error("Não é possível alterar agendas para datas passadas.");
     }
   }
-  if (eventData.dtStartTime && eventData.dtEndTime && eventData.dtStartTime > eventData.dtEndTime) {
-    throw new Error('início do agendamento precisa ser anterior ao final');
+  if (+eventData.startTime > +eventData.endTime) {
+    throw new Error("início do agendamento precisa ser anterior ao final");
   }
 
   return await eventRepository.createEvent({
@@ -65,8 +74,10 @@ export const createEvent = async (eventData: EventRegistrationData) => {
   });
 };
 
-export const updateEvent = async (nEventID: number, eventData: Partial<EventRegistrationData>) => {
-
+export const updateEvent = async (
+  nEventID: number,
+  eventData: Partial<EventRegistrationData>
+) => {
   const existingEvent = await eventRepository.getEventById(nEventID);
 
   if (!existingEvent) {
@@ -74,28 +85,31 @@ export const updateEvent = async (nEventID: number, eventData: Partial<EventRegi
   }
   if (existingEvent) {
     if (!existingEvent.bActive) {
-      throw new Error('O evento não está ativo e não pode ser editado.');
+      throw new Error("O evento não está ativo e não pode ser editado.");
     }
   }
 
   if (!existingEvent.nAuthorID) {
-    throw new Error('Não é permitido alterar o autor.');
+    throw new Error("Não é permitido alterar o autor.");
   }
   if (!existingEvent.dtDate) {
     const dataAtual = new Date();
     if (new Date(existingEvent.dtDate) < dataAtual) {
-      throw new Error('Não é possível alterar agendas para datas passadas.');
+      throw new Error("Não é possível alterar agendas para datas passadas.");
     }
   }
-  if (existingEvent.dtStartTime && existingEvent.dtEndTime && existingEvent.dtStartTime > existingEvent.dtEndTime) {
-    throw new Error('início do agendamento precisa ser anterior ao final');
+  if (
+    existingEvent.dtStartTime &&
+    existingEvent.dtEndTime &&
+    existingEvent.dtStartTime > existingEvent.dtEndTime
+  ) {
+    throw new Error("início do agendamento precisa ser anterior ao final");
   }
 
   return await eventRepository.updateEvent(nEventID, eventData);
 };
 
 export const deleteEvent = async (nEventID: number) => {
-
   const existingEvent = await eventRepository.getEventById(nEventID);
   if (!existingEvent) {
     throw new Error(errorMessages.EVENT_NOT_FOUND);
@@ -125,9 +139,16 @@ export const listEventByID = async (nEventID: number) => {
   return result;
 };
 
-export const listEventsByFilters = async (nEventType: number, nAuthorID: number, dtStartTime: string) => {
-
-  const result = await eventRepository.getEventsByFilters(nEventType, nAuthorID, dtStartTime);
+export const listEventsByFilters = async (
+  nEventType: number,
+  nAuthorID: number,
+  dtStartTime: string
+) => {
+  const result = await eventRepository.getEventsByFilters(
+    nEventType,
+    nAuthorID,
+    dtStartTime
+  );
   if (!result) {
     throw new Error(errorMessages.EVENTS_NOT_FOUND);
   }
@@ -136,7 +157,6 @@ export const listEventsByFilters = async (nEventType: number, nAuthorID: number,
 };
 
 export const AllEventsToPatient = async (nPatientID: number) => {
-
   if (!nPatientID) {
     throw new Error(errorMessages.ID_NOT_FOUND);
   }
@@ -147,4 +167,4 @@ export const AllEventsToPatient = async (nPatientID: number) => {
   }
 
   return result;
-};
+};
\ No newline at end of file

src/services/user/userService.ts

@@ -60,7 +60,6 @@ export const loginUser = async (email: string, password: string) => {
 
   try {
     const user = await userRepository.getUserByEmail(email);
-    console.log(user);
     if (!user) {
       throw new Error(errorMessages.USER_NOT_FOUND);
     }
@@ -91,7 +90,6 @@ export const loginUser = async (email: string, password: string) => {
 };
 
 export const removeUser = async (nUserId: number) => {
-  console.log(nUserId);
   if (!nUserId) {
     throw new Error(errorMessages.ID_NOT_FOUND);
   }