Setup email jobs.

Author: Mohamed-Ramadan1

src/controllers/checkout/checkoutController.ts

@@ -24,6 +24,8 @@ import { ICartItem } from "../../models/cartItem/cartItem.interface";
 import Stripe from "stripe";
 // modules imports
 
+
+
 // checkout with cash
 export const checkoutWithCash = catchAsync(
   async (req: CheckoutRequest, res: Response, next: NextFunction) => {

src/jobs/queueJobs/emailsQueue.ts

@@ -0,0 +1,22 @@
+import Bull from "bull";
+
+export const emailQueue = new Bull("email-queue", {
+  redis: {
+    host: "localhost",
+    port: 6379,
+  },
+});
+
+// emailQueue.process(async (job) => {
+//   // send email logic here
+//   console.log("Sending email to: ", job);
+// });
+
+emailQueue.process(async (job) => {
+  return console.log("kill all them", job);
+});
+
+// Define a local completed event
+emailQueue.on("completed", (job, result) => {
+  console.log(`Job completed with result ${result}`);
+});