Adding Symfony Roadrunner (#14)

* Adding Symfony Roadrunner

* cs

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,32 @@
+# RoadRunner Runtime for Symfony with nyholm/psr7
+
+A runtime for [RoadRunner](https://roadrunner.dev/)
+
+## Installation
+
+```
+composer require runtime/roadrunner-symfony-nyholm
+```
+
+## Usage
+
+Define the environment variable `APP_RUNTIME` for your application.
+
+```
+APP_RUNTIME=Runtime\RoadRunnerSymfonyNyholm\Runtime
+```
+
+
+```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/roadrunner-symfony-nyholm",
+    "type": "library",
+    "description": "Roadrunner runtime for with nyholm/psr7",
+    "license": "MIT",
+    "authors": [
+        {
+            "name": "Tobias Nyholm",
+            "email": "[email protected]"
+        }
+    ],
+    "require": {
+        "nyholm/psr7": "^1.4",
+        "spiral/roadrunner": "^2.0",
+        "symfony/psr-http-message-bridge": "^2.1",
+        "symfony/runtime": "5.x-dev"
+    },
+    "require-dev": {
+        "symfony/phpunit-bridge": "^5.2"
+    },
+    "autoload": {
+        "psr-4": {
+            "Runtime\\RoadRunnerSymfonyNyholm\\": "src/"
+        }
+    },
+    "autoload-dev": {
+        "psr-4": {
+            "Runtime\\RoadRunnerSymfonyNyholm\\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,54 @@
+<?php
+
+namespace Runtime\RoadRunnerSymfonyNyholm;
+
+use Nyholm\Psr7;
+use Spiral\RoadRunner;
+use Symfony\Bridge\PsrHttpMessage\Factory\HttpFoundationFactory;
+use Symfony\Bridge\PsrHttpMessage\Factory\PsrHttpFactory;
+use Symfony\Bridge\PsrHttpMessage\HttpFoundationFactoryInterface;
+use Symfony\Bridge\PsrHttpMessage\HttpMessageFactoryInterface;
+use Symfony\Component\HttpKernel\HttpKernelInterface;
+use Symfony\Component\HttpKernel\TerminableInterface;
+use Symfony\Component\Runtime\RunnerInterface;
+
+/**
+ * @author Tobias Nyholm <[email protected]>
+ */
+class Runner implements RunnerInterface
+{
+    private $kernel;
+    private $httpFoundationFactory;
+    private $httpMessageFactory;
+    private $psrFactory;
+
+    public function __construct(HttpKernelInterface $kernel, ?HttpFoundationFactoryInterface $httpFoundationFactory = null, ?HttpMessageFactoryInterface $httpMessageFactory = null)
+    {
+        $this->kernel = $kernel;
+        $this->psrFactory = new Psr7\Factory\Psr17Factory();
+        $this->httpFoundationFactory = $httpFoundationFactory ?? new HttpFoundationFactory();
+        $this->httpMessageFactory = $httpMessageFactory ?? new PsrHttpFactory($this->psrFactory, $this->psrFactory, $this->psrFactory, $this->psrFactory);
+    }
+
+    public function run(): int
+    {
+        $worker = RoadRunner\Worker::create();
+        $worker = new RoadRunner\Http\PSR7Worker($worker, $this->psrFactory, $this->psrFactory, $this->psrFactory);
+
+        while ($request = $worker->waitRequest()) {
+            try {
+                $sfRequest = $this->httpFoundationFactory->createRequest($request);
+                $sfResponse = $this->kernel->handle($sfRequest);
+                $worker->respond($this->httpMessageFactory->createResponse($sfResponse));
+
+                if ($this->kernel instanceof TerminableInterface) {
+                    $this->kernel->terminate($sfRequest, $sfResponse);
+                }
+            } catch (\Throwable $e) {
+                $worker->getWorker()->error((string) $e);
+            }
+        }
+
+        return 0;
+    }
+}

src/Runtime.php

@@ -0,0 +1,24 @@
+<?php
+
+namespace Runtime\RoadRunnerSymfonyNyholm;
+
+use Symfony\Component\HttpKernel\HttpKernelInterface;
+use Symfony\Component\Runtime\RunnerInterface;
+use Symfony\Component\Runtime\SymfonyRuntime;
+
+/**
+ * A runtime for RoadRunner.
+ *
+ * @author Tobias Nyholm <[email protected]>
+ */
+class Runtime extends SymfonyRuntime
+{
+    public function getRunner(?object $application): RunnerInterface
+    {
+        if ($application instanceof HttpKernelInterface) {
+            return new Runner($application);
+        }
+
+        return parent::getRunner($application);
+    }
+}