MiddlewareResolver::resolveCallback()   A
last analyzed

Complexity

Conditions 1
Paths 1

Size

Total Lines 17
Code Lines 13

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 16
CRAP Score 1

Importance

Changes 0
Metric Value
cc 1
eloc 13
c 0
b 0
f 0
nc 1
nop 2
dl 0
loc 17
ccs 16
cts 16
cp 1
crap 1
rs 9.8333
1
<?php
2
3
/**
4
 * It's free open-source software released under the MIT License.
5
 *
6
 * @author Anatoly Nekhay <[email protected]>
7
 * @copyright Copyright (c) 2018, Anatoly Nekhay
8
 * @license https://github.com/sunrise-php/http-router/blob/master/LICENSE
9
 * @link https://github.com/sunrise-php/http-router
10
 */
11
12
declare(strict_types=1);
13
14
namespace Sunrise\Http\Router;
15
16
use InvalidArgumentException;
17
use LogicException;
18
use Psr\Http\Message\ResponseInterface;
19
use Psr\Http\Message\ServerRequestInterface;
20
use Psr\Http\Server\MiddlewareInterface;
21
use Psr\Http\Server\RequestHandlerInterface;
22
use ReflectionException;
23
use ReflectionMethod;
24
use Sunrise\Http\Router\Middleware\CallableMiddleware;
25
use Sunrise\Http\Router\ParameterResolver\DirectInjectionParameterResolver;
26
27
use function is_array;
28
use function is_callable;
29
use function is_string;
30
use function is_subclass_of;
31
use function sprintf;
32
33
/**
34
 * @since 3.0.0
35
 */
36
final class MiddlewareResolver implements MiddlewareResolverInterface
37
{
38 9
    public function __construct(
39
        private readonly ClassResolverInterface $classResolver,
40
        private readonly ParameterResolverChainInterface $parameterResolverChain,
41
        private readonly ResponseResolverChainInterface $responseResolverChain,
42
    ) {
43 9
    }
44
45
    /**
46
     * @inheritDoc
47
     *
48
     * @throws InvalidArgumentException
49
     * @throws LogicException
50
     * @throws ReflectionException
51
     */
52 6
    public function resolveMiddleware(mixed $reference): MiddlewareInterface
53
    {
54 6
        if ($reference instanceof MiddlewareInterface) {
55 1
            return $reference;
56
        }
57
58 5
        if (is_string($reference) && is_subclass_of($reference, MiddlewareInterface::class)) {
59 1
            return $this->classResolver->resolveClass($reference);
60
        }
61
62
        // https://github.com/php/php-src/blob/3ed526441400060aa4e618b91b3352371fcd02a8/Zend/zend_API.c#L3884-L3932
63 4
        if (is_array($reference) && is_callable($reference, true)) {
64
            /** @var array{0: class-string|object, 1: string} $reference */
65
66 3
            if (is_string($reference[0])) {
67 2
                $reference[0] = $this->classResolver->resolveClass($reference[0]);
68
            }
69
70 3
            if (is_callable($reference)) {
71 3
                return $this->resolveCallback($reference, new ReflectionMethod($reference[0], $reference[1]));
72
            }
73
        }
74
75 1
        throw new InvalidArgumentException(sprintf(
76 1
            'The middleware reference "%s" could not be resolved.',
77 1
            ReferenceResolver::stringifyReference($reference),
78 1
        ));
79
    }
80
81
    /**
82
     * @throws InvalidArgumentException
83
     * @throws LogicException
84
     */
85 3
    private function resolveCallback(callable $callback, ReflectionMethod $reflection): MiddlewareInterface
86
    {
87 3
        return new CallableMiddleware(
88 3
            fn(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface => (
89 3
                $this->responseResolverChain->resolveResponse(
90 3
                    $callback(
91 3
                        ...$this->parameterResolverChain
92 3
                            ->withContext($request)
93 3
                            ->withResolver(
94 3
                                new DirectInjectionParameterResolver($request),
95 3
                                new DirectInjectionParameterResolver($request->getBody()),
96 3
                                new DirectInjectionParameterResolver($handler),
97 3
                            )
98 3
                            ->resolveParameters(...$reflection->getParameters())
99 3
                    ),
100 3
                    $reflection,
101 3
                    $request,
102 3
                )
103 3
            )
104 3
        );
105
    }
106
}
107