feat(user controller): created API for email update

feat #49

frontend/src/app/auth.service.ts

@@ -7,7 +7,7 @@ import { Tokens } from './interfaces/Tokens';
   providedIn: 'root',
 })
 export class AuthService {
-  constructor(private http: HttpClient) { }
+  constructor(private http: HttpClient) {}
 
   api = environment.apiUrl;
   isLoggedIn = false;
@@ -54,8 +54,10 @@ export class AuthService {
     });
   }
 
-  updateUserEmail(newEmail: string) {
-
+  updateUserEmail(email: string) {
+    return this.http.post(`${this.api}/user/email`, {
+      email,
+    });
   }
 
   refreshSession() {

frontend/src/app/interfaces/User.ts

@@ -2,4 +2,5 @@ export interface User {
   firstName: string;
   lastName: string;
   title: string;
+  email?: string;
 }

frontend/src/app/user-profile/user-profile.component.html

@@ -49,7 +49,7 @@ <h4>Contact Information</h4>
           </div>
         </div>
         <div id="formContent">
-          <form [formGroup]="emailForm" (ngSubmit)="onSubmit(emailForm)" id="emailForm">
+          <form [formGroup]="emailForm" (ngSubmit)="onEmailFormSubmit(emailForm)" id="emailForm">
             <div class="col-md-12">
               <div class="form-group row">
                 <label for="email" class="col-4 col-form-label">Email:</label>

frontend/src/app/user-profile/user-profile.component.ts

@@ -34,6 +34,7 @@ export class UserProfileComponent implements OnInit {
       this.user = user;
       this.rebuildForm();
       this.rebuildSecurityForm();
+      this.rebuildEmailForm();
     });
   }
 
@@ -79,7 +80,9 @@ export class UserProfileComponent implements OnInit {
   }
 
   rebuildEmailForm() {
-    this.emailForm.reset({});
+    this.emailForm.reset({
+      email: this.user.email,
+    });
   }
   onSubmit(form: FormGroup) {
     if (!this.isEdit) {
@@ -124,7 +127,14 @@ export class UserProfileComponent implements OnInit {
       this.isEmailEdit = true;
       this.emailForm.enable();
     } else {
-      // this.authService.updateUserEmail
+      this.authService
+        .updateUserEmail(form.value.email)
+        .subscribe((res: string) => {
+          this.alertService.success(res);
+          this.isEmailEdit = false;
+          this.emailForm.disable();
+          this.emailForm.reset();
+        });
     }
   }
 }

src/app.ts

@@ -52,12 +52,14 @@ app.set('serverIpAddress', serverIpAddress);
 app.listen(serverPort, () => console.info(`Server running on ${serverIpAddress}:${serverPort}`));
 // create typeorm connection
 createConnection().then((_) => {
-  // Check for initial configuration
-  // If none exist, insert it
+  // Check for initial configuration and user
+  // If none exist, insert
   configController.initialInsert();
   // register routes
   app.post('/api/user/register', userController.register);
   app.post('/api/user/invite', jwtMiddleware.checkToken, userController.invite);
+  app.post('/api/user/email', jwtMiddleware.checkToken, userController.updateUserEmail);
+  // app.get('/api/user/email', jwtMiddleware.checkToken);
   app.patch('/api/user', jwtMiddleware.checkToken, userController.patch);
   app.get('/api/user', jwtMiddleware.checkToken, userController.getUser);
   app.get('/api/users', jwtMiddleware.checkToken, userController.getUsers);

src/routes/user.controller.ts

@@ -210,3 +210,40 @@ export const getUsersById = async (userIds: number[]) => {
   }
   return userArray;
 };
+/**
+ * @description Send email update request
+ * @param {UserRequest} req
+ * @param {Response} res
+ * @returns string
+ */
+export const updateUserEmail = async (req: UserRequest, res: Response) => {
+  const email = req.body.email;
+  if (!email) {
+    return res.status(400).json('Email is invalid');
+  }
+  const user = await getConnection().getRepository(User).findOne(req.user);
+  const emails = await getConnection()
+    .getRepository(User)
+    .find({ select: ['email'] });
+  const existingEmails = emails.map((x) => x.email);
+  if (existingEmails.includes(email)) {
+    return res.status(400).json('Email is already taken');
+  }
+  user.uuid = uuidv4();
+  user.newEmail = email;
+  const errors = await validate(user);
+  if (errors.length > 0) {
+    return res.status(400).json('Email is invalid');
+  } else {
+    await getConnection().getRepository(User).save(user);
+    emailService.sendUpdateUserEmail(user, (err, info) => {
+      if (err) {
+        return res
+          .status(400)
+          .json('There was a problem updating your email address.  Please contact an administrator for assistance.');
+      } else {
+        return res.status(200).json(`A confirmation email has been sent to ${user.newEmail}`);
+      }
+    });
+  }
+};

src/services/email.service.ts

@@ -2,6 +2,7 @@ import nodemailer = require('nodemailer');
 import { getConnection } from 'typeorm';
 import { Config } from '../entity/Config';
 import { decrypt } from '../utilities/crypto.utility';
+import { User } from '../entity/User';
 
 /**
  * @description Send email
@@ -104,3 +105,24 @@ export const sendInvitationEmail = (uuid, userEmail) => {
     }
   });
 };
+
+/**
+ * @description Prepare invitation email
+ * @param {string} uuid
+ * @returns string
+ */
+export const sendUpdateUserEmail = (user: User, callback) => {
+  const mailOptions = {
+    from: process.env.FROM_EMAIL,
+    subject: 'Bulwark - Email update request',
+    text: `An email update has been requested for Bulwark.  Please click the link to confirm this update. ${process.env.PROD_URL}/#/register/${user.uuid}`,
+    to: user.newEmail
+  };
+  sendEmail(mailOptions, (err, info) => {
+    if (err) {
+      callback(err);
+    } else {
+      callback(null, info);
+    }
+  });
+};