ReactPHP implementation added

Code refactored

Author: ahmard

README.md

@@ -7,6 +7,7 @@ composer require ahmard/php-server
 
 ## Usage
 ### PHP Built-In Server
+An implementation of [Built-In Server](https://www.php.net/manual/en/features.commandline.webserver.php)
 
 - With document root
 ```php
@@ -33,4 +34,27 @@ use PHPServer\BuiltIn\Server;
 Server::create('127.0.0.1', '9900')
     ->onRequest(fn() => var_dump('Request Received'))
     ->start();
+```
+
+
+### ReactPHP
+An implementation of [ReactPHP](https://reactphp.org)
+
+```php
+use PHPServer\React\Server;
+use Psr\Http\Message\RequestInterface;
+use React\Http\Message\Response;
+
+require 'vendor/autoload.php';
+
+$handler = function (RequestInterface $request) {
+    $html = 'Welcome,<br/>';
+    $html .= "Method: {$request->getMethod()}<br/>";
+    $html .= "Route: {$request->getUri()->getPath()}";
+    return new Response(200, ['Content-Type' => 'text/html'], $html);
+};
+
+Server::create('127.0.0.1', 9001)
+    ->onRequest($handler)
+    ->start();
 ```

bin/built-in.php

@@ -0,0 +1,16 @@
+<?php
+
+use PHPServer\ServerInfo;
+use PHPServer\Terminal;
+
+require 'vendor/autoload.php';
+
+$arguments = Terminal::performServerChecks(true);
+
+/**@var ServerInfo $serverInfo * */
+$serverInfo = $arguments['info'];
+
+
+if (null !== $serverInfo->getRequestCallback()) {
+    $serverInfo->getRequestCallback()();
+}

bin/react.php

@@ -0,0 +1,17 @@
+<?php
+
+use PHPServer\ServerInfo;
+use PHPServer\Terminal;
+use React\Http\HttpServer;
+use React\Socket\SocketServer;
+
+require 'vendor/autoload.php';
+
+$arguments = Terminal::performServerChecks();
+
+/**@var ServerInfo $serverInfo * */
+$serverInfo = $arguments['info'];
+
+$socket = new SocketServer("{$serverInfo->getHost()}:{$serverInfo->getPort()}");
+$http = new HttpServer($serverInfo->getRequestCallback());
+$http->listen($socket);

composer.json

@@ -5,7 +5,9 @@
     "license": "MIT",
     "require": {
         "php": "^8.0",
-        "react/child-process": "^0.6.3"
+        "react/child-process": "^0.6.3",
+        "react/http": "^1.5",
+        "opis/closure": "^3.6"
     },
     "require-dev": {
         "phpstan/phpstan": "^0.12.98",
@@ -14,7 +16,8 @@
     "autoload": {
         "psr-4": {
             "PHPServer\\": "src/"
-        }
+        },
+        "files": ["src/functions.php"]
     },
     "authors": [
         {

requests.http

@@ -0,0 +1,4 @@
+GET http://localhost:9001/
+Accept: application/json
+
+###

src/BuiltIn/Factory.php

@@ -3,60 +3,93 @@
 namespace PHPServer\BuiltIn;
 
 use Closure;
-use JetBrains\PhpStorm\ArrayShape;
 use JetBrains\PhpStorm\Pure;
+use PHPServer\ServerCommand;
+use PHPServer\ServerInfo;
+use PHPServer\ServerInterface;
+use PHPServer\ServerProcess;
+use PHPServer\StartedServer;
+use PHPServer\StartedServerInterface;
+use PHPServer\Terminal;
+use function PHPServer\base_path;
 
-class Server
+class Server implements ServerInterface
 {
+    protected static array $filledInfo = [];
     protected string|null $documentRoot = null;
     protected string|null $routerScript = null;
     protected Closure|null $requestCallback = null;
 
+    public function __construct(
+        protected string $host,
+        protected int    $port
+    )
+    {
+    }
 
-    #[Pure] public static function create(float|string $host, int $port): Server
+    #[Pure] public static function create(string $host, int $port): static
     {
         return new Server($host, $port);
     }
 
-    public function __construct(
-        protected float|string $host,
-        protected int $port
-    )
+    public function getCommand(): ServerCommand
     {
+        $config = $this->getInfo();
+        $command = "php -S {$config->getHost()}:{$config->getPort()}";
+
+        if (null == $config->getDocumentRoot()) {
+
+            if (null !== $config->getRouterScript()) {
+                $command .= " {$config->getRouterScript()}";
+            }
+
+            if (null !== $config->getRequestCallback()) {
+                $s = Terminal::encodeArgument($this->getInfo()->toArray());
+                $command = 'PHP_SERVER_INFO="' . $s . '" ' . $command;
+                $command .= ' ' . base_path('bin/built-in.php');
+            }
+
+        }
+
+        $serverCommand = ServerCommand::create($command);
+
+        if (null !== $config->getDocumentRoot()) {
+            $serverCommand->addArgument('-t', $config->getDocumentRoot());
+        }
+
+        return $serverCommand;
     }
 
-    public function setDocumentRoot(string $path): Server
+    public function getInfo(): ServerInfo
+    {
+        return ServerInfo::create()
+            ->setHost($this->host)
+            ->setPort($this->port)
+            ->setDocumentRoot($this->documentRoot)
+            ->setRequestCallback($this->requestCallback)
+            ->setRouterScript($this->routerScript);
+    }
+
+    public function setDocumentRoot(string $path): static
     {
         $this->documentRoot = $path;
         return $this;
     }
 
-    public function setRouterScript(string $filePath): Server
+    public function setRouterScript(string $filePath): static
     {
         $this->routerScript = $filePath;
         return $this;
     }
 
-    public function onRequest(callable $callback): Server
+    public function onRequest(callable $callback): static
     {
         $this->requestCallback = $callback;
         return $this;
     }
 
-    public function start(): StartedServer
+    public function start(): StartedServerInterface
     {
         return new StartedServer($this, ServerProcess::create($this));
     }
-
-    #[ArrayShape(['host' => "int|string", 'port' => "int", 'document_root' => "null|string", 'router_script' => "null|string", 'request_callback' => "\Closure|null"])]
-    public function getInfo(): array
-    {
-        return [
-            'host' => $this->host,
-            'port' => $this->port,
-            'document_root' => $this->documentRoot,
-            'router_script' => $this->routerScript,
-            'request_callback' => $this->requestCallback,
-        ];
-    }
 }

src/BuiltIn/Server.php

@@ -0,0 +1,68 @@
+<?php
+
+namespace PHPServer\React;
+
+use Closure;
+use JetBrains\PhpStorm\Pure;
+use PHPServer\ServerCommand;
+use PHPServer\ServerInfo;
+use PHPServer\ServerInterface;
+use PHPServer\ServerProcess;
+use PHPServer\StartedServer;
+use PHPServer\StartedServerInterface;
+use PHPServer\Terminal;
+use function PHPServer\base_path;
+
+class Server implements ServerInterface
+{
+    protected string|null $documentRoot = null;
+    protected string|null $routerScript = null;
+    protected Closure|null $requestCallback = null;
+
+    public function __construct(
+        protected string $host,
+        protected int    $port
+    )
+    {
+    }
+
+    #[Pure] public static function create(string $host, int $port): static
+    {
+        return new Server($host, $port);
+    }
+
+    public function setDocumentRoot(string $path): static
+    {
+        $this->documentRoot = $path;
+        return $this;
+    }
+
+    public function onRequest(callable $callback): static
+    {
+        $this->requestCallback = $callback;
+        return $this;
+    }
+
+    public function start(): StartedServerInterface
+    {
+        return new StartedServer($this, ServerProcess::create($this));
+    }
+
+    public function getCommand(): ServerCommand
+    {
+        $serverInfo = Terminal::encodeArgument($this->getInfo()->toArray());
+
+        return ServerCommand::create('php ' . base_path('bin/react.php'))
+            ->addArgument('-s', $serverInfo);
+    }
+
+    public function getInfo(): ServerInfo
+    {
+        return ServerInfo::create()
+            ->setHost($this->host)
+            ->setPort($this->port)
+            ->setDocumentRoot($this->documentRoot)
+            ->setRequestCallback($this->requestCallback)
+            ->setRouterScript($this->routerScript);
+    }
+}