queue/tests/Unit/Message/IdEnvelopeTest.php at 209ba7bcdf74ffb347f61a7ac860e0ed43975ff8 · yiisoft/queue · 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
104
105
106
107
108
109
<?php

declare(strict_types=1);

namespace Yiisoft\Queue\Tests\Unit\Message;

use PHPUnit\Framework\TestCase;
use Yiisoft\Queue\Message\IdEnvelope;
use Yiisoft\Queue\Message\Message;
use Yiisoft\Queue\Message\MessageInterface;

final class IdEnvelopeTest extends TestCase
{
    public function testConstructor(): void
    {
        $message = $this->createMessage();
        $id = 'test-id';

        $envelope = new IdEnvelope($message, $id);

        $this->assertSame($message, $envelope->getMessage());
        $this->assertSame($id, $envelope->getId());
    }

    public function testFromMessageWithStringId(): void
    {
        $id = 'test-id';
        $message = $this->createMessage([IdEnvelope::MESSAGE_ID_KEY => $id]);

        $envelope = IdEnvelope::fromMessage($message);

        $this->assertSame($id, $envelope->getId());
    }

    public function testFromMessageWithIntId(): void
    {
        $id = 123;
        $message = $this->createMessage([IdEnvelope::MESSAGE_ID_KEY => $id]);

        $envelope = IdEnvelope::fromMessage($message);

        $this->assertSame($id, $envelope->getId());
    }

    public function testFromMessageWithNullId(): void
    {
        $message = $this->createMessage();

        $envelope = IdEnvelope::fromMessage($message);

        $this->assertNull($envelope->getId());
    }

    public function testFromMessageWithObjectHavingToString(): void
    {
        $stringableObject = new class () {
            public function __toString(): string
            {
                return 'object-id';
            }
        };
        $message = $this->createMessage([IdEnvelope::MESSAGE_ID_KEY => $stringableObject]);
        $envelope = IdEnvelope::fromMessage($message);

        $this->assertSame('object-id', $envelope->getId());
    }

    public function testFromMessageWithInvalidIdType(): void
    {
        $invalidId = ['array-cannot-be-id'];
        $message = $this->createMessage([IdEnvelope::MESSAGE_ID_KEY => $invalidId]);
        $message = IdEnvelope::fromMessage($message);

        $this->assertNull($message->getId());
    }

    public function testGetEnvelopeMetadata(): void
    {
        $id = 'test-id';
        $message = $this->createMessage();
        $envelope = new IdEnvelope($message, $id);

        $metadata = $envelope->getMetadata();

        $this->assertArrayHasKey(IdEnvelope::MESSAGE_ID_KEY, $metadata);
        $this->assertSame($id, $metadata[IdEnvelope::MESSAGE_ID_KEY]);
    }

    public function testFromData(): void
    {
        $handlerName = 'test-handler';
        $data = ['key' => 'value'];
        $metadata = ['meta' => 'data', IdEnvelope::MESSAGE_ID_KEY => 'test-id'];

        $envelope = IdEnvelope::fromData($handlerName, $data, $metadata);

        $this->assertInstanceOf(IdEnvelope::class, $envelope);
        $this->assertSame($handlerName, $envelope->getHandlerName());
        $this->assertSame($data, $envelope->getData());
        $this->assertArrayHasKey('meta', $envelope->getMetadata());
        $this->assertSame('data', $envelope->getMetadata()['meta']);
        $this->assertSame('test-id', $envelope->getId());
    }

    private function createMessage(array $metadata = []): MessageInterface
    {
        return new Message('test-handler', ['test-data'], $metadata);
    }
}