Sending email functionality

backend/package.json

@@ -10,7 +10,8 @@
     "http-errors": "^2.0.0",
     "module-alias": "^2.2.3",
     "mongodb": "^5.7.0",
-    "mongoose": "^7.4.0"
+    "mongoose": "^7.4.0",
+    "nodemailer": "^6.9.13"
   },
   "name": "backend",
   "version": "1.0.0",
@@ -32,6 +33,7 @@
     "@types/cors": "^2.8.13",
     "@types/express": "^4.17.17",
     "@types/http-errors": "^2.0.1",
+    "@types/nodemailer": "^6.4.15",
     "@typescript-eslint/eslint-plugin": "latest",
     "@typescript-eslint/parser": "latest",
     "bun-types": "latest",

backend/src/services/email.ts

@@ -0,0 +1,26 @@
+import "dotenv/config";
+
+import { createTransport } from "nodemailer";
+
+export async function sendEmail(recipient: string, subjectString: string, body: string) {
+  const transporter = createTransport({
+    port: 465, // true for 465, false for other ports
+    host: "smtp.gmail.com",
+    auth: {
+      user: process.env.GMAILUSER,
+      pass: process.env.GMAILPASS,
+    },
+    secure: true,
+  });
+
+  const mailData = {
+    from: process.env.GMAILUSER, // sender address
+    to: recipient, // list of receivers
+    subject: subjectString,
+    text: body,
+  };
+
+  const response = await transporter.sendMail(mailData);
+
+  return response;
+}

backend/src/services/referral.ts

@@ -1,5 +1,8 @@
 import { ObjectId } from "mongoose";
 
+import { sendEmail } from "./email";
+import { getUserByID } from "./user";
+
 import { ReferralModel } from "@/models/referral";
 
 export async function getUnitReferrals(id: string) {
@@ -27,17 +30,57 @@ export async function createReferral(
   return referral;
 }
 
+const INACTIVE_REFERRAL_STATUSES = ["Leased", "Denied", "Canceled"];
+
 export async function editReferral(
   id: string,
   assignedHousingLocatorId: string,
   assignedReferringStaffId: string,
   status: string,
 ) {
+  const Ref = await ReferralModel.findById(id);
+  const updateHL = Ref?.assignedHousingLocator?.toString() !== assignedHousingLocatorId;
+  const setLeased =
+    status === "Leased" &&
+    Ref?.status !== "Leased" &&
+    Ref?.status !== "Denied" &&
+    Ref?.status !== "Canceled";
   await ReferralModel.findByIdAndUpdate(id, {
     assignedHousingLocator: assignedHousingLocatorId,
     assignedReferringStaff: assignedReferringStaffId,
     status,
   });
   const referral = await ReferralModel.findById(id);
+  const HL = await getUserByID(referral?.assignedHousingLocator?.toString() ?? "");
+
+  if (updateHL) {
+    if (HL !== null) {
+      await sendEmail(
+        HL.email,
+        "Referral Update",
+        `You have been assigned a new referral. Please login to the portal to view the update.`,
+      );
+    }
+  }
+  if (setLeased) {
+    const refs = await getUnitReferrals(referral?.unitId.toString() ?? "");
+    const userPromises = [];
+    const emailPromises = [];
+    for (const ref of refs) {
+      if (!INACTIVE_REFERRAL_STATUSES.includes(ref.status)) {
+        userPromises.push(getUserByID(ref.assignedHousingLocator?.toString() ?? ""));
+      }
+    }
+    const users = await Promise.all(userPromises);
+    for (const user of users) {
+      if (user?.email) {
+        emailPromises.push(
+          sendEmail(user.email, "Referral Update", "One of your referrals has been leased."),
+        );
+      }
+    }
+    await Promise.all(emailPromises);
+  }
+
   return referral;
 }

backend/src/services/user.ts

@@ -4,6 +4,8 @@
 
 import { UserModel } from "../models/user";
 
+import { sendEmail } from "./email";
+
 // Fetch users from the database
 export async function getUsers() {
   const users = await UserModel.find({});
@@ -46,5 +48,25 @@ export async function getUserByID(id: string) {
 }
 
 export async function elevateUser(id: string) {
+  const RS = await getUserByID(id);
+  if (RS !== null) {
+    await sendEmail(
+      RS.email,
+      "Elevation to Housing Locator",
+      "You have been elevated to a Housing Locator",
+    );
+  }
   return await UserModel.findByIdAndUpdate(id, { isHousingLocator: true });
 }
+
+export async function demoteUser(id: string) {
+  const RS = await getUserByID(id);
+  if (RS !== null) {
+    await sendEmail(
+      RS.email,
+      "Housing Locator Demotion",
+      "You have been demoted from a Housing Locator",
+    );
+  }
+  return await UserModel.findByIdAndUpdate(id, { isHousingLocator: false });
+}