as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

改名

Browse Source
This commit is contained in:
Mr·x
2021-08-03 15:13:12 +08:00
parent e07d8ca163
commit fed06d7728
1 changed files with 10 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Server/HTTPServerListener.php
+10 -4
View File
@@ -6,8 +6,6 @@ use Exception;
use HttpServer\Http\Context; use HttpServer\Http\Context;
use HttpServer\Http\Request as HSRequest; use HttpServer\Http\Request as HSRequest;
use HttpServer\Route\Router; use HttpServer\Route\Router;
use ReflectionException;
use Snowflake\Exception\NotFindClassException;
use Snowflake\Snowflake; use Snowflake\Snowflake;
use Swoole\Error; use Swoole\Error;
use Swoole\Http\Request; use Swoole\Http\Request;
@@ -56,7 +54,15 @@ class HTTPServerListener extends Abstracts\Server
$this->setEvents(Constant::CONNECT, $settings['events'][Constant::CONNECT] ?? null); $this->setEvents(Constant::CONNECT, $settings['events'][Constant::CONNECT] ?? null);
$server->set(array_merge($settings['settings'] ?? [], ['enable_unsafe_event' => false])); $server->set(array_merge($settings['settings'] ?? [], ['enable_unsafe_event' => false]));
$server->on('request', [$this, 'onRequest']); if (isset($settings['events'][Constant::REQUEST])) {
$event = $settings['events'][Constant::REQUEST];
if (is_array($event) && is_string($event[0])) {
$event[0] = di($event[0]);
}
$server->on('request', $event);
} else {
$server->on('request', [$this, 'onRequest']);
}
$server->on('connect', [$this, 'onConnect']); $server->on('connect', [$this, 'onConnect']);
$server->on('close', [$this, 'onClose']); $server->on('close', [$this, 'onClose']);
return $server; return $server;
@@ -86,7 +92,7 @@ class HTTPServerListener extends Abstracts\Server
$this->router->dispatch(HSRequest::create($request)); $this->router->dispatch(HSRequest::create($request));
} catch (Error | Throwable $exception) { } catch (Error | Throwable $exception) {
$this->response->send(jTraceEx($exception),500); $this->response->send(jTraceEx($exception), 500);
} }
} }