Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly
Appearance settings

Commit 0713fbd

Browse filesBrowse files
nicolas-grekasnicolas-grekas
committed
[HttpClient] Add portable HTTP/2 implementation based on Amp's HTTP client
1 parent 83a53a5 commit 0713fbd
Copy full SHA for 0713fbd

19 files changed

+1412
-188
lines changed

‎.appveyor.yml

Copy file name to clipboardExpand all lines: .appveyor.yml
+2Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,9 @@ test_script:
5959
- SET SYMFONY_PHPUNIT_SKIPPED_TESTS=phpunit.skipped
6060
- copy /Y c:\php\php.ini-min c:\php\php.ini
6161
- IF %APPVEYOR_REPO_BRANCH% neq master (rm -Rf src\Symfony\Bridge\PhpUnit)
62+
- mv src\Symfony\Component\HttpClient\phpunit.xml.dist src\Symfony\Component\HttpClient\phpunit.xml
6263
- php phpunit src\Symfony --exclude-group tty,benchmark,intl-data || SET X=!errorlevel!
6364
- copy /Y c:\php\php.ini-max c:\php\php.ini
65+
- php phpunit src\Symfony\Component\HttpClient || SET X=!errorlevel!
6466
- php phpunit src\Symfony --exclude-group tty,benchmark,intl-data || SET X=!errorlevel!
6567
- exit %X%

‎composer.json

Copy file name to clipboardExpand all lines: composer.json
+2Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -99,6 +99,8 @@
9999
"symfony/yaml": "self.version"
100100
},
101101
"require-dev": {
102+
"amphp/http-client": "^4.1",
103+
"amphp/http-tunnel": "^1.0",
102104
"cache/integration-tests": "dev-master",
103105
"doctrine/annotations": "~1.0",
104106
"doctrine/cache": "~1.6",

‎src/Symfony/Component/HttpClient/AmpHttpClient.php

Copy file name to clipboard
+158Lines changed: 158 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,158 @@
1+
<?php
2+
3+
/*
4+
* This file is part of the Symfony package.
5+
*
6+
* (c) Fabien Potencier <fabien@symfony.com>
7+
*
8+
* For the full copyright and license information, please view the LICENSE
9+
* file that was distributed with this source code.
10+
*/
11+
12+
namespace Symfony\Component\HttpClient;
13+
14+
use Amp\CancelledException;
15+
use Amp\Http\Client\DelegateHttpClient;
16+
use Amp\Http\Client\Request;
17+
use Amp\Http\Tunnel\Http1TunnelConnector;
18+
use Psr\Log\LoggerAwareInterface;
19+
use Psr\Log\LoggerAwareTrait;
20+
use Symfony\Component\HttpClient\Exception\TransportException;
21+
use Symfony\Component\HttpClient\Internal\AmpClientState;
22+
use Symfony\Component\HttpClient\Response\AmpResponse;
23+
use Symfony\Component\HttpClient\Response\ResponseStream;
24+
use Symfony\Contracts\HttpClient\HttpClientInterface;
25+
use Symfony\Contracts\HttpClient\ResponseInterface;
26+
use Symfony\Contracts\HttpClient\ResponseStreamInterface;
27+
use Symfony\Contracts\Service\ResetInterface;
28+
29+
if (!interface_exists(DelegateHttpClient::class)) {
30+
throw new \LogicException('You cannot use "Symfony\Component\HttpClient\AmpHttpClient" as the "amphp/http-client" package is not installed. Try running "composer require amphp/http-client".');
31+
}
32+
33+
/**
34+
* A portable implementation of the HttpClientInterface contracts based on Amp's HTTP client.
35+
*
36+
* @author Nicolas Grekas <p@tchwork.com>
37+
*/
38+
final class AmpHttpClient implements HttpClientInterface, LoggerAwareInterface, ResetInterface
39+
{
40+
use HttpClientTrait;
41+
use LoggerAwareTrait;
42+
43+
private $defaultOptions = self::OPTIONS_DEFAULTS;
44+
45+
/** @var AmpClientState */
46+
private $multi;
47+
48+
/**
49+
* @param array $defaultOptions Default requests' options
50+
* @param int $maxHostConnections The maximum number of connections to open
51+
*
52+
* @see HttpClientInterface::OPTIONS_DEFAULTS for available options
53+
*/
54+
public function __construct(array $defaultOptions = [], callable $clientConfigurator = null, int $maxHostConnections = 6, int $maxPendingPushes = 50)
55+
{
56+
$this->defaultOptions['buffer'] = $this->defaultOptions['buffer'] ?? \Closure::fromCallable([__CLASS__, 'shouldBuffer']);
57+
58+
if ($defaultOptions) {
59+
[, $this->defaultOptions] = self::prepareRequest(null, null, $defaultOptions, $this->defaultOptions);
60+
}
61+
62+
$this->multi = new AmpClientState($clientConfigurator, $maxHostConnections, $maxPendingPushes, $this->logger);
63+
}
64+
65+
/**
66+
* @see HttpClientInterface::OPTIONS_DEFAULTS for available options
67+
*
68+
* {@inheritdoc}
69+
*/
70+
public function request(string $method, string $url, array $options = []): ResponseInterface
71+
{
72+
[$url, $options] = self::prepareRequest($method, $url, $options, $this->defaultOptions);
73+
74+
$options['proxy'] = self::getProxy($options['proxy'], $url, $options['no_proxy']);
75+
76+
if (null !== $options['proxy'] && !class_exists(Http1TunnelConnector::class)) {
77+
throw new \LogicException('You cannot use the "proxy" option as the "amphp/http-tunnel" package is not installed. Try running "composer require amphp/http-tunnel".');
78+
}
79+
80+
if ('' !== $options['body'] && 'POST' === $method && !isset($options['normalized_headers']['content-type'])) {
81+
$options['headers'][] = 'Content-Type: application/x-www-form-urlencoded';
82+
}
83+
84+
if (!isset($options['normalized_headers']['user-agent'])) {
85+
$options['headers'][] = 'User-Agent: Symfony HttpClient/Amp';
86+
}
87+
88+
if (0 < $options['max_duration']) {
89+
$options['timeout'] = min($options['max_duration'], $options['timeout']);
90+
}
91+
92+
if ($options['resolve']) {
93+
$this->multi->dnsCache = $options['resolve'] + $this->multi->dnsCache;
94+
}
95+
96+
if ($options['peer_fingerprint'] && !isset($options['peer_fingerprint']['pin-sha256'])) {
97+
throw new TransportException(__CLASS__.' supports only "pin-sha256" fingerprints.');
98+
}
99+
100+
$request = new Request(implode('', $url), $method);
101+
102+
if ($options['http_version']) {
103+
switch ((float) $options['http_version']) {
104+
case 1.0: $request->setProtocolVersions(['1.0']); break;
105+
case 1.1: $request->setProtocolVersions(['1.1', '1.0']); break;
106+
default: $request->setProtocolVersions(['2', '1.1', '1.0']); break;
107+
}
108+
}
109+
110+
foreach ($options['headers'] as $v) {
111+
$h = explode(': ', $v, 2);
112+
$request->addHeader($h[0], $h[1]);
113+
}
114+
115+
$request->setTcpConnectTimeout(1000 * $options['timeout']);
116+
$request->setTlsHandshakeTimeout(1000 * $options['timeout']);
117+
$request->setTransferTimeout(1000 * $options['max_duration']);
118+
119+
if ('' !== $request->getUri()->getUserInfo() && !$request->hasHeader('authorization')) {
120+
$auth = explode(':', $request->getUri()->getUserInfo(), 2);
121+
$auth = array_map('rawurldecode', $auth) + [1 => ''];
122+
$request->setHeader('Authorization', 'Basic '.base64_encode(implode(':', $auth)));
123+
}
124+
125+
return new AmpResponse($this->multi, $request, $options, $this->logger);
126+
}
127+
128+
/**
129+
* {@inheritdoc}
130+
*/
131+
public function stream($responses, float $timeout = null): ResponseStreamInterface
132+
{
133+
if ($responses instanceof AmpResponse) {
134+
$responses = [$responses];
135+
} elseif (!is_iterable($responses)) {
136+
throw new \TypeError(sprintf('%s() expects parameter 1 to be an iterable of AmpResponse objects, %s given.', __METHOD__, \is_object($responses) ? \get_class($responses) : \gettype($responses)));
137+
}
138+
139+
return new ResponseStream(AmpResponse::stream($responses, $timeout));
140+
}
141+
142+
public function reset()
143+
{
144+
$this->multi->dnsCache = [];
145+
146+
foreach ($this->multi->pushedResponses as $authority => $pushedResponses) {
147+
foreach ($pushedResponses as [$pushedUrl, $pushDeferred]) {
148+
$pushDeferred->fail(new CancelledException());
149+
150+
if ($this->logger) {
151+
$this->logger->debug(sprintf('Unused pushed response: "%s"', $pushedUrl));
152+
}
153+
}
154+
}
155+
156+
$this->multi->pushedResponses = [];
157+
}
158+
}

‎src/Symfony/Component/HttpClient/CHANGELOG.md

Copy file name to clipboardExpand all lines: src/Symfony/Component/HttpClient/CHANGELOG.md
+3-2Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,9 @@ CHANGELOG
44
5.1.0
55
-----
66

7-
* added `NoPrivateNetworkHttpClient` decorator
8-
* added `LoggerAwareInterface` to `ScopingHttpClient` and `TraceableHttpClient`
7+
* added `NoPrivateNetworkHttpClient` decorator
8+
* added `AmpHttpClient`, a portable HTTP/2 implementation based on Amp
9+
* added `LoggerAwareInterface` to `ScopingHttpClient` and `TraceableHttpClient`
910

1011
4.4.0
1112
-----

‎src/Symfony/Component/HttpClient/HttpClientTrait.php

Copy file name to clipboardExpand all lines: src/Symfony/Component/HttpClient/HttpClientTrait.php
+43Lines changed: 43 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,7 @@
1212
namespace Symfony\Component\HttpClient;
1313

1414
use Symfony\Component\HttpClient\Exception\InvalidArgumentException;
15+
use Symfony\Component\HttpClient\Exception\TransportException;
1516

1617
/**
1718
* Provides the common logic from writing HttpClientInterface implementations.
@@ -541,6 +542,48 @@ private static function mergeQueryString(?string $queryString, array $queryArray
541542
return implode('&', $replace ? array_replace($query, $queryArray) : ($query + $queryArray));
542543
}
543544

545+
/**
546+
* Loads proxy configuration from the same environment variables as curl when no proxy is explicitly set.
547+
*/
548+
private static function getProxy(?string $proxy, array $url, ?string $noProxy): ?array
549+
{
550+
if (null === $proxy) {
551+
// Ignore HTTP_PROXY except on the CLI to work around httpoxy set of vulnerabilities
552+
$proxy = $_SERVER['http_proxy'] ?? (\in_array(\PHP_SAPI, ['cli', 'phpdbg'], true) ? $_SERVER['HTTP_PROXY'] ?? null : null) ?? $_SERVER['all_proxy'] ?? $_SERVER['ALL_PROXY'] ?? null;
553+
554+
if ('https:' === $url['scheme']) {
555+
$proxy = $_SERVER['https_proxy'] ?? $_SERVER['HTTPS_PROXY'] ?? $proxy;
556+
}
557+
}
558+
559+
if (null === $proxy) {
560+
return null;
561+
}
562+
563+
$proxy = (parse_url($proxy) ?: []) + ['scheme' => 'http'];
564+
565+
if (!isset($proxy['host'])) {
566+
throw new TransportException('Invalid HTTP proxy: host is missing.');
567+
}
568+
569+
if ('http' === $proxy['scheme']) {
570+
$proxyUrl = 'tcp://'.$proxy['host'].':'.($proxy['port'] ?? '80');
571+
} elseif ('https' === $proxy['scheme']) {
572+
$proxyUrl = 'ssl://'.$proxy['host'].':'.($proxy['port'] ?? '443');
573+
} else {
574+
throw new TransportException(sprintf('Unsupported proxy scheme "%s": "http" or "https" expected.', $proxy['scheme']));
575+
}
576+
577+
$noProxy = $noProxy ?? $_SERVER['no_proxy'] ?? $_SERVER['NO_PROXY'] ?? '';
578+
$noProxy = $noProxy ? preg_split('/[\s,]+/', $noProxy) : [];
579+
580+
return [
581+
'url' => $proxyUrl,
582+
'auth' => isset($proxy['user']) ? 'Basic '.base64_encode(rawurldecode($proxy['user']).':'.rawurldecode($proxy['pass'] ?? '')) : null,
583+
'no_proxy' => $noProxy,
584+
];
585+
}
586+
544587
private static function shouldBuffer(array $headers): bool
545588
{
546589
if (null === $contentType = $headers['content-type'][0] ?? null) {

‎src/Symfony/Component/HttpClient/Internal/AmpBody.php

Copy file name to clipboard
+141Lines changed: 141 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,141 @@
1+
<?php
2+
3+
/*
4+
* This file is part of the Symfony package.
5+
*
6+
* (c) Fabien Potencier <fabien@symfony.com>
7+
*
8+
* For the full copyright and license information, please view the LICENSE
9+
* file that was distributed with this source code.
10+
*/
11+
12+
namespace Symfony\Component\HttpClient\Internal;
13+
14+
use Amp\ByteStream\InputStream;
15+
use Amp\ByteStream\ResourceInputStream;
16+
use Amp\Http\Client\RequestBody;
17+
use Amp\Promise;
18+
use Amp\Success;
19+
use Symfony\Component\HttpClient\Exception\TransportException;
20+
21+
/**
22+
* @author Nicolas Grekas <p@tchwork.com>
23+
*
24+
* @internal
25+
*/
26+
class AmpBody implements RequestBody, InputStream
27+
{
28+
private $body;
29+
private $onProgress;
30+
private $offset = 0;
31+
private $length = -1;
32+
private $uploaded;
33+
34+
public function __construct($body, &$info, \closure $onProgress)
35+
{
36+
$this->body = $body;
37+
$this->info = &$info;
38+
$this->onProgress = $onProgress;
39+
40+
if (\is_resource($body)) {
41+
$this->offset = ftell($body);
42+
$this->length = fstat($body)['size'];
43+
$this->body = new ResourceInputStream($body);
44+
} elseif (\is_string($body)) {
45+
$this->length = \strlen($body);
46+
}
47+
}
48+
49+
public function createBodyStream(): InputStream
50+
{
51+
if (null !== $this->uploaded) {
52+
$this->uploaded = null;
53+
54+
if (\is_string($this->body)) {
55+
$this->offset = 0;
56+
} elseif ($this->body instanceof ResourceInputStream) {
57+
fseek($this->body->getResource(), $this->offset);
58+
}
59+
}
60+
61+
return $this;
62+
}
63+
64+
public function getHeaders(): Promise
65+
{
66+
return new Success([]);
67+
}
68+
69+
public function getBodyLength(): Promise
70+
{
71+
return new Success($this->length - $this->offset);
72+
}
73+
74+
public function read(): Promise
75+
{
76+
$this->info['size_upload'] += $this->uploaded;
77+
$this->uploaded = 0;
78+
($this->onProgress)();
79+
80+
$chunk = $this->doRead();
81+
$chunk->onResolve(function ($e, $data) {
82+
if (null !== $data) {
83+
$this->uploaded = \strlen($data);
84+
} else {
85+
$this->info['upload_content_length'] = $this->info['size_upload'];
86+
}
87+
});
88+
89+
return $chunk;
90+
}
91+
92+
public static function rewind(RequestBody $body): RequestBody
93+
{
94+
if (!$body instanceof self) {
95+
return $body;
96+
}
97+
98+
$body->uploaded = null;
99+
100+
if ($body->body instanceof ResourceInputStream) {
101+
fseek($body->body->getResource(), $body->offset);
102+
103+
return new $body($body->body, $body->info, $body->onProgress);
104+
}
105+
106+
if (\is_string($body->body)) {
107+
$body->offset = 0;
108+
}
109+
110+
return $body;
111+
}
112+
113+
private function doRead(): Promise
114+
{
115+
if ($this->body instanceof ResourceInputStream) {
116+
return $this->body->read();
117+
}
118+
119+
if (null === $this->offset || !$this->length) {
120+
return new Success();
121+
}
122+
123+
if (\is_string($this->body)) {
124+
$this->offset = null;
125+
126+
return new Success($this->body);
127+
}
128+
129+
if ('' === $data = ($this->body)(16372)) {
130+
$this->offset = null;
131+
132+
return new Success();
133+
}
134+
135+
if (!\is_string($data)) {
136+
throw new TransportException(sprintf('Return value of the "body" option callback must be string, %s returned.', \gettype($data)));
137+
}
138+
139+
return new Success($data);
140+
}
141+
}

0 commit comments

Comments
0 (0)
Morty Proxy This is a proxified and sanitized view of the page, visit original site.