fix: resolve config providers in queue:work command

Author: RomainLanz

commands/queue_work.ts

@@ -9,7 +9,7 @@
 
 import { flags, BaseCommand } from '@adonisjs/core/ace'
 import type { CommandOptions } from '@adonisjs/core/types/ace'
-import type { QueueManagerConfig } from '@boringnode/queue/types'
+import type { QueueConfig } from '../src/types/main.js'
 
 export default class QueueWork extends BaseCommand {
   static commandName = 'queue:work'
@@ -28,7 +28,7 @@ export default class QueueWork extends BaseCommand {
 
   async run() {
     const { Worker } = await import('@boringnode/queue')
-    const config = this.app.config.get<QueueManagerConfig>('queue')
+    const config = this.app.config.get<QueueConfig>('queue')
 
     /**
      * Commit the router to ensure all routes are registered.
@@ -38,12 +38,26 @@ export default class QueueWork extends BaseCommand {
     const router = await this.app.container.make('router')
     router.commit()
 
+    /**
+     * Resolve adapter factories from config providers
+     */
+    const resolvedAdapters: Record<string, () => any> = {}
+
+    for (const [name, adapterConfig] of Object.entries(config.adapters)) {
+      if (typeof adapterConfig === 'function') {
+        resolvedAdapters[name] = adapterConfig as () => any
+      } else {
+        resolvedAdapters[name] = await adapterConfig.resolver(this.app)
+      }
+    }
+
     const queues = this.queue ? this.queue.split(',').map((q) => q.trim()) : ['default']
 
     this.logger.info(`Starting worker for queues: ${queues.join(', ')}`)
 
     const worker = new Worker({
       ...config,
+      adapters: resolvedAdapters,
       ...(this.concurrency && { concurrency: this.concurrency }),
     })
     await worker.start(queues)