Added inertia:check-ssr Artisan command and isHealthy() method on HttpGateway

Author: pascalbaljet

src/Commands/CheckSsr.php

@@ -0,0 +1,44 @@
+<?php
+
+namespace Inertia\Commands;
+
+use Illuminate\Console\Command;
+use Inertia\Ssr\Gateway;
+use Inertia\Ssr\HasHealthCheck;
+use Symfony\Component\Console\Attribute\AsCommand;
+
+#[AsCommand(name: 'inertia:check-ssr')]
+class CheckSsr extends Command
+{
+    /**
+     * The console command name.
+     *
+     * @var string
+     */
+    protected $signature = 'inertia:check-ssr';
+
+    /**
+     * The console command description.
+     *
+     * @var string
+     */
+    protected $description = 'Check the Inertia SSR server health status';
+
+    /**
+     * check the SSR server via a Node process.
+     */
+    public function handle(Gateway $gateway): int
+    {
+        if (! $gateway instanceof HasHealthCheck) {
+            $this->error('The SSR gateway does not support health checks.');
+
+            return self::FAILURE;
+        }
+
+        ($check = $gateway->isHealthy())
+            ? $this->info('Inertia SSR server is running.')
+            : $this->error('Inertia SSR server is not running.');
+
+        return $check ? self::SUCCESS : self::FAILURE;
+    }
+}

src/ServiceProvider.php

@@ -68,6 +68,7 @@ protected function registerConsoleCommands(): void
             Commands\CreateMiddleware::class,
             Commands\StartSsr::class,
             Commands\StopSsr::class,
+            Commands\CheckSsr::class,
         ]);
     }
 

src/Ssr/HasHealthCheck.php

@@ -0,0 +1,11 @@
+<?php
+
+namespace Inertia\Ssr;
+
+interface HasHealthCheck
+{
+    /**
+     * Determine if the SSR server is healthy.
+     */
+    public function isHealthy(): bool;
+}

src/Ssr/HttpGateway.php

@@ -5,8 +5,9 @@
 use Exception;
 use Illuminate\Http\Client\StrayRequestException;
 use Illuminate\Support\Facades\Http;
+use Illuminate\Support\Str;
 
-class HttpGateway implements Gateway
+class HttpGateway implements Gateway, HasHealthCheck
 {
     /**
      * Dispatch the Inertia page to the Server Side Rendering engine.
@@ -21,7 +22,7 @@ public function dispatch(array $page): ?Response
             return null;
         }
 
-        if (! $url = $this->getHttpUrl()) {
+        if (! $url = $this->getUrl('/render')) {
             return null;
         }
 
@@ -45,6 +46,14 @@ public function dispatch(array $page): ?Response
         );
     }
 
+    /**
+     * Determine if the SSR server is healthy.
+     */
+    public function isHealthy(): bool
+    {
+        return Http::get($this->getUrl('/health'))->successful();
+    }
+
     /**
      * Determine if dispatch should proceed even if no bundle is detected.
      */
@@ -62,10 +71,12 @@ protected function bundleExists(): bool
     }
 
     /**
-     * Get the SSR URL from the configuration, ensuring it ends with '/render'.
+     * Get the SSR URL from the configuration, ensuring it ends with '/{$path}'.
      */
-    public function getHttpUrl(): ?string
+    public function getUrl(string $path): ?string
     {
-        return str_replace('/render', '', rtrim(config('inertia.ssr.url', 'http://127.0.0.1:13714'), '/')).'/render';
+        $path = Str::start($path, '/');
+
+        return str_replace($path, '', rtrim(config('inertia.ssr.url', 'http://127.0.0.1:13714'), '/')).$path;
     }
 }

tests/Commands/CheckSsrTest.php

@@ -0,0 +1,71 @@
+<?php
+
+namespace Inertia\Tests;
+
+use Illuminate\Foundation\Application;
+use Inertia\Commands\CheckSsr; // Assuming you updated the command name
+use Inertia\Ssr\Gateway;
+use Inertia\Ssr\HttpGateway; // Your concrete Gateway implementation
+use Mockery as m;
+use PHPUnit\Framework\TestCase;
+use Symfony\Component\Console\Input\ArrayInput;
+use Symfony\Component\Console\Output\BufferedOutput; // Import BufferedOutput
+
+class CheckSsrTest extends TestCase
+{
+    protected function tearDown(): void
+    {
+        m::close();
+    }
+
+    public function test_success_on_healthy_ssr_server()
+    {
+        $container = new Application;
+        $container->instance(Gateway::class, m::mock(HttpGateway::class)
+            ->shouldReceive('isHealthy')
+            ->andReturnTrue()
+            ->getMock()
+        );
+
+        $command = new CheckSsr;
+        $command->setLaravel($container);
+
+        $exitCode = $command->run(new ArrayInput([]), $output = new BufferedOutput);
+
+        $this->assertEquals(0, $exitCode);
+        $this->assertStringContainsString('Inertia SSR server is running.', $output->fetch());
+    }
+
+    public function test_failure_on_unhealthy_ssr_server()
+    {
+        $container = new Application;
+        $container->instance(Gateway::class, m::mock(HttpGateway::class)
+            ->shouldReceive('isHealthy')
+            ->andReturnFalse()
+            ->getMock()
+        );
+
+        $command = new CheckSsr;
+        $command->setLaravel($container);
+
+        $exitCode = $command->run(new ArrayInput([]), $output = new BufferedOutput);
+
+        $this->assertEquals(1, $exitCode);
+        $this->assertStringContainsString('Inertia SSR server is not running.', $output->fetch());
+    }
+
+    public function test_failure_on_unsupported_gateway()
+    {
+        $container = new Application;
+        $container->instance(Gateway::class, m::mock(Gateway::class));
+
+        $command = new CheckSsr;
+        $command->setLaravel($container);
+
+        $output = new BufferedOutput;
+        $exitCode = $command->run(new ArrayInput([]), $output = new BufferedOutput);
+
+        $this->assertEquals(1, $exitCode);
+        $this->assertStringContainsString('The SSR gateway does not support health checks.', $output->fetch());
+    }
+}

tests/HttpGatewayTest.php

@@ -9,11 +9,14 @@ class HttpGatewayTest extends TestCase
 {
     protected HttpGateway $gateway;
 
+    protected string $renderUrl;
+
     protected function setUp(): void
     {
         parent::setUp();
 
         $this->gateway = new HttpGateway;
+        $this->renderUrl = $this->gateway->getUrl('render');
 
         Http::preventStrayRequests();
     }
@@ -46,7 +49,7 @@ public function test_it_uses_the_configured_http_url_when_the_bundle_file_is_det
         ]);
 
         Http::fake([
-            $this->gateway->getHttpUrl() => Http::response(json_encode([
+            $this->renderUrl => Http::response(json_encode([
                 'head' => ['<title>SSR Test</title>', '<style></style>'],
                 'body' => '<div id="app">SSR Response</div>',
             ])),
@@ -69,7 +72,7 @@ public function test_it_uses_the_configured_http_url__when_bundle_file_detection
         ]);
 
         Http::fake([
-            $this->gateway->getHttpUrl() => Http::response(json_encode([
+            $this->renderUrl => Http::response(json_encode([
                 'head' => ['<title>SSR Test</title>', '<style></style>'],
                 'body' => '<div id="app">SSR Response</div>',
             ])),
@@ -91,7 +94,7 @@ public function test_it_returns_null_when_the_http_request_fails()
         ]);
 
         Http::fake([
-            $this->gateway->getHttpUrl() => Http::response(null, 500),
+            $this->renderUrl => Http::response(null, 500),
         ]);
 
         $this->assertNull($this->gateway->dispatch(['page' => self::EXAMPLE_PAGE_OBJECT]));
@@ -105,9 +108,21 @@ public function test_it_returns_null_when_invalid_json_is_returned()
         ]);
 
         Http::fake([
-            $this->gateway->getHttpUrl() => Http::response('invalid json'),
+            $this->renderUrl => Http::response('invalid json'),
         ]);
 
         $this->assertNull($this->gateway->dispatch(['page' => self::EXAMPLE_PAGE_OBJECT]));
     }
+
+    public function test_health_check_the_ssr_server()
+    {
+        Http::fake([
+            $this->gateway->getUrl('health') => Http::sequence()
+                ->push(status: 200)
+                ->push(status: 500),
+        ]);
+
+        $this->assertTrue($this->gateway->isHealthy());
+        $this->assertFalse($this->gateway->isHealthy());
+    }
 }