Файл: sngine-v2.8/Script/includes/libs/AWS/Aws/Handler/GuzzleV6/GuzzleHandler.php
Строк: 101
<?php
namespace AwsHandlerGuzzleV6;
use Exception;
use GuzzleHttpExceptionConnectException;
use GuzzleHttpExceptionRequestException;
use GuzzleHttpPromise;
use GuzzleHttpClient;
use GuzzleHttpClientInterface;
use GuzzleHttpTransferStats;
use PsrHttpMessageRequestInterface as Psr7Request;
/**
* A request handler that sends PSR-7-compatible requests with Guzzle 6.
*/
class GuzzleHandler
{
/** @var ClientInterface */
private $client;
/**
* @param ClientInterface $client
*/
public function __construct(ClientInterface $client = null)
{
$this->client = $client ?: new Client();
}
/**
* @param Psr7Request $request
* @param array $options
*
* @return PromisePromise
*/
public function __invoke(Psr7Request $request, array $options = [])
{
$request = $request->withHeader(
'User-Agent',
$request->getHeaderLine('User-Agent')
. ' ' . GuzzleHttpdefault_user_agent()
);
return $this->client->sendAsync($request, $this->parseOptions($options))
->otherwise(
static function (Exception $e) {
$error = [
'exception' => $e,
'connection_error' => $e instanceof ConnectException,
'response' => null,
];
if ($e instanceof RequestException && $e->getResponse()) {
$error['response'] = $e->getResponse();
}
return new PromiseRejectedPromise($error);
}
);
}
private function parseOptions(array $options)
{
if (isset($options['http_stats_receiver'])) {
$fn = $options['http_stats_receiver'];
unset($options['http_stats_receiver']);
$prev = isset($options['on_stats'])
? $options['on_stats']
: null;
$options['on_stats'] = static function (
TransferStats $stats
) use ($fn, $prev) {
if (is_callable($prev)) {
$prev($stats);
}
$transferStats = ['total_time' => $stats->getTransferTime()];
$transferStats += $stats->getHandlerStats();
$fn($transferStats);
};
}
return $options;
}
}