Implemented crud over user table on mysql db

.gitignore

@@ -1 +1,2 @@
 node_modules
+dist

.vscode/launch.json

@@ -0,0 +1,18 @@
+{
+    // Use IntelliSense to learn about possible attributes.
+    // Hover to view descriptions of existing attributes.
+    // For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
+    "version": "0.2.0",
+    "configurations": [
+        {
+            "name": "Attach by Process ID",
+            "processId": "${command:PickProcess}",
+            "request": "attach",
+            "skipFiles": [
+                "<node_internals>/**"
+            ],
+            "type": "node"
+        }
+
+    ]
+}

DDL.sql

@@ -1,9 +1,10 @@
 -- DB DDL script for OSlash clone
 
-CREATE TABLE `user`
+CREATE TABLE `users`
 (
- `id`           bigint NOT NULL ,
+ `id`           bigint NOT NULL AUTO_INCREMENT,
  `email`        varchar(100) NOT NULL ,
+ `name`         varchar(100) NOT NULL ,
  `password`     varchar(100) NOT NULL ,
  `created_dttm` datetime NOT NULL ,
  `updated_dttm` datetime NOT NULL ,

src/app.ts

@@ -1,6 +1,6 @@
 import express from 'express';
 import morgan from 'morgan';
-import sequelize from './config/mysql';
+import databaseObj from './models';
 import swaggerJSDoc from 'swagger-jsdoc';
 import swaggerUi from 'swagger-ui-express';
 import { Routes } from './interfaces/routes.interface';
@@ -38,6 +38,7 @@ class App {
   }
 
   private connectToDatabase() {
+    const { sequelize } = databaseObj;
     sequelize.authenticate().then(() => {
       console.log('Connection has been established successfully.');
     }).catch((error) => {

src/controllers/user.controller.ts

@@ -0,0 +1,20 @@
+import { NextFunction, Request, Response } from 'express';
+import {  UserData } from '../interfaces/user.interface';
+import userService from '../services/user.service';
+
+class UsersController {
+  public userService = new userService();
+
+  public getUserByEmail = async (req: Request, res: Response, next: NextFunction) => {
+    try {
+      const email: string = req.params.email;
+      const findOneUserData: UserData = await this.userService.findUserDataByEmail(email);
+
+      res.status(200).json({ data: findOneUserData, message: 'findOne' });
+    } catch (error) {
+      next(error);
+    }
+  };
+}
+
+export default UsersController;

src/dtos/users.dto.ts

@@ -0,0 +1,17 @@
+import { IsString, IsNotEmpty } from 'class-validator';
+
+export class CreateUserDto {
+
+    @IsString()
+    @IsNotEmpty()
+    public email: string;
+
+    @IsString()
+    @IsNotEmpty()
+    public password: string;
+}
+
+
+
+
+

src/interfaces/user.interface.ts

@@ -0,0 +1,8 @@
+export interface UserData {
+    _id: number;
+    email: string;
+    password: string;
+    created_dttm: string;
+    updated_dttm: string;
+}
+

src/models/index.ts

@@ -0,0 +1,13 @@
+import { Sequelize, DataTypes } from 'sequelize';
+import User from './user.model';
+import { DB_HOST, DB_PASSWORD, DB_USERNAME } from '../config/index';
+
+const sequelize = new Sequelize(`mysql://${DB_USERNAME}:${DB_PASSWORD}@${DB_HOST}/slash`);
+
+const databaseObj = {
+    Sequelize,
+    sequelize,
+    User : User(sequelize, Sequelize, DataTypes),
+};
+
+export default databaseObj;

src/models/user.model.ts

@@ -0,0 +1,22 @@
+const User = (sequelize, Sequelize, DataTypes) => {
+    const User = sequelize.define(
+      "users",
+      {
+        email: {
+          type: DataTypes.STRING,
+          unique: true,
+          primaryKey: true
+        },
+        password: {
+          type: DataTypes.STRING
+        }
+      },
+      {
+        createdAt: "created_dttm",
+        updatedAt: "updated_dttm"
+      }
+    );
+    return User;
+};
+
+export default User;

src/routes/auth.route.ts

@@ -0,0 +1,19 @@
+
+import { Router } from 'express';
+import { Routes } from '../interfaces/routes.interface';
+
+class HealthRoute implements Routes {
+  public route = '/health';
+  public router = Router();
+  public healthController = new HealthController();
+
+  constructor() {
+    this.initializeRoutes();
+  }
+
+  private initializeRoutes() {
+    this.router.get(`${this.route}`, this.healthController.healthCheck);
+  }
+}
+
+export default HealthRoute;

src/routes/user.route.ts

@@ -0,0 +1,19 @@
+import { Router } from 'express';
+import UsersController from '../controllers/user.controller';
+import { Routes } from '../interfaces/routes.interface';
+
+class UsersRoute implements Routes {
+  public route = '/user';
+  public router = Router();
+  public usersController = new UsersController();
+
+  constructor() {
+    this.initializeRoutes();
+  }
+
+  private initializeRoutes() {
+    this.router.get(`${this.route}/:email`, this.usersController.getUserByEmail);
+  }
+}
+
+export default UsersRoute;

src/server.ts

@@ -1,7 +1,8 @@
 import App from './app';
 import HealthRoute from './routes/health.route';
+import UserRoute from './routes/user.route';
 
-const app = new App([new HealthRoute()]);
+const app = new App([new HealthRoute(), new UserRoute()]);
 
 app.listen();
 

src/services/user.service.ts

@@ -0,0 +1,20 @@
+import { UserData } from '../interfaces/user.interface';
+import { HttpException } from '../utils/exception';
+import Db from '../models';
+import * as R from 'ramda';
+import { nullCheck } from '../utils/ramda';
+
+class UserService {
+
+  public async findUserDataByEmail(email: string): Promise<UserData> {
+    if (nullCheck(email)) throw new HttpException(400, "email is undefined");
+
+    const userResult: UserData = await Db.User.findByPk(email);
+    if (!userResult) throw new HttpException(204, '');
+
+    return userResult;
+  }
+
+}
+
+export default UserService;