docs(bullmq-pro): update changelog to v6.4.0 (#2192)

docs/gitbook/bullmq-pro/changelog.md

@@ -1,3 +1,25 @@
+# [6.4.0](https://github.com/taskforcesh/bullmq-pro/compare/v6.3.4...v6.4.0) (2023-09-16)
+
+
+### Features
+
+* **connection:** provide skipVersionCheck option for shared connections ([#2149](https://github.com/taskforcesh/bullmq/issues/2149)) ref [#2148](https://github.com/taskforcesh/bullmq/issues/2148) ([914820f](https://github.com/taskforcesh/bullmq/commit/914820f720cbc48b49f4bd1c46d148eb2bb5b79c))
+* **sandbox:** sandbox: emulate moveToDelayed method ([#180](https://github.com/taskforcesh/bullmq-pro/issues/180)) ([d61de09](https://github.com/taskforcesh/bullmq-pro/commit/d61de095115481b688101bfaf0b126a02545cc6f)) ref [#2118](https://github.com/taskforcesh/bullmq/issues/2118)
+
+
+### Bug Fixes
+
+* **remove:** change error message when job is locked (python) ([#2175](https://github.com/taskforcesh/bullmq/issues/2175)) ([2f5628f](https://github.com/taskforcesh/bullmq/commit/2f5628feffab66cdcc78abf4d7bb608bdcaa65bb))
+* **sandbox:** ignore extra params on processor ([#2142](https://github.com/taskforcesh/bullmq/issues/2142)) ([3602c20](https://github.com/taskforcesh/bullmq/commit/3602c20ab80cbe0a0d3de66210a01ad119e1090b))
+
+
+## [6.3.4](https://github.com/taskforcesh/bullmq-pro/compare/v6.3.3...v6.3.4) (2023-08-18)
+
+
+### Bug Fixes
+
+* **worker:** abort rate-limit delay when closing worker ([#179](https://github.com/taskforcesh/bullmq-pro/issues/179)) ([4ad650b](https://github.com/taskforcesh/bullmq-pro/commit/4ad650b7bc0c6a950536df252e510cb96e2e0054))
+
 ## [6.3.3](https://github.com/taskforcesh/bullmq-pro/compare/v6.3.2...v6.3.3) (2023-08-15)
 
 

src/classes/child-processor.ts

@@ -1,4 +1,5 @@
-import { JobJson, ParentCommand, SandboxedJob } from '../interfaces';
+import { ParentCommand } from '../enums';
+import { JobJson, SandboxedJob } from '../interfaces';
 import { errorToJSON } from '../utils';
 
 enum ChildStatus {

src/classes/child.ts

@@ -1,7 +1,7 @@
 import { ChildProcess, fork } from 'child_process';
 import { Worker } from 'worker_threads';
 import { AddressInfo, createServer } from 'net';
-import { ChildCommand, ParentCommand } from '../interfaces';
+import { ChildCommand, ParentCommand } from '../enums';
 import { EventEmitter } from 'events';
 
 /**

src/classes/main-base.ts

@@ -4,7 +4,7 @@
  */
 import { toString } from 'lodash';
 import { ChildProcessor } from './child-processor';
-import { ParentCommand, ChildCommand } from '../interfaces';
+import { ParentCommand, ChildCommand } from '../enums';
 import { errorToJSON } from '../utils';
 
 export default (

src/classes/sandbox.ts

@@ -1,4 +1,5 @@
-import { ChildCommand, ChildMessage, ParentCommand } from '../interfaces';
+import { ChildCommand, ParentCommand } from '../enums';
+import { ChildMessage } from '../interfaces';
 import { ChildPool } from './child-pool';
 import { Job } from './job';
 

src/classes/worker.ts

@@ -165,31 +165,26 @@ export class Worker<
   readonly opts: WorkerOptions;
   readonly id: string;
 
-  private drained: boolean = false;
-  private waiting: Promise<string> | null = null;
-  private running = false;
-  private blockUntil = 0;
-  private limitUntil = 0;
   private abortDelayController: AbortController | null = null;
-
-  protected processFn: Processor<DataType, ResultType, NameType>;
-
-  private resumeWorker: () => void;
-  protected paused: Promise<void>;
-  private _repeat: Repeat;
-  private childPool: ChildPool;
-
-  private extendLocksTimer: NodeJS.Timeout | null = null;
-
-  private blockingConnection: RedisConnection;
-
-  private stalledCheckTimer: NodeJS.Timeout;
-
   private asyncFifoQueue: AsyncFifoQueue<void | Job<
     DataType,
     ResultType,
     NameType
   >>;
+  private blockingConnection: RedisConnection;
+  private blockUntil = 0;
+  private childPool: ChildPool;
+  private drained: boolean = false;
+  private extendLocksTimer: NodeJS.Timeout | null = null;
+  private limitUntil = 0;
+  private resumeWorker: () => void;
+  private stalledCheckTimer: NodeJS.Timeout;
+  private waiting: Promise<string> | null = null;
+  private _repeat: Repeat;
+
+  protected paused: Promise<void>;
+  protected processFn: Processor<DataType, ResultType, NameType>;
+  protected running = false;
 
   static RateLimitError(): Error {
     return new Error(RATE_LIMIT_ERROR);

src/enums/index.ts

@@ -1,2 +1,4 @@
-export * from './error-code.enum';
+export * from './child-command';
+export * from './error-code';
+export * from './parent-command';
 export * from './metrics-time';

src/interfaces/child-message.ts

@@ -1,4 +1,4 @@
-import { ParentCommand } from './parent-command';
+import { ParentCommand } from '../enums/parent-command';
 
 export interface ChildMessage {
   cmd: ParentCommand;

src/interfaces/index.ts

@@ -1,7 +1,6 @@
 export * from './advanced-options';
 export * from './backoff-options';
 export * from './base-job-options';
-export * from './child-command';
 export * from './child-message';
 export * from './connection';
 export * from './flow-job';
@@ -11,7 +10,6 @@ export * from './keep-jobs';
 export * from './metrics-options';
 export * from './metrics';
 export * from './minimal-job';
-export * from './parent-command';
 export * from './parent-message';
 export * from './parent';
 export * from './queue-options';

src/interfaces/parent-message.ts

@@ -1,4 +1,4 @@
-import { ChildCommand } from './child-command';
+import { ChildCommand } from '../enums/child-command';
 import { JobJson } from './job-json';
 
 export interface ParentMessage {