改名

http-handler/Abstracts/Handler.php

@@ -2,11 +2,12 @@
 
 namespace Http\Handler\Abstracts;
 
+use Http\Handler\Handler as CHl;
+use Kiri\Kiri;
 use Psr\Http\Message\ResponseInterface;
 use Psr\Http\Message\ServerRequestInterface;
 use Psr\Http\Server\MiddlewareInterface;
 use Psr\Http\Server\RequestHandlerInterface;
-use Http\Handler\Handler as CHl;
 
 
 abstract class Handler implements RequestHandlerInterface
@@ -33,7 +34,11 @@ abstract class Handler implements RequestHandlerInterface
 	protected function execute(ServerRequestInterface $request): ResponseInterface
 	{
 		if (empty($this->middlewares) || !isset($this->middlewares[$this->offset])) {
-			return call_user_func($this->handler->callback, ...$this->handler->params);
+			[$controller, $action] = $this->handler->callback;
+
+			$controller = Kiri::getDi()->get($controller);
+
+			return call_user_func([$controller, $action], ...$this->handler->params);
 		}
 
 		$middleware = $this->middlewares[$this->offset];

http-handler/Abstracts/HandlerManager.php

@@ -13,11 +13,11 @@ class HandlerManager
 
 
 	/**
-	 * @param $path
-	 * @param $method
-	 * @param $handler
+	 * @param string $path
+	 * @param string $method
+	 * @param \Http\Handler\Handler|Closure $handler
 	 */
-	public static function add($path, $method, $handler)
+	public static function add(string $path, string $method, \Http\Handler\Handler|Closure $handler)
 	{
 		if (!isset(static::$handlers[$path])) {
 			static::$handlers[$path] = [];

http-handler/CoreMiddleware.php

@@ -20,6 +20,9 @@ class CoreMiddleware extends Middleware
 	public function process(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface
 	{
 		// TODO: Implement process() method.
+
+
+
 		return $handler->handle($request);
 	}
 

http-handler/Dispatcher.php

@@ -3,9 +3,14 @@
 namespace Http\Handler;
 
 use Exception;
+use Kiri\Core\Help;
 use Psr\Http\Message\ResponseInterface;
 use Psr\Http\Message\ServerRequestInterface;
 
+
+/**
+ *
+ */
 class Dispatcher extends \Http\Handler\Abstracts\Handler
 {
 
@@ -17,6 +22,35 @@ class Dispatcher extends \Http\Handler\Abstracts\Handler
 	 */
 	public function handle(ServerRequestInterface $request): ResponseInterface
 	{
-		return $this->execute($request);
+		$response = $this->execute($request);
+		if (!$response instanceof ResponseInterface) {
+			return $this->transferToResponse($response);
+		}
+		return $response;
+	}
+
+
+	/**
+	 * @param mixed $responseData
+	 * @return \Server\Constrict\ResponseInterface
+	 * @throws Exception
+	 */
+	private function transferToResponse(mixed $responseData): ResponseInterface
+	{
+		$interface = response()->withStatus(200);
+		if (!$interface->hasContentType()) {
+			$interface->withContentType('application/json;charset=utf-8');
+		}
+		if (is_object($responseData)) {
+			$responseData = get_object_vars($responseData);
+		}
+		if ($interface->getContentType() == 'application/xml;charset=utf-8') {
+			$interface->getBody()->write(Help::toXml($responseData));
+		} else if (is_array($responseData)) {
+			$interface->getBody()->write(json_encode($responseData));
+		} else {
+			$interface->getBody()->write((string)$responseData);
+		}
+		return $interface;
 	}
 }

http-handler/TestRequest.php

@@ -8,10 +8,10 @@ use Http\Handler\Abstracts\HandlerManager;
 use Http\Message\ServerRequest;
 use Http\Message\Stream;
 use Http\Route\MiddlewareManager;
-use Psr\Http\Message\ResponseInterface;
 use Psr\Http\Message\ServerRequestInterface;
 use Server\Constrict\RequestInterface;
 use Server\Constrict\ResponseEmitter;
+use Server\Constrict\ResponseInterface;
 use Swoole\Http\Request;
 use Swoole\Http\Response;
 
@@ -19,75 +19,65 @@ class TestRequest
 {
 
 
-    private ?ResponseEmitter $response = null;
+	private ?ResponseEmitter $response = null;
 
 
-    /**
-     * @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(null);
-            } else if (is_null($handler)) {
-                $PsrResponse->withStatus(404)->withBody(null);
-            } else {
-                $PsrResponse = $this->handler($handler, $PsrRequest);
-            }
-        } catch (\Throwable $throwable) {
-            $PsrResponse = $this->throwable($throwable);
-        } finally {
-            $this->response->sender($response, $PsrResponse);
-        }
-    }
+	/**
+	 * @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(null);
+			} else if (is_null($handler)) {
+				$PsrResponse->withStatus(404)->withBody(null);
+			} else {
+				$PsrResponse = $this->handler($handler, $PsrRequest);
+			}
+		} catch (\Throwable $throwable) {
+			$PsrResponse = \response()->withStatus($throwable->getCode())
+				->withContentType(\Http\Message\Response::CONTENT_TYPE_HTML)
+				->withBody(new Stream(jTraceEx($throwable)));
+		} finally {
+			$this->response->sender($response, $PsrResponse);
+		}
+	}
 
 
-    /**
-     * @param \Throwable $throwable
-     * @return \Psr\Http\Message\ResponseInterface
-     */
-    protected function throwable(\Throwable $throwable): ResponseInterface
-    {
-        return \response()->withStatus($throwable->getCode())
-            ->withContentType(\Http\Message\Response::CONTENT_TYPE_HTML)
-            ->withBody(new Stream(jTraceEx($throwable)));
-    }
+	/**
+	 * @param Handler $handler
+	 * @param $PsrRequest
+	 * @return ResponseInterface
+	 * @throws Exception
+	 */
+	protected function handler(Handler $handler, $PsrRequest): \Psr\Http\Message\ResponseInterface
+	{
+		$middlewares = MiddlewareManager::get($handler->callback);
+
+		$dispatcher = new Dispatcher($handler, $middlewares);
+
+		return $dispatcher->handle($PsrRequest);
+	}
 
 
-    /**
-     * @param \Http\Handler\Handler $handler
-     * @param $PsrRequest
-     * @return \Psr\Http\Message\ResponseInterface
-     * @throws \Exception
-     */
-    protected function handler(Handler $handler, $PsrRequest): ResponseInterface
-    {
-        $middlewares = MiddlewareManager::get($handler->callback);
+	/**
+	 * @param Request $request
+	 * @return array<ServerRequestInterface, ResponseInterface>
+	 * @throws Exception
+	 */
+	private function initRequestResponse(Request $request): array
+	{
+		$PsrResponse = Context::setContext(ResponseInterface::class, new \Http\Message\Response());
 
-        $dispatcher = new Dispatcher($handler, $middlewares);
+		$PsrRequest = Context::setContext(RequestInterface::class, ServerRequest::createServerRequest($request));
 
-        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));
-
-        return [$PsrRequest, $PsrResponse];
-    }
+		return [$PsrRequest, $PsrResponse];
+	}
 
 }