Files
kiri-core/HttpServer/Events/OnRequest.php
T
2021-02-25 14:42:26 +08:00

95 lines
2.4 KiB
PHP

<?php
declare(strict_types=1);
namespace HttpServer\Events;
use Exception;
use HttpServer\Abstracts\Callback;
use HttpServer\Exception\ExitException;
use HttpServer\Http\Request as HRequest;
use HttpServer\Http\Response as HResponse;
use ReflectionException;
use Snowflake\Event;
use Snowflake\Exception\ComponentException;
use Snowflake\Exception\NotFindClassException;
use Snowflake\Snowflake;
use Swoole\Coroutine;
use Swoole\Error;
use Swoole\Http\Request;
use Swoole\Http\Response;
/**
* Class OnRequest
* @package HttpServer\Events
*/
class OnRequest extends Callback
{
/**
* @param Request $request
* @param Response $response
* @return void
* @throws Exception
*/
public function onHandler(Request $request, Response $response): mixed
{
try {
Coroutine::defer(function () use ($request) {
fire(Event::SYSTEM_RESOURCE_RELEASES);
});
[$request, $response] = static::create($request, $response);
if ($request->is('favicon.ico')) {
return \send(null, 404);
}
return \router()->dispatch();
} catch (ExitException | Error | \Throwable $exception) {
$this->addError($exception);
if ($exception instanceof ExitException) {
return \send($exception->getMessage(), $exception->getCode());
}
return $this->sendErrorMessage($request, $response, $exception);
}
}
/**
* @param $request
* @param $response
* @return array
* @throws NotFindClassException
* @throws ReflectionException
*/
public static function create($request, $response): array
{
return [HRequest::create($request), HResponse::create($response)];
}
/**
* @param $sRequest
* @param $sResponse
* @param $exception
* @return bool|string
* @throws ComponentException
* @throws Exception
*/
protected function sendErrorMessage($sRequest, $sResponse, $exception): bool|string
{
$params = Snowflake::app()->getLogger()->exception($exception);
if ($sResponse instanceof Response) {
$sResponse->header('Access-Control-Allow-Origin', '*');
$sResponse->status(200);
return $sResponse->end($params);
}
$sResponse->addHeader('Access-Control-Allow-Origin', '*');
$sResponse->addHeader('Access-Control-Allow-Headers', $sRequest->headers->get('access-control-request-headers'));
$sResponse->addHeader('Access-Control-Request-Method', $sRequest->headers->get('access-control-request-method'));
return $sResponse->send($params, 200);
}
}