This commit is contained in:
as2252258@163.com
2021-09-26 00:26:58 +08:00
parent 477de51126
commit b8b3221d51
3 changed files with 17 additions and 19 deletions
+1 -1
View File
@@ -102,10 +102,10 @@ abstract class Handler implements RequestHandlerInterface
if (!$interface->hasContentType()) { if (!$interface->hasContentType()) {
$interface->withContentType('application/json;charset=utf-8'); $interface->withContentType('application/json;charset=utf-8');
} }
if (str_contains($interface->getContentType(), 'xml')) {
if (is_object($responseData)) { if (is_object($responseData)) {
$responseData = get_object_vars($responseData); $responseData = get_object_vars($responseData);
} }
if (str_contains($interface->getContentType(), 'xml')) {
$interface->getBody()->write(Help::toXml($responseData)); $interface->getBody()->write(Help::toXml($responseData));
} else if (is_array($responseData)) { } else if (is_array($responseData)) {
$interface->getBody()->write(json_encode($responseData)); $interface->getBody()->write(json_encode($responseData));
+12 -7
View File
@@ -38,28 +38,33 @@ class MiddlewareManager extends BaseObject
if (is_string($middlewares)) { if (is_string($middlewares)) {
$middlewares = [$middlewares]; $middlewares = [$middlewares];
} }
$source = static::$_middlewares[$class][$method]; $source = &static::$_middlewares[$class][$method];
foreach ($middlewares as $middleware) { foreach ($middlewares as $middleware) {
if (isset($source[$middleware])) { $middleware = di($middleware);
if (!in_array($middleware, $source)) {
continue; continue;
} }
$source[$middleware] = di($middleware); $source[] = $middleware;
} }
return true; return true;
} }
/**
* @param $class
* @param $method
* @return array
*/
private static function setDefault($class, $method): array private static function setDefault($class, $method): array
{ {
if (is_object($class)) { if (is_object($class)) {
$class = $class::class; $class = $class::class;
} }
if (!isset(static::$_middlewares[$class])) { if (!isset(static::$_middlewares[$class])) {
static::$_middlewares[$class] = []; static::$_middlewares[$class] = [];
} }
if (!isset(static::$_middlewares[$class][$method])) { if (!isset(static::$_middlewares[$class][$method])) {
static::$_middlewares[$class][$method] = new Iterator(); static::$_middlewares[$class][$method] = [];
} }
return [$class, $method]; return [$class, $method];
} }
@@ -69,12 +74,12 @@ class MiddlewareManager extends BaseObject
* @param $handler * @param $handler
* @return Iterator|null * @return Iterator|null
*/ */
public static function get($handler): ?Iterator public static function get($handler): ?array
{ {
if (!($handler instanceof Closure)) { if (!($handler instanceof Closure)) {
return static::$_middlewares[$handler[0]][$handler[1]] ?? null; return static::$_middlewares[$handler[0]][$handler[1]] ?? null;
} }
return di(Iterator::class); return null;
} }
+2 -9
View File
@@ -47,10 +47,6 @@ class Http implements OnCloseInterface, OnConnectInterface, OnRequestInterface
public Router $router; public Router $router;
#[Inject(Dispatcher::class)]
public Dispatcher $dispatcher;
/** /**
* @var ExceptionHandlerInterface * @var ExceptionHandlerInterface
*/ */
@@ -118,11 +114,8 @@ class Http implements OnCloseInterface, OnConnectInterface, OnRequestInterface
protected function handler(Handler $handler, $PsrRequest): \Psr\Http\Message\ResponseInterface protected function handler(Handler $handler, $PsrRequest): \Psr\Http\Message\ResponseInterface
{ {
$middlewares = MiddlewareManager::get($handler->callback); $middlewares = MiddlewareManager::get($handler->callback);
$this->dispatcher->setHandler($handler); $dispatcher = new Dispatcher($handler, $middlewares);
if (!empty($middlewares)) { return $dispatcher->handle($PsrRequest);
$this->dispatcher->setMiddlewares($middlewares);
}
return $this->dispatcher->handle($PsrRequest);
} }