kiri-core/http-handler/Abstracts/Handler.php

<?php

namespace Http\Handler\Abstracts;

use Http\Handler\Handler as CHl;
use Kiri\Core\Help;
use Kiri\Kiri;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use Psr\Http\Server\MiddlewareInterface;
use Psr\Http\Server\RequestHandlerInterface;


abstract class Handler implements RequestHandlerInterface
{


	private int $offset = 0;


	/**
	 * @param CHl $handler
	 * @param array|null $middlewares
	 */
	public function __construct(protected CHl $handler, protected ?array $middlewares)
	{
	}


	/**
	 * @param ServerRequestInterface $request
	 * @return ResponseInterface
	 * @throws \Exception
	 */
	protected function execute(ServerRequestInterface $request): ResponseInterface
	{
		if (empty($this->middlewares) || !isset($this->middlewares[$this->offset])) {
			return $this->dispatcher();
		}

		$middleware = $this->middlewares[$this->offset];
		if (!($middleware instanceof MiddlewareInterface)) {
			throw new \Exception('get_implements_class($middleware) not found method process.');
		}

		++$this->offset;

		return $middleware->process($request, $this);
	}


	/**
	 * @return mixed
	 * @throws \Exception
	 */
	protected function dispatcher(): mixed
	{
		if ($this->handler->callback instanceof \Closure) {
			$response = call_user_func($this->handler->callback, ...$this->handler->params);
		} else {
			[$controller, $action] = $this->handler->callback;

			$controller = Kiri::getDi()->get($controller);

			$response = call_user_func([$controller, $action], ...$this->handler->params);
		}
		if (!($response instanceof ResponseInterface)) {
			$response = $this->transferToResponse($response);
		}
		return $response;
	}


	/**
	 * @param mixed $responseData
	 * @return \Server\Constrict\ResponseInterface
	 * @throws \Exception
	 */
	private function transferToResponse(mixed $responseData): ResponseInterface
	{
		$interface = response()->withStatus(200);
		if (!$interface->hasContentType()) {
			$interface->withContentType('application/json;charset=utf-8');
		}
		if (is_object($responseData)) {
			$responseData = get_object_vars($responseData);
		}
		if ($interface->getContentType() == 'application/xml;charset=utf-8') {
			$interface->getBody()->write(Help::toXml($responseData));
		} else if (is_array($responseData)) {
			$interface->getBody()->write(json_encode($responseData));
		} else {
			$interface->getBody()->write((string)$responseData);
		}
		return $interface;
	}


}