graphql: Added graphql support for vaccination

Author: OscarS05

api/src/graphql/resolvers.js

@@ -14,6 +14,10 @@ const {
   query: dewormingQueries,
   mutation: dewormingMutation,
 } = require('./resolvers/deworming/index');
+const {
+  query: vaccinationQueries,
+  mutation: vaccinationMutation,
+} = require('./resolvers/vaccination/index');
 
 const resolvers = {
   Query: {
@@ -22,11 +26,13 @@ const resolvers = {
     ...userQueries,
     ...animalQueries,
     ...dewormingQueries,
+    ...vaccinationQueries,
   },
   Mutation: {
     ...userMutations,
     ...animalMutation,
     ...dewormingMutation,
+    ...vaccinationMutation,
   },
 
   NameType,

api/src/graphql/resolvers/vaccination/index.js

@@ -0,0 +1,20 @@
+const {
+  getAll: getAllVaccinations,
+  getById: getVaccinationById,
+  create: createVaccination,
+  update: updateVaccination,
+  destroy: deleteVaccination,
+} = require('./vaccination.resolvers');
+
+const query = {
+  vaccinations: getAllVaccinations,
+  vaccination: getVaccinationById,
+};
+
+const mutation = {
+  createVaccination,
+  updateVaccination,
+  deleteVaccination,
+};
+
+module.exports = { query, mutation };

api/src/graphql/resolvers/vaccination/vaccination.resolvers.js

@@ -0,0 +1,48 @@
+const {
+  getAllVaccination,
+  getVaccination,
+  createVaccination,
+  updateVaccination,
+  deleteVaccination,
+} = require('../../../modules/vaccination/vaccination.service');
+const {
+  validateGraphQLSession,
+} = require('../../../middlewares/authentication');
+
+const getAll = async (_, { query = {} }, context) => {
+  const user = await validateGraphQLSession(context.req);
+
+  return getAllVaccination(user.id, query);
+};
+
+const getById = async (_, { id: vaccinationId }, context) => {
+  const user = await validateGraphQLSession(context.req);
+
+  return getVaccination(user.id, vaccinationId);
+};
+
+const create = async (_, { input }, context) => {
+  const user = await validateGraphQLSession(context.req);
+
+  return createVaccination(user.id, input);
+};
+
+const update = async (_, { id: vaccinationId, changes }, context) => {
+  const user = await validateGraphQLSession(context.req);
+
+  return updateVaccination(user.id, vaccinationId, changes);
+};
+
+const destroy = async (_, { id: vaccinationId }, context) => {
+  const user = await validateGraphQLSession(context.req);
+
+  return deleteVaccination(user.id, vaccinationId);
+};
+
+module.exports = {
+  getAll,
+  getById,
+  create,
+  update,
+  destroy,
+};

api/src/graphql/schemas/vaccination.schema.graphql

@@ -0,0 +1,36 @@
+type Query {
+  vaccinations(query: queryVaccination): [Vaccination!]!
+  vaccination(id: UUID!): Vaccination!
+}
+
+type Mutation {
+  createVaccination(input: CreateVaccination!): Vaccination!
+  updateVaccination(id: UUID!, changes: UpdateVaccination!): Vaccination!
+  deleteVaccination(id: UUID!): Int!
+}
+
+type Vaccination {
+  id: UUID!
+  vaccine: String!
+  description: String
+  animal: AnimalSummaryResponse!
+  registeredAt: Date!
+}
+
+input queryVaccination {
+  animalId: UUID
+  vaccine: String
+  limit: Int
+  offset: Int
+}
+
+input CreateVaccination {
+  vaccine: String!
+  description: String
+  animalId: UUID!
+}
+
+input UpdateVaccination {
+  vaccine: String
+  description: String
+}

api/src/modules/vaccination/vaccination.repository.js

@@ -1,8 +1,10 @@
 const sequelize = require('../../store/db/sequelize');
 
-const findAllVaccinations = async (userId, filters) => {
+const findAllVaccinations = async (userId, { where, limit, offset }) => {
   return sequelize.models.Vaccination.findAll({
-    where: filters,
+    where,
+    limit,
+    offset,
     include: [
       {
         model: sequelize.models.Animal,

api/src/modules/vaccination/vaccination.service.js

@@ -20,12 +20,18 @@ const formatVaccination = (vaccination) => {
 };
 
 const buildFilters = (query) => {
-  const { vaccine, animalId } = query;
+  const { vaccine, animalId, limit = 10, offset = 0 } = query;
 
-  return {
+  const where = {
     ...(vaccine && { vaccine: { [Op.iLike]: `%${vaccine}%` } }),
     ...(animalId && { animalId }),
   };
+
+  return {
+    where,
+    limit: parseInt(limit, 10),
+    offset: parseInt(offset, 10),
+  };
 };
 
 const getAllVaccination = async (userId, query) => {
@@ -89,7 +95,7 @@ const createVaccination = async (userId, vaccinationData) => {
     throw Boom.badRequest('Something went wrong creating the vaccination');
   }
 
-  return newVaccination;
+  return getVaccination(userId, newVaccination.id);
 };
 
 const updateVaccination = async (userId, vaccinationId, vaccinationData) => {
@@ -116,7 +122,7 @@ const updateVaccination = async (userId, vaccinationId, vaccinationData) => {
     throw Boom.badRequest('Something went wrong creating the vaccination');
   }
 
-  return updatedVaccination;
+  return getVaccination(userId, updatedVaccination.id);
 };
 
 const deleteVaccination = async (userId, vaccinationId) => {

tests/unit/vaccination-service.test.js

@@ -102,7 +102,7 @@ describe('Vaccination service', () => {
       );
       expect(vaccinationRepository.findAllVaccinations).toHaveBeenCalledWith(
         userId,
-        { animalId: query.animalId },
+        { where: { animalId: query.animalId }, limit: 10, offset: 0 },
       );
     });
 
@@ -203,13 +203,15 @@ describe('Vaccination service', () => {
     });
 
     test('It should return a new vaccination', async () => {
-      vaccinationRepository.create.mockResolvedValue({
+      const newVaccination = {
         ...dbResponse,
         id: fakeUuid,
         vaccine: vaccinationData.vaccine,
         description: vaccinationData.description,
-      });
+      };
+      vaccinationRepository.create.mockResolvedValue(newVaccination);
       animalRepository.findOne.mockResolvedValue(animal1());
+      vaccinationRepository.findOne.mockResolvedValue(newVaccination);
 
       const result = await createVaccination(userId, vaccinationData);
 
@@ -287,8 +289,9 @@ describe('Vaccination service', () => {
     });
 
     test('It should return an updated vaccination', async () => {
-      vaccinationRepository.findOne.mockResolvedValue(vaccination1());
+      vaccinationRepository.findOne.mockResolvedValueOnce(vaccination1());
       vaccinationRepository.update.mockResolvedValue([1, [dbResponse]]);
+      vaccinationRepository.findOne.mockResolvedValueOnce(dbResponse);
 
       const result = await updateVaccination(
         userId,
@@ -299,15 +302,16 @@ describe('Vaccination service', () => {
       expect(result.id).toBe(vaccinationId);
       expect(result.vaccine).toBe(vaccinationData.vaccine);
       expect(result.description).toBe(vaccinationData.description);
-      expect(vaccinationRepository.findOne).toHaveBeenCalledTimes(1);
+      expect(vaccinationRepository.findOne).toHaveBeenCalledTimes(2);
       expect(vaccinationRepository.update).toHaveBeenCalledTimes(1);
     });
 
     test('It should return an updated vaccination with only name updated', async () => {
       delete vaccinationData.description;
 
-      vaccinationRepository.findOne.mockResolvedValue(vaccination1());
+      vaccinationRepository.findOne.mockResolvedValueOnce(vaccination1());
       vaccinationRepository.update.mockResolvedValue([1, [dbResponse]]);
+      vaccinationRepository.findOne.mockResolvedValueOnce(dbResponse);
 
       const result = await updateVaccination(
         userId,
@@ -318,7 +322,7 @@ describe('Vaccination service', () => {
       expect(result.id).toBe(vaccinationId);
       expect(result.vaccine).toBe(vaccinationData.vaccine);
       expect(result.description).not.toBe(vaccinationData.description);
-      expect(vaccinationRepository.findOne).toHaveBeenCalledTimes(1);
+      expect(vaccinationRepository.findOne).toHaveBeenCalledTimes(2);
       expect(vaccinationRepository.update).toHaveBeenCalledTimes(1);
     });