fix(sandbox): extend SandboxedJob from JobJsonSandbox (#2446) fixes #…

…2439
taskforcesh · Feb 24, 2024 · 7606e36 · 7606e36
1 parent 8f8cb88
commit 7606e36
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 7 deletions.
diff --git a/src/classes/child-processor.ts b/src/classes/child-processor.ts
@@ -1,5 +1,6 @@
 import { ParentCommand } from '../enums';
-import { JobJson, SandboxedJob } from '../interfaces';
+import { SandboxedJob } from '../interfaces';
+import { JobJsonSandbox } from '../types';
 import { errorToJSON } from '../utils';
 
 enum ChildStatus {
@@ -61,7 +62,7 @@ export class ChildProcessor {
     });
   }
 
-  public async start(jobJson: JobJson, token?: string): Promise<void> {
+  public async start(jobJson: JobJsonSandbox, token?: string): Promise<void> {
     if (this.status !== ChildStatus.Idle) {
       return this.send({
         cmd: ParentCommand.Error,
@@ -110,7 +111,7 @@ export class ChildProcessor {
    * The wrapped job adds back some of those original functions.
    */
   protected wrapJob(
-    job: JobJson,
+    job: JobJsonSandbox,
     send: (msg: any) => Promise<void>,
   ): SandboxedJob {
     return {

diff --git a/src/classes/job.ts b/src/classes/job.ts
@@ -8,7 +8,6 @@ import {
   JobJson,
   JobJsonRaw,
   MinimalJob,
-  MoveToDelayedOpts,
   MoveToWaitingChildrenOpts,
   ParentKeys,
   ParentOpts,

diff --git a/src/interfaces/sandboxed-job.ts b/src/interfaces/sandboxed-job.ts
@@ -1,11 +1,10 @@
-import { JobsOptions } from '../types';
-import { JobJson } from './job-json';
+import { JobJsonSandbox, JobsOptions } from '../types';
 
 /**
  * @see {@link https://docs.bullmq.io/guide/workers/sandboxed-processors}
  */
 export interface SandboxedJob<T = any, R = any>
-  extends Omit<JobJson, 'data' | 'opts' | 'returnValue'> {
+  extends Omit<JobJsonSandbox, 'data' | 'opts' | 'returnValue'> {
   data: T;
   opts: JobsOptions;
   moveToDelayed: (timestamp: number, token?: string) => Promise<void>;