From d86c2e888e1c34ed32007917ee5c8bccb34761dd Mon Sep 17 00:00:00 2001
From: Mikael Svens <mikael@svens.tech>
Date: Thu, 30 Jan 2025 14:21:31 +0100
Subject: [PATCH 1/2] Fix broken queue mock.

---
 packages/bull/ZembleQueueMock.ts | 20 ++++++++++----------
 1 file changed, 10 insertions(+), 10 deletions(-)

diff --git a/packages/bull/ZembleQueueMock.ts b/packages/bull/ZembleQueueMock.ts
index 1e0697a1..3f56c9e7 100644
--- a/packages/bull/ZembleQueueMock.ts
+++ b/packages/bull/ZembleQueueMock.ts
@@ -25,6 +25,8 @@ class ZembleQueueMock<DataType = unknown, ResultType extends PromiseLike<unknown
 
   private isPaused = false
 
+  private jobsRemaining = 0
+
   constructor(
     readonly worker: ZembleWorker,
     _?: ZembleQueueConfig,
@@ -54,8 +56,6 @@ class ZembleQueueMock<DataType = unknown, ResultType extends PromiseLike<unknown
     return this.#queueInternal
   }
 
-  #jobsRemaining = 0
-
   async addBulk(jobs: Parameters<ZembleQueueBull<DataType, ResultType>['addBulk']>[number]) {
     // eslint-disable-next-line @typescript-eslint/no-unsafe-argument, @typescript-eslint/no-explicit-any
     const js = jobs.map((job) => this.#createMockJob(job.name, job.data as any, job.opts))
@@ -94,14 +94,12 @@ class ZembleQueueMock<DataType = unknown, ResultType extends PromiseLike<unknown
     return job
   }
 
-  #executeWorker(job: Job<DataType, ResultType, string>) {
+  async #executeWorker(job: Job<DataType, ResultType, string>) {
     try {
-      // eslint-disable-next-line no-plusplus
-      this.#jobsRemaining++
-      return this.#worker(job, { logger: zembleContext.logger })
+      return await this.#worker(job, { logger: zembleContext.logger })
     } finally {
       // eslint-disable-next-line no-plusplus
-      this.#jobsRemaining--
+      this.jobsRemaining--
       this.#triggerWaitUntilFinishedIfNeeded()
     }
   }
@@ -113,8 +111,10 @@ class ZembleQueueMock<DataType = unknown, ResultType extends PromiseLike<unknown
 
     const job = this.#createMockJob(name, data, opts)
     this.jobs.push(job)
+    // eslint-disable-next-line no-plusplus
+    this.jobsRemaining++
     setTimeout(async () => {
-      this.#executeWorker(job)
+      await this.#executeWorker(job)
     }, 0)
     return job
   }
@@ -149,7 +149,7 @@ class ZembleQueueMock<DataType = unknown, ResultType extends PromiseLike<unknown
 
   #triggerWaitUntilFinishedIfNeeded() {
     if (this.#waitUntilFinishedResolver) {
-      if (this.#jobsRemaining === 0) {
+      if (this.jobsRemaining === 0) {
         this.#waitUntilFinishedResolver()
         this.#waitUntilFinishedPromise = undefined
         this.#waitUntilFinishedResolver = undefined
@@ -159,7 +159,7 @@ class ZembleQueueMock<DataType = unknown, ResultType extends PromiseLike<unknown
 
   async waitUntilEmpty() {
     if (!this.#waitUntilFinishedPromise) {
-      if (this.#jobsRemaining === 0) {
+      if (this.jobsRemaining === 0) {
         return Promise.resolve()
       }
 

From 9b71567407259ca2c008d7d3740cac1c9a6c91c5 Mon Sep 17 00:00:00 2001
From: Mikael Svens <svensmikael@gmail.com>
Date: Thu, 30 Jan 2025 14:44:16 +0100
Subject: [PATCH 2/2] Create sixty-seals-give.md

---
 .changeset/sixty-seals-give.md | 5 +++++
 1 file changed, 5 insertions(+)
 create mode 100644 .changeset/sixty-seals-give.md

diff --git a/.changeset/sixty-seals-give.md b/.changeset/sixty-seals-give.md
new file mode 100644
index 00000000..28be0094
--- /dev/null
+++ b/.changeset/sixty-seals-give.md
@@ -0,0 +1,5 @@
+---
+"@zemble/bull": patch
+---
+
+Fix broken queue mock.