Merge pull request #38 from AthennaIO/develop

test(process): adjust drivers test

Author: jlenon7

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@athenna/queue",
-  "version": "5.21.0",
+  "version": "5.22.0",
   "description": "The Athenna queue handler.",
   "license": "MIT",
   "author": "João Lenon <lenon@athenna.io>",

package.json

@@ -281,6 +281,7 @@ export class MemoryDriver extends Driver {
         job.availableAt = Date.now() + this.noAckDelayMs + requeueJitterMs
       }
     } catch (error) {
+      console.log('error', error)
       await new MemoryDriverExceptionHandler().handle({
         job,
         error,

src/drivers/MemoryDriver.ts

@@ -158,19 +158,20 @@ export class AwsSqsDriverTest extends BaseTest {
 
   @Test()
   public async shouldBeAbleToProcessTheNextJobFromTheQueueWithAProcessor({ assert }: Context) {
-    assert.plan(1)
-
     const queue = Queue.connection('aws_sqs')
 
     await queue.add({ name: 'lenon' })
 
+    let data: any = {}
+    let attempts: number
+
     await queue.process(async job => {
-      assert.containSubset(job, {
-        attempts: 1,
-        queue: 'default',
-        data: { name: 'lenon' }
-      })
+      data = job.data
+      attempts = job.attempts
     })
+
+    assert.equal(attempts, 0)
+    assert.equal(data.name, 'lenon')
   }
 
   @Test()

tests/unit/drivers/AwsSqsDriverTest.ts

@@ -162,19 +162,20 @@ export class DatabaseDriverTest {
 
   @Test()
   public async shouldBeAbleToProcessTheNextJobFromTheQueueWithAProcessor({ assert }: Context) {
-    assert.plan(1)
-
     const queue = Queue.connection('database')
 
     await queue.add({ name: 'lenon' })
 
+    let data: any = {}
+    let attempts: number
+
     await queue.process(async job => {
-      assert.containSubset(job, {
-        attempts: 1,
-        queue: 'default',
-        data: { name: 'lenon' }
-      })
+      data = job.data
+      attempts = job.attempts
     })
+
+    assert.equal(attempts, 0)
+    assert.equal(data.name, 'lenon')
   }
 
   @Test()

tests/unit/drivers/DatabaseDriverTest.ts

@@ -150,18 +150,20 @@ export class MemoryDriverTest {
 
   @Test()
   public async shouldBeAbleToProcessTheNextJobFromTheQueueWithAProcessor({ assert }: Context) {
-    assert.plan(1)
-
     const queue = Queue.connection('memory')
 
     await queue.add({ name: 'lenon' })
 
+    let data: any = {}
+    let attempts: number
+
     await queue.process(async job => {
-      assert.containSubset(job, {
-        attempts: 1,
-        data: { name: 'lenon' }
-      })
+      data = job.data
+      attempts = job.attempts
     })
+
+    assert.equal(attempts, 0)
+    assert.equal(data.name, 'lenon')
   }
 
   @Test()