Include sleep option in queue config (#564)

* feat/add-sleep-option-to-queue-config | expose sleep option to QueueConfig

* feat/add-sleep-option-to-queue-config | include default sleep option in nativephp config file

Author: chr15k

config/nativephp.php

@@ -141,6 +141,7 @@
             'queues' => ['default'],
             'memory_limit' => 128,
             'timeout' => 60,
+            'sleep' => 3,
         ],
     ],
 

src/DTOs/QueueConfig.php

@@ -12,6 +12,7 @@ public function __construct(
         public readonly array $queuesToConsume,
         public readonly int $memoryLimit,
         public readonly int $timeout,
+        public readonly int $sleep,
     ) {}
 
     /**
@@ -26,6 +27,7 @@ function (array|string $worker, string $alias) {
                     $worker['queues'] ?? ['default'],
                     $worker['memory_limit'] ?? 128,
                     $worker['timeout'] ?? 60,
+                    $worker['sleep'] ?? 3,
                 );
             },
             $config,

src/QueueWorker.php

@@ -31,6 +31,7 @@ public function up(string|QueueConfig $config): void
                 '--queue='.implode(',', $config->queuesToConsume),
                 "--memory={$config->memoryLimit}",
                 "--timeout={$config->timeout}",
+                "--sleep={$config->sleep}",
             ],
             'queue_'.$config->alias,
             persistent: true,

tests/DTOs/QueueWorkerTest.php

@@ -21,6 +21,8 @@
                 fn (QueueConfig $config) => $config->alias === $worker)))->memoryLimit->toBe(128);
             expect(Arr::first(array_filter($configObject,
                 fn (QueueConfig $config) => $config->alias === $worker)))->timeout->toBe(60);
+            expect(Arr::first(array_filter($configObject,
+                fn (QueueConfig $config) => $config->alias === $worker)))->sleep->toBe(3);
 
             continue;
         }
@@ -35,6 +37,8 @@
             fn (QueueConfig $config) => $config->alias === $alias)))->memoryLimit->toBe($worker['memory_limit'] ?? 128);
         expect(Arr::first(array_filter($configObject,
             fn (QueueConfig $config) => $config->alias === $alias)))->timeout->toBe($worker['timeout'] ?? 60);
+        expect(Arr::first(array_filter($configObject,
+            fn (QueueConfig $config) => $config->alias === $alias)))->sleep->toBe($worker['sleep'] ?? 3);
     }
 })->with([
     [
@@ -44,6 +48,7 @@
                     'queues' => ['default'],
                     'memory_limit' => 64,
                     'timeout' => 60,
+                    'sleep' => 3,
                 ],
             ],
         ],

tests/Fakes/FakeQueueWorkerTest.php

@@ -17,8 +17,8 @@
 it('asserts up using callable', function () {
     swap(QueueWorkerContract::class, $fake = app(QueueWorkerFake::class));
 
-    $fake->up(new QueueConfig('testA', ['default'], 123, 123));
-    $fake->up(new QueueConfig('testB', ['default'], 123, 123));
+    $fake->up(new QueueConfig('testA', ['default'], 123, 123, 0));
+    $fake->up(new QueueConfig('testB', ['default'], 123, 123, 0));
 
     $fake->assertUp(fn (QueueConfig $up) => $up->alias === 'testA');
     $fake->assertUp(fn (QueueConfig $up) => $up->alias === 'testB');

tests/QueueWorker/QueueWorkerTest.php

@@ -9,7 +9,7 @@
 
     $workerName = 'some_worker';
 
-    $config = new QueueConfig($workerName, ['default'], 128, 61);
+    $config = new QueueConfig($workerName, ['default'], 128, 61, 5);
 
     QueueWorker::up($config);
 
@@ -20,6 +20,7 @@
             '--queue=default',
             '--memory=128',
             '--timeout=61',
+            '--sleep=5',
         ]);
 
         expect($iniSettings)->toBe([