Exercicios md03/22.3

Md03_Dev_Back_end/Bloco22/exercicios/src/app.js

@@ -1,12 +1,10 @@
 const express = require('express');
-const connection = require('./models/connection');
-const { travelModel } = require('./models');
-const { passagerRoute, driverRoute } = require('./routes');
+const { passengerRoute, driverRoute } = require('./routes');
 
 const app = express();
 
 app.use(express.json());
-app.use('/passengers', passagerRoute);
+app.use('/passengers', passengerRoute);
 app.use('/drivers', driverRoute);
 
 module.exports = app;

Md03_Dev_Back_end/Bloco22/exercicios/src/controllers/passenger.controller.js

@@ -0,0 +1,22 @@
+// src/controllers/passenger.controller.js
+const passengerService = require('../services/passenger.service');
+const { mapError } = require('../utils/errorMap');
+
+const createTravel = async (req, res) => {
+  const { passengerId } = req.params;
+  const { startingAddress, endingAddress, waypoints } = req.body;
+
+  const { type, message } = await passengerService.requestTravel(passengerId, startingAddress, endingAddress, waypoints);
+
+  // Linha de código responsável por gerar uma resposta em caso de erro no
+  // processamento do componente de software da camada `Service`
+  if (type) {
+    return res.status(mapError(type)).json(message);
+  }
+
+  res.status(201).json(message);
+};
+
+module.exports = {
+  createTravel,
+};

Md03_Dev_Back_end/Bloco22/exercicios/src/models/driver.model.js

@@ -8,6 +8,15 @@ const findAll = async () => {
   return camelize(result);
 }
 
+const findById = async (driverId) => {
+  const [[result]] = await connection.execute(
+    'SELECT * FROM drivers WHERE id = ?',
+    [driverId],
+  );
+  return camelize(result);
+};
+
 module.exports = {
   findAll,
+  findById
 }

Md03_Dev_Back_end/Bloco22/exercicios/src/models/index.js

@@ -1,11 +1,11 @@
 const travelModel = require('./travel.model');
 const driverModel = require('./driver.model');
-const passagerModel = require('./passager.model');
+const passengerModel = require('./passenger.model');
 const waypointModel = require('./waypoint.model');
 
 module.exports = {
   travelModel,
   driverModel,
-  passagerModel,
+  passengerModel,
   waypointModel,
 }

Md03_Dev_Back_end/Bloco22/exercicios/src/routes/driver.router.js

@@ -0,0 +1,47 @@
+const { Router } = require('express');
+const { driverService } = require('../services');
+const { mapError } = require('../utils/errorMap');
+
+const route = Router();
+
+route.get('/open/travels', async (_req, res) => {
+  const { type, message } = await driverService.getWaitingDriverTravels();
+
+  if (type) return res.status(mapError(type)).json({ message });
+
+  res.status(200).json(message);
+});
+
+route.get('/', async (_req,res) => {
+  const { type, message } = await driverService.findAll();
+
+  if (type) return res.status(mapError(type)).json({ message });
+
+  res.status(200).json(message);
+});
+
+route.put('/:driverId/travels/:travelId/assign', async (req, res) => {
+  const { type, message } = await driverService.travelAssign(req.params);
+
+  if (type) return res.status(mapError(type)).json({ message });
+
+  res.status(200).json(message);
+});
+
+route.put('/:driverId/travels/:travelId/start', async (req, res) => {
+  const { type, message } = await driverService.startTravel(req.params);
+
+  if (type) return res.status(mapError(type)).json({ message });
+
+  res.status(200).json(message);
+});
+
+route.put('/:driverId/travels/:travelId/end', async (req, res) => {
+  const { type, message } = await driverService.endTravel(req.params);
+
+  if (type) return res.status(mapError(type)).json({ message });
+
+  res.status(200).json(message);
+});
+
+module.exports = route;

Md03_Dev_Back_end/Bloco22/exercicios/src/routes/index.js

@@ -1,7 +1,7 @@
-const driverRoute = require("./driverRoute");
-const passagerRoute = require("./passagerRoute");
+const driverRoute = require("./driver.router");
+const passengerRoute = require("./passenger.router.js");
 
 module.exports = {
   driverRoute,
-  passagerRoute,
+  passengerRoute,
 }

Md03_Dev_Back_end/Bloco22/exercicios/src/routes/passenger.router.js

@@ -0,0 +1,8 @@
+const { Router } = require('express');
+const { createTravel } = require('../controllers/passenger.controller');
+
+const route = Router();
+
+route.post('/:passengerId/request/travel', createTravel);
+
+module.exports = route;

Md03_Dev_Back_end/Bloco22/exercicios/src/services/driver.service.js

@@ -0,0 +1,69 @@
+const { travelModel, driverModel } = require('../models');
+const {
+  validateInputValues,
+  validateAlreadyDriver,
+} = require('./validations/validationsInputValues');
+
+const WAITING_DRIVER = 1;
+const DRIVER_ON_THE_WAY = 2;
+const TRAVEL_IN_PROGRESS = 3;
+const TRAVEL_FINISHED = 4;
+
+const getWaitingDriverTravels = async () => {
+  const result = await travelModel.findByTravelStatusId(WAITING_DRIVER);
+
+  if (result.length > 0) return { type: null, message: result };
+
+  return { type: 'TRAVEL_NOT_FOUND', message: 'Not found waiting travel' };
+}
+
+const findAll = async () => {
+  const result = await driverModel.findAll();
+
+  if (result.length > 0) return { type: null, message: result };
+
+  return { type: 'DRIVER_NOT_FOUND', message: 'Not found driver' };
+}
+
+async function setStatus(status, travelId, driverId) {
+  await travelModel.setStatus(status, travelId, driverId);
+
+  const result = await travelModel.findById(travelId);
+  return { type: null, message: result };
+}
+
+const travelAssign = async ({ travelId, driverId }) => {
+  let error  = await checkValidations({ travelId, driverId });
+
+  if (error.type) return error;
+
+  error = await validateAlreadyDriver(travelId);
+  if (error.type) return error;
+
+  await travelModel.setDriver(travelId, driverId);
+  return await setStatus(DRIVER_ON_THE_WAY, travelId, driverId);
+}
+
+const startTravel = async ({ travelId, driverId }) => {
+  const error  = await validateInputValues({ travelId, driverId });
+
+  if (error.type) return error;
+
+  return await setStatus(TRAVEL_IN_PROGRESS, travelId, driverId);
+}
+
+const endTravel = async ({ travelId, driverId }) => {
+  const error  = await validateInputValues({ travelId, driverId });
+
+  if (error.type) return error;
+
+  return await setStatus(TRAVEL_FINISHED, travelId, driverId);
+}
+
+module.exports = {
+  getWaitingDriverTravels,
+  findAll,
+  travelAssign,
+  startTravel,
+  endTravel
+};

Md03_Dev_Back_end/Bloco22/exercicios/src/services/index.js

@@ -0,0 +1,7 @@
+const passengerService = require('./passenger.service');
+const driverService = require('./driver.service');
+
+module.exports = {
+  passengerService,
+  driverService
+}

Md03_Dev_Back_end/Bloco22/exercicios/src/services/passager.service.js → Md03_Dev_Back_end/Bloco22/exercicios/src/services/passenger.service.js

@@ -1,8 +1,8 @@
-const { travelModel, passagerModel, waypointModel } = require('../models');
+const { travelModel, passengerModel, waypointModel } = require('../models');
 const { validateRequestTravelSchema } = require('./validations/validationsInputValues');
 
 const doesPassengerExist = async (passengerId) => {
-  const passenger = await passagerModel.findById(passengerId);
+  const passenger = await passengerModel.findById(passengerId);
 
   if (passenger) return true;
   return false;

Md03_Dev_Back_end/Bloco22/exercicios/src/services/validations/schemas.js

@@ -15,7 +15,14 @@ const addRequestTravelSchema = Joi.object({
   waypoints: Joi.array().items(waypointSchema)
 });
 
+const addPassengerSchema = Joi.object({
+  name: Joi.string().min(3).required(),
+  email: Joi.string().email().required(),
+  phone: Joi.string().min(9).max(20).required() 
+});
+
 module.exports = {
   idSchema,
   addRequestTravelSchema,
+  addPassengerSchema,
 };

Md03_Dev_Back_end/Bloco22/exercicios/src/services/validations/validationsInputValues.js

@@ -1,5 +1,6 @@
 // src/services/validations/validationsInputValues.js
-const { addRequestTravelSchema } = require('./schemas');
+const { travelModel, driverModel } = require('../../models');
+const { addRequestTravelSchema, idSchema, addPassengerSchema } = require('./schemas');
 
 const validateRequestTravelSchema = (passengerId, startingAddress, endingAddress, waypoints) => {
   const { error } = addRequestTravelSchema
@@ -9,6 +10,47 @@ const validateRequestTravelSchema = (passengerId, startingAddress, endingAddress
   return { type: null, message: '' };
 };
 
+const validateInputValues = async ({ travelId, driverId }) => {
+  /* Valida se travelId existe */
+  const travel = await travelModel.findById(travelId);
+  if (!travel) return { type: 'TRAVEL_NOT_FOUND', message: 'travel id not found' };
+
+  /* Valida se driverId existe */
+  const driver = await driverModel.findById(driverId);
+  if (!driver) return { type: 'DRIVER_NOT_FOUND', message: 'driver id not found' };
+
+  return { type: null, message: '' };
+};
+
+const validateAlreadyDriver = async (travelId) => {
+  const travel = await travelModel.findById(travelId);
+
+  if (travel && travel.driverId) {
+    return { type: 'TRAVEL_CONFLICT', message: 'travel already assigned' };
+  }
+
+  return { type: null, message: '' };
+};
+
+const validateId = (id) => {
+  const { error } = idSchema.validate(id);
+  if (error) return { type: 'INVALID_VALUE', message: '"id" must be a number' };
+
+  return { type: null, message: '' };
+};
+
+const validateNewPassenger = (name, email, phone) => {
+  const { error } = addPassengerSchema
+    .validate({ name, email, phone });
+  if (error) return { type: 'INVALID_VALUE', message: error.message };
+
+  return { type: null, message: '' };
+};
+
 module.exports = {
   validateRequestTravelSchema,
+  validateInputValues,
+  validateAlreadyDriver,
+  validateId,
+  validateNewPassenger
 };

Md03_Dev_Back_end/Bloco22/exercicios/src/utils/errorMap.js

@@ -0,0 +1,13 @@
+const errorMap = {
+  TRAVEL_NOT_FOUND: 404,
+  DRIVER_NOT_FOUND: 404,
+  INVALID_VALUE: 422,
+  TRAVEL_CONFLICT: 409,
+};
+
+const mapError = (type) => errorMap[type] || 500;
+
+module.exports = {
+  errorMap,
+  mapError,
+};