wip

Author: brendt

Dockerfile

@@ -0,0 +1,12 @@
+FROM dunglas/frankenphp
+
+COPY . /app/public
+
+RUN install-php-extensions \
+	pdo_mysql \
+	gd \
+	intl \
+	zip \
+	opcache
+
+ENV FRANKENPHP_CONFIG="worker ./public/index.php"

packages/router/src/Commands/ServeCommand.php

@@ -5,19 +5,26 @@
 namespace Tempest\Router\Commands;
 
 use Tempest\Console\ConsoleCommand;
+use Tempest\Console\HasConsole;
 use Tempest\Intl\Number;
 use Tempest\Support\Str;
+use function Tempest\Support\path;
 
 final readonly class ServeCommand
 {
+    use HasConsole;
+
     #[ConsoleCommand(
         name: 'serve',
         description: 'Starts a PHP development server',
     )]
-    public function __invoke(string $host = '127.0.0.1', int $port = 8000, string $publicDir = 'public/'): void
-    {
-        $routerFile = __DIR__ . '/router.php';
-
+    public function __invoke(
+        string $host = 'localhost',
+        int $port = 8000,
+        int $httpsPort = 4433,
+        string $publicDir = './public/',
+        bool $worker = false,
+    ): void {
         if (Str\contains($host, ':')) {
             [$host, $overriddenPort] = explode(':', $host, limit: 2);
 
@@ -26,6 +33,39 @@ public function __invoke(string $host = '127.0.0.1', int $port = 8000, string $p
             $port = Number\parse($overriddenPort, default: $port);
         }
 
+        if ($worker) {
+            $this->worker($host, $port, $httpsPort, $publicDir);
+        } else {
+            $this->serve($host, $port, $publicDir);
+        }
+    }
+
+    private function worker(string $host, int $port, int $httpsPort, string $publicDir): void
+    {
+        $this->success('Listening on http://' . $host . ':' . $port . ', https://' . $host . ':' . $httpsPort);
+
+        $command = sprintf(<<<'SH'
+        docker run \
+            -e FRANKENPHP_CONFIG="worker %s" \
+            -v $PWD:/app \
+            -p %d:80 -p %d:443 -p %d:443/udp \
+            dunglas/frankenphp
+        SH,
+        path($publicDir, 'index.php')->toString(),
+        $port,
+        $httpsPort,
+        $httpsPort
+        );
+
+        $this->info($command);
+
+        passthru($command);
+    }
+
+    private function serve(string $host, int $port, string $publicDir): void
+    {
+        $routerFile = __DIR__ . '/router.php';
+
         passthru("php -S {$host}:{$port} -t {$publicDir} {$routerFile}");
     }
 }

packages/router/src/WorkerApplication.php

@@ -0,0 +1,66 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Tempest\Router;
+
+use Tempest\Container\Container;
+use Tempest\Container\Singleton;
+use Tempest\Core\Application;
+use Tempest\Core\DeferredTasks;
+use Tempest\Core\Kernel;
+use Tempest\Core\Kernel\FinishDeferredTasks;
+use Tempest\Core\Tempest;
+use Tempest\Http\RequestFactory;
+use Tempest\Http\Session\Session;
+use Tempest\Log\Channels\AppendLogChannel;
+use Tempest\Log\LogConfig;
+
+use function Tempest\env;
+use function Tempest\Support\path;
+
+#[Singleton]
+final readonly class WorkerApplication implements Application
+{
+    public function __construct(
+        private Container $container,
+    ) {}
+
+    /** @param \Tempest\Discovery\DiscoveryLocation[] $discoveryLocations */
+    public static function boot(
+        string $root,
+        array $discoveryLocations = [],
+    ): self {
+        $container = Tempest::boot($root, $discoveryLocations);
+
+        $application = $container->get(WorkerApplication::class);
+
+        // Application-specific setup
+        $logConfig = $container->get(LogConfig::class);
+
+        if ($logConfig->debugLogPath === null && $logConfig->serverLogPath === null && $logConfig->channels === []) {
+            $logConfig->debugLogPath = path($container->get(Kernel::class)->root, '/log/debug.log')->toString();
+            $logConfig->serverLogPath = env('SERVER_LOG');
+            $logConfig->channels[] = new AppendLogChannel(path($root, '/log/tempest.log')->toString());
+        }
+
+        return $application;
+    }
+
+    public function run(): void
+    {
+        $router = $this->container->get(Router::class);
+
+        $psrRequest = $this->container->get(RequestFactory::class)->make();
+
+        $responseSender = $this->container->get(ResponseSender::class);
+
+        $responseSender->send(
+            $router->dispatch($psrRequest),
+        );
+
+        $this->container->get(Session::class)->cleanup();
+
+        $this->container->invoke(FinishDeferredTasks::class);
+    }
+}