coolify/app/Jobs/ProxyCheckJob.php

41 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:24:44 +02:00
$servers = Server::all()->whereRelation('settings', 'is_reachable', true)->whereRelation('settings', 'is_usable', true)->whereNotNull('proxy')->get();
2023-07-14 13:38:24 +02:00
foreach ($servers as $server) {
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
}
}
}