MessengerAzureBundle/tests/Messenger/Transport/AzureTransportFactoryTest.php at 4348828708f0e3708f45b91d19598d82973462ba · AymDev/MessengerAzureBundle · 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
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
<?php

declare(strict_types=1);

namespace Tests\AymDev\MessengerAzureBundle\Messenger\Transport;

use AymDev\MessengerAzureBundle\Messenger\Transport\AzureHttpClientConfigurationBuilder;
use AymDev\MessengerAzureBundle\Messenger\Transport\AzureHttpClientFactory;
use AymDev\MessengerAzureBundle\Messenger\Transport\AzureTransport;
use AymDev\MessengerAzureBundle\Messenger\Transport\AzureTransportFactory;
use AymDev\MessengerAzureBundle\Messenger\Transport\DsnParser;
use PHPUnit\Framework\TestCase;
use Symfony\Component\Messenger\Transport\Serialization\SerializerInterface;

final class AzureTransportFactoryTest extends TestCase
{
    /**
     * The factory must supports DSN prefixed with "azure://"
     */
    public function testSupportsAzureDsn(): void
    {
        $factory = new AzureTransportFactory(
            new DsnParser(),
            new AzureHttpClientConfigurationBuilder(),
            new AzureHttpClientFactory()
        );

        self::assertTrue($factory->supports('azure://KeyName:Key@namespace', []));
        self::assertTrue($factory->supports('azure://', []));
        self::assertFalse($factory->supports('test://something', []));
    }

    /**
     * The entity path is mandatory
     */
    public function testThrowsOnMissingEntityPath(): void
    {
        self::expectException(\InvalidArgumentException::class);
        self::expectExceptionCode(1643989596);

        $factory = new AzureTransportFactory(
            new DsnParser(),
            new AzureHttpClientConfigurationBuilder(),
            new AzureHttpClientFactory()
        );

        $factory->createTransport(
            'azure://KeyName:Key@namespace',
            [
                'transport_name' => 'test-transport',
            ],
            self::createStub(SerializerInterface::class)
        );
    }

    /**
     * The receive mode can only be peek-lock or receive-and-delete
     */
    public function testThrowsOnInvalidReceiveMode(): void
    {
        self::expectException(\InvalidArgumentException::class);
        self::expectExceptionCode(1643994036);

        $factory = new AzureTransportFactory(
            new DsnParser(),
            new AzureHttpClientConfigurationBuilder(),
            new AzureHttpClientFactory()
        );

        $factory->createTransport(
            'azure://KeyName:Key@namespace',
            [
                'transport_name' => 'test-transport',
                'entity_path' => 'entity',
                'receive_mode' => 'invalid',
            ],
            self::createStub(SerializerInterface::class)
        );
    }

    /**
     * The factory must return an Azure transport
     */
    public function testCreateTransport(): void
    {
        $factory = new AzureTransportFactory(
            new DsnParser(),
            new AzureHttpClientConfigurationBuilder(),
            new AzureHttpClientFactory()
        );

        $transport = $factory->createTransport(
            'azure://KeyName:Key@namespace',
            [
                'transport_name' => 'test-transport',
                'entity_path' => 'entity',
            ],
            self::createStub(SerializerInterface::class)
        );

        self::assertInstanceOf(AzureTransport::class, $transport);
    }
}