docs: Update email sending functionality and dependencies with BullMQ

.vscode/settings.json

@@ -1,3 +1,3 @@
 {
-	"cSpell.words": ["healthz", "knexfile", "tseslint", "wajeht"]
+	"cSpell.words": ["bullmq", "healthz", "knexfile", "tseslint", "wajeht"]
 }

package.json

@@ -37,6 +37,7 @@
 	},
 	"dependencies": {
 		"bcrypt": "^5.1.1",
+		"bullmq": "^5.12.1",
 		"compression": "^1.7.4",
 		"cors": "^2.8.5",
 		"dotenv": "^16.4.5",

src/jobs/email.job.ts

@@ -0,0 +1,30 @@
+import { Queue, Worker } from 'bullmq';
+import { redis } from '../database/db';
+import { sendEmail } from './utils/email';
+
+const queueName = 'sendEmailQueue';
+
+export const sendEmailQueue = new Queue(queueName, {
+	connection: redis,
+});
+
+const processSendEmailJob = async (job: any) => {
+	try {
+		job.updateProgress(0);
+		await sendEmail({ tenant: job.data.tenant, coach: job.data.coach });
+		job.updateProgress(100);
+		console.info(`Email successfully sent for tenant: ${job.data.tenant}`);
+	} catch (error) {
+		console.error(`Failed to send email for tenant: ${job.data.tenant}`, error);
+	}
+};
+
+new Worker(queueName, processSendEmailJob, { connection: redis });
+
+export async function sendApproveTenantEmailJob(data: any) {
+	try {
+		await sendEmailQueue.add('sendEmailJob', data);
+	} catch (error) {
+		console.error(`Failed to add job to queue for tenant: ${data.tenant}`, error);
+	}
+}

src/notification/email.ts → src/jobs/utils/email.ts

@@ -1,6 +1,6 @@
 import nodemailer from 'nodemailer';
 
-import { emailConfig, appConfig } from '../config';
+import { emailConfig, appConfig } from '../../config';
 
 const transporter = nodemailer.createTransport(emailConfig);
 
@@ -15,7 +15,7 @@ interface SendMailOptions {
 
 const template = `<h1>hello world</h1>`;
 
-export async function send({
+export async function sendEmail({
 	to = `${domain} <${emailConfig.alias}>`,
 	subject,
 	html: template,

src/notification/sms.ts → src/jobs/utils/sms.ts

@@ -1,5 +1,5 @@
 import twilio from 'twilio';
-import { smsConfig } from '../config';
+import { smsConfig } from '../../config';
 
 const client = twilio(smsConfig.accountSid, smsConfig.authToken);