support amp

Author: LTaooo

composer.json

@@ -31,6 +31,7 @@
         "symfony/finder": "^6",
         "guzzlehttp/guzzle": "^7.7",
         "symfony/dotenv": "^6.0",
+        "monolog/monolog": "^3.4",
         "ext-simplexml": "*"
     }
 }

src/Commands/StartCommand.php

@@ -33,6 +33,7 @@ protected function execute(InputInterface $input, OutputInterface $output): int
             Driver::WORKERMAN => $this->workermanStart(),
             Driver::ROADRUNNER => $this->roadrunnerStart($output, $serverConfig),
             Driver::SWOOLE => $this->swooleStart(),
+            Driver::AMP => $this->ampStart(),
             default => throw new RuntimeException('unsupported driver: ' . $serverConfig->getDriver()),
         };
     }
@@ -91,4 +92,16 @@ private function swooleStart(): int
 
         return Command::SUCCESS;
     }
+
+    /**
+     * @throws ContainerExceptionInterface
+     * @throws ReflectionException
+     * @throws NotFoundExceptionInterface
+     */
+    private function ampStart(): int
+    {
+        Application::getClass(Application::class)->run();
+
+        return Command::SUCCESS;
+    }
 }

src/Http/Enum/Driver.php

@@ -11,4 +11,6 @@ class Driver
     public const ROADRUNNER = 'roadrunner';
 
     public const SWOOLE = 'swoole';
+
+    public const AMP = 'amp';
 }

src/Http/ServerFactory.php

@@ -4,6 +4,7 @@
 
 namespace MicroPHP\Framework\Http;
 
+use MicroPHP\Amp\AmpHttpServer;
 use MicroPHP\Framework\Http\Contract\HttpServerInterface;
 use MicroPHP\Framework\Http\Enum\Driver;
 use MicroPHP\RoadRunner\RoadRunnerHttpServer;
@@ -21,6 +22,7 @@ public static function newServer(): HttpServerInterface
             Driver::WORKERMAN => new WorkermanHttpServer(),
             Driver::ROADRUNNER => new RoadRunnerHttpServer(),
             Driver::SWOOLE => new SwooleHttpServer(),
+            Driver::AMP => new AmpHttpServer(),
             default => throw new RuntimeException('unsupported driver: ' . $serverConfig->getDriver()),
         };
     }

src/Http/ServerRequest.php

@@ -4,6 +4,9 @@
 
 namespace MicroPHP\Framework\Http;
 
+use Amp\ByteStream\BufferException;
+use Amp\ByteStream\StreamException;
+use Amp\Http\Server\ClientException;
 use GuzzleHttp\Psr7\HttpFactory;
 use GuzzleHttp\Psr7\Uri;
 use InvalidArgumentException;
@@ -45,6 +48,26 @@ public static function fromSwoole(Request $swooleRequest): ServerRequestInterfac
             ->withUploadedFiles(self::normalizeFiles($swooleRequest->files ?? []));
     }
 
+    /**
+     * @throws ClientException
+     * @throws BufferException
+     * @throws StreamException
+     */
+    public static function fromAmp(\Amp\Http\Server\Request $ampRequest): ServerRequestInterface|ServerRequest
+    {
+        $request = new ServerRequest(
+            $ampRequest->getMethod(),
+            $ampRequest->getUri(),
+            $ampRequest->getHeaders(),
+            $ampRequest->getBody()->buffer(),
+            $ampRequest->getProtocolVersion(),
+        );
+
+        return $request->withParsedBody(self::normalizeParsedBody([], $request))
+            ->withCookieParams($ampRequest->getCookies())
+            ->withQueryParams($ampRequest->getQueryParameters());
+    }
+
     protected static function normalizeParsedBody(array $data = [], RequestInterface $request = null): array
     {
         if (! $request) {

src/Router/Router.php

@@ -10,7 +10,7 @@ class Router extends \League\Route\Router
 {
     public function getOrPost(string $path, $handler): RouteGroup
     {
-        return $this->group('', function(RouteGroup $group) use ($path, $handler) {
+        return $this->group('', function (RouteGroup $group) use ($path, $handler) {
             $group->get($path, $handler);
             $group->post($path, $handler);
         });