Adding Swoole (#11)

* Adding Swoole

* Normalize composer

* Hack namespace

* Add extension

Author: Nyholm

.github/FUNDING.yml

@@ -0,0 +1,3 @@
+# These are supported funding model platforms
+
+github: [nyholm]

.gitignore

@@ -0,0 +1,2 @@
+/vendor/
+composer.lock

README.md

@@ -0,0 +1,49 @@
+# Swoole Runtime
+
+A runtime for [Swoole](https://www.swoole.co.uk/)
+
+## Installation
+
+```
+composer require runtime/swoole
+```
+
+## Usage
+
+Define the environment variable `APP_RUNTIME` for your application.
+
+```
+APP_RUNTIME=Runtime\Swoole\Runtime
+```
+
+### Pure PHP
+
+```php
+// public/index.php
+
+use Swoole\Http\Request;
+use Swoole\Http\Response;
+
+require_once dirname(__DIR__).'/vendor/autoload_runtime.php';
+
+return function () {
+    return function (Request $request, Response $response) {
+        $response->header("Content-Type", "text/plain");
+        $response->end("Hello World\n");
+    };
+};
+```
+
+### Symfony
+
+```php
+// public/index.php
+
+use App\Kernel;
+
+require_once dirname(__DIR__).'/vendor/autoload_runtime.php';
+
+return function (array $context) {
+    return new Kernel($context['APP_ENV'], (bool) $context['APP_DEBUG']);
+};
+```

composer.json

@@ -0,0 +1,33 @@
+{
+    "name": "runtime/swoole",
+    "type": "library",
+    "description": "Swoole runtime",
+    "license": "MIT",
+    "authors": [
+        {
+            "name": "Tobias Nyholm",
+            "email": "[email protected]"
+        }
+    ],
+    "require": {
+        "symfony/runtime": "5.x-dev"
+    },
+    "require-dev": {
+        "swoole/ide-helper": "^4.6",
+        "symfony/http-foundation": "^4.4 || ^5.2",
+        "symfony/http-kernel": "^4.4 || ^5.2",
+        "symfony/phpunit-bridge": "^5.2"
+    },
+    "autoload": {
+        "psr-4": {
+            "Runtime\\Swoole\\": "src/"
+        }
+    },
+    "autoload-dev": {
+        "psr-4": {
+            "Runtime\\Swoole\\Tests\\": "tests/"
+        }
+    },
+    "minimum-stability": "dev",
+    "prefer-stable": true
+}

phpunit.xml.dist

@@ -0,0 +1,19 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<phpunit xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:noNamespaceSchemaLocation="https://schema.phpunit.de/9.3/phpunit.xsd"
+         backupGlobals="false"
+         colors="true"
+         bootstrap="vendor/autoload.php"
+         failOnRisky="true"
+         failOnWarning="true"
+>
+  <php>
+    <ini name="error_reporting" value="-1"/>
+  </php>
+  <testsuites>
+    <testsuite name="Test Suite">
+      <directory>./tests</directory>
+      <directory suffix=".phpt">./tests/phpt</directory>
+    </testsuite>
+  </testsuites>
+</phpunit>

src/Runner.php

@@ -0,0 +1,36 @@
+<?php
+
+namespace Runtime\Swoole;
+
+use Swoole\Http\Server;
+use Symfony\Component\Runtime\RunnerInterface;
+
+/**
+ * A simple runner that will run a callable.
+ *
+ * @author Tobias Nyholm <[email protected]>
+ */
+class Runner implements RunnerInterface
+{
+    private $application;
+    private $port;
+    private $host;
+
+    public function __construct(callable $application, $host, $port)
+    {
+        $this->application = $application;
+        $this->host = $host;
+        $this->port = $port;
+    }
+
+    public function run(): int
+    {
+        $server = new Server($this->host, $this->port);
+
+        $server->on('request', $this->application);
+
+        $server->start();
+
+        return 0;
+    }
+}

src/Runtime.php

@@ -0,0 +1,36 @@
+<?php
+
+namespace Runtime\Swoole;
+
+use Symfony\Component\HttpKernel\HttpKernelInterface;
+use Symfony\Component\Runtime\RunnerInterface;
+use Symfony\Component\Runtime\SymfonyRuntime;
+
+/**
+ * A runtime for Swoole.
+ *
+ * @author Tobias Nyholm <[email protected]>
+ */
+class Runtime extends SymfonyRuntime
+{
+    public function __construct(array $options)
+    {
+        $options['swoole_host'] = $options['swoole_host'] ?? $_SERVER['SWOOLE_HOST'] ?? $_ENV['SWOOLE_HOST'] ?? '127.0.0.1';
+        $options['swoole_port'] = $options['swoole_port'] ?? $_SERVER['SWOOLE_PORT'] ?? $_ENV['SWOOLE_PORT'] ?? 8000;
+
+        parent::__construct($options);
+    }
+
+    public function getRunner(?object $application): RunnerInterface
+    {
+        if (is_callable($application)) {
+            return new Runner($application, $this->options['swoole_host'], $this->options['swoole_port']);
+        }
+
+        if ($application instanceof HttpKernelInterface) {
+            return new SymfonyRunner($application, $this->options['swoole_host'], $this->options['swoole_port']);
+        }
+
+        return parent::getRunner($application);
+    }
+}

src/SymfonyRunner.php

@@ -0,0 +1,59 @@
+<?php
+
+namespace Runtime\Swoole;
+
+use Swoole\Http\Request;
+use Swoole\Http\Response;
+use Swoole\Http\Server;
+use Symfony\Component\HttpFoundation\Request as SymfonyRequest;
+use Symfony\Component\HttpKernel\HttpKernelInterface;
+use Symfony\Component\Runtime\RunnerInterface;
+
+/**
+ * A runner for Symfony.
+ *
+ * @author Tobias Nyholm <[email protected]>
+ */
+class SymfonyRunner implements RunnerInterface
+{
+    private $application;
+    private $port;
+    private $host;
+
+    public function __construct(HttpKernelInterface $application, $host, $port)
+    {
+        $this->application = $application;
+        $this->host = $host;
+        $this->port = $port;
+    }
+
+    public function run(): int
+    {
+        $server = new Server($this->host, $this->port);
+
+        $app = $this->application;
+
+        $server->on('request', function (Request $request, Response $response) use ($app) {
+            // convert to HttpFoundation request
+            $sfRequest = new SymfonyRequest(
+                $request->get ?? [],
+                $request->post ?? [],
+                [],
+                $request->cookie ?? [],
+                $request->files ?? [],
+                $request->server ?? [],
+                $request->rawContent()
+            );
+
+            $sfResponse = $app->handle($sfRequest);
+            foreach ($sfResponse->headers->all() as $name => $value) {
+                $response->header($name, $value);
+            }
+            $response->end($sfResponse->getContent());
+        });
+
+        $server->start();
+
+        return 0;
+    }
+}