Merge pull request #3 from Gambitier/book-services

create Book Library controllers/service/repo

Author: gambitier

Projects/BooksLibrary/package-lock.json

@@ -32,6 +32,7 @@
         "dotenv": "^16.0.0",
         "express": "^4.17.3",
         "express-fileupload": "^1.3.1",
+        "express-validator": "^6.14.0",
         "jsonwebtoken": "^8.5.1",
         "pg": "^8.7.3",
         "reflect-metadata": "^0.1.13",

Projects/BooksLibrary/package.json

@@ -1,4 +1,8 @@
+import { UserValidator } from 'api/validators/user.validator';
 import { Authorizer } from 'auth/authorizer';
+import { ResponseHandler } from 'common/response.handler';
+import { UserDomainModel } from 'domain.types/user/user.domain.model';
+import { UserDetailsDto } from 'domain.types/user/user.dto';
 import express from 'express';
 import { UserService } from 'services/user.service';
 import { Loader } from 'startup/loader';
@@ -30,6 +34,25 @@ export class UserController {
     };
 
     create = async (request: express.Request, response: express.Response): Promise<void> => {
-        throw new Error('Method not implemented.');
+        try {
+            // request.context = 'User.create';
+
+            const domainData: UserDomainModel = await UserValidator.create(request, response);
+
+            const userdetails: UserDetailsDto = await this._service.create(domainData);
+
+            ResponseHandler.success(
+                request,
+                response,
+                'User created!',
+                200,
+                {
+                    entity: userdetails,
+                },
+                false
+            );
+        } catch (err) {
+            ResponseHandler.handleError(request, response, err);
+        }
     };
 }

Projects/BooksLibrary/src/api/controllers/user.controller.ts

@@ -1,5 +1,6 @@
 import express from 'express';
 import { Logger } from '../../common/logger';
+import { register } from './user.routes';
 
 export class Router {
     private _app = null;
@@ -14,9 +15,12 @@ export class Router {
                 //Handling the base route
                 this._app.get('/api/v1/', (req, res) => {
                     res.send({
-                        message : `API [Version ${process.env.API_VERSION}]`,
+                        message: `API [Version ${process.env.API_VERSION}]`,
                     });
                 });
+
+                register(this._app);
+
                 resolve(true);
             } catch (error) {
                 Logger.instance().log('Error initializing the router: ' + error.message);

Projects/BooksLibrary/src/api/routes/router.ts

@@ -1,18 +1,18 @@
-import express from 'express';
-import { Loader } from '../../startup/loader';
+import express, { Router } from 'express';
+// import { Loader } from '../../startup/loader';
 import { UserController } from '../controllers/user.controller';
 
 ///////////////////////////////////////////////////////////////////////////////////
 
 export const register = (app: express.Application): void => {
-    const router = express.Router();
-    const authenticator = Loader.authenticator;
+    const router: Router = express.Router();
+    // const authenticator = Loader.authenticator;
     const controller = new UserController();
 
     router.post('/', controller.create);
-    router.get('/', authenticator.authenticateUser, controller.search);
-    router.get('/:id', authenticator.authenticateUser, controller.getById);
-    router.delete('/:id', authenticator.authenticateUser, controller.delete);
+    // router.get('/', authenticator.authenticateUser, controller.search);
+    // router.get('/:id', authenticator.authenticateUser, controller.getById);
+    // router.delete('/:id', authenticator.authenticateUser, controller.delete);
 
     app.use('/api/v1/users', router);
 };

Projects/BooksLibrary/src/api/routes/user.routes.ts

@@ -0,0 +1,38 @@
+/* eslint-disable newline-per-chained-call */
+import { Helper } from 'common/helper';
+import { ResponseHandler } from 'common/response.handler';
+import { UserDomainModel } from 'domain.types/user/user.domain.model';
+import express from 'express';
+import { body, oneOf, param, query, validationResult } from 'express-validator';
+
+export class UserValidator {
+    static create = async (request: express.Request, response: express.Response): Promise<UserDomainModel> => {
+        try {
+            await body('Prefix').optional().trim().run(request);
+            await body('FirstName').isString().notEmpty().trim().run(request);
+            await body('MiddleName').optional().trim().run(request);
+            await body('LastName').isString().notEmpty().trim().run(request);
+            await body('Email').isEmail().trim().run(request);
+            await body('Password').isString().notEmpty().trim().run(request);
+
+            const result = validationResult(request);
+            if (!result.isEmpty()) {
+                Helper.handleValidationError(result);
+            }
+
+            const createUserDomainModel: UserDomainModel = {
+                Prefix: request.body.prefix,
+                FirstName: request.body.FirstName,
+                MiddleName: request.body.MiddleName,
+                LastName: request.body.LastName,
+                Email: request.body.Email,
+                Password: request.body.Password,
+                RoleId: request.body.RoleId ?? null,
+            };
+
+            return createUserDomainModel;
+        } catch (err) {
+            ResponseHandler.handleError(request, response, err);
+        }
+    };
+}

Projects/BooksLibrary/src/api/validators/user.validator.ts

@@ -44,6 +44,9 @@ export default class Application {
             //Connect with database
             await Loader.databaseConnector.init();
 
+            //call the seeder
+            await Loader.seeder.init();
+
             //Set-up middlewares
             await this.setupMiddlewares();
 
@@ -58,6 +61,8 @@ export default class Application {
             await this.listen();
         } catch (error) {
             Logger.instance().log(`An error occurred while starting api service. ${error.message}`);
+            // eslint-disable-next-line no-console
+            console.error(error);
         }
     };
 

Projects/BooksLibrary/src/app.ts

@@ -0,0 +1,13 @@
+import { InputValidationError } from './input.validation.error';
+
+export class Helper {
+    static handleValidationError = (result) => {
+        let index = 1;
+        const errorMessages = [];
+        for (const er of result.errors) {
+            errorMessages.push(` ${index}. ${er.msg} - <${er.value}> for <${er.param}> in ${er.location}`);
+            index++;
+        }
+        throw new InputValidationError(errorMessages);
+    };
+}

Projects/BooksLibrary/src/common/helper.ts

@@ -29,8 +29,8 @@ export class ResponseHandler {
             Message: msg,
             HttpCode: httpErrorCode ? httpErrorCode : 500,
             Trace: trace_path,
-            User: request ? request.currentUser : null,
-            Context: request ? request.context : null,
+            User: null,
+            Context: 'request ? request.context : null',
             Request: {
                 Method: request ? request.method : null,
                 Host: request ? request.hostname : null,
@@ -73,8 +73,8 @@ export class ResponseHandler {
             HttpCode: httpCode ?? 200,
             Data: data ?? null,
             Trace: null,
-            User: request ? request.currentUser : null,
-            Context: request ? request.context : null,
+            User: null,
+            Context: 'request ? request.context : null',
             Request: {
                 Method: request ? request.method : null,
                 Host: request ? request.hostname : null,
@@ -89,10 +89,11 @@ export class ResponseHandler {
         };
 
         if (process.env.NODE_ENV !== 'test') {
+            const logObj = { ...responseObject };
             if (!logDataObject) {
-                responseObject.Data = null;
+                logObj.Data = null;
             }
-            Logger.instance().log(JSON.stringify(responseObject, null, 2));
+            Logger.instance().log(JSON.stringify(logObj, null, 2));
         }
 
         ActivityRecorder.record(responseObject);

Projects/BooksLibrary/src/common/response.handler.ts

@@ -0,0 +1,7 @@
+import { UserDomainModel } from 'domain.types/user/user.domain.model';
+import { UserDetailsDto } from 'domain.types/user/user.dto';
+
+export interface IUserRepo {
+    findUsersByRoleId(id: string): Promise<UserDetailsDto[]>;
+    createUser(userDetails: UserDomainModel): Promise<UserDetailsDto>;
+}