workflow/tests/Unit/Traits/MonitorQueueConnectionTest.php at 1bb49dbe5884c0f492e3a26769a5a67fd8036b7f · durable-workflow/workflow · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
<?php

declare(strict_types=1);

namespace Tests\Unit\Traits;

use Tests\TestCase;
use Workflow\Traits\MonitorQueueConnection;

class MonitorQueueConnectionTest extends TestCase
{
    public function testReturnsDefaultConnection(): void
    {
        config([
            'queue.default' => 'sync',
            'workflows.monitor_connection' => config('queue.default'),
        ]);

        $instance = $this->makeAnonymousTraitInstance();

        $this->assertSame(config('queue.default'), $instance->viaConnection());
    }

    public function testReturnsDefaultQueue(): void
    {
        config([
            'queue.default' => 'sync',
            'workflows.monitor_connection' => config('queue.default'),
        ]);

        $instance = $this->makeAnonymousTraitInstance();

        $this->assertSame('default', $instance->viaQueue());
    }

    public function testReturnsCustomConnection(): void
    {
        config([
            'queue.default' => 'sync',
            'workflows.monitor_connection' => 'custom_connection',
        ]);

        $instance = $this->makeAnonymousTraitInstance();

        $this->assertSame('custom_connection', $instance->viaConnection());
    }

    public function testReturnsCustomQueue(): void
    {
        config([
            'queue.default' => 'sync',
            'workflows.monitor_connection' => config('queue.default'),
            'workflows.monitor_queue' => 'custom_queue',
        ]);

        $instance = $this->makeAnonymousTraitInstance();

        $this->assertSame('custom_queue', $instance->viaQueue());
    }

    private function makeAnonymousTraitInstance(): object
    {
        return new class() {
            use MonitorQueueConnection;
        };
    }
}