fix(sandbox): use updateProgress method name

src/classes/master.ts

@@ -62,9 +62,9 @@ process.on('message', msg => {
         processor = promisify(processor);
       } else {
         const origProcessor = processor;
-        processor = function() {
+        processor = function(...args: any[]) {
           try {
-            return Promise.resolve(origProcessor.apply(null, arguments));
+            return Promise.resolve(origProcessor(...args));
           } catch (err) {
             return Promise.reject(err);
           }
@@ -92,12 +92,9 @@ process.on('message', msg => {
             value: result,
           });
         } catch (err) {
-          if (!err.message) {
-            err = new Error(err);
-          }
           await processSendAsync({
             cmd: 'failed',
-            value: err,
+            value: !err.message ? new Error(err) : err,
           });
         } finally {
           status = 'IDLE';
@@ -133,6 +130,27 @@ process.on('uncaughtException', err => {
 function wrapJob(job: JobJson): SandboxedJob {
   let progressValue = job.progress;
 
+  const updateProgress = (progress: number | object) => {
+    // Locally store reference to new progress value
+    // so that we can return it from this process synchronously.
+    progressValue = progress;
+    // Send message to update job progress.
+    process.send({
+      cmd: 'progress',
+      value: progress,
+    });
+    return Promise.resolve();
+  };
+
+  const progress = (progress?: number | object) => {
+    if (progress) {
+      return updateProgress(progress);
+    } else {
+      // Return the last known progress value.
+      return progressValue;
+    }
+  };
+
   return {
     ...job,
     data: JSON.parse(job.data || '{}'),
@@ -143,22 +161,11 @@ function wrapJob(job: JobJson): SandboxedJob {
      * If no argument is given, it behaves as a sync getter.
      * If an argument is given, it behaves as an async setter.
      */
-    progress: (progress?: any) => {
-      if (progress) {
-        // Locally store reference to new progress value
-        // so that we can return it from this process synchronously.
-        progressValue = progress;
-        // Send message to update job progress.
-        process.send({
-          cmd: 'progress',
-          value: progress,
-        });
-        return Promise.resolve();
-      } else {
-        // Return the last known progress value.
-        return progressValue;
-      }
-    },
+    progress,
+    /*
+     * Emulate the real job `updateProgress` function, should works as `progress` function.
+     */
+    updateProgress,
     /*
      * Emulate the real job `log` function.
      */

src/interfaces/sandboxed-job.ts

@@ -5,12 +5,13 @@ import { JobsOptions } from './jobs-options';
  * @see {@link https://docs.bullmq.io/guide/workers/sandboxed-processors}
  */
 export interface SandboxedJob<T = any, R = any>
-  extends Omit<JobJson, 'data' | 'opts' | 'progress' | 'log' | 'returnValue'> {
+  extends Omit<JobJson, 'data' | 'opts' | 'progress' | 'returnValue'> {
   data: T;
   opts: JobsOptions;
   progress:
     | (() => object | number)
     | ((value: object | number) => Promise<void>);
+  updateProgress: (value: object | number) => Promise<void>;
   log: (row: any) => void;
   returnValue: R;
 }

src/test/fixtures/fixture_processor_progress.js

@@ -9,7 +9,7 @@ const delay = require('./delay');
 module.exports = function(job) {
   return delay(50)
     .then(() => {
-      job.progress(10);
+      job.updateProgress(10);
       job.log(job.progress());
       return delay(100);
     })
@@ -19,7 +19,7 @@ module.exports = function(job) {
       return delay(150);
     })
     .then(() => {
-      job.progress(78);
+      job.updateProgress(78);
       job.log(job.progress());
       return delay(100);
     })

src/test/test_sandboxed_process.ts

@@ -35,7 +35,7 @@ describe('sandboxed process', () => {
       drainDelay: 1,
     });
 
-    const completting = new Promise((resolve, reject) => {
+    const completing = new Promise((resolve, reject) => {
       worker.on('completed', async (job, value) => {
         try {
           expect(job.data).to.be.eql({ foo: 'bar' });
@@ -53,7 +53,7 @@ describe('sandboxed process', () => {
 
     await queue.add('test', { foo: 'bar' });
 
-    await completting;
+    await completing;
 
     await worker.close();
   });
@@ -64,7 +64,7 @@ describe('sandboxed process', () => {
       drainDelay: 1,
     });
 
-    const completting = new Promise((resolve, reject) => {
+    const completing = new Promise((resolve, reject) => {
       worker.on('completed', async (job, value) => {
         try {
           expect(job.data).to.be.eql({ foo: 'bar' });
@@ -82,7 +82,7 @@ describe('sandboxed process', () => {
 
     await queue.add('foobar', { foo: 'bar' });
 
-    await completting;
+    await completing;
   });
 
   it('should process with concurrent processors', async function() {
@@ -142,7 +142,7 @@ describe('sandboxed process', () => {
       queue.add('4', { foo: 'bar4' }),
     ]);
 
-    const completting = new Promise((resolve, reject) => {
+    const completing = new Promise((resolve, reject) => {
       const after4 = after(4, async () => {
         expect(worker['childPool'].getAllFree().length).to.eql(1);
         await worker.close();
@@ -164,7 +164,7 @@ describe('sandboxed process', () => {
       });
     });
 
-    await completting;
+    await completing;
   });
 
   it('should process and update progress', async () => {
@@ -319,7 +319,7 @@ describe('sandboxed process', () => {
       drainDelay: 1,
     });
 
-    const completting = new Promise((resolve, reject) => {
+    const completing = new Promise((resolve, reject) => {
       worker.on('completed', async () => {
         try {
           expect(Object.keys(worker['childPool'].retained)).to.have.lengthOf(0);
@@ -336,7 +336,7 @@ describe('sandboxed process', () => {
 
     await queue.add('test', { foo: 'bar' });
 
-    await completting;
+    await completing;
 
     await worker.close();
   });