File: PublishBatchInputTest.php

package info (click to toggle)
php-async-aws-sns 1.11.0-1
  • links: PTS, VCS
  • area: main
  • in suites: forky, sid
  • size: 516 kB
  • sloc: php: 2,567; makefile: 33
file content (45 lines) | stat: -rw-r--r-- 1,759 bytes parent folder | download | duplicates (3)
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
<?php

namespace AsyncAws\Sns\Tests\Unit\Input;

use AsyncAws\Core\Test\TestCase;
use AsyncAws\Sns\Input\PublishBatchInput;
use AsyncAws\Sns\ValueObject\MessageAttributeValue;
use AsyncAws\Sns\ValueObject\PublishBatchRequestEntry;

class PublishBatchInputTest extends TestCase
{
    public function testRequest(): void
    {
        $input = new PublishBatchInput([
            'TopicArn' => 'arn:aws:sns:us-east-1:46563727:async',
            'PublishBatchRequestEntries' => [new PublishBatchRequestEntry([
                'Id' => 'qwertyuiop',
                'Message' => 'Foo',
                'Subject' => 'MySubject',
                'MessageAttributes' => ['myAttribute' => new MessageAttributeValue([
                    'DataType' => 'String',
                    'StringValue' => 'Foobar',
                ])],
            ])],
        ]);

        // see https://docs.aws.amazon.com/sns/latest/api/API_PublishBatch.html
        $expected = '
            POST / HTTP/1.0
            Content-Type: application/x-www-form-urlencoded

            Action=PublishBatch
            &PublishBatchRequestEntries.member.1.Id=qwertyuiop
            &PublishBatchRequestEntries.member.1.Message=Foo
            &PublishBatchRequestEntries.member.1.MessageAttributes.entry.1.Name=myAttribute
            &PublishBatchRequestEntries.member.1.MessageAttributes.entry.1.Value.DataType=String
            &PublishBatchRequestEntries.member.1.MessageAttributes.entry.1.Value.StringValue=Foobar
            &PublishBatchRequestEntries.member.1.Subject=MySubject
            &TopicArn=arn%3Aaws%3Asns%3Aus-east-1%3A46563727%3Aasync
            &Version=2010-03-31
                ';

        self::assertRequestEqualsHttpRequest($expected, $input->request());
    }
}