RequestMiddleware.php

<?php declare(strict_types=1);

namespace Webhook\App\Api\Public\Controller;

use Amp\Http\HttpStatus;
use Amp\Http\Server\Request as HttpRequest;
use Amp\Http\Server\Response as HttpResponse;
use Webhook\App\Api\Public\Controller\Request as AppRequest;
use Webhook\App\Http\Server\Request as RequestAdaptor;
use Webhook\App\HttpException;

final readonly class RequestMiddleware
{
    public function __invoke(HttpRequest $request, callable $next): HttpResponse
    {
        $requestAdaptor = new RequestAdaptor($request);

        try {
            $data = $requestAdaptor->getData();
        } catch (\Throwable $exception) {
            throw new HttpException(code: HttpStatus::BAD_REQUEST, previous: $exception);
        }

        $appRequest = new AppRequest(
            clientId: $request->getAttribute('clientId'),
            urlParams: $request->getAttribute('urlParams'),
            query: $requestAdaptor->getQuery(),
            data: $data,
            headers: $requestAdaptor->getHeaders(),
        );

        /** @var Response $appResponse */
        $appResponse = $next($appRequest);

        $headers = $appResponse->headers;
        $body = $appResponse->body;
        if (\is_array($body)) {
            $body = \json_encode($body, JSON_UNESCAPED_UNICODE | JSON_THROW_ON_ERROR);
            $headers['content-type'] = 'application/json';
        }
        return new HttpResponse(
            status: $appResponse->status,
            headers: $headers,
            body: $body,
        );
    }
}