chore: wip

Author: chrisbbreuer

test/getters.test.ts

@@ -333,7 +333,7 @@ describe('Jobs getters', () => {
     const data = { foo: 'sup!' }
     const job = await queue.add('test', data)
     const returnedJob = await queue.getJob(job.id!)
-    expect(returnedJob!.data).to.eql(data)
+    expect(returnedJob!.data).toEqual(data)
     expect(returnedJob!.id).toBe(job.id)
   })
 

test/job.test.ts

@@ -1,18 +1,15 @@
-/* eslint-env node */
-'use strict'
-
 import type { JobsOptions } from '../src/types'
-import { expect } from 'chai'
-import { default as IORedis } from 'ioredis'
+import IORedis from 'ioredis'
 import { after } from 'lodash'
 import {
-  after as afterAll,
+  expect,
+  afterAll,
   afterEach,
-  before,
+  beforeAll,
   beforeEach,
   describe,
   it,
-} from 'mocha'
+} from 'bun:test'
 import { v4 } from 'uuid'
 import { Job, Queue, QueueEvents, Worker } from '../src/classes'
 import { delay, getParentKey, removeAllQueueData } from '../src/utils'
@@ -23,8 +20,9 @@ describe('Job', () => {
 
   let queue: Queue
   let queueName: string
-  let connection
-  before(async () => {
+  let connection: IORedis
+
+  beforeAll(async () => {
     connection = new IORedis(redisHost, { maxRetriesPerRequest: null })
   })
 
@@ -62,7 +60,7 @@ describe('Job', () => {
       expect(storedJob).toHaveProperty('data')
 
       expect(storedJob.data.foo).toBe('bar')
-      expect(storedJob.opts).to.be.an('object')
+      expect(storedJob.opts).toBeObject()
       expect(storedJob.opts.timestamp).toBe(timestamp)
     })
 
@@ -87,7 +85,7 @@ describe('Job', () => {
       const data = { foo: 'bar' } // 13 bytes
       const opts = { sizeLimit: 20 }
       const createdJob = await Job.create(queue, 'test', data, opts)
-      expect(createdJob).to.not.be.null
+      expect(createdJob).not.toBeNull()
       expect(createdJob).toHaveProperty('opts')
       expect(createdJob.opts.sizeLimit).toBe(20)
     })
@@ -207,7 +205,7 @@ describe('Job', () => {
       job.progress = 20
       const json = JSON.stringify(job)
       const parsed = JSON.parse(json)
-      expect(parsed).to.have.deep.property('data', data)
+      expect(parsed).toHaveProperty('data', data)
       expect(parsed).toHaveProperty('name', 'test')
       expect(parsed).toHaveProperty('returnvalue', 1)
       expect(parsed).toHaveProperty('progress', 20)
@@ -226,7 +224,7 @@ describe('Job', () => {
       const job = await Job.create(queue, 'test', data)
       const json = JSON.stringify(job)
       const parsed = JSON.parse(json)
-      expect(parsed).to.have.deep.property('data', data)
+      expect(parsed).toHaveProperty('data', data)
 
       const newQueue = new Queue(queueName, { connection, prefix })
       let worker: Worker
@@ -390,24 +388,24 @@ describe('Job', () => {
       const job = await Job.create(queue, 'test', { foo: 'bar' })
       await job.updateProgress({ total: 120, completed: 40 })
       const storedJob = await Job.fromId(queue, job.id!)
-      expect(storedJob!.progress).to.eql({ total: 120, completed: 40 })
+      expect(storedJob!.progress).toEqual({ total: 120, completed: 40 })
     })
 
     it('can set and get progress as string', async () => {
       const job = await Job.create(queue, 'test', { foo: 'bar' })
       await job.updateProgress('hello, world!')
       const storedJob = await Job.fromId(queue, job.id!)
-      expect(storedJob!.progress).to.eql('hello, world!')
+      expect(storedJob!.progress).toEqual('hello, world!')
     })
 
     it('can set and get progress as boolean', async () => {
       const job = await Job.create(queue, 'test', { foo: 'bar' })
       await job.updateProgress(false)
       let storedJob = await Job.fromId(queue, job.id!)
-      expect(storedJob!.progress).to.eql(false)
+      expect(storedJob!.progress).toEqual(false)
       await job.updateProgress(true)
       storedJob = await Job.fromId(queue, job.id!)
-      expect(storedJob!.progress).to.eql(true)
+      expect(storedJob!.progress).toEqual(true)
     })
 
     it('can set progress as number using the Queue instance', async () => {
@@ -423,7 +421,7 @@ describe('Job', () => {
       const job = await Job.create(queue, 'test', { foo: 'bar' })
       await queue.updateJobProgress(job.id!, { total: 120, completed: 40 })
       const storedJob = await Job.fromId(queue, job.id!)
-      expect(storedJob!.progress).to.eql({ total: 120, completed: 40 })
+      expect(storedJob!.progress).toEqual({ total: 120, completed: 40 })
     })
 
     describe('when job is removed', () => {
@@ -696,7 +694,7 @@ describe('Job', () => {
 
       const isCompleted = await job.isCompleted()
 
-      expect(isCompleted).to.be.false
+      expect(isCompleted).toBeFalse()
 
       await childrenWorker.close()
       await parentWorker.close()
@@ -716,7 +714,7 @@ describe('Job', () => {
       await job.moveToFailed(new Error('test error'), '0', true)
       const isFailed2 = await job.isFailed()
       expect(isFailed2).toBe(true)
-      expect(job.stacktrace).not.be.equal(null)
+      expect(job.stacktrace).not.toEqual(null)
       expect(job.stacktrace.length).toBe(1)
       expect(job.stacktrace[0]).toInclude('test_job.ts')
       await worker.close()
@@ -734,7 +732,7 @@ describe('Job', () => {
         await job.moveToFailed(new CustomError('test error'), '0', true)
         const isFailed2 = await job.isFailed()
         expect(isFailed2).toBe(true)
-        expect(job.stacktrace).not.be.equal(null)
+        expect(job.stacktrace).not.toEqual(null)
         expect(job.stacktrace.length).toBe(1)
         expect(job.stacktrace[0]).toInclude('test_job.ts')
         await worker.close()
@@ -763,7 +761,7 @@ describe('Job', () => {
 
       const isFailed2 = await job.isFailed()
       expect(isFailed2).toBe(false)
-      expect(job.stacktrace).not.be.equal(null)
+      expect(job.stacktrace).not.toEqual(null)
       expect(job.stacktrace.length).toBe(1)
       const isWaiting = await job.isWaiting()
       expect(isWaiting).toBe(true)
@@ -841,7 +839,7 @@ describe('Job', () => {
 
         expect(isFailed2).toBe(true)
         expect(state).toBe('failed')
-        expect(job.stacktrace).not.be.equal(null)
+        expect(job.stacktrace).not.toEqual(null)
         expect(job.stacktrace.length).toBe(1)
         await worker.close()
       })
@@ -867,7 +865,7 @@ describe('Job', () => {
         const isFailed2 = await job.isFailed()
 
         expect(isFailed2).toBe(false)
-        expect(job.stacktrace).not.be.equal(null)
+        expect(job.stacktrace).not.toEqual(null)
         expect(job.stacktrace.length).toBe(1)
         const isDelayed = await job.isDelayed()
         expect(isDelayed).toBe(true)
@@ -893,8 +891,8 @@ describe('Job', () => {
       await job.moveToFailed(new Error('failed once'), '0', true)
       const isFailed1 = await job.isFailed()
       const stackTrace1 = job.stacktrace[0]
-      expect(isFailed1).to.be.false
-      expect(job.stacktrace).not.be.equal(null)
+      expect(isFailed1).toBeFalse()
+      expect(job.stacktrace).not.toEqual(null)
       expect(job.stacktrace.length).toBe(stackTraceLimit)
       // second time failed.
       const again = (await worker.getNextJob(token)) as Job
@@ -904,7 +902,7 @@ describe('Job', () => {
       expect(isFailed2).toBeTrue()
       expect(again.name).toBe(job.name)
       expect(again.stacktrace.length).toBe(stackTraceLimit)
-      expect(stackTrace1).not.be.equal(stackTrace2)
+      expect(stackTrace1).not.toEqual(stackTrace2)
       await worker.close()
     })
 
@@ -925,7 +923,7 @@ describe('Job', () => {
         // first time failed.
         await job.moveToFailed(new Error('failed once'), '0', true)
         const isFailed1 = await job.isFailed()
-        expect(isFailed1).to.be.false
+        expect(isFailed1).toBeFalse()
         expect(job.stacktrace.length).toBe(stackTraceLimit)
         // second time failed.
         const again = (await worker.getNextJob(token)) as Job
@@ -947,7 +945,7 @@ describe('Job', () => {
       await job.moveToFailed(new Error('test error'), '0')
       const sameJob = await queue.getJob(id!)
       expect(sameJob).toBeTruthy()
-      expect(sameJob.stacktrace).to.be.not.empty
+      expect(sameJob.stacktrace).not.toBeEmpty()
       await worker.close()
     })
   })
@@ -1770,7 +1768,7 @@ describe('Job', () => {
 
       const result = await job.waitUntilFinished(queueEvents)
 
-      expect(result).to.be.an('object')
+      expect(result).toBeObject()
       expect(result.resultFoo).equal('bar')
 
       await worker.close()
@@ -1790,7 +1788,7 @@ describe('Job', () => {
       await delay(600)
 
       const result = await job.waitUntilFinished(queueEvents)
-      expect(result).to.be.an('object')
+      expect(result).toBeObject()
       expect(result.resultFoo).equal('bar')
 
       await worker.close()
@@ -1842,7 +1840,7 @@ describe('Job', () => {
       await delay(500)
       const result = await job.waitUntilFinished(queueEvents)
 
-      expect(result).to.be.an('object')
+      expect(result).toBeObject()
       expect(result.resultFoo).equal('bar')
 
       await worker.close()

test/job_scheduler.test.ts

@@ -1906,7 +1906,7 @@ describe('Job Scheduler', function () {
       const removed = await queue.removeJobScheduler(repeatableJobs[0].key)
       expect(removed).toBeTrue()
       const removed2 = await queue.removeJobScheduler(repeatableJobs[0].key)
-      expect(removed2).to.be.false
+      expect(removed2).toBeFalse()
     })
   })
 
@@ -2365,7 +2365,7 @@ describe('Job Scheduler', function () {
 
     const jobs = await queue.getRepeatableJobs()
     // Repeatable job was recreated
-    expect(jobs.length).to.eql(0)
+    expect(jobs.length).toEqual(0)
 
     await worker!.close()
   })

test/pause.test.ts

@@ -333,7 +333,7 @@ describe('Pause', () => {
 
     await queue.resume()
     const isResumedQueuePaused = await queue.isPaused()
-    expect(isResumedQueuePaused).to.be.false
+    expect(isResumedQueuePaused).toBeFalse()
   })
 
   it('should pause and resume worker without error', async () => {

test/rate_limiter.test.ts

@@ -807,7 +807,7 @@ describe('Rate Limiter', () => {
           await delay(dynamicLimit / 2)
 
           const jobs = await queue.getJobs(['prioritized'], 0, -1, true)
-          expect(jobs.map(x => x.name)).to.eql(['1', '2', '3', '4'])
+          expect(jobs.map(x => x.name)).toEqual(['1', '2', '3', '4'])
 
           await worker.close()
         })
@@ -844,7 +844,7 @@ describe('Rate Limiter', () => {
           await delay(dynamicLimit * 4)
 
           const jobs = await queue.getJobs(['prioritized'], 0, -1, true)
-          expect(jobs.map(x => x.name)).to.eql(['1', '3', '2', '4'])
+          expect(jobs.map(x => x.name)).toEqual(['1', '3', '2', '4'])
 
           await worker.close()
         })

test/repeat.test.ts

@@ -1497,7 +1497,7 @@ describe('repeat', function () {
       const removed = await queue.removeRepeatableByKey(repeatableJobs[0].key)
       expect(removed).toBeTrue()
       const removed2 = await queue.removeRepeatableByKey(repeatableJobs[0].key)
-      expect(removed2).to.be.false
+      expect(removed2).toBeFalse()
     })
   })
 
@@ -1752,7 +1752,7 @@ describe('repeat', function () {
 
     const jobs = await queue.getRepeatableJobs()
     // Repeatable job was recreated
-    expect(jobs.length).to.eql(0)
+    expect(jobs.length).toEqual(0)
 
     await worker!.close()
   })

test/sandboxed_process.test.ts

@@ -608,7 +608,7 @@ function sandboxProcessTests(
 
       const completing = new Promise<void>((resolve, reject) => {
         const after4 = after(4, () => {
-          expect(worker.childPool.getAllFree().length).to.eql(4)
+          expect(worker.childPool.getAllFree().length).toEqual(4)
           resolve()
         })
 
@@ -618,7 +618,7 @@ function sandboxProcessTests(
             expect(
               Object.keys(worker.childPool.retained).length
               + worker.childPool.getAllFree().length,
-            ).to.eql(4)
+            ).toEqual(4)
             after4()
           }
           catch (err) {
@@ -652,7 +652,7 @@ function sandboxProcessTests(
 
       const completing = new Promise<void>((resolve, reject) => {
         const after4 = after(4, async () => {
-          expect(worker.childPool.getAllFree().length).to.eql(1)
+          expect(worker.childPool.getAllFree().length).toEqual(1)
           resolve()
         })
 
@@ -662,7 +662,7 @@ function sandboxProcessTests(
             expect(
               Object.keys(worker.childPool.retained).length
               + worker.childPool.getAllFree().length,
-            ).to.eql(1)
+            ).toEqual(1)
             await after4()
           }
           catch (err) {
@@ -1524,7 +1524,7 @@ function sandboxProcessTests(
       await worker.close()
 
       // ensure the child did get cleaned up
-      expect(!!child.killed).to.eql(true)
+      expect(!!child.killed).toEqual(true)
       expect(Object.keys(worker.childPool.retained)).toHaveLength(0)
       expect(worker.childPool.getAllFree()).toHaveLength(0)