feat: add Worker::reset() method and call it in beforeEach hooks

Author: Алексей Тихомиров

src/Worker.php

@@ -178,6 +178,18 @@ public function getMaxTime(): int
         return $this->maxTime;
     }
 
+    /**
+     * Reset worker state for testing or reuse.
+     * Clears counters and limits to initial values.
+     */
+    public function reset(): void
+    {
+        $this->jobsProcessed = 0;
+        $this->maxJobs = 0;
+        $this->maxTime = 0;
+        $this->startTime = time();
+    }
+
     public function getMemoryLimit(): int
     {
         return $this->memoryLimit;

tests/Feature/CliIntegrationTest.php

@@ -31,6 +31,9 @@
 
     // Повторная очистка кэша
     wp_cache_flush();
+
+    // Сброс состояния воркера для каждого теста
+    WPQueue::worker()->reset();
 });
 
 afterEach(function (): void {
@@ -192,7 +195,7 @@
     $worker->runNextJob('default');
 
     $logs = WPQueue::logs()->recent(10);
-    $failed = array_filter($logs, fn ($log) => $log['status'] === 'failed');
+    $failed = array_filter($logs, fn($log) => $log['status'] === 'failed');
 
     expect($failed)->not->toBeEmpty();
 });
@@ -207,7 +210,7 @@
 
     // Проверяем что задача провалилась
     $logs = WPQueue::logs()->recent(10);
-    $failed = array_filter($logs, fn ($log) => $log['status'] === 'failed');
+    $failed = array_filter($logs, fn($log) => $log['status'] === 'failed');
 
     expect($failed)->not->toBeEmpty();
 
@@ -218,7 +221,7 @@
 
     // Проверяем что теперь 2 проваленные задачи
     $logs = WPQueue::logs()->recent(10);
-    $failed = array_filter($logs, fn ($log) => $log['status'] === 'failed');
+    $failed = array_filter($logs, fn($log) => $log['status'] === 'failed');
 
     expect(count($failed))->toBe(2);
 });

tests/Feature/QueueIntegrationTest.php

@@ -30,6 +30,9 @@
 
     // Повторная очистка кэша
     wp_cache_flush();
+
+    // Сброс состояния воркера для каждого теста
+    WPQueue::worker()->reset();
 });
 
 afterEach(function (): void {

tests/Feature/RestApiIntegrationTest.php

@@ -26,6 +26,9 @@
     // Повторная очистка кэша
     wp_cache_flush();
 
+    // Сброс состояния воркера для каждого теста
+    WPQueue::worker()->reset();
+
     // Мок для REST API
     global $wp_rest_server;
     $wp_rest_server = new \WP_REST_Server();