Fix server status check and add new job

app/Http/Livewire/Project/Application/Heading.php

@@ -4,6 +4,7 @@ namespace App\Http\Livewire\Project\Application;
 
 use App\Actions\Application\StopApplication;
 use App\Jobs\ContainerStatusJob;
+use App\Jobs\ServerStatusJob;
 use App\Models\Application;
 use Livewire\Component;
 use Visus\Cuid2\Cuid2;
@@ -28,6 +29,8 @@ class Heading extends Component
             $this->application->previews->each(function ($preview) {
                 $preview->refresh();
             });
+        } else {
+            dispatch(new ServerStatusJob($this->application->destination->server));
         }
     }
 

app/Http/Livewire/Project/Application/Rollback.php

@@ -42,28 +42,31 @@ class Rollback extends Component
     {
         try {
             $image = $this->application->uuid;
-            $output = instant_remote_process([
+            if ($this->application->destination->server->isFunctional()) {
-                "docker inspect --format='{{.Config.Image}}' {$this->application->uuid}",
+                $output = instant_remote_process([
-            ], $this->application->destination->server, throwError: false);
+                    "docker inspect --format='{{.Config.Image}}' {$this->application->uuid}",
-            $current_tag = Str::of($output)->trim()->explode(":");
+                ], $this->application->destination->server, throwError: false);
-            $this->current = data_get($current_tag, 1);
+                $current_tag = Str::of($output)->trim()->explode(":");
+                $this->current = data_get($current_tag, 1);
 
-            $output = instant_remote_process([
+                $output = instant_remote_process([
-                "docker images --format '{{.Repository}}#{{.Tag}}#{{.CreatedAt}}'",
+                    "docker images --format '{{.Repository}}#{{.Tag}}#{{.CreatedAt}}'",
-            ], $this->application->destination->server);
+                ], $this->application->destination->server);
-            $this->images = Str::of($output)->trim()->explode("\n")->filter(function ($item) use ($image) {
+                $this->images = Str::of($output)->trim()->explode("\n")->filter(function ($item) use ($image) {
-                return Str::of($item)->contains($image);
+                    return Str::of($item)->contains($image);
-            })->map(function ($item) {
+                })->map(function ($item) {
-                $item = Str::of($item)->explode('#');
+                    $item = Str::of($item)->explode('#');
-                if ($item[1] === $this->current) {
+                    if ($item[1] === $this->current) {
-                    // $is_current = true;
+                        // $is_current = true;
-                }
+                    }
-                return [
+                    return [
-                    'tag' => $item[1],
+                        'tag' => $item[1],
-                    'created_at' => $item[2],
+                        'created_at' => $item[2],
-                    'is_current' => $is_current ?? null,
+                        'is_current' => $is_current ?? null,
-                ];
+                    ];
-            })->toArray();
+                })->toArray();
+            }
+            return [];
         } catch (\Throwable $e) {
             return handleError($e, $this);
         }

app/Jobs/ContainerStatusJob.php

@@ -37,8 +37,9 @@ class ContainerStatusJob implements ShouldQueue, ShouldBeEncrypted
 
     public function handle(): void
     {
-        // ray("checking server status for {$this->server->id}");
+        ray("checking container statuses for {$this->server->id}");
         try {
+            $this->server->checkServerRediness();
             $containers = instant_remote_process(["docker container ls -q"], $this->server);
             if (!$containers) {
                 return;

app/Models/Server.php

@@ -131,11 +131,11 @@ class Server extends BaseModel
     public function checkServerRediness()
     {
         $serverUptimeCheckNumber = $this->unreachable_count;
-        $serverUptimeCheckNumberMax = 5;
+        $serverUptimeCheckNumberMax = 3;
 
         $currentTime = now()->timestamp;
         $runtime5Minutes = 1 * 60;
-        // Run for 1 minutes max and check every 5 seconds
+        // Run for 1 minutes max and check every 5 seconds for 3 times
         while ($currentTime + $runtime5Minutes > now()->timestamp) {
             if ($serverUptimeCheckNumber >= $serverUptimeCheckNumberMax) {
                 if ($this->unreachable_notification_sent === false) {

app/Models/User.php

@@ -52,7 +52,6 @@ class User extends Authenticatable implements SendsEmail
     }
     public function createToken(string $name, array $abilities = ['*'], DateTimeInterface $expiresAt = null)
     {
-        ray('asd');
         $plainTextToken = sprintf(
             '%s%s%s',
             config('sanctum.token_prefix', ''),