add missing pieces to run antidot with react php

.gitignore

@@ -1,4 +1,5 @@
-.phpunit.result.cache
+/.phpunit.result.cache
 /composer.lock
 /coverage
+/infection.log
 /vendor

README.md

@@ -1,2 +1,3 @@
-# Antidot Framework Tactician Adapter
+# Antidot React Framework
+
 

composer.json

@@ -1,10 +1,10 @@
 {
-    "name": "antidot-fw/tactician",
-    "description": "Tactician Command bus adapter for Antidot Framework.",
+    "name": "antidot-fw/react-framework",
+    "description": "Antidot React Framework",
     "keywords": [
-        "psr-11",
-        "tacticican",
-        "command-bus"
+        "psr-15",
+        "react-php",
+        "antidot-framework"
     ],
     "type": "library",
     "license": "BSD-2-Clause",
@@ -15,27 +15,28 @@
     ],
     "require": {
         "php": "^7.4.3",
-        "beberlei/assert": "^3.2",
-        "enqueue/enqueue": "^0.10.1",
+        "antidot-fw/framework": "^0.1.3",
         "psr/container": "^1.0.0",
-        "psr/event-dispatcher": "^1.0"
+        "ramsey/uuid": "^4.1",
+        "react/http": "^1.2"
     },
     "require-dev": {
-        "phpro/grumphp": "~0.17",
+        "clue/block-react": "^1.4",
+        "infection/infection": "^0.20",
+        "phpro/grumphp": "^1.0.0",
         "phpunit/phpunit": "^8.0 || ^9.0",
-        "infection/infection": "^0.17",
         "squizlabs/php_codesniffer": "^3.4",
         "symfony/var-dumper": "^5.1",
-        "vimeo/psalm": "^3.14"
+        "vimeo/psalm": "^4.4"
     },
     "autoload": {
         "psr-4": {
-            "Antidot\\Tactician\\": "src"
+            "Antidot\\React\\": "src"
         }
     },
     "autoload-dev": {
         "psr-4": {
-            "AntidotTest\\Tactician\\": "test"
+            "AntidotTest\\React\\": "test"
         }
     },
     "scripts": {
@@ -47,7 +48,7 @@
         ],
         "cs-check": "phpcs src --colors",
         "cs-fix": "phpcbf src --colors",
-        "infection": "infection",
+        "infection": "XDEBUG_MODE=coverage infection",
         "psalm": "psalm",
         "test": "phpunit --colors=always"
     },

phpcs.xml.dist

@@ -1,6 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<ruleset name="Anti.Framework DBAL adapter coding standard">
-    <description>Anti.Framework DBAL adapter coding standard</description>
+<ruleset name="Antidot React Framework coding standard">
+    <description>Antidot React Framework coding standard</description>
 
     <!-- display progress -->
     <arg value="p"/>

psalm.xml

@@ -5,6 +5,7 @@
     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
     xmlns="https://getpsalm.org/schema/config"
     xsi:schemaLocation="https://getpsalm.org/schema/config vendor/vimeo/psalm/config.xsd"
+    autoloader="vendor/autoload.php"
 >
     <projectFiles>
         <directory name="src" />
@@ -33,7 +34,6 @@
         <MissingReturnType errorLevel="info" />
         <MissingPropertyType errorLevel="info" />
         <InvalidDocblock errorLevel="info" />
-        <MisplacedRequiredParam errorLevel="info" />
 
         <PropertyNotSetInConstructor errorLevel="info" />
         <MissingConstructor errorLevel="info" />

src/Container/Config/ConfigProvider.php

@@ -1,11 +1,20 @@
 <?php
 
-namespace Antidot\Tactician\Container\Config;
+namespace Antidot\React\Container\Config;
+
+use Antidot\Application\Http\Application;
+use Antidot\React\ReactApplicationFactory;
 
 class ConfigProvider
 {
     public function __invoke(): array
     {
-        return [];
+        return [
+            'dependencies' => [
+                'factories' => [
+                    Application::class => ReactApplicationFactory::class,
+                ],
+            ]
+        ];
     }
 }

src/MiddlewarePipeline.php

@@ -0,0 +1,108 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Antidot\React;
+
+use Antidot\Application\Http\Handler\NextHandler;
+use Antidot\Application\Http\Middleware\Pipeline;
+use Psr\Http\Message\ResponseInterface;
+use Psr\Http\Message\ServerRequestInterface;
+use Psr\Http\Server\MiddlewareInterface;
+use Psr\Http\Server\RequestHandlerInterface;
+use Ramsey\Uuid\Uuid;
+use SplQueue;
+use Throwable;
+use function React\Promise\reject;
+use function React\Promise\resolve;
+
+class MiddlewarePipeline implements Pipeline
+{
+    /** @var array<SplQueue> */
+    public array $concurrentPipelines;
+    /** @var array<MiddlewareInterface> */
+    private array $middlewareCollection;
+
+    /**
+     * @param array<MiddlewareInterface> $middlewareCollection
+     * @param array<SplQueue> $concurrentPipelines
+     */
+    public function __construct(
+        array $middlewareCollection = [],
+        array $concurrentPipelines = []
+    ) {
+        $this->concurrentPipelines = $concurrentPipelines;
+        $this->middlewareCollection = $middlewareCollection;
+    }
+
+    public function pipe(MiddlewareInterface $middleware): void
+    {
+        $this->middlewareCollection[] = $middleware;
+    }
+
+    public function handle(ServerRequestInterface $request): ResponseInterface
+    {
+        /** @var string $requestId */
+        $requestId = $request->getAttribute('request_id');
+        $this->setCurrentPipeline($requestId);
+
+        return new PromiseResponse(resolve($request)->then(
+            function (ServerRequestInterface $request) {
+                /** @var string $requestId */
+                $requestId = $request->getAttribute('request_id');
+                try {
+                    /** @var MiddlewareInterface $middleware */
+                    $middleware = $this->concurrentPipelines[$requestId]->dequeue();
+
+                    $response = $middleware->process($request, $this);
+                    unset($this->concurrentPipelines[$requestId]);
+
+                    return resolve($response);
+                } catch (Throwable $exception) {
+                    unset($this->concurrentPipelines[$requestId]);
+
+                    return reject($exception);
+                }
+            }
+        ));
+    }
+
+    public function process(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface
+    {
+        /** @var ?string $requestId */
+        $requestId = $request->getAttribute('request_id');
+        if (!$requestId) {
+            $requestId = Uuid::uuid4()->toString();
+            $request = $request->withAttribute('request_id', $requestId);
+        }
+        $this->setCurrentPipeline($requestId);
+
+        return new PromiseResponse(resolve($request)
+            ->then(function (ServerRequestInterface $request) use ($handler) {
+                /** @var string $requestId */
+                $requestId = $request->getAttribute('request_id');
+                try {
+                    /** @var SplQueue<MiddlewareInterface> $queue */
+                    $queue = $this->concurrentPipelines[$requestId];
+                    $next = new NextHandler($queue, $handler);
+
+                    return resolve($next->handle($request));
+                } catch (Throwable $exception) {
+                    unset($this->concurrentPipelines[$requestId]);
+
+                    return reject($exception);
+                }
+            }));
+    }
+
+    private function setCurrentPipeline(string $requestId): void
+    {
+        if (empty($this->concurrentPipelines[$requestId])) {
+            $queue = new SplQueue();
+            foreach ($this->middlewareCollection as $middlewareName) {
+                $queue->enqueue($middlewareName);
+            }
+            $this->concurrentPipelines[$requestId] = $queue;
+        }
+    }
+}

src/PromiseResponse.php

@@ -0,0 +1,40 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Antidot\React;
+
+use Psr\Http\Message\ResponseInterface;
+use React\Promise\PromiseInterface;
+use RingCentral\Psr7\Response;
+use Throwable;
+
+class PromiseResponse extends Response implements PromiseInterface
+{
+    private PromiseInterface $promise;
+    protected $stream;
+
+    /**
+     * @param PromiseInterface $promise
+     * @param mixed $body
+     * @param int $status
+     * @param array $headers
+     */
+    public function __construct(
+        PromiseInterface $promise,
+        $body = null,
+        int $status = 200,
+        array $headers = []
+    ) {
+        parent::__construct($status, $headers, $body);
+        $this->promise = $promise;
+    }
+
+    final public function then(
+        callable $onFulfilled = null,
+        callable $onRejected = null,
+        callable $onProgress = null
+    ): PromiseInterface {
+        return $this->promise->then($onFulfilled, $onRejected, $onProgress);
+    }
+}