Merge pull request #419 from bcgov/chore/move-emails-backend

feat: move all email generation to back end

Author: kyle1morel

.github/environments/values.dev.yaml

@@ -4,7 +4,6 @@ config:
   configMap:
     FRONTEND_APIPATH: api/v1
     FRONTEND_CHES_ROADMAP_BCC: NRM.PermittingAndData@gov.bc.ca
-    FRONTEND_CHES_SUBMISSION_CC: NRM.PermittingAndData@gov.bc.ca
     FRONTEND_COMS_APIPATH: https://coms-dev.api.gov.bc.ca/api/v1
     FRONTEND_COMS_BUCKETID: 5aa446ca-23c5-4f3b-9300-d8623bc4d101
     FRONTEND_GEOCODER_APIPATH: https://geocoder.api.gov.bc.ca
@@ -18,6 +17,7 @@ config:
     SERVER_BODYLIMIT: 30mb
     SERVER_CHEFS_APIPATH: https://submit.digital.gov.bc.ca/app/api/v1
     SERVER_CHES_APIPATH: https://ches-dev.api.gov.bc.ca/api/v1
+    SERVER_CHES_SUBMISSION_CC: NRM.PermittingAndData@gov.bc.ca
     SERVER_CHES_TOKENURL: https://dev.loginproxy.gov.bc.ca/auth/realms/comsvcauth/protocol/openid-connect/token
     SERVER_DB_PORT: "5432"
     SERVER_ENV: dev

.github/environments/values.prod.yaml

@@ -4,7 +4,6 @@ config:
   configMap:
     FRONTEND_APIPATH: api/v1
     FRONTEND_CHES_ROADMAP_BCC: Navigator.Service@gov.bc.ca
-    FRONTEND_CHES_SUBMISSION_CC: Navigator.Service@gov.bc.ca
     FRONTEND_COMS_APIPATH: https://coms.api.gov.bc.ca/api/v1
     FRONTEND_COMS_BUCKETID: 0089d041-5aab-485e-842d-8875475d0ed6
     FRONTEND_GEOCODER_APIPATH: https://geocoder.api.gov.bc.ca
@@ -18,6 +17,7 @@ config:
     SERVER_BODYLIMIT: 30mb
     SERVER_CHEFS_APIPATH: https://submit.digital.gov.bc.ca/app/api/v1
     SERVER_CHES_APIPATH: https://ches.api.gov.bc.ca/api/v1
+    SERVER_CHES_SUBMISSION_CC: Navigator.Service@gov.bc.ca
     SERVER_CHES_TOKENURL: https://loginproxy.gov.bc.ca/auth/realms/comsvcauth/protocol/openid-connect/token
     SERVER_DB_PORT: "5432"
     SERVER_ENV: prod

.github/environments/values.test.yaml

@@ -4,7 +4,6 @@ config:
   configMap:
     FRONTEND_APIPATH: api/v1
     FRONTEND_CHES_ROADMAP_BCC: NRM.PermittingAndData@gov.bc.ca
-    FRONTEND_CHES_SUBMISSION_CC: NRM.PermittingAndData@gov.bc.ca
     FRONTEND_COMS_APIPATH: https://coms-test.api.gov.bc.ca/api/v1
     FRONTEND_COMS_BUCKETID: a9eabd1d-5f77-4c60-bf6b-83ffa0e21c59
     FRONTEND_GEOCODER_APIPATH: https://geocoder.api.gov.bc.ca
@@ -18,6 +17,7 @@ config:
     SERVER_BODYLIMIT: 30mb
     SERVER_CHEFS_APIPATH: https://submit.digital.gov.bc.ca/app/api/v1
     SERVER_CHES_APIPATH: https://ches-test.api.gov.bc.ca/api/v1
+    SERVER_CHES_SUBMISSION_CC: NRM.PermittingAndData@gov.bc.ca
     SERVER_CHES_TOKENURL: https://test.loginproxy.gov.bc.ca/auth/realms/comsvcauth/protocol/openid-connect/token
     SERVER_DB_PORT: "5432"
     SERVER_ENV: test
@@ -30,7 +30,7 @@ config:
     SERVER_OIDC_PUBLICKEY: MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAiFdv9GA83uHuy8Eu9yiZHGGF9j6J8t7FkbcpaN81GDjwbjsIJ0OJO9dKRAx6BAtTC4ubJTBJMPvQER5ikOhIeBi4o25fg61jpgsU6oRZHkCXc9gX6mrjMjbsPaf3/bjjYxP5jicBDJQeD1oRa24+tiGggoQ7k6gDEN+cRYqqNpzC/GQbkUPk8YsgroncEgu8ChMh/3ERsLV2zorchMANUq76max16mHrhtWIQxrb/STpSt4JuSlUzzBV/dcXjJe5gywZHe0jAutFhNqjHzHdgyaC4RAd3eYQo+Kl/JOgy2AZrnx+CiPmvOJKe9tAW4k4H087ng8aVE40v4HW/FEbnwIDAQAB
     SERVER_OPENMAPS_APIPATH: https://openmaps.gov.bc.ca
     SERVER_PCNS_APPURL: https://pcns-test-master.apps.silver.devops.gov.bc.ca
-    SERVER_PCNS_NAVEMAIL: Navigator.Service@gov.bc.ca
+    SERVER_PCNS_NAVEMAIL: NRM.PermittingAndData@gov.bc.ca
     SERVER_PEACH_APIPATH: "https://nr-peach-test-main-api.azurewebsites.net/api/v1"
     SERVER_PEACH_TOKENURL: https://test.loginproxy.gov.bc.ca/auth/realms/permittingexchange/protocol/openid-connect/token
     SERVER_PORT: "8080"

app/config/custom-environment-variables.json

@@ -4,9 +4,6 @@
     "ches": {
       "roadmap": {
         "bcc": "FRONTEND_CHES_ROADMAP_BCC"
-      },
-      "submission": {
-        "cc": "FRONTEND_CHES_SUBMISSION_CC"
       }
     },
     "coms": {
@@ -41,6 +38,9 @@
       "apiPath": "SERVER_CHES_APIPATH",
       "clientId": "SERVER_CHES_CLIENTID",
       "clientSecret": "SERVER_CHES_CLIENTSECRET",
+      "submission": {
+        "cc": "SERVER_CHES_SUBMISSION_CC"
+      },
       "tokenUrl": "SERVER_CHES_TOKENURL"
     },
     "chefs": {

app/package.json

@@ -3,7 +3,7 @@
   "version": "0.9.0",
   "license": "Apache-2.0",
   "private": true,
-  "description": "Permit Connect Services",
+  "description": "Permit Connect Navigator Service",
   "author": "NRM Permitting and Data Solutions <NRM.PermittingAndData@gov.bc.ca>",
   "main": "server.ts",
   "scripts": {

app/peachSync.ts

@@ -30,7 +30,9 @@ async function syncPeachToPcns() {
   if (updatedPermits.length === 0) return;
 
   try {
-    await sendPermitUpdateNotifications(updatedPermits);
+    for (const permit of updatedPermits) {
+      await sendPermitUpdateNotifications(permit, true);
+    }
   } catch (error) {
     log.warn('PEACH sync completed but sending notifications failed', error);
   }

app/src/controllers/activityContact.ts

@@ -43,7 +43,9 @@ const getTeamMemberEmailTemplateData = async (
     const templateParams = {
       dearName: `${contact.firstName} ${contact.lastName}`,
       adminName: adminContact?.length ? `${adminContact[0].firstName} ${adminContact[0].lastName}` : undefined,
-      projectName
+      projectName,
+      initiative: project.activity?.initiative?.code.toLowerCase(),
+      projectId: project.projectId
     };
 
     const navEmail: string = config.get('server.pcns.navEmail');

app/src/controllers/electrificationProject.ts

@@ -1,3 +1,4 @@
+import config from 'config';
 import { v4 as uuidv4 } from 'uuid';
 
 import { transactionWrapper } from '../db/utils/transactionWrapper.ts';
@@ -24,7 +25,8 @@ import {
 } from '../services/electrificationProject.ts';
 import { Initiative } from '../utils/enums/application.ts';
 import { ActivityContactRole, ApplicationStatus, DraftCode, SubmissionType } from '../utils/enums/projectCommon.ts';
-import { isTruthy } from '../utils/utils.ts';
+import { confirmationTemplateElectrificationSubmission } from '../utils/templates';
+import { isTruthy, toTitleCase } from '../utils/utils.ts';
 
 import type { Request, Response } from 'express';
 import type { PrismaTransactionClient } from '../db/dataConnection.ts';
@@ -61,11 +63,11 @@ const generateElectrificationProjectData = async (
     const contacts = await searchContacts(tx, { userId: [currentContext.userId!] });
     if (contacts[0]) await createActivityContact(tx, activityId, contacts[0].contactId, ActivityContactRole.PRIMARY);
   }
-
+  const UUID = uuidv4();
   // Put new electrification project together
   const electrificationProjectData: ElectrificationProject = {
     ...data.project,
-    electrificationProjectId: uuidv4(),
+    electrificationProjectId: UUID,
     activityId: activityId,
     submittedAt: new Date(),
     submissionType: SubmissionType.GUIDANCE,
@@ -239,10 +241,36 @@ export const submitElectrificationProjectDraftController = async (
       return { ...data, contact: contactResponse[0] };
     }
   );
-
+  await emailProjectConfirmation(result);
   res.status(201).json({ ...result, contact: result.contact });
 };
 
+async function emailProjectConfirmation(projectWithContact: ElectrificationProject & { contact: Contact }) {
+  const configCC = config.get<string>('server.ches.submission.cc');
+  const subject = 'Confirmation of Project Submission';
+
+  const body = confirmationTemplateElectrificationSubmission({
+    contactName:
+      projectWithContact.contact?.firstName && projectWithContact.contact?.lastName
+        ? `${projectWithContact.contact?.firstName} ${projectWithContact.contact?.lastName}`
+        : '',
+    initiative: toTitleCase(Initiative.ELECTRIFICATION),
+    activityId: projectWithContact.activityId,
+    projectId: projectWithContact.electrificationProjectId
+  });
+
+  const emailData = {
+    from: configCC,
+    to: [projectWithContact.contact.email!],
+    cc: [configCC],
+    subject: subject,
+    bodyType: 'html',
+    body: body
+  };
+
+  await email(emailData);
+}
+
 export const upsertElectrificationProjectDraftController = async (req: Request<never, never, Draft>, res: Response) => {
   const update = req.body.draftId && req.body.activityId;
 

app/src/controllers/enquiry.ts

@@ -1,3 +1,4 @@
+import config from 'config';
 import { v4 as uuidv4 } from 'uuid';
 
 import { transactionWrapper } from '../db/utils/transactionWrapper.ts';
@@ -10,6 +11,7 @@ import {
 import { createActivity, deleteActivity } from '../services/activity.ts';
 import { createActivityContact, listActivityContacts } from '../services/activityContact.ts';
 import { searchContacts, upsertContacts } from '../services/contact.ts';
+import { email } from '../services/email.ts';
 import {
   createEnquiry,
   deleteEnquiry,
@@ -19,12 +21,14 @@ import {
   searchEnquiries,
   updateEnquiry
 } from '../services/enquiry.ts';
+import { getProjectByActivityId } from '../services/project.ts';
 import {
   ActivityContactRole,
   ApplicationStatus,
   EnquirySubmittedMethod,
   SubmissionType
 } from '../utils/enums/projectCommon.ts';
+import { confirmationTemplateEnquiry } from '../utils/templates';
 import { getCurrentUsername, isTruthy } from '../utils/utils.ts';
 
 import type { Request, Response } from 'express';
@@ -110,9 +114,69 @@ export const createEnquiryController = async (req: Request<never, never, Enquiry
     return { ...data, contact: contactResponse[0] };
   });
 
+  await emailEnquiryConfirmation(result, req.currentContext.initiative!, req.body.basic?.relatedActivityId);
   res.status(201).json(result);
 };
 
+async function emailEnquiryConfirmation(
+  enquiryWithContact: Enquiry & { contact: Contact },
+  initiative: string,
+  relatedActivityId?: string
+) {
+  await transactionWrapper<void>(async (tx: PrismaTransactionClient) => {
+    const configCC = config.get<string>('server.ches.submission.cc');
+
+    let permitDescription = '';
+    let enquiryDescription: string = enquiryWithContact.enquiryDescription || '';
+    let firstTwoSentences: string;
+
+    // If has permit description convert \n to <br>
+    if (enquiryDescription.includes('Tracking ID:')) {
+      const descriptionSplit = enquiryDescription.split('\n\n');
+      permitDescription = descriptionSplit[0]?.replace(/\n/g, '<br>') + '<br><br>';
+      enquiryDescription = descriptionSplit.slice(1, descriptionSplit.length).join(' ');
+    }
+
+    // Get the first two sentences of the enquiry description using proper sentence segmentation
+    // If there are more than two sentences in enquiryDescription, add '..' to the end
+    const segmenter = new Intl.Segmenter('en', { granularity: 'sentence' });
+    const segments = Array.from(segmenter.segment(enquiryDescription));
+    const sentences = segments.map((s) => s.segment.trim()).filter((sentence: string) => sentence.length > 0);
+
+    firstTwoSentences = sentences.slice(0, 2).join(' ');
+    if (sentences.length > 2) {
+      firstTwoSentences = firstTwoSentences.concat('..');
+    }
+
+    if (permitDescription) firstTwoSentences = permitDescription + firstTwoSentences;
+
+    const projectId = relatedActivityId ? (await getProjectByActivityId(tx, relatedActivityId))?.projectId : undefined;
+
+    const body = confirmationTemplateEnquiry({
+      contactName:
+        enquiryWithContact.contact?.firstName && enquiryWithContact.contact?.lastName
+          ? `${enquiryWithContact.contact?.firstName} ${enquiryWithContact.contact?.lastName}`
+          : '',
+      activityId: enquiryWithContact.activityId,
+      enquiryDescription: firstTwoSentences.trim(),
+      enquiryId: enquiryWithContact.enquiryId,
+      projectId: projectId,
+      initiative: initiative.toLowerCase()
+    });
+
+    const emailData = {
+      from: configCC,
+      to: [enquiryWithContact.contact.email!],
+      cc: [configCC],
+      subject: 'Confirmation of Enquiry Submission',
+      bodyType: 'html',
+      body: body
+    };
+
+    await email(emailData);
+  });
+}
+
 export const deleteEnquiryController = async (req: Request<{ enquiryId: string }>, res: Response) => {
   await transactionWrapper<void>(async (tx: PrismaTransactionClient) => {
     const enquiry = await getEnquiry(tx, req.params.enquiryId);

app/src/controllers/housingProject.ts

@@ -1,3 +1,4 @@
+import config from 'config';
 import { v4 as uuidv4 } from 'uuid';
 
 import { transactionWrapper } from '../db/utils/transactionWrapper.ts';
@@ -29,7 +30,8 @@ import { BasicResponse, Initiative } from '../utils/enums/application.ts';
 import { NumResidentialUnits } from '../utils/enums/housing.ts';
 import { PermitNeeded, PermitStage, PermitState } from '../utils/enums/permit.ts';
 import { ActivityContactRole, ApplicationStatus, DraftCode, SubmissionType } from '../utils/enums/projectCommon.ts';
-import { getCurrentUsername, isTruthy, omit } from '../utils/utils.ts';
+import { confirmationTemplateHousingSubmission } from '../utils/templates';
+import { getCurrentUsername, isTruthy, omit, toTitleCase } from '../utils/utils.ts';
 
 import type { Request, Response } from 'express';
 import type { PrismaTransactionClient } from '../db/dataConnection.ts';
@@ -420,10 +422,35 @@ export const submitHousingProjectDraftController = async (
       return { ...data, contact: contactResponse[0] };
     }
   );
-
+  await emailProjectConfirmation(result);
   res.status(201).json({ ...result, contact: result.contact });
 };
 
+async function emailProjectConfirmation(projectWithContact: HousingProject & { contact: Contact }) {
+  const configCC = config.get<string>('server.ches.submission.cc');
+
+  const body = confirmationTemplateHousingSubmission({
+    contactName:
+      projectWithContact.contact?.firstName && projectWithContact.contact?.lastName
+        ? `${projectWithContact.contact?.firstName} ${projectWithContact.contact?.lastName}`
+        : '',
+    initiative: toTitleCase(Initiative.HOUSING),
+    activityId: projectWithContact.activityId,
+    projectId: projectWithContact.housingProjectId
+  });
+
+  const emailData = {
+    from: configCC,
+    to: [projectWithContact.contact.email!],
+    cc: [configCC],
+    subject: 'Confirmation of Project Submission',
+    bodyType: 'html',
+    body: body
+  };
+
+  await email(emailData);
+}
+
 export const upsertHousingProjectDraftController = async (req: Request<never, never, Draft>, res: Response) => {
   const update = req.body.draftId && req.body.activityId;