From c3685fdbef3a136e46d36e99ac9d983776711dae Mon Sep 17 00:00:00 2001
From: kawanamiyuu <i.am.really.you@gmail.com>
Date: Wed, 8 Jul 2020 22:43:18 +0900
Subject: [PATCH] extract framework from "kawanamiyuu/htb-feed"

---
 composer.json                     | 11 +++++-
 src/Application.php               | 47 +++++++++++++++++++++++++
 src/ApplicationInterface.php      | 15 ++++++++
 src/ExceptionHandler.php          | 29 ++++++++++++++++
 src/ExceptionHandlerInterface.php | 14 ++++++++
 src/FrameworkModule.php           | 57 +++++++++++++++++++++++++++++++
 src/MiddlewareContainer.php       | 33 ++++++++++++++++++
 src/RequestHandlerProvider.php    | 33 ++++++++++++++++++
 src/ResponseEmitter.php           | 16 +++++++++
 src/ResponseEmitterInterface.php  | 12 +++++++
 tests/FakeMiddleware.php          | 18 ++++++++++
 tests/FakeRequestHandler.php      | 27 +++++++++++++++
 tests/FrameworkModuleTest.php     | 23 +++++++++++++
 13 files changed, 334 insertions(+), 1 deletion(-)
 create mode 100644 src/Application.php
 create mode 100644 src/ApplicationInterface.php
 create mode 100644 src/ExceptionHandler.php
 create mode 100644 src/ExceptionHandlerInterface.php
 create mode 100644 src/FrameworkModule.php
 create mode 100644 src/MiddlewareContainer.php
 create mode 100644 src/RequestHandlerProvider.php
 create mode 100644 src/ResponseEmitter.php
 create mode 100644 src/ResponseEmitterInterface.php
 create mode 100644 tests/FakeMiddleware.php
 create mode 100644 tests/FakeRequestHandler.php
 create mode 100644 tests/FrameworkModuleTest.php

diff --git a/composer.json b/composer.json
index b838dae..4ec6567 100644
--- a/composer.json
+++ b/composer.json
@@ -2,6 +2,7 @@
     "name": "k9u/framework",
     "type": "library",
     "description": "Web Application Framework for PHP.",
+    "keywords": ["framework", "psr-7", "psr-15"],
     "license": "MIT",
     "authors": [
         {
@@ -11,7 +12,15 @@
     ],
     "minimum-stability": "stable",
     "require": {
-        "php": "^7.4"
+        "php": "^7.4",
+        "laminas/laminas-diactoros": "^2.3",
+        "laminas/laminas-httphandlerrunner": "^1.2",
+        "psr/http-factory": "^1.0",
+        "psr/http-message": "^1.0",
+        "psr/http-server-handler": "^1.0",
+        "psr/http-server-middleware": "^1.0",
+        "ray/di": "^2.10",
+        "relay/relay": "^2.1"
     },
     "require-dev": {
         "phpmd/phpmd": "^2.8",
diff --git a/src/Application.php b/src/Application.php
new file mode 100644
index 0000000..b4f1d70
--- /dev/null
+++ b/src/Application.php
@@ -0,0 +1,47 @@
+<?php
+
+declare(strict_types=1);
+
+namespace K9u\Framework;
+
+use Psr\Http\Message\ServerRequestInterface;
+use Psr\Http\Server\RequestHandlerInterface;
+use Throwable;
+
+/**
+ * @SuppressWarnings("PMD.LongVariable")
+ */
+class Application implements ApplicationInterface
+{
+    private RequestHandlerInterface $requestHandler;
+
+    private ExceptionHandlerInterface $exceptionHandler;
+
+    private ResponseEmitterInterface $responseEmitter;
+
+    /**
+     * @param RequestHandlerInterface   $requestHandler
+     * @param ExceptionHandlerInterface $exceptionHandler
+     * @param ResponseEmitterInterface  $responseEmitter
+     */
+    public function __construct(
+        RequestHandlerInterface $requestHandler,
+        ExceptionHandlerInterface $exceptionHandler,
+        ResponseEmitterInterface $responseEmitter
+    ) {
+        $this->requestHandler = $requestHandler;
+        $this->exceptionHandler = $exceptionHandler;
+        $this->responseEmitter = $responseEmitter;
+    }
+
+    public function __invoke(ServerRequestInterface $request): void
+    {
+        try {
+            $response = $this->requestHandler->handle($request);
+        } catch (Throwable $th) {
+            $response = ($this->exceptionHandler)($th, $request);
+        }
+
+        ($this->responseEmitter)($response);
+    }
+}
diff --git a/src/ApplicationInterface.php b/src/ApplicationInterface.php
new file mode 100644
index 0000000..d9d024f
--- /dev/null
+++ b/src/ApplicationInterface.php
@@ -0,0 +1,15 @@
+<?php
+
+declare(strict_types=1);
+
+namespace K9u\Framework;
+
+use Psr\Http\Message\ServerRequestInterface;
+
+interface ApplicationInterface
+{
+    /**
+     * @param ServerRequestInterface $request
+     */
+    public function __invoke(ServerRequestInterface $request): void;
+}
diff --git a/src/ExceptionHandler.php b/src/ExceptionHandler.php
new file mode 100644
index 0000000..083f60f
--- /dev/null
+++ b/src/ExceptionHandler.php
@@ -0,0 +1,29 @@
+<?php
+
+declare(strict_types=1);
+
+namespace K9u\Framework;
+
+use Psr\Http\Message\ResponseFactoryInterface;
+use Psr\Http\Message\ResponseInterface;
+use Psr\Http\Message\ServerRequestInterface;
+use Throwable;
+
+class ExceptionHandler implements ExceptionHandlerInterface
+{
+    private ResponseFactoryInterface $responseFactory;
+
+    public function __construct(ResponseFactoryInterface $responseFactory)
+    {
+        $this->responseFactory = $responseFactory;
+    }
+
+    public function __invoke(Throwable $throwable, ServerRequestInterface $request): ResponseInterface
+    {
+        unset($request); // unused
+
+        error_log((string) $throwable);
+
+        return $this->responseFactory->createResponse(505);
+    }
+}
diff --git a/src/ExceptionHandlerInterface.php b/src/ExceptionHandlerInterface.php
new file mode 100644
index 0000000..53293af
--- /dev/null
+++ b/src/ExceptionHandlerInterface.php
@@ -0,0 +1,14 @@
+<?php
+
+declare(strict_types=1);
+
+namespace K9u\Framework;
+
+use Psr\Http\Message\ResponseInterface;
+use Psr\Http\Message\ServerRequestInterface;
+use Throwable;
+
+interface ExceptionHandlerInterface
+{
+    public function __invoke(Throwable $throwable, ServerRequestInterface $request): ResponseInterface;
+}
diff --git a/src/FrameworkModule.php b/src/FrameworkModule.php
new file mode 100644
index 0000000..7cb557c
--- /dev/null
+++ b/src/FrameworkModule.php
@@ -0,0 +1,57 @@
+<?php
+
+declare(strict_types=1);
+
+namespace K9u\Framework;
+
+use Laminas\Diactoros\ResponseFactory;
+use Psr\Http\Message\ResponseFactoryInterface;
+use Psr\Http\Server\RequestHandlerInterface;
+use Ray\Di\AbstractModule;
+use Ray\Di\Scope;
+
+/**
+ * @SuppressWarnings("PHPMD.CouplingBetweenObjects")
+ */
+class FrameworkModule extends AbstractModule
+{
+    /**
+     * @var array<class-string>
+     */
+    private array $middlewares;
+
+    /**
+     * @param array<class-string> $middlewares
+     * @param AbstractModule|null $module
+     */
+    public function __construct(array $middlewares, AbstractModule $module = null)
+    {
+        $this->middlewares = $middlewares;
+        parent::__construct($module);
+    }
+
+    protected function configure(): void
+    {
+        foreach ($this->middlewares as $middleware) {
+            $this->bind($middleware)->in(Scope::SINGLETON);
+        }
+
+        $this->bind(MiddlewareContainer::class)
+            ->toInstance(new MiddlewareContainer($this->middlewares));
+
+        $this->bind(RequestHandlerInterface::class)
+            ->toProvider(RequestHandlerProvider::class)->in(Scope::SINGLETON);
+
+        $this->bind(ResponseFactoryInterface::class)
+            ->to(ResponseFactory::class)->in(Scope::SINGLETON);
+
+        $this->bind(ExceptionHandlerInterface::class)
+            ->to(ExceptionHandler::class)->in(Scope::SINGLETON);
+
+        $this->bind(ResponseEmitterInterface::class)
+            ->to(ResponseEmitter::class)->in(Scope::SINGLETON);
+
+        $this->bind(ApplicationInterface::class)
+            ->to(Application::class)->in(Scope::SINGLETON);
+    }
+}
diff --git a/src/MiddlewareContainer.php b/src/MiddlewareContainer.php
new file mode 100644
index 0000000..7f41d07
--- /dev/null
+++ b/src/MiddlewareContainer.php
@@ -0,0 +1,33 @@
+<?php
+
+declare(strict_types=1);
+
+namespace K9u\Framework;
+
+use ArrayIterator;
+use IteratorAggregate;
+use Traversable;
+
+/**
+ * @implements \IteratorAggregate<class-string>
+ */
+class MiddlewareContainer implements IteratorAggregate
+{
+    /**
+     * @var array<class-string> $middlewares
+     */
+    private array $middlewares;
+
+    /**
+     * @param array<class-string> $middlewares
+     */
+    public function __construct(array $middlewares)
+    {
+        $this->middlewares = $middlewares;
+    }
+
+    public function getIterator(): Traversable
+    {
+        return new ArrayIterator($this->middlewares);
+    }
+}
diff --git a/src/RequestHandlerProvider.php b/src/RequestHandlerProvider.php
new file mode 100644
index 0000000..8cc75f8
--- /dev/null
+++ b/src/RequestHandlerProvider.php
@@ -0,0 +1,33 @@
+<?php
+
+declare(strict_types=1);
+
+namespace K9u\Framework;
+
+use Psr\Http\Server\MiddlewareInterface;
+use Psr\Http\Server\RequestHandlerInterface;
+use Ray\Di\InjectorInterface;
+use Ray\Di\ProviderInterface;
+use Relay\Relay;
+
+class RequestHandlerProvider implements ProviderInterface
+{
+    private MiddlewareContainer $middlewareContainer;
+
+    private InjectorInterface $injector;
+
+    public function __construct(MiddlewareContainer $middlewareContainer, InjectorInterface $injector)
+    {
+        $this->middlewareContainer = $middlewareContainer;
+        $this->injector = $injector;
+    }
+
+    public function get(): RequestHandlerInterface
+    {
+        return new Relay($this->middlewareContainer, function ($middleware) {
+            $instance = $this->injector->getInstance($middleware);
+            assert($instance instanceof MiddlewareInterface || $instance instanceof RequestHandlerInterface);
+            return $instance;
+        });
+    }
+}
diff --git a/src/ResponseEmitter.php b/src/ResponseEmitter.php
new file mode 100644
index 0000000..0ae82f8
--- /dev/null
+++ b/src/ResponseEmitter.php
@@ -0,0 +1,16 @@
+<?php
+
+declare(strict_types=1);
+
+namespace K9u\Framework;
+
+use Laminas\HttpHandlerRunner\Emitter\SapiStreamEmitter;
+use Psr\Http\Message\ResponseInterface;
+
+class ResponseEmitter implements ResponseEmitterInterface
+{
+    public function __invoke(ResponseInterface $response): void
+    {
+        (new SapiStreamEmitter())->emit($response);
+    }
+}
diff --git a/src/ResponseEmitterInterface.php b/src/ResponseEmitterInterface.php
new file mode 100644
index 0000000..b6dcbef
--- /dev/null
+++ b/src/ResponseEmitterInterface.php
@@ -0,0 +1,12 @@
+<?php
+
+declare(strict_types=1);
+
+namespace K9u\Framework;
+
+use Psr\Http\Message\ResponseInterface;
+
+interface ResponseEmitterInterface
+{
+    public function __invoke(ResponseInterface $response): void;
+}
diff --git a/tests/FakeMiddleware.php b/tests/FakeMiddleware.php
new file mode 100644
index 0000000..ae787e8
--- /dev/null
+++ b/tests/FakeMiddleware.php
@@ -0,0 +1,18 @@
+<?php
+
+declare(strict_types=1);
+
+namespace K9u\Framework;
+
+use Psr\Http\Message\ResponseInterface;
+use Psr\Http\Message\ServerRequestInterface;
+use Psr\Http\Server\MiddlewareInterface;
+use Psr\Http\Server\RequestHandlerInterface;
+
+class FakeMiddleware implements MiddlewareInterface
+{
+    public function process(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface
+    {
+        return $handler->handle($request);
+    }
+}
diff --git a/tests/FakeRequestHandler.php b/tests/FakeRequestHandler.php
new file mode 100644
index 0000000..f13d82c
--- /dev/null
+++ b/tests/FakeRequestHandler.php
@@ -0,0 +1,27 @@
+<?php
+
+declare(strict_types=1);
+
+namespace K9u\Framework;
+
+use Psr\Http\Message\ResponseFactoryInterface;
+use Psr\Http\Message\ResponseInterface;
+use Psr\Http\Message\ServerRequestInterface;
+use Psr\Http\Server\RequestHandlerInterface;
+
+class FakeRequestHandler implements RequestHandlerInterface
+{
+    private ResponseFactoryInterface $responseFactory;
+
+    public function __construct(ResponseFactoryInterface $responseFactory)
+    {
+        $this->responseFactory = $responseFactory;
+    }
+
+    public function handle(ServerRequestInterface $request): ResponseInterface
+    {
+        unset($request); // unused
+
+        return $this->responseFactory->createResponse(200);
+    }
+}
diff --git a/tests/FrameworkModuleTest.php b/tests/FrameworkModuleTest.php
new file mode 100644
index 0000000..ee50cb1
--- /dev/null
+++ b/tests/FrameworkModuleTest.php
@@ -0,0 +1,23 @@
+<?php
+
+declare(strict_types=1);
+
+namespace K9u\Framework;
+
+use PHPUnit\Framework\TestCase;
+use Ray\Di\Injector;
+
+class FrameworkModuleTest extends TestCase
+{
+    public function testCompile(): void
+    {
+        $injector = new Injector(new FrameworkModule([
+            FakeMiddleware::class,
+            FakeRequestHandler::class
+        ]));
+
+        $instance = $injector->getInstance(ApplicationInterface::class);
+
+        $this->assertInstanceOf(ApplicationInterface::class, $instance);
+    }
+}