ADDED: Login, Register, regenerate access token, logout services

.env.sample

@@ -1,3 +1,45 @@
 # Mentoring User Service Config
-APPLICATION_PORT = 3000
-APPLICATION_ENV = development
+
+APPLICATION_PORT = 3000                                                              // Port on which service runs
+
+APPLICATION_ENV = development                                                        // Service environment
+
+MONGODB_URL = mongodb://localhost:27017/elevate-user                                 // Database connectivity url
+
+SALT_ROUNDS = 10                                                                     // Number of rounds for encryption
+
+ACCESS_TOKEN_SECRET = 'bsj82AHBxahusub12yexlashsbxAXADHBlaj'                         // Token secret to generate access token
+
+REFRESH_TOKEN_SECRET = 'baXDUDQ7YEXKH182ELXKJHJKLhasjxlADahgdsd'                     // Token secret to generate refresh token
+
+# KAFKA Configurations
+
+KAFKA_URL = localhost:9092                                                           // Kafka hosted server url
+KAFKA_GROUP_ID = userservice                                                         // Kafka group to which consumer belongs
+KAFKA_TOPIC =                                                                        // Kafka topic to consume data from
+NOTIFICATION_KAFKA_TOPIC = notificationtopic                                         // Kafka topic to push notification data
+
+# CLOUD STOARGE TYPE
+
+CLOUD_STORAGE = 'GCP/AWS/AZURE'                                                      // Any one of three features available for cloud storage
+
+# GCP Credentials
+
+GCP_PATH = 'gcp.json'                                                                // Gcp json config file path
+DEFAULT_GCP_BUCKET_NAME = 'gcp-bucket-storage-name'                                  // Gcp bucket name which stores files
+GCP_PROJECT_ID = 'project-id'                                                        // Gcp project id
+
+# AWS Credentials
+
+AWS_ACCESS_KEY_ID = 'ashdaqwgeiqwye739182xo1y371xo1237o'                             // Aws access key id
+AWS_SECRET_ACCESS_KEY = '189273bxoyeb1yxliuxb173t71x17x173o1'                        // Aws secret access key
+AWS_BUCKET_REGION = 'ap-south-1'                                                     // Aws region where bucket will be located
+AWS_BUCKET_ENDPOINT = 's3.ap-south-1.amazonaws.com'                                  // Aws end point
+DEFAULT_AWS_BUCKET_NAME = 'aws-bucket-storage-name'                                  // Aws bucket name which stores files
+
+# AZURE Credentials
+
+AZURE_ACCOUNT_NAME = 'account-name'                                                  // Azure storage account name
+AZURE_ACCOUNT_KEY = 'xbad1y381xuhebbi27234724x1yphqbe848hkqje1u3=='                  // Azure storage account key
+DEFAULT_AZURE_CONTAINER_NAME = 'azure-container-storage-name'                        // Azure storage container which stores files
+INTERNAL_ACCESS_TOKEN = 'baXDUDQ7YEXKH182ELXKJHJKLhasjxlADahgdsd'

.gitignore

@@ -30,6 +30,7 @@ build/Release
 
 # Dependency directories
 node_modules
+tmp
 jspm_packages
 doc
 .vscode
@@ -58,9 +59,13 @@ package-lock.json
 
 public/assessment/web
 public/assessment/web2
+public/tmp
 
 .env
 
 # Ignore all credentials
 generics/helpers/credentials/*
 
+gcp.json
+gcp1.json
+

app.js

@@ -8,12 +8,17 @@
 const express = require('express');
 const bodyParser = require('body-parser');
 const cors = require('cors');
-require("dotenv").config({ path: './.env.sample' });
+const expressFileUpload = require('express-fileupload');
+
+require('dotenv').config({ path: './.env' });
+require('./configs');
 
 const app = express();
 
 app.use(cors());
 
+app.use(expressFileUpload());
+
 app.use(bodyParser.urlencoded({ extended: true, limit: '50MB' }));
 app.use(bodyParser.json({ limit: '50MB' }));
 

configs/index.js

@@ -3,4 +3,54 @@
  * author : Aman Kumar Gupta
  * Date : 31-Sep-2021
  * Description : Contains connections of all configs
- */
+ */
+
+ require("./mongodb")();
+
+ require("./kafka")();
+ const path = require("path");
+ const fs = require("fs");
+ const requireAll = require("require-all");
+
+ global.PROJECT_ROOT_DIRECTORY = path.join(__dirname, '..');
+
+ //load base v1 controllers
+ const pathToController = PROJECT_ROOT_DIRECTORY + "/controllers/v1/";
+
+ fs.readdirSync(pathToController).forEach(function (file) {
+   checkWhetherFolderExistsOrNot(pathToController, file);
+ });
+
+ /**
+* Check whether folder exists or Not.
+* @method
+* @name checkWhetherFolderExistsOrNot
+* @param {String} pathToFolder - path to folder.
+* @param {String} file - File name.
+*/
+
+ function checkWhetherFolderExistsOrNot(pathToFolder, file) {
+
+   let folderExists = fs.lstatSync(pathToFolder + file).isDirectory();
+
+   if (folderExists) {
+     fs.readdirSync(pathToFolder + file).forEach(function (folderOrFile) {
+       checkWhetherFolderExistsOrNot(pathToFolder + file + "/", folderOrFile);
+     })
+
+   } else {
+     if (file.match(/\.js$/) !== null) {
+       require(pathToFolder + file);
+     }
+   }
+
+ }
+
+
+  // All controllers
+  global.controllers = requireAll({
+    dirname: PROJECT_ROOT_DIRECTORY + "/controllers",
+    resolve: function (Controller) {
+      return new Controller();
+    }
+  });

configs/kafka.js

@@ -0,0 +1,50 @@
+/**
+ * name : configs/kafka
+ * author : Aman Gupta
+ * Date : 08-Nov-2021
+ * Description : Kafka connection configurations
+*/
+
+const Kafka = require('kafka-node');
+
+module.exports = () => {
+    const Producer = Kafka.Producer;
+    const KafkaClient = new Kafka.KafkaClient({
+        kafkaHost: process.env.KAFKA_URL
+    });
+    const producer = new Producer(KafkaClient);
+
+    /* Uncomment while writing consuming actions for this service */
+    // const Consumer = Kafka.Consumer;
+    // const consumer = new Consumer(KafkaClient, [ { topic: process.env.KAFKA_TOPIC } ], { autoCommit: true, groupId: process.env.KAFKA_GROUP_ID })
+
+    /* Registered events */
+
+    KafkaClient.on('error', error => {
+        console.log('Kafka connection error: ', error);
+    });
+
+    KafkaClient.on('connect', () => {
+        console.log('Connected to kafka client');
+    });
+
+    producer.on('error', error => {
+        console.log('Kafka producer intialization error: ', error);
+    });
+
+    producer.on('ready', () => {
+        console.log('Producer intialized successfully');
+    });
+
+    // consumer.on('error', error => {
+    //     console.log('Kafka consumer intialization error: ', error);
+    // });
+
+    // consumer.on('message', message => {
+    //     // perform action using message
+    // });
+
+    global.kafkaProducer = producer;
+    global.kafkaClient = KafkaClient;
+
+};

configs/mongodb.js

@@ -0,0 +1,43 @@
+/**
+ * name : configs/mongodb
+ * author : Aman
+ * Date : 07-Oct-2021
+ * Description : Mongodb connections configurations
+*/
+
+const mongoose = require("mongoose");
+const mongoose_autopopulate = require("mongoose-autopopulate");
+const mongoose_timestamp = require("mongoose-timestamp");
+const mongoose_paginate = require('mongoose-paginate-v2');
+
+module.exports = function () {
+
+  // Added to remove depreciation warnings from logs.
+  mongoose.set('useCreateIndex', true)
+  mongoose.set('useFindAndModify', false)
+  mongoose.set('useUnifiedTopology', true)
+
+  const db = mongoose.createConnection(
+    process.env.MONGODB_URL,
+    {
+      useNewUrlParser: true
+    }
+  );
+
+  db.on("error", function () {
+    console.log("Database connection error:")
+  });
+
+  db.once("open", function () {
+    console.log("Connected to DB");
+  });
+
+  mongoose.plugin(mongoose_timestamp, {
+    createdAt: "createdAt",
+    updatedAt: "updatedAt"
+  });
+
+  mongoose.plugin(mongoose_autopopulate);
+  mongoose.plugin(mongoose_paginate);
+  global.db = db;
+};

constants/api-responses.js

@@ -1,3 +1,42 @@
 module.exports = {
-    'registeredSuccessfully': 'User Registered Successfully'
+    "EMAIL_INVALID": "Email Id is invalid",
+    "PASSWORD_INVALID": "Password is invalid",
+    "USER_ALREADY_EXISTS": "User already exists",
+    "USER_DOESNOT_EXISTS": "User doesnot exists",
+    "USER_CREATED_SUCCESSFULLY": "User created successfully",
+    "LOGGED_IN_SUCCESSFULLY": "User logged in successfully",
+    "LOGGED_OUT_SUCCESSFULLY": "User logged out successfully",
+    "UNAUTHORIZED_REQUEST": "Unauthorized request",
+    "REFRESH_TOKEN_EXPIRED": "Refresh token expired",
+    "ACCESS_TOKEN_EXPIRED": "Access token expired",
+    "ACCESS_TOKEN_GENERATED_SUCCESSFULLY": "Access token generated successfully",
+    "INVALID_REFRESH_TOKEN": "Invalid refresh token",
+    "REFRESH_TOKEN_NOT_FOUND": "Refresh token not found",
+    "PROFILE_UPDATED_SUCCESSFULLY": "Profile updated successfully",
+    "PROFILE_FETCHED_SUCCESSFULLY": "Profile fetched successfully",
+    "FORM_ALREADY_EXISTS": "Form already exists",
+    "FORM_CREATED_SUCCESSFULLY": "Form created successfully",
+    "FORM_UPDATED_SUCCESSFULLY": "Form updated successfully",
+    "FORM_FETCHED_SUCCESSFULLY": "Form fetched successfully",
+    "FORM_NOT_FOUND": "Form not found",
+    "USER_ENTITY_NOT_FOUND": "User entity not found",
+    "USER_ENTITY_ALREADY_EXISTS": "User entity already exists",
+    "USER_ENTITY_ALREADY_DELETED": "User entity already deleted",
+    "USER_ENTITY_CREATED_SUCCESSFULLY": "User entity created successfully",
+    "USER_ENTITY_UPDATED_SUCCESSFULLY": "User entity updated successfully",
+    "USER_ENTITY_DELETED_SUCCESSFULLY": "User entity deleted successfully",
+    "USER_ENTITY_FETCHED_SUCCESSFULLY": "User entity fetched successfully",
+    "OTP_SENT_SUCCESSFULLY": "Otp sent successfully",
+    "PASSWORD_RESET_SUCCESSFULLY": "Password reset successfully",
+    "OTP_INVALID": "Invalid otp",
+    "SYSTEM_USER_ALREADY_EXISTS": "System User already exists",
+    "NOT_AN_ADMIN": "Not an admin",
+    "MENTOR_LIST": "Mentor list fetched successfully",
+    "FILE_NOT_PROVIDED": "File not provided",
+    "FILE_UPLOADED_SUCCESSFULLY": "File uploaded successfully",
+    "SIGNED_URL_GENERATED_SUCCESSFULLY": "Signed Url Generated Successfully",
+    "INCORRECT_INTERNAL_ACCESS_TOKEN": "Invalid internal access token",
+    "USER_IS_A_MENTOR":"User has mentor access",
+    "USER_IS_NOT_A_MENTOR":"User does't have mentor access",
+    "USER_UPDATED_SUCCESSFULLY": "User successfully updated"
 };

constants/common.js

@@ -5,19 +5,19 @@
  * Description : All commonly used constants through out the service
  */
 
-const successResponse = (statusCode = 500, message, data = [], totalCounts = undefined, token = undefined) => {
+const successResponse = ({statusCode = 500, responseCode = 'OK', message, result = []}) => {
     return {
         statusCode,
+        responseCode,
         message,
-        data,
-        totalCounts,
-        token
+        result
     }
 };
 
-const failureResponse = ({ message = "Oops! Something Went Wrong.", statusCode = 500 }) => {
+const failureResponse = ({ message = "Oops! Something Went Wrong.", statusCode = 500, responseCode }) => {
     const error = new Error(message);
     error.statusCode = statusCode;
+    error.responseCode = responseCode;
     return error;
 };
 
@@ -27,5 +27,18 @@ module.exports = {
         DEFAULT_PAGE_SIZE: 100,
     },
     successResponse,
-    failureResponse
+    failureResponse,
+    guestUrls: [
+        '/user/v1/account/login',
+        '/user/v1/account/create',
+        '/user/v1/account/generateToken',
+        '/user/v1/account/generateOtp',
+        '/user/v1/account/resetPassword',
+        '/user/v1/systemUsers/create',
+        '/user/v1/systemUsers/login'
+    ],
+    uploadUrls: [
+        'bulkCreateMentors',
+        '/user/v1/account/verifyMentor'
+    ]
 };