Swoole server implementation

Console helper added
Environment file helper added
Project kernel file added
AbstractServer added to help with creation servers easily
ServerInfo can now be populated with data directly to it
Encoded CLI arguments can now be retrieved and decoded at once

Author: ahmard

.gitignore

@@ -1,3 +1,5 @@
 /.idea/
 /vendor/
-/composer.lock
+/composer.lock
+/bin/.pid
+.env

README.md

@@ -60,4 +60,33 @@ Server::create('127.0.0.1', 9001)
     ->onRequest($handler)
     ->start()
     ->logOutputToConsole();
+```
+
+### Swoole
+An implementation of [Swoole](https://swoole.co.uk)
+
+```php
+use PHPServer\Swoole\Http\Request;
+use PHPServer\Swoole\Server;
+
+require 'vendor/autoload.php';
+
+$handler = function (Request $request) {
+    $html = 'Welcome,<br/>';
+    $html .= "Method: {$request->getMethod()}<br/>";
+    $html .= "Route: {$request->getUri()->getPath()}";
+    $request->response()->html($html);
+};
+
+Server::create('127.0.0.1', 9904)
+    ->watchFilesystemChanges([__DIR__])
+    ->onRequest($handler)
+    ->setServerConfig([
+        'enable_static_handler' => true,
+        'http_parse_post' => true,
+        'worker_num' => 8,
+        'package_max_length' => 10 * 1024 * 1024
+    ])
+    ->start()
+    ->logOutputToConsole();
 ```

bin/swoole.php

@@ -0,0 +1,81 @@
+<?php
+
+use Dotenv\Dotenv;
+use PHPServer\Env;
+use PHPServer\ServerInfo;
+use PHPServer\Swoole\Console;
+use PHPServer\Swoole\Http\Request;
+use PHPServer\Swoole\Http\Response;
+use PHPServer\Terminal;
+use Swoole\Http\Request as SWRequest;
+use Swoole\Http\Response as SWResponse;
+use Swoole\Http\Server;
+use Swoole\Runtime;
+use Swotch\Watcher;
+
+require 'vendor/autoload.php';
+
+$swooleData = Terminal::getArgumentAndDecode('s', 'swoole');
+$serverData = Terminal::getArgumentAndDecode('i', 'server-info');
+
+$serverInfo = ServerInfo::create($serverData);
+
+function handleException(Throwable $exception, ?Request $request = null): void
+{
+    try {
+        $request?->response()->html($exception);
+    } catch (Throwable $exception) {
+        if (!Env::isInProduction()) {
+            $request->response()->html($exception);
+            return;
+        }
+
+        $request->response()->html('Internal Server Error');
+    } finally {
+        Console::error($exception);
+    }
+}
+
+set_exception_handler('handleException');
+
+try {
+
+    if (null !== $serverInfo->getEnvDirectory()) {
+        $dotEnv = Dotenv::createImmutable(__DIR__)->load();
+    }
+
+    //Runtime configuration
+    Runtime::enableCoroutine(true, SWOOLE_HOOK_ALL);
+
+    $server = new Server($serverInfo->getHost(), $serverInfo->getPort());
+
+    $server->on(
+        'request',
+        function (SWRequest $swRequest, SWResponse $swResponse) use ($serverInfo): void {
+            $response = new Response($swResponse);
+            $request = new Request($swRequest, $response);
+            $response->setRequest($request);
+            $serverInfo->getRequestCallback()($request);
+        }
+    );
+
+    $server->on('start', function (Server $server) use ($serverInfo, $swooleData) {
+        Console::info("Swoole server started at http://{$serverInfo->getHost()}:{$serverInfo->getPort()}");
+
+        file_put_contents(__DIR__ . '/.pid', $server->getMasterPid());
+
+        //Run file watcher
+        if (!empty($swooleData['watch_filesystem_changes'])) {
+            go(function () use ($server, $swooleData) {
+                Watcher::watch($swooleData['watch_filesystem_changes'])
+                    ->onAny(fn($e) => $server->reload());
+            });
+        }
+    });
+
+    $server->set(\PHPServer\Swoole\Server::cleanSwooleServerConfig($swooleData));
+
+    $server->start();
+} catch (Error $error) {
+    dump($error);
+}

composer.json

@@ -5,14 +5,20 @@
     "license": "MIT",
     "require": {
         "php": "^8.0",
+        "ext-pdo": "*",
         "react/child-process": "^0.6.3",
         "react/http": "^1.5",
         "opis/closure": "^3.6",
-        "symfony/console": "^5.3"
+        "symfony/console": "^5.3",
+        "ahmard/quick-route": "^3.8",
+        "nette/utils": "^3.2",
+        "vlucas/phpdotenv": "^5.3"
     },
     "require-dev": {
         "phpstan/phpstan": "^0.12.98",
-        "symfony/var-dumper": "^5.3"
+        "symfony/var-dumper": "^5.3",
+        "swoole/ide-helper": "^4.7",
+        "ahmard/swotch": "^0.0.1"
     },
     "autoload": {
         "psr-4": {

phpstan.neon

@@ -1,6 +1,7 @@
 parameters:
     level: 6
     checkMissingIterableValueType: false
+    checkGenericClassInNonGenericObjectType: false
     paths:
         - bin
         - src

src/AbstractServer.php

@@ -0,0 +1,59 @@
+<?php
+
+namespace PHPServer;
+
+use Closure;
+use JetBrains\PhpStorm\Pure;
+
+abstract class AbstractServer implements ServerInterface
+{
+    protected string|null $documentRoot = null;
+    protected string|null $routerScript = null;
+    protected string|null $envDir = 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 static($host, $port);
+    }
+
+    public function setDocumentRoot(string $path): static
+    {
+        $this->documentRoot = $path;
+        return $this;
+    }
+
+    public function setEnvDirectory(string $path): static
+    {
+        $this->envDir = $path;
+        return $this;
+    }
+
+    public function onRequest(callable $callback): static
+    {
+        $this->requestCallback = $callback;
+        return $this;
+    }
+
+    public function start(): RunningServer
+    {
+        return new RunningServer($this, ServerProcess::create($this));
+    }
+
+    public function getInfo(): ServerInfo
+    {
+        return ServerInfo::create()
+            ->setHost($this->host)
+            ->setPort($this->port)
+            ->setDocumentRoot($this->documentRoot)
+            ->setRequestCallback($this->requestCallback)
+            ->setRouterScript($this->routerScript);
+    }
+}

src/BuiltIn/Server.php

@@ -3,33 +3,18 @@
 namespace PHPServer\BuiltIn;
 
 use Closure;
-use JetBrains\PhpStorm\Pure;
+use PHPServer\AbstractServer;
 use PHPServer\ServerCommand;
-use PHPServer\ServerInfo;
-use PHPServer\ServerInterface;
-use PHPServer\ServerProcess;
-use PHPServer\RunningServer;
 use PHPServer\Terminal;
 use function PHPServer\base_path;
 
-class Server implements ServerInterface
+class Server extends AbstractServer
 {
     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(string $host, int $port): static
-    {
-        return new static($host, $port);
-    }
 
     public function getCommand(): ServerCommand
     {
@@ -58,37 +43,4 @@ public function getCommand(): ServerCommand
 
         return $serverCommand;
     }
-
-    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): static
-    {
-        $this->routerScript = $filePath;
-        return $this;
-    }
-
-    public function onRequest(callable $callback): static
-    {
-        $this->requestCallback = $callback;
-        return $this;
-    }
-
-    public function start(): RunningServer
-    {
-        return new RunningServer($this, ServerProcess::create($this));
-    }
 }