Skip to content

Commit f6269a9

Browse files
shulardshulard
committed
feat: Client now use ReactPHP Browser object.
Also upgrade all the test suite to match the new behaviour.
1 parent 2f516e5 commit f6269a9

File tree

5 files changed

+121
-263
lines changed

5 files changed

+121
-263
lines changed

‎src/Client.php

Lines changed: 15 additions & 118 deletions
Original file line numberDiff line numberDiff line change
@@ -4,31 +4,22 @@
44

55
use Http\Client\HttpClient;
66
use Http\Client\HttpAsyncClient;
7-
use Http\Client\Exception\HttpException;
8-
use Http\Client\Exception\RequestException;
9-
use Http\Discovery\MessageFactoryDiscovery;
10-
use Http\Discovery\StreamFactoryDiscovery;
11-
use Http\Message\ResponseFactory;
12-
use Http\Message\StreamFactory;
137
use Psr\Http\Message\RequestInterface;
148
use Psr\Http\Message\ResponseInterface;
15-
use Psr\Http\Message\StreamInterface;
169
use React\EventLoop\LoopInterface;
17-
use React\HttpClient\Client as ReactClient;
18-
use React\HttpClient\Request as ReactRequest;
19-
use React\HttpClient\Response as ReactResponse;
10+
use React\Http\Browser as ReactBrowser;
2011

2112
/**
2213
* Client for the React promise implementation.
2314
*
24-
* @author Stéphane Hulard <[email protected]>
15+
* @author Stéphane Hulard <[email protected]>
2516
*/
2617
class Client implements HttpClient, HttpAsyncClient
2718
{
2819
/**
2920
* React HTTP client.
3021
*
31-
* @var Client
22+
* @var ReactBrowser
3223
*/
3324
private $client;
3425

@@ -39,41 +30,21 @@ class Client implements HttpClient, HttpAsyncClient
3930
*/
4031
private $loop;
4132

42-
/**
43-
* @var ResponseFactory
44-
*/
45-
private $responseFactory;
46-
47-
/**
48-
* @var StreamFactory
49-
*/
50-
private $streamFactory;
51-
5233
/**
5334
* Initialize the React client.
54-
*
55-
* @param ResponseFactory|null $responseFactory
56-
* @param LoopInterface|null $loop
57-
* @param ReactClient|null $client
58-
* @param StreamFactory|null $streamFactory
5935
*/
6036
public function __construct(
61-
ResponseFactory $responseFactory = null,
6237
LoopInterface $loop = null,
63-
ReactClient $client = null,
64-
StreamFactory $streamFactory = null
38+
ReactBrowser $client = null
6539
) {
6640
if (null !== $client && null === $loop) {
6741
throw new \RuntimeException(
6842
'You must give a LoopInterface instance with the Client'
6943
);
7044
}
7145

72-
$this->loop = $loop ?: ReactFactory::buildEventLoop();
46+
$this->loop = $loop ?: ReactFactory::buildEventLoop();
7347
$this->client = $client ?: ReactFactory::buildHttpClient($this->loop);
74-
75-
$this->responseFactory = $responseFactory ?: MessageFactoryDiscovery::find();
76-
$this->streamFactory = $streamFactory ?: StreamFactoryDiscovery::find();
7748
}
7849

7950
/**
@@ -91,91 +62,17 @@ public function sendRequest(RequestInterface $request): ResponseInterface
9162
*/
9263
public function sendAsyncRequest(RequestInterface $request)
9364
{
94-
$reactRequest = $this->buildReactRequest($request);
95-
$promise = new Promise($this->loop);
96-
97-
$reactRequest->on('error', function (\Exception $error) use ($promise, $request) {
98-
$promise->reject(new RequestException(
99-
$error->getMessage(),
100-
$request,
101-
$error
102-
));
103-
});
104-
105-
$reactRequest->on('response', function (ReactResponse $reactResponse = null) use ($promise, $request) {
106-
$bodyStream = $this->streamFactory->createStream();
107-
$reactResponse->on('data', function ($data) use (&$bodyStream) {
108-
$bodyStream->write((string) $data);
109-
});
110-
111-
$reactResponse->on('end', function (\Exception $error = null) use ($promise, $request, $reactResponse, &$bodyStream) {
112-
$response = $this->buildResponse(
113-
$reactResponse,
114-
$bodyStream
115-
);
116-
if (null !== $error) {
117-
$promise->reject(new HttpException(
118-
$error->getMessage(),
119-
$request,
120-
$response,
121-
$error
122-
));
123-
} else {
124-
$promise->resolve($response);
125-
}
126-
});
127-
});
128-
129-
$reactRequest->end((string) $request->getBody());
130-
131-
return $promise;
132-
}
133-
134-
/**
135-
* Build a React request from the PSR7 RequestInterface.
136-
*
137-
* @param RequestInterface $request
138-
*
139-
* @return ReactRequest
140-
*/
141-
private function buildReactRequest(RequestInterface $request)
142-
{
143-
$headers = [];
144-
145-
foreach ($request->getHeaders() as $name => $value) {
146-
$headers[$name] = (is_array($value) ? $value[0] : $value);
147-
}
148-
149-
$reactRequest = $this->client->request(
150-
$request->getMethod(),
151-
(string) $request->getUri(),
152-
$headers,
153-
$request->getProtocolVersion()
65+
$promise = new Promise(
66+
$this->client->request(
67+
$request->getMethod(),
68+
$request->getUri(),
69+
$request->getHeaders(),
70+
$request->getBody()
71+
),
72+
$this->loop,
73+
$request
15474
);
15575

156-
return $reactRequest;
157-
}
158-
159-
/**
160-
* Transform a React Response to a valid PSR7 ResponseInterface instance.
161-
*
162-
* @param ReactResponse $response
163-
* @param StreamInterface $body
164-
*
165-
* @return ResponseInterface
166-
*/
167-
private function buildResponse(
168-
ReactResponse $response,
169-
StreamInterface $body
170-
) {
171-
$body->rewind();
172-
173-
return $this->responseFactory->createResponse(
174-
$response->getCode(),
175-
$response->getReasonPhrase(),
176-
$response->getHeaders(),
177-
$body,
178-
$response->getVersion()
179-
);
76+
return $promise;
18077
}
18178
}

‎src/Promise.php

Lines changed: 50 additions & 109 deletions
Original file line numberDiff line numberDiff line change
@@ -2,15 +2,19 @@
22

33
namespace Http\Adapter\React;
44

5-
use React\EventLoop\LoopInterface;
6-
use Http\Client\Exception;
5+
use Http\Client\Exception as HttplugException;
76
use Http\Promise\Promise as HttpPromise;
7+
use Psr\Http\Message\RequestInterface;
88
use Psr\Http\Message\ResponseInterface;
9+
use React\EventLoop\LoopInterface;
10+
use React\Promise\PromiseInterface;
11+
use RuntimeException;
12+
use UnexpectedValueException;
913

1014
/**
1115
* React promise adapter implementation.
1216
*
13-
* @author Stéphane Hulard <[email protected]>
17+
* @author Stéphane Hulard <[email protected]>
1418
*
1519
* @internal
1620
*/
@@ -38,128 +42,65 @@ final class Promise implements HttpPromise
3842
private $exception;
3943

4044
/**
41-
* @var callable|null
42-
*/
43-
private $onFulfilled;
44-
45-
/**
46-
* @var callable|null
47-
*/
48-
private $onRejected;
49-
50-
/**
51-
* React Event Loop used for synchronous processing.
45+
* HTTP Request
5246
*
53-
* @var LoopInterface
47+
* @var RequestInterface
5448
*/
55-
private $loop;
56-
57-
public function __construct(LoopInterface $loop)
58-
{
59-
$this->loop = $loop;
60-
}
49+
private $request;
6150

6251
/**
63-
* Allow to apply callable when the promise resolve.
52+
* Adapted ReactPHP promise
6453
*
65-
* @param callable|null $onFulfilled
66-
* @param callable|null $onRejected
67-
*
68-
* @return Promise
54+
* @var PromiseInterface
6955
*/
70-
public function then(callable $onFulfilled = null, callable $onRejected = null)
71-
{
72-
$newPromise = new self($this->loop);
73-
74-
$onFulfilled = null !== $onFulfilled ? $onFulfilled : function (ResponseInterface $response) {
75-
return $response;
76-
};
77-
78-
$onRejected = null !== $onRejected ? $onRejected : function (Exception $exception) {
79-
throw $exception;
80-
};
81-
82-
$this->onFulfilled = function (ResponseInterface $response) use ($onFulfilled, $newPromise) {
83-
try {
84-
$return = $onFulfilled($response);
85-
86-
$newPromise->resolve(null !== $return ? $return : $response);
87-
} catch (Exception $exception) {
88-
$newPromise->reject($exception);
89-
}
90-
};
91-
92-
$this->onRejected = function (Exception $exception) use ($onRejected, $newPromise) {
93-
try {
94-
$newPromise->resolve($onRejected($exception));
95-
} catch (Exception $exception) {
96-
$newPromise->reject($exception);
97-
}
98-
};
99-
100-
if (HttpPromise::FULFILLED === $this->state) {
101-
$this->doResolve($this->response);
102-
}
103-
104-
if (HttpPromise::REJECTED === $this->state) {
105-
$this->doReject($this->exception);
106-
}
107-
108-
return $newPromise;
109-
}
56+
private $promise;
11057

11158
/**
112-
* Resolve this promise.
59+
* ReactPHP LoopInterface
11360
*
114-
* @param ResponseInterface $response
115-
*
116-
* @internal
61+
* @var LoopInterface
11762
*/
118-
public function resolve(ResponseInterface $response)
119-
{
120-
if (HttpPromise::PENDING !== $this->state) {
121-
throw new \RuntimeException('Promise is already resolved');
122-
}
123-
124-
$this->state = HttpPromise::FULFILLED;
125-
$this->response = $response;
126-
$this->doResolve($response);
127-
}
128-
129-
private function doResolve(ResponseInterface $response)
130-
{
131-
$onFulfilled = $this->onFulfilled;
132-
133-
if (null !== $onFulfilled) {
134-
$onFulfilled($response);
135-
}
136-
}
63+
private $loop;
13764

138-
/**
139-
* Reject this promise.
140-
*
141-
* @param Exception $exception
142-
*
143-
* @internal
144-
*/
145-
public function reject(Exception $exception)
65+
public function __construct(PromiseInterface $promise, LoopInterface $loop, RequestInterface $request)
14666
{
147-
if (HttpPromise::PENDING !== $this->state) {
148-
throw new \RuntimeException('Promise is already resolved');
149-
}
67+
$this->state = self::PENDING;
68+
69+
$this->request = $request;
70+
$this->loop = $loop;
71+
$this->promise = $promise->then(
72+
/**
73+
* @param ResponseInterface|null $response
74+
*/
75+
function (?ResponseInterface $response): ResponseInterface {
76+
$this->response = $response;
77+
$this->state = self::FULFILLED;
78+
79+
return $response;
80+
},
81+
/**
82+
* @param mixed $reason
83+
*/
84+
function ($reason): void {
85+
$this->state = self::REJECTED;
86+
87+
if ($reason instanceof HttplugException) {
88+
$this->exception = $reason;
89+
} elseif ($reason instanceof RuntimeException) {
90+
$this->exception = new HttplugException\NetworkException($reason->getMessage(), $this->request, $reason);
91+
} elseif ($reason instanceof \Throwable) {
92+
$this->exception = new HttplugException\TransferException('Invalid exception returned from ReactPHP', 0, $reason);
93+
} else {
94+
$this->exception = new UnexpectedValueException('Reason returned from ReactPHP must be an Exception');
95+
}
15096

151-
$this->state = HttpPromise::REJECTED;
152-
$this->exception = $exception;
153-
$this->doReject($exception);
97+
throw $this->exception;
98+
});
15499
}
155100

156-
private function doReject(Exception $exception)
101+
public function then(?callable $onFulfilled = null, ?callable $onRejected = null)
157102
{
158-
$onRejected = $this->onRejected;
159-
160-
if (null !== $onRejected) {
161-
$onRejected($exception);
162-
}
103+
return new self($this->promise->then($onFulfilled, $onRejected), $this->loop, $this->request);
163104
}
164105

165106
/**

0 commit comments

Comments
 (0)