✨ Send emails

Author: AnandChowdhary

package.json

@@ -16,7 +16,9 @@
     "@types/bcrypt": "^3.0.0",
     "@types/dotenv": "^6.1.1",
     "@types/express": "^4.16.1",
+    "@types/fs-extra": "^5.0.5",
     "@types/jest": "^24.0.11",
+    "@types/marked": "^0.6.5",
     "@types/mysql": "^2.15.5",
     "@types/node": "^11.13.6",
     "concurrently": "^4.1.0",
@@ -31,8 +33,13 @@
     "typescript": "^3.4.4"
   },
   "dependencies": {
+    "@types/mustache": "^0.8.32",
     "bcrypt": "^3.0.6",
+    "fs-extra": "^7.0.1",
+    "marked": "^0.6.2",
+    "mustache": "^3.0.1",
     "mysql": "^2.17.1",
+    "node-ses": "^2.2.0",
     "reflect-metadata": "^0.1.13"
   }
 }

src/config.ts

@@ -2,7 +2,7 @@ import { config } from "dotenv";
 config();
 
 // Server
-export const PORT = process.env.PORT || 7008;
+export const PORT = process.env.PORT || 7007;
 
 // Database
 export const DB_HOST = process.env.DB_HOST || "localhost";
@@ -12,3 +12,8 @@ export const DB_PORT = process.env.DB_PORT
 export const DB_USERNAME = process.env.DB_USERNAME || "root";
 export const DB_PASSWORD = process.env.DB_PASSWORD || "";
 export const DB_DATABASE = process.env.DB_DATABASE || "database";
+
+// Email
+export const SES_EMAIL = process.env.SES_EMAIL || "";
+export const SES_ACCESS = process.env.SES_ACCESS || "";
+export const SES_SECRET = process.env.SES_SECRET || "";

src/crud/email.ts

@@ -1,7 +1,7 @@
 import { query, tableValues } from "../helpers/mysql";
 import { Email } from "../interfaces/tables/emails";
 
-export const createEmail = async (email: Email) => {
+export const createEmail = async (email: Email, sendVerification = true) => {
   // Clean up values
   email.email = email.email.toLowerCase();
   email.isVerified = false;

src/crud/user.ts

@@ -31,7 +31,7 @@ interface KV {
   [index: string]: any;
 }
 export const updateUser = async (id: number, user: KV) => {
-  user.updatedAt = user.createdAt;
+  user.updatedAt = new Date();
   // Create user
   return await query(`UPDATE users SET ${setValues(user)} WHERE id = ?`, [
     ...Object.values(user),

src/helpers/mail.ts

@@ -0,0 +1,39 @@
+import * as ses from "node-ses";
+import { Mail } from "../interfaces/mail";
+import { SES_SECRET, SES_ACCESS, SES_EMAIL } from "../config";
+import { readFile } from "fs-extra";
+import { join } from "path";
+import { render } from "mustache";
+import marked from "marked";
+import i18n from "../i18n";
+
+const client = ses.createClient({ key: SES_ACCESS, secret: SES_SECRET });
+
+export const sendMail = (mail: Mail) =>
+  new Promise((resolve, reject) => {
+    client.sendEmail(mail, (error: Error, data: any, response: any) => {
+      if (error) return reject(error);
+      resolve(response);
+    });
+  });
+
+export const mail = async (
+  to: number | string,
+  template: string,
+  data: any = {}
+) => {
+  const altText = render(
+    (await readFile(
+      join(__dirname, "..", "..", "src", "templates", `${template}.md`)
+    )).toString(),
+    data
+  );
+  const message = marked(altText);
+  return await sendMail({
+    from: SES_EMAIL,
+    to: to.toString(),
+    subject: i18n.en.emails["verify-email"],
+    message,
+    altText
+  });
+};

src/i18n.ts

@@ -0,0 +1,7 @@
+export default {
+  en: {
+    emails: {
+      "verify-email": "Verify your new email"
+    }
+  }
+};

src/index.ts

@@ -9,7 +9,7 @@ app.get("/create-account", async (req, res) => {
   try {
     const users = await register(
       { name: "Anand Chowdhary" },
-      "anandchowdhary@gmail.com"
+      "anand@oswaldlabs.com"
     );
     res.json({ success: true, users });
   } catch (error) {

src/interfaces/mail.ts

@@ -0,0 +1,10 @@
+export interface Mail {
+  from?: string;
+  to: string | string[];
+  cc?: string | string[];
+  bcc?: string | string[];
+  subject: string;
+  message: string;
+  altText?: string;
+  replyTo?: string;
+}

src/rest/auth.ts

@@ -2,6 +2,7 @@ import { User } from "../interfaces/tables/user";
 import { createUser, updateUser } from "../crud/user";
 import { InsertResult } from "../interfaces/mysql";
 import { createEmail } from "../crud/email";
+import { mail } from "../helpers/mail";
 
 export const register = async (
   user: User,
@@ -20,5 +21,7 @@ export const register = async (
     });
     const emailId = newEmail.insertId;
     await updateUser(userId, { primaryEmail: emailId });
+    await mail(email, "verify-email", { name: user.name, email });
   }
+  return { created: true };
 };

src/templates/verify-email.md

@@ -0,0 +1,8 @@
+# Verify your email
+
+Dear {{name}},
+
+Click here to verify your email address: https://example.com?email={{email}}.
+
+If you didn't request this email, you can safely ignore it.
+