155 lines
3.8 KiB
PHP
155 lines
3.8 KiB
PHP
<?php
|
|
|
|
namespace Server\Service;
|
|
|
|
|
|
use Annotation\Inject;
|
|
use Exception;
|
|
use Http\Handler\Abstracts\HandlerManager;
|
|
use Http\Handler\Context;
|
|
use Http\Handler\Dispatcher;
|
|
use Http\Handler\Handler;
|
|
use Http\Handler\Router;
|
|
use Http\Message\ServerRequest;
|
|
use Http\Message\Stream;
|
|
use Kiri\Abstracts\Config;
|
|
use Kiri\Exception\ConfigException;
|
|
use Kiri\Kiri;
|
|
use Psr\Http\Message\ServerRequestInterface;
|
|
use Server\Abstracts\Utility\EventDispatchHelper;
|
|
use Server\Abstracts\Utility\ResponseHelper;
|
|
use Server\Constrict\RequestInterface;
|
|
use Server\Constrict\ResponseEmitter;
|
|
use Server\Constrict\ResponseInterface;
|
|
use Server\Events\OnAfterRequest;
|
|
use Server\ExceptionHandlerDispatcher;
|
|
use Server\ExceptionHandlerInterface;
|
|
use Server\SInterface\OnCloseInterface;
|
|
use Server\SInterface\OnConnectInterface;
|
|
use Server\SInterface\OnRequestInterface;
|
|
use Swoole\Http\Request;
|
|
use Swoole\Http\Response;
|
|
use Swoole\Server;
|
|
|
|
/**
|
|
*
|
|
*/
|
|
class Http implements OnCloseInterface, OnConnectInterface, OnRequestInterface
|
|
{
|
|
|
|
use EventDispatchHelper;
|
|
use ResponseHelper;
|
|
|
|
/** @var Router|mixed */
|
|
#[Inject(Router::class)]
|
|
public Router $router;
|
|
|
|
|
|
/**
|
|
* @var ExceptionHandlerInterface
|
|
*/
|
|
public ExceptionHandlerInterface $exceptionHandler;
|
|
|
|
|
|
/**
|
|
* @throws ConfigException
|
|
*/
|
|
public function init()
|
|
{
|
|
$exceptionHandler = Config::get('exception.http', ExceptionHandlerDispatcher::class);
|
|
if (!in_array(ExceptionHandlerInterface::class, class_implements($exceptionHandler))) {
|
|
$exceptionHandler = ExceptionHandlerDispatcher::class;
|
|
}
|
|
$this->exceptionHandler = Kiri::getDi()->get($exceptionHandler);
|
|
$this->responseEmitter = Kiri::getDi()->get(ResponseEmitter::class);
|
|
}
|
|
|
|
|
|
/**
|
|
* @param Server $server
|
|
* @param int $fd
|
|
*/
|
|
public function onConnect(Server $server, int $fd): void
|
|
{
|
|
// TODO: Implement onConnect() method.
|
|
}
|
|
|
|
|
|
/**
|
|
* @param Request $request
|
|
* @param Response $response
|
|
* @throws Exception
|
|
*/
|
|
public function onRequest(Request $request, Response $response): void
|
|
{
|
|
try {
|
|
[$PsrRequest, $PsrResponse] = $this->initRequestResponse($request);
|
|
/** @var Handler $handler */
|
|
$handler = HandlerManager::get($request->server['request_uri'], $request->getMethod());
|
|
if (is_integer($handler)) {
|
|
$PsrResponse->withStatus($handler)->withBody(new Stream('Allow Method[' . $request->getMethod() . '].'));
|
|
} else if (is_null($handler)) {
|
|
$PsrResponse->withStatus(404)->withBody(new Stream('Page not found.'));
|
|
} else {
|
|
$PsrResponse = $this->handler($handler, $PsrRequest);
|
|
}
|
|
} catch (\Throwable $throwable) {
|
|
$PsrResponse = $this->exceptionHandler->emit($throwable, $this->response);
|
|
} finally {
|
|
$this->responseEmitter->sender($response, $PsrResponse);
|
|
$this->eventDispatch->dispatch(new OnAfterRequest());
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
* @param Handler $handler
|
|
* @param $PsrRequest
|
|
* @return ResponseInterface
|
|
* @throws Exception
|
|
*/
|
|
protected function handler(Handler $handler, $PsrRequest): \Psr\Http\Message\ResponseInterface
|
|
{
|
|
$dispatcher = new Dispatcher($handler, $handler->_middlewares);
|
|
return $dispatcher->handle($PsrRequest);
|
|
}
|
|
|
|
|
|
/**
|
|
* @param Request $request
|
|
* @return array<ServerRequestInterface, ResponseInterface>
|
|
* @throws Exception
|
|
*/
|
|
private function initRequestResponse(Request $request): array
|
|
{
|
|
$PsrResponse = Context::setContext(ResponseInterface::class, new \Http\Message\Response());
|
|
|
|
$PsrRequest = Context::setContext(RequestInterface::class, ServerRequest::createServerRequest($request));
|
|
if ($PsrRequest->isMethod('OPTIONS')) {
|
|
$request->server['request_uri'] = '/*';
|
|
}
|
|
return [$PsrRequest, $PsrResponse];
|
|
}
|
|
|
|
|
|
/**
|
|
* @param Server $server
|
|
* @param int $fd
|
|
* @throws Exception
|
|
*/
|
|
public function onDisconnect(Server $server, int $fd): void
|
|
{
|
|
}
|
|
|
|
|
|
/**
|
|
* @param Server $server
|
|
* @param int $fd
|
|
* @throws Exception
|
|
*/
|
|
public function onClose(Server $server, int $fd): void
|
|
{
|
|
}
|
|
|
|
}
|