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
|
<?php
declare(strict_types=1);
namespace AsyncAws\Core\Tests\Unit;
use AsyncAws\Core\AbstractApi;
use AsyncAws\Core\Configuration;
use AsyncAws\Core\EndpointDiscovery\EndpointInterface;
use AsyncAws\Core\Request;
use AsyncAws\Core\RequestContext;
use AsyncAws\Core\Response;
use AsyncAws\Core\Stream\StringStream;
use PHPUnit\Framework\TestCase;
use Symfony\Contracts\HttpClient\HttpClientInterface;
use Symfony\Contracts\HttpClient\ResponseInterface;
class AbstractApiTest extends TestCase
{
public function testGetEndpointRegion()
{
$api = new DummyApi();
// Use default region
$endpoint = $api->getEndpoint('/some/path', [], null);
self::assertEquals('https://foobar.us-east-1.amazonaws.com/some/path', $endpoint);
$endpoint = $api->getEndpoint('/some/path', [], 'eu-central-1');
self::assertEquals('https://foobar.eu-central-1.amazonaws.com/some/path', $endpoint);
// Use region from config
$api = new DummyApi(['region' => 'eu-north-1']);
$endpoint = $api->getEndpoint('/some/path', [], null);
self::assertEquals('https://foobar.eu-north-1.amazonaws.com/some/path', $endpoint);
$endpoint = $api->getEndpoint('/some/path', [], 'eu-central-1');
self::assertEquals('https://foobar.eu-central-1.amazonaws.com/some/path', $endpoint);
}
public function testDiscoveredEndpoint()
{
$httpClient = $this->createMock(HttpClientInterface::class);
$api = new DummyApi([
'region' => 'eu-west-1',
'accessKeyId' => 'key',
'accessKeySecret' => 'secret',
], null, $httpClient);
$response = $this->createMock(ResponseInterface::class);
$httpClient->expects(self::once())
->method('request')
->with('GET', 'https://foobar.discovered.amazonaws.com/foo')
->willReturn($response)
;
$response = $api->getResponseExposed(new Request('GET', '/foo', [], [], StringStream::create('')), new RequestContext(['requiresEndpointDiscovery' => true]));
$response->cancel();
}
}
class DummyApi extends AbstractApi
{
public function getEndpoint(string $uri, array $query, ?string $region): string
{
return parent::getEndpoint($uri, $query, $region);
}
public function getResponseExposed(Request $request, ?RequestContext $context = null): Response
{
return parent::getResponse($request, $context);
}
protected function getEndpointMetadata(?string $region): array
{
if (null === $region) {
$region = Configuration::DEFAULT_REGION;
}
return [
'endpoint' => "https://foobar.$region.amazonaws.com",
'signRegion' => $region,
'signService' => 'foobar',
'signVersions' => ['v4'],
];
}
protected function discoverEndpoints(?string $region): array
{
return [new class implements EndpointInterface {
public function getAddress(): string
{
return 'https://foobar.discovered.amazonaws.com';
}
public function getCachePeriodInMinutes(): int
{
return 3600;
}
}];
}
}
|
