✨ Delete emails

Author: AnandChowdhary

package.json

@@ -8,6 +8,7 @@
   "scripts": {
     "build": "touch .env && mkdir -p dist && cp .env dist/.env && tsc",
     "start": "concurrently 'yarn watch-build' 'yarn watch-prettier' 'yarn watch-server'",
+    "prettier-all": "prettier '{src,examples}/**/*.{ts,json}' --write",
     "watch-build": "onchange '{src,examples}/**/*.ts' -- yarn build",
     "watch-prettier": "onchange '{src,examples}/**/*.{ts,json}' -- prettier --write {{changed}}",
     "watch-server": "cd dist && nodemon index.js"

src/crud/email.ts

@@ -15,12 +15,18 @@ export const createEmail = async (email: Email, sendVerification = true) => {
   email.isVerified = false;
   email.createdAt = new Date();
   email.updatedAt = email.createdAt;
-  const result = <InsertResult> await query(
-    `INSERT INTO emails ${tableValues(email)}`,
-    Object.values(email)
+  const result = <InsertResult>(
+    await query(
+      `INSERT INTO emails ${tableValues(email)}`,
+      Object.values(email)
+    )
   );
   if (sendVerification) {
-    await sendEmailVerification(result.insertId, email.email, await getUser(email.userId));
+    await sendEmailVerification(
+      result.insertId,
+      email.email,
+      await getUser(email.userId)
+    );
   }
   return result;
 };

src/rest/auth.ts

@@ -11,7 +11,12 @@ import { mail } from "../helpers/mail";
 import { verifyToken, loginToken, passwordResetToken } from "../helpers/jwt";
 import { KeyValue, Locals } from "../interfaces/general";
 import { createEvent } from "../crud/event";
-import { EventType, ErrorCode, MembershipRole, Templates } from "../interfaces/enum";
+import {
+  EventType,
+  ErrorCode,
+  MembershipRole,
+  Templates
+} from "../interfaces/enum";
 import { compare, hash } from "bcrypt";
 import { deleteSensitiveInfoUser } from "../helpers/utils";
 import { createMembership } from "../crud/membership";

src/rest/user.ts

@@ -9,7 +9,7 @@ import {
   getUserOrganizationId,
   getUserMembershipObject
 } from "../crud/membership";
-import { createEmail } from "../crud/email";
+import { createEmail, deleteEmail, getEmail } from "../crud/email";
 import { Locals } from "../interfaces/general";
 import { createEvent } from "../crud/event";
 
@@ -40,6 +40,25 @@ export const addEmailToUser = async (
 ) => {
   // Add email validation
   await createEmail({ email, userId });
-  await createEvent({ type: EventType.EMAIL_CREATED, data: { email } }, locals);
+  await createEvent(
+    { userId, type: EventType.EMAIL_CREATED, data: { email } },
+    locals
+  );
+  return;
+};
+
+export const deleteEmailFromUser = async (
+  emailId: number,
+  userId: number,
+  locals: Locals
+) => {
+  const email = await getEmail(emailId);
+  if (email.userId != userId)
+    throw new Error(ErrorCode.INSUFFICIENT_PERMISSION);
+  await deleteEmail(emailId);
+  await createEvent(
+    { userId, type: EventType.EMAIL_DELETED, data: { email: email.email } },
+    locals
+  );
   return;
 };

src/routes/emails.ts

@@ -1,7 +1,7 @@
 import { Request, Response } from "express";
 import { verifyEmail } from "../rest/auth";
 import { ErrorCode } from "../interfaces/enum";
-import { addEmailToUser } from "../rest/user";
+import { addEmailToUser, deleteEmailFromUser } from "../rest/user";
 
 export const routeEmailAdd = async (req: Request, res: Response) => {
   const email = req.body.email;
@@ -10,6 +10,13 @@ export const routeEmailAdd = async (req: Request, res: Response) => {
   res.json({ success: true });
 };
 
+export const routeEmailDelete = async (req: Request, res: Response) => {
+  const emailId = req.params.id;
+  if (!emailId) throw new Error(ErrorCode.MISSING_FIELD);
+  await deleteEmailFromUser(emailId, res.locals.token.id, res.locals);
+  res.json({ success: true });
+};
+
 export const routeEmailVerify = async (req: Request, res: Response) => {
   await verifyEmail(req.body.token || req.params.token, res.locals);
   res.json({ success: true });

src/routes/index.ts

@@ -1,7 +1,7 @@
 import { Application } from "express";
 import asyncHandler from "express-async-handler";
 import { routeUserMe, routeUserPut, routeUserId } from "./users";
-import { routeEmailVerify, routeEmailAdd } from "./emails";
+import { routeEmailVerify, routeEmailAdd, routeEmailDelete } from "./emails";
 import { routeOrganizationCreate } from "./organizations";
 import { authHandler } from "../helpers/middleware";
 import {
@@ -43,6 +43,7 @@ const routesUser = (app: Application) => {
 
 const routesEmail = (app: Application) => {
   app.put("/emails", authHandler, asyncHandler(routeEmailAdd));
+  app.delete("/emails/:id", authHandler, asyncHandler(routeEmailDelete));
   app.post("/emails/verify", asyncHandler(routeEmailVerify));
 };