test(kernel): adjust worker tests

Author: jlenon7

src/worker/WorkerTaskBuilder.ts

@@ -32,11 +32,6 @@ export class WorkerTaskBuilder {
      */
     connection?: string
 
-    /**
-     * The interval instance of the worker task.
-     */
-    interval?: NodeJS.Timeout
-
     /**
      * Define if the worker task is registered.
      */
@@ -51,11 +46,6 @@ export class WorkerTaskBuilder {
      * The handler of the worker task.
      */
     handler?: (ctx: Context) => any | Promise<any>
-
-    /**
-     * Define if the worker task is running.
-     */
-    isRunning?: boolean
   } = {}
 
   private timers: NodeJS.Timeout[] = []

tests/unit/drivers/AwsSqsDriverTest.ts

@@ -11,8 +11,8 @@ import { Is, Path } from '@athenna/common'
 import { EnvHelper } from '@athenna/config'
 import { LoggerProvider } from '@athenna/logger'
 import { BaseTest } from '#tests/helpers/BaseTest'
-import { Queue, QueueProvider, WorkerProvider } from '#src'
-import { Test, type Context, BeforeEach, AfterEach, Skip } from '@athenna/test'
+import { Queue, WorkerProvider, QueueProvider } from '#src'
+import { Test, type Context, BeforeEach, AfterEach, Skip, AfterAll } from '@athenna/test'
 
 export class AwsSqsDriverTest extends BaseTest {
   @BeforeEach()
@@ -36,6 +36,25 @@ export class AwsSqsDriverTest extends BaseTest {
     Config.clear()
   }
 
+  @AfterAll()
+  public async afterAll() {
+    await Config.loadAll(Path.fixtures('config'))
+
+    new QueueProvider().register()
+    new WorkerProvider().register()
+    new LoggerProvider().register()
+
+    await Queue.connection('aws_sqs').truncate().catch()
+
+    await Queue.closeAll()
+
+    Queue.worker().close()
+
+    ioc.reconstruct()
+
+    Config.clear()
+  }
+
   @Test()
   public async shouldBeAbleToConnectToDriver({ assert }: Context) {
     Queue.connection('aws_sqs')

tests/unit/providers/WorkerProviderTest.ts

@@ -45,7 +45,14 @@ export class WorkerProviderTest {
     new QueueProvider().register()
     new WorkerProvider().register()
 
-    assert.lengthOf(Queue.worker().getWorkerTasks(), 0)
+    new QueueProvider().shutdown()
+    new WorkerProvider().shutdown()
+
+    assert.isTrue(
+      Queue.worker()
+        .getWorkerTasks()
+        .every(worker => worker.worker.isRegistered === false)
+    )
   }
 
   @Test()