coolify/app/Jobs/PullSentinelImageJob.php

59 lines
1.7 KiB
PHP
Raw Normal View History

<?php
namespace App\Jobs;
use App\Actions\Server\StartSentinel;
use App\Models\Server;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldBeEncrypted;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\Middleware\WithoutOverlapping;
use Illuminate\Queue\SerializesModels;
2024-06-10 22:43:34 +02:00
class PullSentinelImageJob implements ShouldBeEncrypted, ShouldQueue
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
public $timeout = 1000;
public function middleware(): array
{
return [(new WithoutOverlapping($this->server->uuid))];
}
public function uniqueId(): string
{
return $this->server->uuid;
}
2024-06-10 22:43:34 +02:00
2024-06-20 13:17:53 +02:00
public function __construct(public Server $server) {}
2024-06-10 22:43:34 +02:00
public function handle(): void
{
try {
$version = get_latest_sentinel_version();
2024-06-18 16:43:18 +02:00
if (! $version) {
ray('Failed to get latest Sentinel version');
2024-06-10 22:43:34 +02:00
return;
}
$local_version = instant_remote_process(['docker exec coolify-sentinel sh -c "curl http://127.0.0.1:8888/api/version"'], $this->server, false);
if (empty($local_version)) {
$local_version = '0.0.0';
}
if (version_compare($local_version, $version, '<')) {
StartSentinel::run($this->server, $version, true);
2024-06-18 16:43:18 +02:00
return;
}
ray('Sentinel image is up to date');
} catch (\Throwable $e) {
2024-06-20 13:17:06 +02:00
// send_internal_notification('PullSentinelImageJob failed with: '.$e->getMessage());
ray($e->getMessage());
throw $e;
}
}
}