await getJob

Author: harryadel

server/imports/actions/add/index.js

@@ -3,7 +3,7 @@ import { Utilities } from "../../utilities"
 const add = async function () {
 	// 0. Prepare variables
 	let error, result, blockAdd;
-
+	
 	// 1. Process arguments + prepare the data
 	const input = Utilities.helpers.processJobArguments(arguments);
 

server/imports/actions/cancel/index.js

@@ -4,7 +4,7 @@ const cancel = async function (job, callback) {
 	let error;
 	let result;
 
-	const jobDoc = Utilities.helpers.getJob(job, {
+	const jobDoc = await Utilities.helpers.getJob(job, {
 		allow: ["pending", "failure"],
 		message: "Unable to cancel job - not found or is resolved: "
 	})

server/imports/actions/execute/process.js

@@ -11,7 +11,6 @@ const process = async function (doc, callback) {
 	const Toolbelt = new toolbelt(doc);
 
 	try {
-		debugger;
 		const res = Utilities.registry.data[doc.name].apply(Toolbelt, doc.arguments);
 		const jobResult = Promise.await(Promise.resolve(res));
 		const resolution = Toolbelt.checkForResolution(jobResult);

server/imports/actions/execute/toolbelt.js

@@ -174,7 +174,7 @@ const toolbelt = function (jobDoc) {
 			"Job has failed: " + queueName + ", " + docId,
 			"Queue was stopped; please correct your job function and restart the server"
 		]);
-		debugger;
+		
 		await Operator.manager.queues[queueName].stop();
 
 		instance.resolved = true;

server/imports/actions/remove/index.js

@@ -3,7 +3,7 @@ import { Utilities } from "../../utilities"
 const remove = async function (job, callback) {
 	let error;
 	let result;
-	const jobDoc = Utilities.helpers.getJob(job);
+	const jobDoc = await Utilities.helpers.getJob(job);
 
 	if (typeof jobDoc === "object") {
 		result = await Utilities.collection.removeAsync(jobDoc._id)

server/imports/actions/replicate/index.js

@@ -3,7 +3,7 @@ import { Utilities } from "../../utilities"
 const replicate = async function (job, config, callback) {
 	let error;
 	let result;
-	const jobDoc = Utilities.helpers.getJob(job);
+	const jobDoc = await Utilities.helpers.getJob(job);
 
 	if (typeof jobDoc === "object") {
 		const replicant = Utilities.helpers.generateJobDoc({

server/imports/actions/reschedule/index.js

@@ -3,8 +3,8 @@ import { Utilities } from "../../utilities"
 const reschedule = async function (job, config, callback) {
 	let error;
 	let result;
-
-	const jobDoc = Utilities.helpers.getJob(job, {
+	
+	const jobDoc = await Utilities.helpers.getJob(job, {
 		allow: ["pending", "failure"],
 		message: 'Unable to reschedule. Job does not exist or has been resolved: '
 	});