From 3f355a89fb0ed102e49cb2addb75010d729586fe Mon Sep 17 00:00:00 2001
From: Chris Keller <ctk8501@gmail.com>
Date: Tue, 22 Apr 2025 18:51:39 -0500
Subject: [PATCH] feat/add-sleep-option-to-queue-config | expose sleep option
 to QueueConfig

---
 src/DTOs/QueueConfig.php              | 2 ++
 src/QueueWorker.php                   | 1 +
 tests/DTOs/QueueWorkerTest.php        | 5 +++++
 tests/Fakes/FakeQueueWorkerTest.php   | 4 ++--
 tests/QueueWorker/QueueWorkerTest.php | 3 ++-
 5 files changed, 12 insertions(+), 3 deletions(-)

diff --git a/src/DTOs/QueueConfig.php b/src/DTOs/QueueConfig.php
index 0ec3ca0..df04d0c 100644
--- a/src/DTOs/QueueConfig.php
+++ b/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,
diff --git a/src/QueueWorker.php b/src/QueueWorker.php
index 875a5c2..f9c2ea1 100644
--- a/src/QueueWorker.php
+++ b/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,
diff --git a/tests/DTOs/QueueWorkerTest.php b/tests/DTOs/QueueWorkerTest.php
index 76209c8..01197aa 100644
--- a/tests/DTOs/QueueWorkerTest.php
+++ b/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,
                 ],
             ],
         ],
diff --git a/tests/Fakes/FakeQueueWorkerTest.php b/tests/Fakes/FakeQueueWorkerTest.php
index 4b22f34..150f2a2 100644
--- a/tests/Fakes/FakeQueueWorkerTest.php
+++ b/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');
diff --git a/tests/QueueWorker/QueueWorkerTest.php b/tests/QueueWorker/QueueWorkerTest.php
index 2a6c137..7605a56 100644
--- a/tests/QueueWorker/QueueWorkerTest.php
+++ b/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([