basic setup

frckbrice · frckbrice · commit baafc2c6f7fa · 2024-06-13T16:44:14.000+01:00
diff --git a/framework-and-drivers/database-access/db-connection.js b/framework-and-drivers/database-access/db-connection.js
@@ -1,4 +1,5 @@
 const MongoClient = require("mongodb").MongoClient;
+const { logEvents } = require("../../middlewares/loggers/logger")
 module.exports = {
 
     connection: async () => {
@@ -13,6 +14,10 @@ module.exports = {
             await client.connect();
         } catch (err) {
             console.log("error connecting to database", err);
+            logEvents(
+                `${err.no}:${err.code}\t${err.syscall}\t${err.hostname}`,
+                "mongoErrLog.log"
+            );
         }
 
         // Provide the name of the database and collection you want to use.
diff --git a/framework-and-drivers/database-access/db-indexes.js b/framework-and-drivers/database-access/db-indexes.js
@@ -0,0 +1,19 @@
+import { makeDb } from '../src/data-access'
+import dotenv from 'dotenv'
+dotenv.config();
+
+(async function setupDb () {
+  console.log('Setting up database...')
+  // database collection will automatically be created if it does not exist
+  // indexes will only be added if they don't exist
+  const db = await makeDb()
+  const result = await db
+    .collection('users')
+    .createIndexes([
+      { key: { id: 1 }, name: 'userId_idx' },
+      { key: { email: 1 }, name: 'email_idx' },
+    ])
+  console.log(result)
+  console.log('Database setup complete...')
+  process.exit()
+})()
diff --git a/framework-and-drivers/database-access/index.js b/framework-and-drivers/database-access/index.js
diff --git a/framework-and-drivers/database-access/store-user.js b/framework-and-drivers/database-access/store-user.js
@@ -14,7 +14,7 @@ module.exports = async function makeUser({ dbConnection }) {
 
     async function findAllUsers() {
         const db = await dbConnection()
-        const result = await db.collection('comments').find({})
+        const result = await db.collection('users').find({})
         return (await result.toArray()).map(({ _id: id, ...found }) => ({
             id,
             ...found
@@ -23,7 +23,7 @@ module.exports = async function makeUser({ dbConnection }) {
 
     async function findUserById() {
         const db = await dbConnection()
-        const result = await db.collection('comments').find({ _id })
+        const result = await db.collection('users').find({ _id })
         const found = await result.toArray()
         if (found.length === 0) {
             return null
@@ -35,7 +35,7 @@ module.exports = async function makeUser({ dbConnection }) {
     async function createUser({ id: _id = Id.makeId(), ...userData }) {
         const db = await dbConnection()
         const result = await db
-            .collection('comments')
+            .collection('users')
             .insertOne({ _id, ...userData })
         const { _id: id, ...insertedInfo } = result.ops[0]
         return { id, ...insertedInfo }
@@ -44,14 +44,14 @@ module.exports = async function makeUser({ dbConnection }) {
     async function updateUser({ id: _id, userData }) {
         const db = await dbConnection()
         const result = await db
-            .collection('comments')
+            .collection('users')
             .updateOne({ _id }, { $set: { ...userData } })
         return result.modifiedCount > 0 ? { id: _id, ...userData } : null
     }
 
     async function deleteUser({ id: _id }) {
         const db = await dbConnection()
-        const result = await db.collection('comments').deleteOne({ _id })
+        const result = await db.collection('users').deleteOne({ _id })
         return result.deletedCount
     }
 }
diff --git a/index.js b/index.js
@@ -3,7 +3,9 @@
 const express = require('express');
 require('dotenv').config();
 const cors = require('cors');
-const { connection } = require('./database-access/db-connection.js');
+const { connection } = require('./framework-and-drivers/database-access/db-connection.js');
+const errorHandler = require('./middlewares/loggers/errorHandler.js');
+const userRouter = require('./routes/user.router.js');
 
 connection().then((db) => {
     console.log("database connected: ", db.databaseName);
@@ -22,6 +24,20 @@ app.use(express.urlencoded({extended: false}));
 app.use('/', (req, res) => {
     res.send('hello world');
 });
+app.use("/users", userRouter);
+
+
+//for no specified endpoint that is not found. this must after all the middlewares
+app.all("*", (req, res) => {
+    res.status(404);
+    if (req.accepts("html")) {
+      res.sendFile(path.join(__dirname, "views", "404.html"));
+    } else if (req.accepts("json")) {
+      res.json({ msg: "404 Not Found" });
+    } else {
+      res.type("txt").send("404 Not Found");
+    }
+});
 
 app.use((req, res, next) => {
   const dntHeader = req.headers['dnt']; // Access DNT header (if present)
@@ -33,7 +49,7 @@ app.use((req, res, next) => {
 });
 
 
-
+app.use(errorHandler);
 
 app.listen(PORT, () => console.log(`Server started on port http://localhost:${PORT}`));
 
diff --git a/interface-adapters/adapter/express-callback/index.js b/interface-adapters/adapter/express-callback/index.js
@@ -0,0 +1,28 @@
+module.exports = function makeExpressCallback (controller) {
+  
+  return (req, res) => {
+    const httpRequest = {
+      body: req.body,
+      query: req.query,
+      params: req.params,
+      ip: req.ip,
+      method: req.method,
+      path: req.path,
+      headers: {
+        'Content-Type': req.get('Content-Type'),
+        Referer: req.get('referer'),
+        'User-Agent': req.get('User-Agent')
+      }
+    }
+
+    controller(httpRequest)
+      .then(httpResponse => {
+        if (httpResponse.headers) {
+          res.set(httpResponse.headers)
+        }
+        res.type('json')
+        res.status(httpResponse.statusCode).send(httpResponse.body)
+      })
+      .catch(e => res.status(500).send({ error: 'An unkown error occurred.' }))
+  }
+}
diff --git a/interface-adapters/config/allowedOrigin.js b/interface-adapters/config/allowedOrigin.js
@@ -0,0 +1,5 @@
+module.exports = {
+  allowedOrigin: [
+    "http://localhost:3001",
+  ],
+};
diff --git a/interface-adapters/config/corsOptions.Js b/interface-adapters/config/corsOptions.Js
@@ -0,0 +1,19 @@
+const { allowedOrigin } = require("./allowedOrigin");
+
+const corsOptions = {
+  origin: (origin, callback) => {
+    // no origin because of postman/thunder testers
+    if (allowedOrigin.includes(origin) || !origin) {
+      console.log({ original_request: origin });
+      callback(null, true);
+    } else {
+      console.log("origin: ", origin);
+      console.log(allowedOrigin.includes(origin));
+      callback(new Error("NOT ALLOW BECAUSE OF CORS"));
+    }
+  },
+  optionSuccessStatus: 200,
+  credentials: true,
+};
+
+module.exports = corsOptions;
diff --git a/interface-adapters/config/validators-errors/errors.js b/interface-adapters/config/validators-errors/errors.js
@@ -0,0 +1,29 @@
+export class UniqueConstraintError extends Error {
+  constructor (value) {
+    super(`${value} must be unique.`)
+
+    if (Error.captureStackTrace) {
+      Error.captureStackTrace(this, UniqueConstraintError)
+    }
+  }
+}
+
+export class InvalidPropertyError extends Error {
+  constructor (msg) {
+    super(msg)
+
+    if (Error.captureStackTrace) {
+      Error.captureStackTrace(this, InvalidPropertyError)
+    }
+  }
+}
+
+export class RequiredParameterError extends Error {
+  constructor (param) {
+    super(`${param} can not be null or undefined.`)
+
+    if (Error.captureStackTrace) {
+      Error.captureStackTrace(this, RequiredParameterError)
+    }
+  }
+}
diff --git a/interface-adapters/config/validators-errors/http-error.js b/interface-adapters/config/validators-errors/http-error.js
@@ -0,0 +1,12 @@
+export default function makeHttpError ({ statusCode, errorMessage }) {
+  return {
+    headers: {
+      'Content-Type': 'application/json'
+    },
+    statusCode,
+    data: JSON.stringify({
+      success: false,
+      error: errorMessage
+    })
+  }
+}
diff --git a/interface-adapters/config/validators-errors/is-valid-email.js b/interface-adapters/config/validators-errors/is-valid-email.js
@@ -0,0 +1,4 @@
+export default function isValidEmail (email) {
+  const valid = new RegExp(/^[^@\s]+@[^@\s]+\.[^@\s]+$/)
+  return valid.test(email)
+}
diff --git a/interface-adapters/config/validators-errors/required-param.js b/interface-adapters/config/validators-errors/required-param.js
@@ -0,0 +1,5 @@
+import { RequiredParameterError } from './errors'
+
+export default function requiredParam (param) {
+  throw new RequiredParameterError(param)
+}
diff --git a/interface-adapters/config/validators-errors/upper-first.js b/interface-adapters/config/validators-errors/upper-first.js
@@ -0,0 +1,6 @@
+export default function upperFirst (word) {
+  if (word.length === 1) {
+    return word.toUpperCase()
+  }
+  return word.charAt(0).toUpperCase() + word.substring(1)
+}
diff --git a/middlewares/auth.js b/middlewares/auth.js
@@ -0,0 +1,9 @@
+isUserAuthenticated = (req, res, next) => {
+  if (req.user) {
+    next();
+  } else {
+    res.status(401).send("You must login first!");
+  }
+};
+
+module.exports = isUserAuthenticated;
diff --git a/middlewares/loggers/errorHandler.js b/middlewares/loggers/errorHandler.js
@@ -0,0 +1,18 @@
+const { logEvents } = require("./logger");
+
+const errorHandler = (err, req, res, next) => {
+  logEvents(
+    `${err.name}: ${err.message}\t${req.method}\t${req.url}\t${req.headers.origin}`,
+    "errLog.log"
+  );
+  console.log(err.stack);
+
+  const status = res.statusCode ? res.statusCode : 500; // server error
+
+  res.status(status);
+
+  res.json({ message: err.message });
+  next(err)
+};
+
+module.exports = errorHandler;
diff --git a/middlewares/loggers/logger.js b/middlewares/loggers/logger.js
@@ -0,0 +1,30 @@
+const { format } = require("date-fns");
+const { v4: uuid } = require("uuid");
+const fs = require("fs");
+const fsPromises = require("fs").promises;
+const path = require("path");
+
+const logEvents = async (message, logFileName) => {
+  const dateTime = format(new Date(), "yyyy-MM-dd\tHH:mm:ss");
+  const logItem = `${dateTime}\t${uuid()}\t${message}\n`;
+
+  try {
+    if (!fs.existsSync(path.join(__dirname, "..", "logs"))) {
+      await fsPromises.mkdir(path.join(__dirname, "..", "logs"));
+    }
+    await fsPromises.appendFile(
+      path.join(__dirname, "..", "logs", logFileName),
+      logItem
+    );
+  } catch (err) {
+    console.log(err);
+  }
+};
+
+const logger = (req, res, next) => {
+  logEvents(`${req.method}\t${req.url}\t${req.headers.origin}`, "reqLog.log");
+  console.log(`${req.method} ${req.path}`);
+  next();
+};
+
+module.exports = { logEvents, logger };
diff --git a/middlewares/loginLimiter.js b/middlewares/loginLimiter.js
@@ -0,0 +1,25 @@
+const rateLimit = require('express-rate-limit');
+
+const logEvents = require('./logger');
+
+const loginLimiter = rateLimit({
+  windowMs: 60 * 1000, // 1minute
+
+  max: 5, // max IP loggin requests /window/,min
+
+  message: ' Too many loggin attempts for this IP address. Please try again in 60 seconds',
+
+  handler: (req, res, next, options) => {
+    logEvents(`Too many requests: ${options.message.message}\t${req.method}\t${req.url}\t${req.headers.origin}`,'errLog.log');
+
+    res.status(options.statusCode).send(options.message);
+
+  },
+
+  standardHeaders: true, //return rate limit in the `RateLimit-*` headers
+  legacyHeaders: false // disabling `X-rateLimit-*` headers
+
+});
+
+module.exports = loginLimiter;
+
diff --git a/middlewares/verifyJwt.js b/middlewares/verifyJwt.js
@@ -0,0 +1,54 @@
+const jwt = require("jsonwebtoken");
+
+const verifyJwt = (req, res, next) => {
+  const authHeader = req.headers.authorization || req.headers.Authorization;
+
+  console.log("\n\nin the verifcation service: before 401 \n\n");
+
+  if (!authHeader?.startsWith("Bearer ")) {
+    return res.status(401).send("UnAuthorized. need to login first");
+  }
+
+  console.log("\n\nin the verifcation service: after 401 \n\n");
+
+  console.log("authHeader: ", authHeader);
+
+  const token = authHeader.split(" ")[1];
+
+  console.log("token", token);
+
+  if (!token) {
+    return res.status(401).send("UnAuthorized. need to login first");
+  }
+
+  console.log("\n\n secret key: ", process.env.ACCESS_TOKEN_SECRETKEY);
+  console.log("\n\n");
+
+  jwt.verify(
+    token,
+    process.env.ACCESS_TOKEN_SECRETKEY,
+    (err, decodedUserInfo) => {
+      if (err) {
+        console.log("\n\n error 403: ", err);
+        console.log("\n\n");
+        return res.status(403).json({ message: "Forbidden" });
+      }
+
+      if (!decodedUserInfo) {
+        return res.status(400).json({ message: "no decodedUserInfo" });
+      }
+      req.user = decodedUserInfo.userInfo.username;
+      req.userId = decodedUserInfo.userInfo.userId;
+      req.roles = decodedUserInfo.userInfo.roles;
+      if (decodedUserInfo.userInfo.email)
+        req.email = decodedUserInfo.userInfo.email;
+      req.picture = decodedUserInfo.userInfo.picture;
+      console.log("\n\nuser", req.user);
+      console.log("\n\ndecodeuser", decodedUserInfo);
+
+      next();
+    }
+  );
+};
+
+module.exports = verifyJwt;
diff --git a/package.json b/package.json
diff --git a/public/css/style.css b/public/css/style.css
diff --git a/public/views/404.html b/public/views/404.html
diff --git a/public/views/index.html b/public/views/index.html
diff --git a/routes/user.router.js b/routes/user.router.js
diff --git a/yarn.lock b/yarn.lock
