add configurable server

Author: Koldo Picaza

README.md

@@ -22,6 +22,20 @@ Open your browser on port `8080`
 
 ## Config
 
+### Server Config
+
+Default config
+
+```yaml
+parameters:
+    server:
+      host: '0.0.0.0'
+      port: '8080'
+      max_concurrency: 100
+      buffer_size: 4194304
+
+```
+
 ### Development Mode
 
 To run it in dev mode you can run `config:development-mode` command

composer.json

@@ -17,7 +17,7 @@
   "require": {
     "php": "^7.4|^8.0",
     "ext-json": "*",
-    "antidot-fw/react-framework": "^1.0.0",
+    "antidot-fw/react-framework": "^1.0.3",
     "antidot-fw/fast-router-adapter": "^0.1.0",
     "antidot-fw/cli": "^1.1.0",
     "antidot-fw/container": "^0.1.0",

public/index.php

@@ -4,65 +4,28 @@
 declare(strict_types=1);
 
 use Antidot\Application\Http\Application;
-use Antidot\React\PromiseResponse;
-use Laminas\Diactoros\Response\HtmlResponse;
-use Psr\Http\Message\ServerRequestInterface;
-use Ramsey\Uuid\Uuid;
-use React\EventLoop\Factory;
-use React\Http\Middleware\LimitConcurrentRequestsMiddleware;
-use React\Http\Middleware\RequestBodyBufferMiddleware;
-use React\Http\Middleware\RequestBodyParserMiddleware;
-use React\Http\Middleware\StreamingRequestMiddleware;
+use Psr\Log\LoggerInterface;
+use React\EventLoop\LoopInterface;
 use React\Http\Server;
 use React\Socket\Server as Socket;
-use function React\Promise\resolve;
 
 require 'vendor/autoload.php';
 
 call_user_func(static function () {
-    $loop = Factory::create();
     $container = require 'config/container.php';
     $application = $container->get(Application::class);
     (require 'router/middleware.php')($application, $container);
     (require 'router/routes.php')($application, $container);
 
-    $server = new Server(
-        $loop,
-        new StreamingRequestMiddleware(),
-        new LimitConcurrentRequestsMiddleware(100), // 100 concurrent buffering handlers
-        new RequestBodyBufferMiddleware(4 * 1024 * 1024), // 4 MiB
-        new RequestBodyParserMiddleware(),
-        static function (ServerRequestInterface $request) use ($application) {
-            try {
-                $response = new PromiseResponse(
-                    resolve($request)
-                        ->then(static fn ($request) => $request->withAttribute('request_id', Uuid::uuid4()->toString()))
-                        ->then(static fn ($request) => $application->handle($request))
-                );
-            } catch (Throwable $exception) {
-                if (!empty($e = $exception->getPrevious())) {
-                    $exception = $e;
-                }
+    $loop = $container->get(LoopInterface::class);
 
-                $response = new HtmlResponse(
-                    sprintf(
-                        '%s in file %s in line %s.',
-                        $exception->getMessage(),
-                        $exception->getFile(),
-                        $exception->getLine()
-                    )
-                );
-            }
-
-            return resolve($response);
-        }
-    );
-
-    $server->on('error', function ($err) {
-        dump($err);
+    $server = $container->get(Server::class);
+    $server->on('error', static function ($err) use ($container) {
+        $logger = $container->get(LoggerInterface::class);
+        $logger->critical($err);
     });
 
-    $socket = new Socket('0.0.0.0:8080', $loop);
+    $socket = $container->get(Socket::class);
     $server->listen($socket);
 
     $loop->run();