@@ -78,9 +78,9 @@ discard block |
||
78 | 78 | } |
79 | 79 | } |
80 | 80 | |
81 | - foreach($config['hosts'] as $c) { |
|
82 | - if( $c['aws'] ) { |
|
83 | - $clientBuilder->setHandler( function(array $request) use($c) { |
|
81 | + foreach ($config['hosts'] as $c) { |
|
82 | + if ($c['aws']) { |
|
83 | + $clientBuilder->setHandler(function(array $request) use($c) { |
|
84 | 84 | $psr7Handler = \Aws\default_http_handler(); |
85 | 85 | $signer = new \Aws\Signature\SignatureV4('es', $c['aws_region']); |
86 | 86 | $request['headers']['Host'][0] = parse_url($request['headers']['Host'][0])['host']; |
@@ -100,9 +100,9 @@ discard block |
||
100 | 100 | ); |
101 | 101 | // Send the signed request to Amazon ES |
102 | 102 | /** @var \Psr\Http\Message\ResponseInterface $response */ |
103 | - $response = $psr7Handler($signedRequest)->then(function (\Psr\Http\Message\ResponseInterface $response) { |
|
103 | + $response = $psr7Handler($signedRequest)->then(function(\Psr\Http\Message\ResponseInterface $response) { |
|
104 | 104 | return $response; |
105 | - }, function ($error) { |
|
105 | + }, function($error) { |
|
106 | 106 | return $error['response']; |
107 | 107 | })->wait(); |
108 | 108 | // Convert the PSR-7 response to a RingPHP response |
@@ -111,7 +111,7 @@ discard block |
||
111 | 111 | 'headers' => $response->getHeaders(), |
112 | 112 | 'body' => $response->getBody()->detach(), |
113 | 113 | 'transfer_stats' => ['total_time' => 0], |
114 | - 'effective_url' => (string)$psr7Request->getUri(), |
|
114 | + 'effective_url' => (string) $psr7Request->getUri(), |
|
115 | 115 | ]); |
116 | 116 | }); |
117 | 117 | } |