prettier

__test__/controllers/jobs/createJob.controller.test.ts

@@ -4,7 +4,7 @@ import { type Queue } from "bullmq";
 import { queueByName } from "../../../src/queues";
 import createJob from "../../../src/controllers/jobs/createJob.controller";
 
-console.error = jest.fn()
+console.error = jest.fn();
 
 // Mock the queueByName function
 jest.mock("../../../src/queues", () => ({

__test__/controllers/jobs/getJob.controller.test.ts

@@ -22,7 +22,7 @@ describe("getJob", () => {
 
   beforeEach(() => {
     req = {
-      params: {}
+      params: {},
     } as Request;
     res = {
       json: jest.fn(),
@@ -105,6 +105,8 @@ describe("getJob", () => {
     await getJob(req, res);
 
     expect(res.status).toHaveBeenCalledWith(500);
-    expect(res.json).toHaveBeenCalledWith({ error: "Failed to get job status" });
+    expect(res.json).toHaveBeenCalledWith({
+      error: "Failed to get job status",
+    });
   });
 });

__test__/index.test.ts

@@ -10,7 +10,7 @@ console.log = jest.fn();
 // Mock mongoose.connect and app.listen
 jest.mock("mongoose", () => ({
   set: jest.fn(),
-  connect: jest.fn()
+  connect: jest.fn(),
 }));
 jest.mock("../src/app", () => ({
   listen: jest.fn(),
@@ -29,7 +29,7 @@ describe("main", () => {
   });
 
   it("should connect to MongoDB and start the server", async () => {
-    await expect(require("../src/index").main()).resolves.not.toThrow()
+    await expect(require("../src/index").main()).resolves.not.toThrow();
 
     expect(mongoose.set).toHaveBeenCalledWith("strictQuery", true);
     expect(mongoose.connect).toHaveBeenCalledWith("mocked-mongodb-url");
@@ -38,8 +38,8 @@ describe("main", () => {
   });
 
   it("should handle errors and log them", async () => {
-    const error = new Error("Connection failed")
-    mongoose.connect = jest.fn().mockRejectedValueOnce(error)
+    const error = new Error("Connection failed");
+    mongoose.connect = jest.fn().mockRejectedValueOnce(error);
     await expect(require("../src/index").main()).rejects.toThrow(error);
 
     expect(mongoose.connect).toHaveBeenCalledWith("mocked-mongodb-url");

__test__/jobs/email.job.test.ts

@@ -1,39 +1,40 @@
-import { type Job } from 'bullmq';
-import emailJob from '../../src/jobs/email.job';
+import { type Job } from "bullmq";
+import emailJob from "../../src/jobs/email.job";
 
-describe('emailJob', () => {
+describe("emailJob", () => {
   let consoleLogSpy: jest.SpyInstance;
   let consoleErrorSpy: jest.SpyInstance;
 
   beforeEach(() => {
-    consoleLogSpy = jest.spyOn(console, 'log');
-    consoleErrorSpy = jest.spyOn(console, 'error');
+    consoleLogSpy = jest.spyOn(console, "log");
+    consoleErrorSpy = jest.spyOn(console, "error");
   });
 
   afterEach(() => {
     consoleLogSpy.mockRestore();
     consoleErrorSpy.mockRestore();
   });
 
-  it('should process email job successfully', async () => {
+  it("should process email job successfully", async () => {
     const jobData = {
-      to: '[email protected]',
-      subject: 'Test Subject',
-      body: 'Test Body',
+      to: "[email protected]",
+      subject: "Test Subject",
+      body: "Test Body",
     };
 
     const job: Partial<Job> = {
-      id: 'jobId',
+      id: "jobId",
       data: jobData,
-      name: 'emailJob',
+      name: "emailJob",
     };
 
     await emailJob(job as Job);
 
-    expect(consoleLogSpy).toHaveBeenCalledWith(`Sending email to ${jobData.to}: ${jobData.subject}`);
-    expect(consoleLogSpy).toHaveBeenCalledWith('Body:', jobData.body);
-    expect(consoleLogSpy).toHaveBeenCalledWith('Email sent successfully');
+    expect(consoleLogSpy).toHaveBeenCalledWith(
+      `Sending email to ${jobData.to}: ${jobData.subject}`
+    );
+    expect(consoleLogSpy).toHaveBeenCalledWith("Body:", jobData.body);
+    expect(consoleLogSpy).toHaveBeenCalledWith("Email sent successfully");
     expect(consoleErrorSpy).not.toHaveBeenCalled();
   });
-
 });

__test__/jobs/imageProcessing.job.test.ts

@@ -1,13 +1,13 @@
-import { type Job } from 'bullmq';
-import imageProcessingJob from '../../src/jobs/imageProcessing.job';
+import { type Job } from "bullmq";
+import imageProcessingJob from "../../src/jobs/imageProcessing.job";
 
-describe('imageProcessingJob', () => {
-  it('should process the image successfully', async () => {
-    const imageUrl = 'https://example.com/image.jpg';
+describe("imageProcessingJob", () => {
+  it("should process the image successfully", async () => {
+    const imageUrl = "https://example.com/image.jpg";
     const jobData = { imageUrl };
     const job: Partial<Job> = {
-      id: 'job-id',
-      name: 'image-processing',
+      id: "job-id",
+      name: "image-processing",
       data: jobData,
       // Mock other attributes as needed
     };

__test__/workers/email.worker.test.ts

@@ -1,28 +1,28 @@
-import { Worker } from 'bullmq'
-import { emailQueue } from '../../src/queues';
-import connection from '../../src/queues/connection';
+import { Worker } from "bullmq";
+import { emailQueue } from "../../src/queues";
+import connection from "../../src/queues/connection";
 
-jest.mock('bullmq', () => ({
+jest.mock("bullmq", () => ({
   ...jest.requireActual("bullmq"),
-  Worker: jest.fn().mockImplementation((queueName, processingFunction, options) => {
-    const workerMock = {
-      on: jest.fn(),
-    };
-    return workerMock;
-  }),
+  Worker: jest
+    .fn()
+    .mockImplementation((queueName, processingFunction, options) => {
+      const workerMock = {
+        on: jest.fn(),
+      };
+      return workerMock;
+    }),
 }));
 
-describe('email.worker', () => {
+describe("email.worker", () => {
   afterEach(() => {
     jest.clearAllMocks();
   });
 
-  it('should create a new BullMQ worker for emailQueue', async () => {
-    require('../../src/workers/email.worker')
-    expect(Worker).toHaveBeenCalledWith(
-      emailQueue.name,
-      expect.any(Function),
-      { connection }
-    );
+  it("should create a new BullMQ worker for emailQueue", async () => {
+    require("../../src/workers/email.worker");
+    expect(Worker).toHaveBeenCalledWith(emailQueue.name, expect.any(Function), {
+      connection,
+    });
   });
 });

src/app.ts

@@ -2,8 +2,8 @@ import express, { type Express, type Request, type Response } from "express";
 import routes from "./routes";
 
 const app: Express = express();
-app.use(express.json())
-app.use(routes)
+app.use(express.json());
+app.use(routes);
 
 app.get("/", (req: Request, res: Response) => {
   res.send("Express + TypeScript Server");

src/controllers/jobs/createJob.controller.ts

@@ -7,21 +7,21 @@ const createJob = async function (req: Request, res: Response) {
   try {
     const { type, data } = req.body; // Assuming you send the job type and data in the request body
 
-    let queue: Queue
+    let queue: Queue;
     try {
-      queue = queueByName(type)
+      queue = queueByName(type);
     } catch (error) {
-      console.error(error)
+      console.error(error);
       return res.status(400).json({ error });
     }
 
     const job = await queue.add(type, data); // Add the job to the appropriate queue
 
     return res.json({ jobId: job.id });
   } catch (error) {
-    console.error('Error creating job:', error);
-    return res.status(500).json({ error: 'Failed to create job' });
+    console.error("Error creating job:", error);
+    return res.status(500).json({ error: "Failed to create job" });
   }
-}
+};
 
-export default createJob
+export default createJob;

src/controllers/jobs/getJob.controller.ts

@@ -7,19 +7,19 @@ const getJob = async function (req: Request, res: Response) {
   try {
     const { type, jobId } = req.params; // Assuming the jobId is passed as a route parameter
 
-    let queue: Queue
+    let queue: Queue;
     try {
-      queue = queueByName(type)
+      queue = queueByName(type);
     } catch (error) {
-      console.error('Error getting job queue:', error)
+      console.error("Error getting job queue:", error);
       return res.status(400).json({ error });
     }
 
     // Fetch the job by its id
     const job = await Job.fromId(queue, jobId);
 
     if (job == null) {
-      return res.status(404).json({ error: 'Job not found' });
+      return res.status(404).json({ error: "Job not found" });
     }
 
     return res.json({
@@ -30,9 +30,9 @@ const getJob = async function (req: Request, res: Response) {
       data: job.data,
     });
   } catch (error) {
-    console.error('Error getting job status:', error);
-    return res.status(500).json({ error: 'Failed to get job status' });
+    console.error("Error getting job status:", error);
+    return res.status(500).json({ error: "Failed to get job status" });
   }
-}
+};
 
-export default getJob
+export default getJob;

src/controllers/jobs/index.ts

@@ -1,7 +1,4 @@
 import createJob from "./createJob.controller";
 import getJob from "./getJob.controller";
 
-export {
-  createJob,
-  getJob
-}
+export { createJob, getJob };

src/index.ts

@@ -2,7 +2,7 @@
 import mongoose from "mongoose";
 import app from "./app";
 import { env } from "./config";
-import './workers'
+import "./workers";
 
 mongoose.set("strictQuery", true);
 

src/jobs/email.job.ts

@@ -1,5 +1,5 @@
 /* eslint-disable @typescript-eslint/restrict-template-expressions */
-import { type Job } from 'bullmq';
+import { type Job } from "bullmq";
 
 const emailJob = async (job: Job): Promise<void> => {
   // Define the processing logic for email jobs
@@ -8,16 +8,16 @@ const emailJob = async (job: Job): Promise<void> => {
   try {
     // Perform email processing logic here
     console.log(`Sending email to ${to}: ${subject}`);
-    console.log('Body:', body);
+    console.log("Body:", body);
 
     // Simulating email sending time
     await new Promise((resolve) => setTimeout(resolve, 2000));
 
-    console.log('Email sent successfully');
+    console.log("Email sent successfully");
   } catch (error) {
-    console.error('Error processing email:', error);
-    throw new Error('Failed to process email'); // Throw an error if email processing fails
+    console.error("Error processing email:", error);
+    throw new Error("Failed to process email"); // Throw an error if email processing fails
   }
-}
+};
 
-export default emailJob
+export default emailJob;

src/jobs/imageProcessing.job.ts

@@ -12,11 +12,11 @@ const imageProcessingJob = async function (job: Job): Promise<void> {
     // Simulating image processing time
     await new Promise((resolve) => setTimeout(resolve, 3000));
 
-    console.log('Image processing completed');
+    console.log("Image processing completed");
   } catch (error) {
-    console.error('Error processing image:', error);
-    throw new Error('Failed to process image'); // Throw an error if image processing fails
+    console.error("Error processing image:", error);
+    throw new Error("Failed to process image"); // Throw an error if image processing fails
   }
-}
+};
 
-export default imageProcessingJob
+export default imageProcessingJob;

src/queues/connection.ts

@@ -3,7 +3,7 @@ import { env } from "../config";
 
 const connection: RedisOptions = {
   host: env.REDIS_QUEUE_HOST,
-  port: env.REDIS_QUEUE_PORT
-}
+  port: env.REDIS_QUEUE_PORT,
+};
 
-export default connection
+export default connection;

src/queues/email.queue.ts

@@ -1,6 +1,6 @@
 import { Queue } from "bullmq";
 import connection from "./connection";
 
-const emailQueue = new Queue('email', { connection })
+const emailQueue = new Queue("email", { connection });
 
-export default emailQueue;
+export default emailQueue;

src/queues/imageProcessing.queue.ts

@@ -1,6 +1,6 @@
 import { Queue } from "bullmq";
 import connection from "./connection";
 
-const imageProcessingQueue = new Queue('imageProcessing', { connection })
+const imageProcessingQueue = new Queue("imageProcessing", { connection });
 
-export default imageProcessingQueue;
+export default imageProcessingQueue;

src/queues/index.ts

@@ -1,9 +1,5 @@
 import emailQueue from "./email.queue";
-import imageProcessingQueue from "./imageProcessing.queue"
+import imageProcessingQueue from "./imageProcessing.queue";
 import queueByName from "./queueByName";
 
-export {
-  emailQueue,
-  imageProcessingQueue,
-  queueByName
-}
+export { emailQueue, imageProcessingQueue, queueByName };

src/queues/queueByName.ts

@@ -3,14 +3,14 @@ import emailQueue from "./email.queue";
 import imageProcessingQueue from "./imageProcessing.queue";
 
 const queueByName = (name: string): Queue => {
-    switch (name) {
-      case emailQueue.name:
-        return emailQueue;
-      case imageProcessingQueue.name:
-        return imageProcessingQueue;
-      default:
-        throw new Error(`No Queue called ${name}`)
-    }
-}
+  switch (name) {
+    case emailQueue.name:
+      return emailQueue;
+    case imageProcessingQueue.name:
+      return imageProcessingQueue;
+    default:
+      throw new Error(`No Queue called ${name}`);
+  }
+};
 
-export default queueByName
+export default queueByName;