lasthourcloud/app/Livewire/Server/Proxy/Deploy.php

95 lines
2.7 KiB
PHP
Raw Normal View History

2023-06-02 13:15:12 +00:00
<?php
2023-12-07 18:06:32 +00:00
namespace App\Livewire\Server\Proxy;
2023-06-02 13:15:12 +00:00
use App\Actions\Proxy\CheckProxy;
2023-07-14 11:38:24 +00:00
use App\Actions\Proxy\StartProxy;
use App\Events\ProxyStatusChanged;
2023-06-02 13:15:12 +00:00
use App\Models\Server;
use Livewire\Component;
class Deploy extends Component
{
public Server $server;
public bool $traefikDashboardAvailable = false;
public ?string $currentRoute = null;
2023-10-13 12:35:02 +00:00
public ?string $serverIp = null;
public function getListeners()
{
$teamId = auth()->user()->currentTeam()->id;
return [
"echo-private:team.{$teamId},ProxyStatusChanged" => 'proxyStarted',
'proxyStatusUpdated',
'traefikDashboardAvailable',
'serverRefresh' => 'proxyStatusUpdated',
"checkProxy", "startProxy"
];
}
public function mount()
{
2023-10-13 12:35:02 +00:00
if ($this->server->id === 0) {
$this->serverIp = base_ip();
} else {
$this->serverIp = $this->server->ip;
}
$this->currentRoute = request()->route()->getName();
}
public function traefikDashboardAvailable(bool $data)
{
$this->traefikDashboardAvailable = $data;
}
public function proxyStarted()
2023-09-18 10:18:45 +00:00
{
CheckProxy::run($this->server, true);
$this->dispatch('success', 'Proxy started.');
2023-09-11 20:29:34 +00:00
}
public function proxyStatusUpdated()
2023-10-13 12:35:02 +00:00
{
$this->server->refresh();
2023-10-13 12:35:02 +00:00
}
public function checkProxy()
{
try {
2023-10-17 17:00:23 +00:00
CheckProxy::run($this->server, true);
2023-12-07 18:06:32 +00:00
$this->dispatch('startProxyPolling');
$this->dispatch('proxyChecked');
} catch (\Throwable $e) {
return handleError($e, $this);
}
}
2023-09-11 20:29:34 +00:00
public function startProxy()
2023-06-02 13:15:12 +00:00
{
2023-09-18 10:18:45 +00:00
try {
2023-09-18 10:29:50 +00:00
$activity = StartProxy::run($this->server);
$this->dispatch('newMonitorActivity', $activity->id, ProxyStatusChanged::class);
2023-09-18 10:18:45 +00:00
} catch (\Throwable $e) {
return handleError($e, $this);
2023-09-18 10:18:45 +00:00
}
2023-06-02 13:15:12 +00:00
}
2023-06-02 13:15:12 +00:00
public function stop()
{
2023-11-29 13:59:06 +00:00
try {
if ($this->server->isSwarm()) {
instant_remote_process([
"docker service rm coolify-proxy_traefik",
], $this->server);
$this->server->proxy->status = 'exited';
$this->server->save();
2023-12-07 18:06:32 +00:00
$this->dispatch('proxyStatusUpdated');
2023-11-29 13:59:06 +00:00
} else {
instant_remote_process([
"docker rm -f coolify-proxy",
], $this->server);
$this->server->proxy->status = 'exited';
$this->server->save();
2023-12-07 18:06:32 +00:00
$this->dispatch('proxyStatusUpdated');
2023-11-29 13:59:06 +00:00
}
} catch (\Throwable $e) {
return handleError($e, $this);
}
2023-06-02 13:15:12 +00:00
}
}