added new to ObjectId (agenda#227)

5ky9uy · Apr 11, 2023 · a67a255 · a67a255
1 parent 308e7de
commit a67a255
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/lib/controllers/agendash.js b/lib/controllers/agendash.js
@@ -42,7 +42,7 @@ module.exports = function (agenda, options) {
 
     if (options.query && options.property) {
       if (options.isObjectId) {
-        preMatch[options.property] = ObjectId(options.query);
+        preMatch[options.property] = new ObjectId(options.query);
       } else if (/^\d+$/.test(options.query)) {
         preMatch[options.property] = Number.parseInt(options.query, 10);
       } else {
@@ -284,7 +284,7 @@ module.exports = function (agenda, options) {
     const collection = agenda._collection.collection || agenda._collection;
     const jobs = await collection
       .find({
-        _id: { $in: jobIds.map((jobId) => ObjectId(jobId)) },
+        _id: { $in: jobIds.map((jobId) => new ObjectId(jobId)) },
       })
       .toArray();
     if (jobs.length === 0) {
@@ -306,7 +306,7 @@ module.exports = function (agenda, options) {
     }
 
     return agenda.cancel({
-      _id: { $in: jobIds.map((jobId) => ObjectId(jobId)) },
+      _id: { $in: jobIds.map((jobId) => new ObjectId(jobId)) },
     });
   };