|
1
|
|
|
<?php declare(strict_types=1); |
|
2
|
|
|
|
|
3
|
|
|
namespace ApiClients\Foundation\Middleware; |
|
4
|
|
|
|
|
5
|
|
|
use Psr\Http\Message\RequestInterface; |
|
6
|
|
|
use Psr\Http\Message\ResponseInterface; |
|
7
|
|
|
use React\Promise\CancellablePromiseInterface; |
|
8
|
|
|
use Throwable; |
|
9
|
|
|
use function React\Promise\reject; |
|
10
|
|
|
use function React\Promise\resolve; |
|
11
|
|
|
|
|
12
|
|
|
final class MiddlewareRunner |
|
13
|
|
|
{ |
|
14
|
|
|
/** |
|
15
|
|
|
* @var array |
|
16
|
|
|
*/ |
|
17
|
|
|
private $options; |
|
18
|
|
|
|
|
19
|
|
|
/** |
|
20
|
|
|
* @var MiddlewareInterface[] |
|
21
|
|
|
*/ |
|
22
|
|
|
private $middlewares; |
|
23
|
|
|
|
|
24
|
|
|
/** |
|
25
|
|
|
* MiddlewareRunner constructor. |
|
26
|
|
|
* @param array $options |
|
27
|
|
|
* @param MiddlewareInterface[] $middlewares |
|
28
|
|
|
*/ |
|
29
|
1 |
|
public function __construct(array $options, MiddlewareInterface ...$middlewares) |
|
30
|
|
|
{ |
|
31
|
1 |
|
$this->options = $options; |
|
32
|
1 |
|
$this->middlewares = $this->orderMiddlewares(...$middlewares); |
|
33
|
1 |
|
} |
|
34
|
|
|
|
|
35
|
|
|
/** |
|
36
|
|
|
* Sort the middlewares by priority |
|
37
|
|
|
* |
|
38
|
|
|
* @param MiddlewareInterface[] $middlewares |
|
39
|
|
|
* @return array |
|
40
|
|
|
*/ |
|
41
|
1 |
|
protected function orderMiddlewares(MiddlewareInterface ...$middlewares): array |
|
42
|
|
|
{ |
|
43
|
|
|
usort($middlewares, function (MiddlewareInterface $left, MiddlewareInterface $right) { |
|
44
|
1 |
|
return $right->priority() <=> $left->priority(); |
|
45
|
1 |
|
}); |
|
46
|
|
|
|
|
47
|
1 |
|
return $middlewares; |
|
48
|
|
|
} |
|
49
|
|
|
|
|
50
|
|
|
/** |
|
51
|
|
|
* @param RequestInterface $request |
|
52
|
|
|
* @return CancellablePromiseInterface |
|
53
|
|
|
*/ |
|
54
|
1 |
|
public function pre( |
|
55
|
|
|
RequestInterface $request |
|
56
|
|
|
): CancellablePromiseInterface { |
|
57
|
1 |
|
$promise = resolve($request); |
|
58
|
|
|
|
|
59
|
1 |
|
foreach ($this->middlewares as $middleware) { |
|
60
|
1 |
|
$requestMiddleware = $middleware; |
|
61
|
|
|
$promise = $promise->then(function (RequestInterface $request) use ($requestMiddleware) { |
|
62
|
1 |
|
return $requestMiddleware->pre($request, $this->options); |
|
63
|
1 |
|
}); |
|
64
|
|
|
} |
|
65
|
|
|
|
|
66
|
1 |
|
return $promise; |
|
67
|
|
|
} |
|
68
|
|
|
|
|
69
|
|
|
/** |
|
70
|
|
|
* @param ResponseInterface $response |
|
71
|
|
|
* @return CancellablePromiseInterface |
|
72
|
|
|
*/ |
|
73
|
1 |
View Code Duplication |
public function post( |
|
|
|
|
|
|
74
|
|
|
ResponseInterface $response |
|
75
|
|
|
): CancellablePromiseInterface { |
|
76
|
1 |
|
$promise = resolve($response); |
|
77
|
|
|
|
|
78
|
1 |
|
$this->middlewares = array_reverse($this->middlewares); |
|
79
|
|
|
|
|
80
|
1 |
|
foreach ($this->middlewares as $middleware) { |
|
81
|
1 |
|
$responseMiddleware = $middleware; |
|
82
|
|
|
$promise = $promise->then(function (ResponseInterface $response) use ($responseMiddleware) { |
|
83
|
1 |
|
return $responseMiddleware->post($response, $this->options); |
|
84
|
1 |
|
}); |
|
85
|
|
|
} |
|
86
|
|
|
|
|
87
|
1 |
|
return $promise; |
|
88
|
|
|
} |
|
89
|
|
|
|
|
90
|
|
|
/** |
|
91
|
|
|
* @param Throwable $throwable |
|
92
|
|
|
* @return CancellablePromiseInterface |
|
93
|
|
|
*/ |
|
94
|
1 |
View Code Duplication |
public function error( |
|
|
|
|
|
|
95
|
|
|
Throwable $throwable |
|
96
|
|
|
): CancellablePromiseInterface { |
|
97
|
|
|
|
|
98
|
1 |
|
$promise = reject($throwable); |
|
99
|
|
|
|
|
100
|
1 |
|
$this->middlewares = array_reverse($this->middlewares); |
|
101
|
|
|
|
|
102
|
1 |
|
foreach ($this->middlewares as $middleware) { |
|
103
|
1 |
|
$errorMiddleware = $middleware; |
|
104
|
1 |
|
$promise = $promise->then(null, function (Throwable $throwable) use ($errorMiddleware) { |
|
105
|
1 |
|
return reject($errorMiddleware->error($throwable, $this->options)); |
|
106
|
1 |
|
}); |
|
107
|
|
|
} |
|
108
|
|
|
|
|
109
|
1 |
|
return $promise; |
|
110
|
|
|
} |
|
111
|
|
|
} |
|
112
|
|
|
|
php-api-clients /
middleware
Loading history...
Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation.
You can also find more detailed suggestions in the “Code” section of your repository.