first commit

src/Server.php

@@ -0,0 +1,165 @@
+<?php
+
+namespace Kiri\Message;
+
+
+use Exception;
+use Kiri;
+use Kiri\Abstracts\AbstractServer;
+use Kiri\Abstracts\Config;
+use Kiri\Abstracts\CoordinatorManager;
+use Kiri\Coordinator;
+use Kiri\Di\ContainerInterface;
+use Kiri\Di\Context;
+use Kiri\Events\EventProvider;
+use Kiri\Exception\ConfigException;
+use Kiri\Message\Abstracts\ExceptionHandlerInterface;
+use Kiri\Message\Abstracts\ResponseHelper;
+use Kiri\Message\Constrict\RequestInterface;
+use Kiri\Message\Constrict\ResponseInterface;
+use Kiri\Message\Handler\DataGrip;
+use Kiri\Message\Handler\Dispatcher;
+use Kiri\Message\Handler\RouterCollector;
+use Kiri\Message\Response as Psr7Response;
+use Kiri\Server\Events\OnAfterWorkerStart;
+use Kiri\Server\Events\OnBeforeWorkerStart;
+use Psr\Container\ContainerExceptionInterface;
+use Psr\Container\NotFoundExceptionInterface;
+use Psr\Http\Message\ResponseInterface as PsrResponseInterface;
+use Psr\Http\Message\ServerRequestInterface;
+use Psr\Http\Server\RequestHandlerInterface;
+use Swoole\Http\Request;
+use Swoole\Http\Response;
+
+
+/**
+ *
+ */
+class Server extends AbstractServer implements OnRequestInterface
+{
+
+	use ResponseHelper;
+
+	public RouterCollector $router;
+
+
+	/**
+	 * @var ExceptionHandlerInterface
+	 */
+	public ExceptionHandlerInterface $exception;
+
+
+	private ContentType $contentType;
+
+	public Emitter $emitter;
+
+
+	/**
+	 * @param ContainerInterface $container
+	 * @param Dispatcher $dispatcher
+	 * @param EventProvider $provider
+	 * @param DataGrip $dataGrip
+	 * @param array $config
+	 * @throws Exception
+	 */
+	public function __construct(
+		public ContainerInterface $container,
+		public Dispatcher         $dispatcher,
+		public EventProvider      $provider,
+		public DataGrip           $dataGrip,
+		array                     $config = [])
+	{
+		parent::__construct($config);
+	}
+
+
+	/**
+	 * @throws ContainerExceptionInterface
+	 * @throws NotFoundExceptionInterface
+	 * @throws Exception
+	 */
+	public function init()
+	{
+		$this->emitter = $this->container->get(Emitter::class);
+
+		$exception = Config::get('exception.http', ExceptionHandlerDispatcher::class);
+		if (!in_array(ExceptionHandlerInterface::class, class_implements($exception))) {
+			$exception = ExceptionHandlerDispatcher::class;
+		}
+		$this->exception = $this->container->get($exception);
+
+		$this->provider->on(OnBeforeWorkerStart::class, [$this, 'onStartWaite']);
+		$this->provider->on(OnAfterWorkerStart::class, [$this, 'onEndWaite']);
+
+		$this->contentType = Config::get('response.format', ContentType::JSON);
+		$this->router = $this->dataGrip->get('http');
+	}
+
+
+	/**
+	 * @return void
+	 */
+	public function onStartWaite(): void
+	{
+		CoordinatorManager::utility(Coordinator::WORKER_START)->waite();
+	}
+
+
+	/**
+	 * @return void
+	 */
+	public function onEndWaite(): void
+	{
+		CoordinatorManager::utility(Coordinator::WORKER_START)->done();
+	}
+
+
+	/**
+	 * @param Request $request
+	 * @param Response $response
+	 * @throws Exception
+	 */
+	public function onRequest(Request $request, Response $response): void
+	{
+		try {
+			/** @var ServerRequest $PsrRequest */
+			$PsrRequest = $this->initRequestAndResponse($request);
+
+			$dispatcher = $this->router->query($request->server['request_uri'], $request->getMethod());
+
+			$PsrResponse = $dispatcher->dispatch->recover($PsrRequest);
+		} catch (\Throwable $throwable) {
+			$this->logger->error($throwable->getMessage(), [$throwable]);
+			$PsrResponse = $this->exception->emit($throwable, di(Constrict\Response::class));
+		} finally {
+			$this->emitter->sender($response, $PsrResponse);
+		}
+	}
+	
+	
+	/**
+	 * @param Request $request
+	 * @return RequestInterface
+	 * @throws Exception
+	 */
+	private function initRequestAndResponse(Request $request): \Psr\Http\Message\RequestInterface
+	{
+		/** @var ResponseInterface $PsrResponse */
+		$PsrResponse = Context::set(ResponseInterface::class, new Psr7Response());
+		$PsrResponse->withContentType($this->contentType);
+
+		$serverRequest = (new ServerRequest())->withData($request->getContent())
+			->withServerParams($request->server)
+			->withServerTarget($request)
+			->withCookieParams($request->cookie ?? [])
+			->withQueryParams($request->get)
+			->withUploadedFiles($request->files)
+			->withMethod($request->getMethod())
+			->withParsedBody($request->post);
+
+		/** @var ServerRequest $PsrRequest */
+		return Context::set(RequestInterface::class, $serverRequest);
+	}
+
+
+}