feat: implement queue assertion helpers

docker-compose.yml

@@ -8,3 +8,5 @@ services:
       - 443:443
     volumes:
       - ./:/app
+    extra_hosts:
+      - "host.docker.internal:host-gateway"

src/Traits/FixturesTrait.php

@@ -132,6 +132,13 @@ public function assertEqualsFixture(string $fixture, $data, bool $exportMode = f
      *                           current version is selected; if none match, falls back to $fixture as-is.
      */
     public function assertEqualsVersionedFixture(string $fixture, $data, array $versions = [], bool $exportMode = false): void
+    {
+        $fixture = $this->getVersioningFixtureName($fixture, $versions);
+
+        $this->assertEqualsFixture($fixture, $data, $exportMode);
+    }
+
+    protected function getVersioningFixtureName(string $fixture, array $versions = []): string
     {
         $currentVersion = (int) app()->version();
         list($filename, $directory) = extract_last_part($fixture, DIRECTORY_SEPARATOR);
@@ -145,11 +152,9 @@ public function assertEqualsVersionedFixture(string $fixture, $data, array $vers
             }
         }
 
-        $finalFixture = (is_null($fixtureVersion))
+        return (is_null($fixtureVersion))
             ? $fixture
             : "{$prefix}laravel_before_v{$fixtureVersion}/{$filename}";
-
-        $this->assertEqualsFixture($finalFixture, $data, $exportMode);
     }
 
     public function exportJson($fixture, $data): void

src/Traits/ReflectionTrait.php

@@ -0,0 +1,24 @@
+<?php
+
+namespace RonasIT\Support\Traits;
+
+use ReflectionClass;
+
+trait ReflectionTrait
+{
+    protected function getObjectAttributes(object $object): array
+    {
+        $reflection = new ReflectionClass($object);
+        $attributes = [];
+
+        foreach ($reflection->getProperties() as $property) {
+            if ($property->isStatic() || !$property->isInitialized($object)) {
+                continue;
+            }
+
+            $attributes[$property->getName()] = $property->getValue($object);
+        }
+
+        return $attributes;
+    }
+}

src/Traits/TestingTrait.php

@@ -2,11 +2,15 @@
 
 namespace RonasIT\Support\Traits;
 
+use Illuminate\Support\Arr;
+use Illuminate\Support\Facades\Queue;
+
 trait TestingTrait
 {
     use FixturesTrait;
     use MailsMockTrait;
     use MockTrait;
+    use ReflectionTrait;
 
     protected function assertExceptionThrew(string $expectedClassName, string $expectedMessage, bool $isStrict = true): void
     {
@@ -18,4 +22,45 @@ protected function assertExceptionThrew(string $expectedClassName, string $expec
 
         $this->expectExceptionMessageMatches("/{$expectedMessage}/");
     }
+
+    public function assertQueueEqualsVersioningFixture(string $fixture, array $versions = [], bool $exportMode = false): void
+    {
+        $fixture = $this->getVersioningFixtureName($fixture, $versions);
+
+        $this->assertQueueEqualsFixture($fixture, $exportMode);
+    }
+
+    public function assertQueueEqualsFixture(string $fixture, bool $exportMode = false): void
+    {
+        $actualData = [];
+
+        foreach (Queue::pushedJobs() as $namespace => $jobs) {
+            $actualData[$namespace] = Arr::map($jobs, function ($job) {
+                $job = $this->getJobObject($job);
+
+                return $this->getObjectAttributes($job);
+            });
+        }
+
+        $actualData = json_decode(json_encode($actualData), true);
+
+        $this->assertEqualsFixture("queue_states/{$fixture}", $actualData, $exportMode);
+    }
+
+    protected function assertQueueEmpty(): void
+    {
+        $this->assertEquals([], Queue::pushedJobs(), 'Failed assert that faked queue is empty.');
+    }
+
+    protected function getJobObject(array $job): object
+    {
+        if (is_object($job['job'])) {
+            return $job['job'];
+        }
+
+        $data = Arr::wrap($job['data']);
+        $className = $job['job'];
+
+        return new $className(...$data);
+    }
 }

tests/TestingTraitTest.php

@@ -2,13 +2,29 @@
 
 namespace RonasIT\Support\Tests;
 
+use Illuminate\Support\Carbon;
+use Illuminate\Support\Facades\Queue;
+use Illuminate\Support\Str;
 use RonasIT\Support\Exceptions\ModelFactoryNotFound;
+use RonasIT\Support\Tests\Support\Mock\Jobs\AnotherTestJob;
+use RonasIT\Support\Tests\Support\Mock\Jobs\TestJob;
 use RonasIT\Support\Traits\TestingTrait;
 
 class TestingTraitTest extends TestCase
 {
     use TestingTrait;
 
+    public static int $laravelMajorVersion;
+
+    public function setUp(): void
+    {
+        parent::setUp();
+
+        Carbon::setTestNow('2020-01-01');
+
+        self::$laravelMajorVersion ??= (int)Str::before($this->app->version(), '.');
+    }
+
     public function testAssertExceptionThrew(): void
     {
         $this->assertExceptionThrew(ModelFactoryNotFound::class, 'full error message');
@@ -26,4 +42,51 @@ public function testAssertExceptionThrewNotStrictly(): void
 
         throw new ModelFactoryNotFound('full error message');
     }
+
+    public function testAssertQueueEqualsFixture(): void
+    {
+        Queue::fake();
+
+        TestJob::dispatch('some payload', ['another payload'])->delay(now()->addMinute());
+
+        $this->assertQueueEqualsVersioningFixture('assert_queue_equals');
+    }
+
+    public function testAssertQueueEqualsFixturePushAsStringWithParams(): void
+    {
+        Queue::fake();
+
+        Queue::push(TestJob::class, [
+            'payload' => 'some payload',
+            'anotherPayload' => ['another payload'],
+        ]);
+
+        $this->assertQueueEqualsVersioningFixture('assert_queue_equals_as_class_name_with_params');
+    }
+
+    public function testAssertQueueEqualsFixturePushAsStringWithOneParam(): void
+    {
+        Queue::fake();
+
+        Queue::push(TestJob::class, 'some payload');
+
+        $this->assertQueueEqualsVersioningFixture('assert_queue_equals_as_class_name_with_one_param');
+    }
+
+    public function testAssertQueueEqualsFixtureDifferentJobs(): void
+    {
+        Queue::fake();
+
+        TestJob::dispatch('some payload', ['another payload']);
+        AnotherTestJob::dispatch('some payload', ['another payload']);
+
+        $this->assertQueueEqualsVersioningFixture('assert_queue_equals_different_jobs');
+    }
+
+    public function testAssertQueueEmpty()
+    {
+        Queue::fake();
+
+        $this->assertQueueEmpty();
+    }
 }

tests/fixtures/TestingTraitTest/queue_states/assert_queue_equals.json

@@ -0,0 +1,24 @@
+{
+    "RonasIT\\Support\\Tests\\Support\\Mock\\Jobs\\TestJob": [
+        {
+            "payload": "some payload",
+            "anotherPayload": [
+                "another payload"
+            ],
+            "tries": 5,
+            "job": null,
+            "connection": null,
+            "queue": "some_queue",
+            "messageGroup": null,
+            "deduplicator": null,
+            "debounceOwner": "",
+            "delay": "2020-01-01T00:01:00.000000Z",
+            "afterCommit": null,
+            "middleware": [],
+            "chained": [],
+            "chainConnection": null,
+            "chainQueue": null,
+            "chainCatchCallbacks": null
+        }
+    ]
+}

tests/fixtures/TestingTraitTest/queue_states/assert_queue_equals_as_class_name_with_one_param.json

@@ -0,0 +1,22 @@
+{
+    "RonasIT\\Support\\Tests\\Support\\Mock\\Jobs\\TestJob": [
+        {
+            "payload": "some payload",
+            "anotherPayload": [],
+            "tries": 5,
+            "job": null,
+            "connection": null,
+            "queue": "some_queue",
+            "messageGroup": null,
+            "deduplicator": null,
+            "debounceOwner": "",
+            "delay": null,
+            "afterCommit": null,
+            "middleware": [],
+            "chained": [],
+            "chainConnection": null,
+            "chainQueue": null,
+            "chainCatchCallbacks": null
+        }
+    ]
+}

tests/fixtures/TestingTraitTest/queue_states/assert_queue_equals_as_class_name_with_params.json

@@ -0,0 +1,24 @@
+{
+    "RonasIT\\Support\\Tests\\Support\\Mock\\Jobs\\TestJob": [
+        {
+            "payload": "some payload",
+            "anotherPayload": [
+                "another payload"
+            ],
+            "tries": 5,
+            "job": null,
+            "connection": null,
+            "queue": "some_queue",
+            "messageGroup": null,
+            "deduplicator": null,
+            "debounceOwner": "",
+            "delay": null,
+            "afterCommit": null,
+            "middleware": [],
+            "chained": [],
+            "chainConnection": null,
+            "chainQueue": null,
+            "chainCatchCallbacks": null
+        }
+    ]
+}

tests/fixtures/TestingTraitTest/queue_states/assert_queue_equals_different_jobs.json

@@ -0,0 +1,42 @@
+{
+    "RonasIT\\Support\\Tests\\Support\\Mock\\Jobs\\TestJob": [
+        {
+            "payload": "some payload",
+            "anotherPayload": [
+                "another payload"
+            ],
+            "tries": 5,
+            "job": null,
+            "connection": null,
+            "queue": "some_queue",
+            "messageGroup": null,
+            "deduplicator": null,
+            "debounceOwner": "",
+            "delay": null,
+            "afterCommit": null,
+            "middleware": [],
+            "chained": [],
+            "chainConnection": null,
+            "chainQueue": null,
+            "chainCatchCallbacks": null
+        }
+    ],
+    "RonasIT\\Support\\Tests\\Support\\Mock\\Jobs\\AnotherTestJob": [
+        {
+            "tries": 5,
+            "job": null,
+            "connection": null,
+            "queue": null,
+            "messageGroup": null,
+            "deduplicator": null,
+            "debounceOwner": "",
+            "delay": null,
+            "afterCommit": null,
+            "middleware": [],
+            "chained": [],
+            "chainConnection": null,
+            "chainQueue": null,
+            "chainCatchCallbacks": null
+        }
+    ]
+}

tests/fixtures/TestingTraitTest/queue_states/laravel_before_v11/assert_queue_equals.json

@@ -0,0 +1,21 @@
+{
+    "RonasIT\\Support\\Tests\\Support\\Mock\\Jobs\\TestJob": [
+        {
+            "tries": 5,
+            "payload": "some payload",
+            "anotherPayload": [
+                "another payload"
+            ],
+            "job": null,
+            "connection": null,
+            "queue": "some_queue",
+            "delay": "2020-01-01T00:01:00.000000Z",
+            "afterCommit": null,
+            "middleware": [],
+            "chained": [],
+            "chainConnection": null,
+            "chainQueue": null,
+            "chainCatchCallbacks": null
+        }
+    ]
+}

tests/fixtures/TestingTraitTest/queue_states/laravel_before_v11/assert_queue_equals_as_class_name.json

@@ -0,0 +1,19 @@
+{
+    "RonasIT\\Support\\Tests\\Support\\Mock\\Jobs\\TestJob": [
+        {
+            "tries": 5,
+            "payload": "",
+            "anotherPayload": [],
+            "job": null,
+            "connection": null,
+            "queue": "some_queue",
+            "delay": null,
+            "afterCommit": null,
+            "middleware": [],
+            "chained": [],
+            "chainConnection": null,
+            "chainQueue": null,
+            "chainCatchCallbacks": null
+        }
+    ]
+}

tests/fixtures/TestingTraitTest/queue_states/laravel_before_v11/assert_queue_equals_as_class_name_with_one_param.json

@@ -0,0 +1,19 @@
+{
+    "RonasIT\\Support\\Tests\\Support\\Mock\\Jobs\\TestJob": [
+        {
+            "tries": 5,
+            "payload": "some payload",
+            "anotherPayload": [],
+            "job": null,
+            "connection": null,
+            "queue": "some_queue",
+            "delay": null,
+            "afterCommit": null,
+            "middleware": [],
+            "chained": [],
+            "chainConnection": null,
+            "chainQueue": null,
+            "chainCatchCallbacks": null
+        }
+    ]
+}