wait for server to connect, then provision

app/Enums/ServerStatus.php

@@ -4,8 +4,11 @@ namespace App\Enums;
 
 enum ServerStatus: string
 {
-    case PENDING = 'pending';
+    case WAITING_FOR_PROVIDER = 'waiting-for-provider';
+    case PROVIDER_TIMEOUT = 'provider-timeout';
+    case UNPROVISIONED = 'unprovisioned';
     case PROVISIONING = 'provisioning';
+    case PROVISIONING_FAILED = 'provisioning-failed';
     case UPDATING = 'updating';
     case ACTIVE = 'active';
     case DELETING = 'deleting';

app/Http/Controllers/ServerController.php

@@ -6,6 +6,7 @@ use App\Actions\GenerateRandomSlug;
 use App\Actions\GetProviderService;
 use App\Enums\ServerProvider;
 use App\Enums\ServerStatus;
+use App\Jobs\Servers\WaitForServerToConnect;
 use App\Models\Organisation;
 use App\Services\ServerProviders\HetznerService;
 use Illuminate\Http\Request;
@@ -56,6 +57,7 @@ class ServerController extends Controller
     public function store(Request $request)
     {
         $rootPassword = Str::random(32);
+        $sudoPassword = Str::random(32);
         $providerService = app(GetProviderService::class)->execute($request->provider);
 
         if (!$providerService) {
@@ -79,13 +81,19 @@ class ServerController extends Controller
             'ipv4' => $createdServer->ipv4,
             'ipv6' => $createdServer->ipv6,
             'provider_status' => $createdServer->status,
-            'status' => ServerStatus::PENDING,
+            'status' => ServerStatus::WAITING_FOR_PROVIDER,
             'region' => $request->location,
             'os' => $request->image,
             'plan' => $request->server_type,
             'user' => '',
         ]);
 
+        dispatch(new WaitForServerToConnect(
+            server: $server,
+            rootPassword: $rootPassword,
+            sudoPassword: $sudoPassword,
+        ))->delay(now()->addSeconds(30));
+
         return redirect()->route('servers.show', ['organisation' => $organisation->id, 'server' => $server->id]);
     }
 

app/Jobs/Servers/ProvisionServer.php

@@ -2,10 +2,12 @@
 
 namespace App\Jobs\Servers;
 
+use App\Enums\ServerStatus;
 use App\Models\Server;
 use Illuminate\Contracts\Queue\ShouldBeEncrypted;
 use Illuminate\Contracts\Queue\ShouldQueue;
 use Illuminate\Foundation\Queue\Queueable;
+use Spatie\Ssh\Ssh;
 
 class ProvisionServer implements ShouldQueue, ShouldBeEncrypted
 {
@@ -14,13 +16,29 @@ class ProvisionServer implements ShouldQueue, ShouldBeEncrypted
     public function __construct(
         protected Server $server,
         protected string $rootPassword,
-    )
-    {
+        protected string $sudoPassword,
+    ) {
         //
     }
 
     public function handle(): void
     {
-        //
+        $ssh = Ssh::create('root', $this->server->ipv4 ?? $this->server->ipv6)
+            ->usePassword($this->rootPassword)
+            ->setTimeout(10);
+
+        $provisionScriptUrl = route('provision-script', [
+            'sudo_password' => $this->sudoPassword,
+            'hostname' => $this->server->hostname,
+            'server_id' => $this->server->id,
+        ]);
+
+        // Download the provision script and execute it
+        // The script will run in the background
+        $ssh->execute("cd ~ && wget --quiet --output-document=provision.sh \"{$provisionScriptUrl}\" && chmod +x provision.sh && ./provision.sh &");
+
+        $this->server->update([
+            'status' => ServerStatus::PROVISIONING,
+        ]);
     }
 }

app/Jobs/Servers/WaitForServerToConnect.php

@@ -0,0 +1,49 @@
+<?php
+
+namespace App\Jobs\Servers;
+
+use App\Enums\ServerStatus;
+use App\Models\Server;
+use Illuminate\Contracts\Queue\ShouldBeEncrypted;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Queue\Queueable;
+use Spatie\Ssh\Ssh;
+
+class WaitForServerToConnect implements ShouldQueue, ShouldBeEncrypted
+{
+    use Queueable;
+
+    public function __construct(
+        protected Server $server,
+        protected string $rootPassword,
+        protected string $sudoPassword,
+    )
+    {
+        //
+    }
+
+    public function handle(): void
+    {
+        try {
+            Ssh::create('root', $this->server->ipv4 ?? $this->server->ipv6)
+                ->usePassword($this->rootPassword)
+                ->setTimeout(10)
+                ->execute('echo "Connected"');
+
+            $this->server->update([
+                'status' => ServerStatus::UNPROVISIONED,
+            ]);
+
+            dispatch(new ProvisionServer($this->server, $this->rootPassword, $this->sudoPassword));
+        } catch (\Throwable $e) {
+            return;
+        }
+    }
+
+    public function failed(\Throwable $exception): void
+    {
+        $this->server->update([
+            'status' => ServerStatus::PROVIDER_TIMEOUT,
+        ]);
+    }
+}