funtional POC

Author: kpicaza

config/services/dependencies.prod.yaml

@@ -26,3 +26,6 @@ parameters:
         options:
           stream: 'var/log/%date%-default.log'
           level: 400
+  server:
+    max_concurrency: 2048
+    workers: 16

public/index.php

@@ -4,6 +4,7 @@
 declare(strict_types=1);
 
 use Antidot\Application\Http\Application;
+use Antidot\React\Child;
 use Psr\Log\LoggerInterface;
 use React\EventLoop\LoopInterface;
 use React\Http\Server;
@@ -18,15 +19,18 @@
     (require 'router/routes.php')($application, $container);
 
     $loop = $container->get(LoopInterface::class);
-
-    $server = $container->get(Server::class);
-    $server->on('error', static function ($err) use ($container) {
-        $logger = $container->get(LoggerInterface::class);
-        $logger->critical($err);
-    });
-
-    $socket = $container->get(Socket::class);
-    $server->listen($socket);
+    Child::fork(
+        shell_exec('nproc') ? (int)shell_exec('nproc') : 16,
+        static function () use ($container) {
+            $server = $container->get(Server::class);
+            $server->on('error', static function ($err) use ($container) {
+                $logger = $container->get(LoggerInterface::class);
+                $logger->critical($err);
+            });
+
+            $socket = $container->get(Socket::class);
+            $server->listen($socket);
+        });
 
     $loop->run();
 });

router/middleware.php

@@ -11,8 +11,8 @@
 
 return static function (Application $app): void {
     $app->pipe(ErrorMiddleware::class);
-    $app->pipe(ExceptionLoggerMiddleware::class);
-    $app->pipe(RequestLoggerMiddleware::class);
+//    $app->pipe(ExceptionLoggerMiddleware::class);
+//    $app->pipe(RequestLoggerMiddleware::class);
     $app->pipe(RouteDispatcherMiddleware::class);
     $app->pipe(RouteNotFoundMiddleware::class);
 };

src/Application/EventListener/SomeEventListener.php

@@ -10,6 +10,7 @@
 use React\Promise\FulfilledPromise;
 use React\Promise\PromiseInterface;
 use function get_class;
+use function React\Promise\resolve;
 use function sprintf;
 
 class SomeEventListener
@@ -24,9 +25,7 @@ public function __construct(LoggerInterface $logger)
 
     public function __invoke(SomeEvent $event): PromiseInterface
     {
-        $promise = new FulfilledPromise($event);
-
-        return $promise->then(function (SomeEvent $event) {
+        return resolve($event)->then(function (SomeEvent $event) {
             $this->logger->debug(sprintf('Event `%s` captured.', get_class($event)));
         });
     }

src/Application/Http/Middleware/HelloWorld.php

@@ -4,18 +4,24 @@
 
 namespace App\Application\Http\Middleware;
 
+use Antidot\React\PromiseResponse;
 use Psr\Http\Message\ResponseInterface;
 use Psr\Http\Message\ServerRequestInterface;
 use Psr\Http\Server\MiddlewareInterface;
 use Psr\Http\Server\RequestHandlerInterface;
+use function React\Promise\resolve;
 
 class HelloWorld implements MiddlewareInterface
 {
     public function process(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface
     {
-        $greet = $request->getQueryParams()['greet'] ?? 'World';
-        $request = $request->withAttribute('greet', $greet);
+        return new PromiseResponse(resolve($request)->then(
+            function (ServerRequestInterface $request) use ($handler): ResponseInterface {
+                $greet = $request->getQueryParams()['greet'] ?? 'World';
+                $request = $request->withAttribute('greet', $greet);
 
-        return $handler->handle($request);
+                return $handler->handle($request);
+            }
+        ));
     }
 }