Added validation to addJob() in jobs/queue.mjs to ensure that data is an object.

Author: rizen

ving/docs/change-log.md

@@ -3,6 +3,11 @@ outline: deep
 ---
 # Change Log
 
+## December 2024
+
+### 2024-12-17
+ * Added validation to addJob() in jobs/queue.mjs to ensure that data is an object.
+
 ## October 2024
 
 ### 2024-10-30

ving/jobs/handlers/Test.mjs

@@ -6,6 +6,6 @@ import ving from '#ving/index.mjs';
  * @returns {boolean} `true`
  */
 export default async function (job) {
-    ving.log('jobs').debug(`Test ran with data: ${JSON.stringify(job.data)}`);
+    ving.log('jobs').debug(`Test ran with data: ${JSON.stringify(job.data)} which is a ${typeof job.data}`);
     return true;
 }

ving/jobs/queue.mjs

@@ -2,6 +2,7 @@ import { Queue } from 'bullmq';
 import ving from '#ving/index.mjs';
 import { useRedis } from '#ving/redis.mjs';
 import { jobHandlers } from '#ving/jobs/map.mjs';
+import { isObject } from '#ving/utils/identify.mjs';
 
 /**
  * Get BullMQ queue object.
@@ -35,7 +36,7 @@ export const getHandlerNames = () => {
  * Enqueues a job in the jobs system.
  * 
  * @param {string} type Must match the filename (without the `.mjs`) of a job handler.
- * @param {Object} data An object containing whatever data you wish to pass into the job.
+ * @param {Object|Undefined} data An object containing whatever data you wish to pass into the job.
  * @param {Object} options An object with optional properties.
  * @param {string} options.queueName The name of the queue to add this job to. Defaults to `jobs`.
  * @param {number} options.delay The number of milliseconds to wait before executing this job. Defaults to running as soon as possible.
@@ -49,6 +50,9 @@ export const getHandlerNames = () => {
 export const addJob = async (type, data = {}, options = { queueName: 'jobs' }) => {
     if (!(getHandlerNames().includes(type)))
         throw ving.ouch(404, `Job handler ${type} is not available.`);
+    if (!isObject(data)) {
+        throw ving.ouch(442, `Data must be an object.`);
+    }
     const queue = getQueue(options);
     const jobOptions = {
         removeOnComplete: {