coolify/app/Jobs/ProxyCheckJob.php

46 lines
1.3 KiB
PHP
Raw Normal View History

2023-05-15 13:45:37 +02:00
<?php
namespace App\Jobs;
2023-07-14 13:38:24 +02:00
use App\Actions\Proxy\StartProxy;
2023-05-15 13:45:37 +02:00
use App\Models\Server;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
2023-07-07 15:50:36 +02:00
class ProxyCheckJob implements ShouldQueue
2023-05-15 13:45:37 +02:00
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
2023-07-14 13:38:24 +02:00
public function __construct()
2023-05-15 13:45:37 +02:00
{
}
2023-05-15 13:45:37 +02:00
public function handle()
{
try {
$container_name = 'coolify-proxy';
2023-08-24 21:34:24 +02:00
$servers = Server::all();
2023-07-14 13:38:24 +02:00
foreach ($servers as $server) {
2023-08-24 21:34:24 +02:00
if (
$server->settings->is_reachable === false || $server->settings->is_usable === false
) {
continue;
}
2023-08-21 18:00:12 +02:00
$status = getContainerStatus(server: $server, container_id: $container_name);
2023-05-15 13:45:37 +02:00
if ($status === 'running') {
2023-07-14 13:38:24 +02:00
continue;
2023-05-15 13:45:37 +02:00
}
2023-07-26 15:20:04 +02:00
// $server->team->notify(new ProxyStoppedNotification($server));
2023-07-14 13:38:24 +02:00
resolve(StartProxy::class)($server);
2023-05-15 13:45:37 +02:00
}
} catch (\Throwable $th) {
ray($th->getMessage());
2023-08-24 16:14:09 +02:00
send_internal_notification('ProxyCheckJob failed with: ' . $th->getMessage());
2023-08-24 21:09:58 +02:00
throw $th;
2023-05-15 13:45:37 +02:00
}
}
}