BenTools\MercurePHP\Hub\RequestHandler

Complexity

Total Complexity

8

Size/Duplication

Total Lines	54
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	handle()	0	13	2
A	getController()	0	11	3
A	withClientId()	0	12	2

<?php

namespace BenTools\MercurePHP\Hub;

use BenTools\MercurePHP\Controller\AbstractController;
use BenTools\MercurePHP\Exception\Http\HttpException;
use BenTools\MercurePHP\Exception\Http\NotFoundHttpException;
use Psr\Http\Message\ServerRequestInterface;
use Ramsey\Uuid\Uuid;
use React\Http\Message\Response;
use React\Promise\PromiseInterface;

use function React\Promise\resolve;

final class RequestHandler
{
    private const CLIENT_NAMESPACE = '530344d8-a802-11ea-bb37-0242ac130002';

    private array $controllers;

    public function __construct(array $controllers)
    {
        $this->controllers = (fn(AbstractController ...$controllers) => $controllers)(...$controllers);
    }

    public function handle(ServerRequestInterface $request): PromiseInterface
    {
        try {
            $request = $this->withClientId($request);
            $handle = $this->getController($request);

            return $handle($request);
        } catch (HttpException $e) {
            return resolve(
                new Response(
                    $e->getStatusCode(),
                    ['Content-Type' => 'text/plain'],
                    $e->getMessage(),
                )
            );
        }
    }

    private function getController(ServerRequestInterface $request): AbstractController
    {
        foreach ($this->controllers as $controller) {
            if (!$controller->matchRequest($request)) {
                continue;
            }

            return $controller;
        }

        throw new NotFoundHttpException('Not found.');
    }

    private function withClientId(ServerRequestInterface $request): ServerRequestInterface
    {
        if (null === $request->getAttribute('clientId')) {
            $serverParams = $request->getServerParams();
            $clientId = Uuid::uuid5(
                self::CLIENT_NAMESPACE,
                ($serverParams['REMOTE_ADDR'] ?? '') . ':' . ($serverParams['REMOTE_PORT'] ?? '')
            );
            $request = $request->withAttribute('clientId', $clientId);
        }

        return $request;
    }
}