feat(job): expose extendLock as a public method

src/classes/job.ts

@@ -207,6 +207,16 @@ export class Job<T = any, R = any, N extends string = string> {
     }
   }
 
+  /**
+   * Extend the lock for this job.
+   *
+   * @param token unique token for the lock
+   * @param duration lock duration in milliseconds
+   */
+  async extendLock(token: string, duration: number) {
+    return Scripts.extendLock(this.queue, this.id, token, duration);
+  }
+
   /**
    * Moves a job to the completed queue.
    * Returned job to be used with Queue.prototype.nextJobFromJobData.

src/classes/scripts.ts

@@ -91,18 +91,18 @@ export class Scripts {
     return (<any>client).removeJob(keys.concat([queue.keys.events, jobId]));
   }
 
-  static async extendLock<T, R, N extends string>(
-    worker: Worker<T, R, N>,
+  static async extendLock(
+    queue: QueueBase,
     jobId: string,
     token: string,
+    duration: number,
   ) {
-    const client = await worker.client;
-    const opts: WorkerOptions = worker.opts;
+    const client = await queue.client;
     const args = [
-      worker.toKey(jobId) + ':lock',
-      worker.keys.stalled,
+      queue.toKey(jobId) + ':lock',
+      queue.keys.stalled,
       token,
-      opts.lockDuration,
+      duration,
       jobId,
     ];
     return (<any>client).extendLock(args);

src/classes/worker.ts

@@ -272,7 +272,7 @@ export class Worker<
         this.opts.lockRenewTime,
         async () => {
           try {
-            const result = await Scripts.extendLock(this, job.id, token);
+            const result = await job.extendLock(token, this.opts.lockDuration);
             if (result && !timerStopped) {
               lockExtender();
             }