This commit is contained in:
2021-02-25 14:42:26 +08:00
parent 8539971ca0
commit 9b1c28e735
6 changed files with 23 additions and 54 deletions
+10 -35
View File
@@ -10,7 +10,6 @@ use HttpServer\Exception\ExitException;
use HttpServer\Http\Request as HRequest; use HttpServer\Http\Request as HRequest;
use HttpServer\Http\Response as HResponse; use HttpServer\Http\Response as HResponse;
use ReflectionException; use ReflectionException;
use Snowflake\Core\Json;
use Snowflake\Event; use Snowflake\Event;
use Snowflake\Exception\ComponentException; use Snowflake\Exception\ComponentException;
use Snowflake\Exception\NotFindClassException; use Snowflake\Exception\NotFindClassException;
@@ -50,7 +49,7 @@ class OnRequest extends Callback
if ($exception instanceof ExitException) { if ($exception instanceof ExitException) {
return \send($exception->getMessage(), $exception->getCode()); return \send($exception->getMessage(), $exception->getCode());
} }
return $this->sendErrorMessage($exception); return $this->sendErrorMessage($request, $response, $exception);
} }
} }
@@ -69,50 +68,26 @@ class OnRequest extends Callback
/** /**
* @param $response * @param $sRequest
* @throws Exception * @param $sResponse
*/
public static function shutdown($response)
{
try {
$error = error_get_last();
if (!isset($error['type'])) {
return;
}
$types = [E_ERROR, E_PARSE, E_CORE_ERROR, E_COMPILE_ERROR];
if (!in_array($error['type'], $types)) {
return;
}
$message = $error['message'] . ':' . microtime(true);
if ($response instanceof Response) {
$response->status(500);
$response->end($message);
}
} catch (\ErrorException $exception) {
$logger = Snowflake::app()->getLogger();
$logger->write($exception->getMessage(), 'shutdown');
} finally {
unset($response);
}
}
/**
* @param $exception * @param $exception
* @return bool|string * @return bool|string
* @throws ComponentException * @throws ComponentException
* @throws Exception * @throws Exception
*/ */
protected function sendErrorMessage($exception): bool|string protected function sendErrorMessage($sRequest, $sResponse, $exception): bool|string
{ {
$params = Snowflake::app()->getLogger()->exception($exception);
$sRequest = \request(); if ($sResponse instanceof Response) {
$sResponse = \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-Origin', '*');
$sResponse->addHeader('Access-Control-Allow-Headers', $sRequest->headers->get('access-control-request-headers')); $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')); $sResponse->addHeader('Access-Control-Request-Method', $sRequest->headers->get('access-control-request-method'));
$params = Snowflake::app()->getLogger()->exception($exception);
return $sResponse->send($params, 200); return $sResponse->send($params, 200);
} }
+2 -1
View File
@@ -5,6 +5,7 @@ namespace HttpServer\Exception;
use JetBrains\PhpStorm\Pure;
use Throwable; use Throwable;
/** /**
@@ -20,7 +21,7 @@ class ExitException extends \Exception
* @param int $code * @param int $code
* @param Throwable|null $previous * @param Throwable|null $previous
*/ */
public function __construct($message = "", $code = 0, Throwable $previous = null) #[Pure] public function __construct($message = "", $code = 0, Throwable $previous = null)
{ {
parent::__construct($message, $code, $previous); parent::__construct($message, $code, $previous);
} }
+1 -1
View File
@@ -454,7 +454,7 @@ class Request extends HttpService
if (!empty($request->post)) { if (!empty($request->post)) {
$sRequest->params->setPosts($request->post ?? []); $sRequest->params->setPosts($request->post ?? []);
} }
$sRequest->headers = Snowflake::createObject(HttpHeaders::class, [array_merge($request->server, $request->header ?? [])]); $sRequest->headers = Snowflake::createObject(HttpHeaders::class, [merge($request->server, $request->header)]);
$sRequest->parseUri(); $sRequest->parseUri();
return $sRequest; return $sRequest;
+6 -7
View File
@@ -472,14 +472,13 @@ class Router extends HttpService implements RouterInterface
public function dispatch(): mixed public function dispatch(): mixed
{ {
if (!($node = $this->find_path(\request()))) { if (!($node = $this->find_path(\request()))) {
return send(self::NOT_FOUND, 404); return send(self::NOT_FOUND);
} else {
send($response = $node->dispatch(), 200);
if (!$node->hasAfter()) {
return null;
}
return $node->afterDispatch($response);
} }
send($response = $node->dispatch(), 200);
if (!$node->hasAfter()) {
return null;
}
return $node->afterDispatch($response);
} }
+3 -9
View File
@@ -210,23 +210,17 @@ class BaseObject implements Configure
*/ */
public function error(mixed $message, $method = null, $file = null) public function error(mixed $message, $method = null, $file = null)
{ {
$socket = Snowflake::app()->getLogger();
if (!empty($file)) { if (!empty($file)) {
echo "\033[41;37m[ERROR][" . date('Y-m-d H:i:s') . ']: ' . $file . "\033[0m"; $socket->output("\033[41;37m[ERROR][" . date('Y-m-d H:i:s') . ']: ' . $file . PHP_EOL . "\033[0m");
echo PHP_EOL;
} }
if (!is_string($message)) { if (!is_string($message)) {
$message = print_r($message, true); $message = print_r($message, true);
} }
$content = (empty($method) ? '' : $method . ': ') . $message; $content = (empty($method) ? '' : $method . ': ') . $message;
$length = strlen('[ERROR][2021-02-20 08:32:02]:'); $message = "\033[41;37m" . PHP_EOL . "[ERROR][" . date('Y-m-d H:i:s') . ']: ' . $content . PHP_EOL . "\033[0m";
$message = "\033[41;37m" . PHP_EOL . "[ERROR][" . date('Y-m-d H:i:s') . ']: ' . PHP_EOL . "\033[0m";
$message .= "\033[41;37m" . str_pad($content, $length, ' ', STR_PAD_LEFT) . "\033[0m";
$message .= PHP_EOL;
$socket = Snowflake::app()->getLogger();
$socket->output($message); $socket->output($message);
} }
+1 -1
View File
@@ -511,7 +511,7 @@ if (!function_exists('send')) {
* @return bool|Response|stdClass|string * @return bool|Response|stdClass|string
* @throws Exception * @throws Exception
*/ */
function send($context, $statusCode = 200): Response|bool|string|stdClass function send($context, $statusCode = 404): Response|bool|string|stdClass
{ {
return \response()->send($context, $statusCode); return \response()->send($context, $statusCode);
} }