image processing job test

__test__/jobs/imageProcessing.job.test.ts

@@ -0,0 +1,17 @@
+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';
+    const jobData = { imageUrl };
+    const job: Partial<Job> = {
+      id: 'job-id',
+      name: 'image-processing',
+      data: jobData,
+      // Mock other attributes as needed
+    };
+
+    await expect(imageProcessingJob(job as Job)).resolves.toBeUndefined();
+  });
+});

src/jobs/imageProcessing.job.ts

@@ -0,0 +1,22 @@
+import { type Job } from "bullmq";
+
+/* eslint-disable @typescript-eslint/restrict-template-expressions */
+const imageProcessingJob = async function (job: Job): Promise<void> {
+  // Define the processing logic for image processing jobs
+  const { imageUrl } = job.data; // Assuming the job data contains the URL of the image to be processed
+
+  try {
+    // Perform image processing logic here
+    console.log(`Processing image: ${imageUrl}`);
+
+    // Simulating image processing time
+    await new Promise((resolve) => setTimeout(resolve, 3000));
+
+    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
+  }
+}
+
+export default imageProcessingJob

src/workers/imageProcessing.worker.ts

@@ -2,40 +2,9 @@
 import { Worker } from 'bullmq';
 import { imageProcessingQueue } from '../queues'; // Assuming you have already defined the imageProcessingQueue
 import connection from '../queues/connection';
+import imageProcessingJob from '../jobs/imageProcessing.job';
 
 // Create a new BullMQ worker instance for imageProcessingQueue
-const imageProcessingWorker = new Worker(imageProcessingQueue.name, async (job) => {
-  // Define the processing logic for image processing jobs
-  const { imageUrl } = job.data; // Assuming the job data contains the URL of the image to be processed
-
-  try {
-    // Perform image processing logic here
-    console.log(`Processing image: ${imageUrl}`);
-
-    // Simulating image processing time
-    await new Promise((resolve) => setTimeout(resolve, 3000));
-
-    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
-  }
-}, { connection });
-
-imageProcessingWorker.on('failed', (job, err) => {
-  if (job !== undefined) {
-    console.error(`Job ${job.id} failed with error:`, err);
-  } else {
-    console.error('The job was undefined.')
-  }
-});
-
-imageProcessingWorker.on('completed', (job) => {
-  console.log(`Job ${job.id} completed successfully`);
-});
-
-imageProcessingWorker.on('error', (error) => {
-  console.error('Worker error:', error);
-});
+const imageProcessingWorker = new Worker(imageProcessingQueue.name, imageProcessingJob, { connection });
 
 export default imageProcessingWorker