feat: add endpoint register and authenticate user

Author: cunkz

.env.example

@@ -1,4 +1,5 @@
 PORT=9000
 APP_ENV=dev
 STORAGE_LOCATION=files
-SYSTEM_SHUTDOWN_DELAY=0
+SYSTEM_SHUTDOWN_DELAY=0
+MONGODB_URL='mongodb://localhost:27017/example?maxPoolSize=10&socketTimeoutMS=10000&connectTimeoutMS=10000&useUnifiedTopology=true'

bin/app/server.js

@@ -24,6 +24,7 @@ class AppServer {
     });
 
     this.app.post('/api/users/v1/register', userHandler.registerUser);
+    this.app.post('/api/users/v1/auth', userHandler.authUser);
   }
 
   async listen(port, cb) {

bin/helpers/components/mongodb/connection.js

@@ -0,0 +1,36 @@
+const { MongoClient } = require('mongodb');
+const configs = require('../../configs/global_config');
+const wrapper = require('../../utils/wrapper');
+const logger = require('../../utils/logger');
+
+let connectionPool = [];
+
+const fetchConnection = async (config) => {
+  const checkConnection = connectionPool.findIndex(c => c.config == config);
+  if(checkConnection === -1) {
+    try {
+      const client = new MongoClient(config);
+      const connection = await client.connect();
+      const dbName = getDatabaseName(config);
+      const pool = { config, connection, dbName };
+      connectionPool.push(pool);
+      return wrapper.data(pool);
+    } catch (err) {
+      logger.log('connection-createConnection', err, 'error');
+      return wrapper.error(err.message);
+    }
+  }
+
+  return wrapper.data(connectionPool[checkConnection]);
+};
+
+const getDatabaseName = (config) => {
+  config = config.replace('//', '');
+  const pattern = new RegExp('/([a-zA-Z0-9-]+)?');
+  const dbNameFound = pattern.exec(config);
+  return dbNameFound[1];
+}
+
+module.exports = {
+  fetchConnection,
+};

bin/helpers/configs/global_config.js

@@ -10,6 +10,9 @@ const config = {
   storage: {
     location: process.env.STORAGE_LOCATION,
   },
+  mongodb: {
+    url: process.env.MONGODB_URL,
+  },
 };
 
 const store = new confidence.Store(config);

bin/modules/user/handlers/api_handler.js

@@ -2,15 +2,17 @@ const wrapper = require('../../../helpers/utils/wrapper');
 const validator = require('../../../helpers/utils/validator');
 
 const commandValidation = require('../services/commands/command_validation');
+const commandDomain = require('../services/commands/command_domain');
+
+const commandUser = new commandDomain();
 
 const registerUser = async (req, res) => {
   const message = 'Register User';
   const payload = req.body;
   const validatePayload = validator.isValidPayload(payload, commandValidation.registerUser);
   const postRequest = async (result) => {
-    return result.err ? result : wrapper.data({ isRegistered: true });
+    return result.err ? result : commandUser.registerUser(result.data);
   };
-
   const sendResponse = async (result) => {
     (result.err)
       ? wrapper.response(res, 'fail', result, message)
@@ -19,7 +21,22 @@ const registerUser = async (req, res) => {
   sendResponse(await postRequest(validatePayload));
 };
 
+const authUser = async (req, res) => {
+  const message = 'Authenticate User';
+  const payload = req.body;
+  const validatePayload = validator.isValidPayload(payload, commandValidation.authUser);
+  const postRequest = async (result) => {
+    return result.err ? result : commandUser.authUser(result.data);
+  };
+  const sendResponse = async (result) => {
+    (result.err)
+      ? wrapper.response(res, 'fail', result, message)
+      : wrapper.response(res, 'success', result, message);
+  };
+  sendResponse(await postRequest(validatePayload));
+};
 
 module.exports = {
   registerUser,
+  authUser,
 };

bin/modules/user/services/commands/command_domain.js

@@ -0,0 +1,52 @@
+const QueryRepository = require('../queries/query_repository');
+const CommandRepository = require('./command_repository');
+
+const configs = require('../../../../helpers/configs/global_config');
+const wrapper = require('../../../../helpers/utils/wrapper');
+const logger = require('../../../../helpers/utils/logger');
+const createError = require('http-errors');
+const { createHash } = require('crypto');
+
+class User {
+  constructor () {    
+    this.query = new QueryRepository(configs.get('/mongodb/url'));
+    this.command = new CommandRepository(configs.get('/mongodb/url'));
+  }
+
+  async registerUser(payload) {
+    const ctx = 'cmd-domain-registerUser';
+    let { email, password } = payload;
+    const checkUser = await this.query.getUserByEmail(email);
+    if(checkUser.err && checkUser.err.message != 'Data not found') return checkUser;
+    else if(checkUser.data) return wrapper.error(new createError.InternalServerError('User already exists'));
+
+    password = createHash('sha256').update(password).digest('hex');
+    const resAddUser = await this.command.addUser(email, password);
+    if(resAddUser.err) {
+      logger.error(ctx, 'Failed Register User', 'addUser', resAddUser);
+      return resAddUser;
+    }
+
+    return wrapper.data('User registration has been successful');
+  }
+
+  async authUser(payload) {
+    const ctx = 'cmd-domain-authUser';
+    let { email, password } = payload;
+    const checkUser = await this.query.getUserByEmail(email);
+    if(checkUser.err) {
+      logger.error(ctx, 'Invalid Email', 'check-user');
+      return wrapper.error(new createError.Unauthorized('Invalid Email or Password'));
+    }
+
+    password = createHash('sha256').update(password).digest('hex');
+    if(password != checkUser.data.password) {
+      logger.error(ctx, 'Invalid Password', 'check-password');
+      return wrapper.error(new createError.Unauthorized('Invalid Email or Password'));
+    }
+
+    return wrapper.data({ userId: checkUser.data.userId });
+  }
+};
+
+module.exports = User;

bin/modules/user/services/commands/command_repository.js

@@ -0,0 +1,47 @@
+const mongodbConn = require('../../../../helpers/components/mongodb/connection');
+const wrapper = require('../../../../helpers/utils/wrapper');
+const logger = require('../../../../helpers/utils/logger');
+const createError = require('http-errors');
+const { v4: uuidv4 } = require('uuid');
+const moment = require('moment');
+
+class CommandRepository {
+  constructor (config) {
+    this.config = config;
+    this.collectionName = 'users';
+  }
+
+  async getDB() {
+    const ctx = 'cmd-repo-getDB';
+    try {
+      const {data: { connection: cacheConnection, dbName }} = await mongodbConn.fetchConnection(this.config);
+      return wrapper.data(cacheConnection.db(dbName).collection(this.collectionName));
+    } catch (err) {
+      logger.error(ctx, err.message, 'Error get db connection');
+      return wrapper.error(err);
+    }
+  };
+
+  async addUser(email, password) {
+    const ctx = 'cmd-repo-addUser';
+    try {
+      const { data:db } = await this.getDB();
+      const document = {
+        userId: uuidv4(),
+        email,
+        password,
+        createdAt: moment().format(),
+      };
+      const recordset = await db.insertOne(document);
+      if (!recordset.acknowledged)
+        return wrapper.error(new createError.InternalServerError(`Failed insert data to mongodb`));
+
+      return wrapper.data(document);
+    } catch (err) {
+      logger.log(ctx, err.message, 'Failed insert data to mongodb');
+      return wrapper.error(new createError.InternalServerError(`Failed insert data to mongodb: ${err.message}`));
+    }
+  }
+};
+
+module.exports = CommandRepository;

bin/modules/user/services/commands/command_validation.js

@@ -2,9 +2,16 @@ const joi = require('joi');
 
 const registerUser = joi.object({
   email: joi.string().required(),
+  name: joi.string().required(),
+  password: joi.string().required(),
+});
+
+const authUser = joi.object({
+  email: joi.string().required(),  
   password: joi.string().required(),
 });
 
 module.exports = {
   registerUser,
+  authUser,
 };

bin/modules/user/services/queries/query_repository.js

@@ -0,0 +1,41 @@
+const mongodbConn = require('../../../../helpers/components/mongodb/connection');
+const wrapper = require('../../../../helpers/utils/wrapper');
+const logger = require('../../../../helpers/utils/logger');
+const createError = require('http-errors');
+const validate = require('validate.js');
+
+class QueryRepository {
+  constructor (config) {
+    this.config = config;
+    this.collectionName = 'users';
+  }
+
+  async getDB() {
+    const ctx = 'cmd-repo-getDB';
+    try {
+      const {data: { connection: cacheConnection, dbName }} = await mongodbConn.fetchConnection(this.config);
+      return wrapper.data(cacheConnection.db(dbName).collection(this.collectionName));
+    } catch (err) {
+      logger.error(ctx, err.message, 'Error get db connection');
+      return wrapper.error(err);
+    }
+  };
+
+  async getUserByEmail(email) {
+    const ctx = 'qry-repo-getUserByEmail';
+    try {
+      const { data: db } = await this.getDB();
+      const parameter = { email: email };
+      const recordset = await db.findOne(parameter);
+      if (validate.isEmpty(recordset)) {
+        return wrapper.error(new createError.NotFound('Data not found'));
+      }
+      return wrapper.data(recordset);
+    } catch (err) {
+      logger.error(ctx, err.message, 'Error get data from mongodb');
+      return wrapper.error(new createError.InternalServerError(`Error get data from mongodb: ${err.message}`));
+    }
+  }
+};
+
+module.exports = QueryRepository;

package.json

@@ -19,8 +19,11 @@
     "http-errors": "^2.0.0",
     "http-status-codes": "^2.3.0",
     "joi": "^17.12.1",
+    "moment": "^2.30.1",
+    "mongodb": "5.9.2",
     "multer": "^1.4.5-lts.1",
     "nodemon": "^3.0.3",
+    "uuid": "^9.0.1",
     "validate.js": "^0.13.1",
     "winston": "^3.11.0"
   }