kiri-http-server/Handler/OnRequest.php

<?php

declare(strict_types=1);

namespace Kiri\Server\Handler;

use Exception;
use Kiri;
use Kiri\Core\Xml;
use Kiri\Di\Inject\Container;
use Kiri\Di\Context;
use Kiri\Di\Interface\ResponseEmitterInterface;
use Kiri\Router\Base\ExceptionHandlerDispatcher;
use Kiri\Router\Constrict\ConstrictRequest;
use Kiri\Router\Constrict\ConstrictResponse;
use Kiri\Router\Constrict\Uri;
use Kiri\Router\DataGrip;
use Kiri\Router\Interface\ExceptionHandlerInterface;
use Kiri\Router\Interface\OnRequestInterface;
use Kiri\Router\RouterCollector;
use Psr\Http\Message\RequestInterface;
use Psr\Http\Message\ResponseInterface;
use Swoole\Http\Request;
use Swoole\Http\Response;
use Kiri\Router\Base\Middleware as MiddlewareManager;
use Throwable;

/**
 * OnRequest event
 */
class OnRequest implements OnRequestInterface
{

    /**
     * @var RouterCollector
     */
    public RouterCollector $router;


    /**
     * @var ExceptionHandlerInterface
     */
    public ExceptionHandlerInterface $exception;


    /**
     * @var ResponseEmitterInterface
     */
    public ResponseEmitterInterface $emitter;


    /**
     * @var Kiri\Router\Request
     */
    #[Container(RequestInterface::class)]
    public RequestInterface $request;


    /**
     * @var ResponseInterface
     */
    #[Container(ResponseInterface::class)]
    public ResponseInterface $response;


    /**
     * @var MiddlewareManager
     */
    public MiddlewareManager $middlewareManager;


    public ConstrictResponse $constrictResponse;

    /**
     * @throws Exception
     */
    public function init(): void
    {
        $container = Kiri::getDi();
        $exception = $this->request->exception;
        if (!in_array(ExceptionHandlerInterface::class, class_implements($exception))) {
            $exception = ExceptionHandlerDispatcher::class;
        }
        $this->exception         = $container->get($exception);
        $this->router            = $container->get(DataGrip::class)->get(ROUTER_TYPE_HTTP);
        $this->emitter           = $this->response->emmit;
        $this->constrictResponse = $container->get(ConstrictResponse::class);
        $this->middlewareManager = $container->get(MiddlewareManager::class);
    }


    /**
     * @param Request $request
     * @param Response $response
     * @throws Exception
     */
    public function onRequest(Request $request, Response $response): void
    {
        try {
            /** @var ConstrictRequest $PsrRequest */
            $PsrRequest = Context::set(RequestInterface::class, $this->constrictRequest($request));

            /** @var ConstrictResponse $PsrResponse */
            $PsrResponse = Context::set(ResponseInterface::class, new ConstrictResponse());
            $PsrResponse->withContentType($this->response->contentType);

            /** @var $dispatcher */
            $dispatcher = $this->router->query($request->server['path_info'], $request->getMethod());

            /** @var $PsrResponse */
            $PsrResponse = $dispatcher->run($PsrRequest);
        } catch (Throwable $throwable) {
            $PsrResponse = $this->exception->emit($throwable, $this->constrictResponse);
        } finally {
            $this->emitter->sender($PsrResponse, $response, $PsrRequest);
        }
    }


    /**
     * @param Request $request
     * @return ConstrictRequest
     */
    protected function constrictRequest(Request $request): ConstrictRequest
    {
        return (new ConstrictRequest())->withHeaders($request->header ?? [])->withUri(new Uri($request))
                                       ->withProtocolVersion($request->server['server_protocol'])->withCookieParams($request->cookie ?? [])
                                       ->withServerParams($request->server)->withQueryParams($request->get ?? [])
                                       ->withParsedBody(function () use ($request) {
                                           $contentType = $request->header['content-type'] ?? 'application/json';
                                           if (\str_contains($contentType, 'json')) {
                                               return \json_decode($request->getContent(), true);
                                           } else if (\str_contains($contentType, 'xml')) {
                                               return Xml::toArray($request->getContent());
                                           } else {
                                               return $request->post ?? [];
                                           }
                                       })->withUploadedFiles($request->files ?? [])
                                       ->withMethod($request->getMethod());
    }


}