Drop restart-limit fields and enforcement from database resources, clear cached Traefik version data when proxies change, and show missing service environment variables from disabled deploy actions.
84 lines
3.5 KiB
PHP
84 lines
3.5 KiB
PHP
<?php
|
|
|
|
namespace App\Actions\Service;
|
|
|
|
use App\Models\Service;
|
|
use Lorisleiva\Actions\Concerns\AsAction;
|
|
use Lorisleiva\Actions\Decorators\JobDecorator;
|
|
use Symfony\Component\Yaml\Yaml;
|
|
|
|
class StartService
|
|
{
|
|
use AsAction;
|
|
|
|
public function configureJob(JobDecorator $job): void
|
|
{
|
|
$job->onQueue(deployment_queue());
|
|
}
|
|
|
|
public function handle(Service $service, bool $pullLatestImages = false, bool $stopBeforeStart = false)
|
|
{
|
|
$service->parse();
|
|
if ($this->shouldStopBeforeStarting($pullLatestImages, $stopBeforeStart)) {
|
|
StopService::run(service: $service, dockerCleanup: false);
|
|
}
|
|
$service->saveComposeConfigs();
|
|
$service->isConfigurationChanged(save: true);
|
|
$service->applications()->get()->each->resetRestartLimit();
|
|
$workdir = $service->workdir();
|
|
// $commands[] = "cd {$workdir}";
|
|
$commands[] = "echo 'Saved configuration files to {$workdir}.'";
|
|
// Ensure .env exists in the correct directory before docker compose tries to load it
|
|
// This is defensive programming - saveComposeConfigs() already creates it,
|
|
// but we guarantee it here in case of any edge cases or manual deployments
|
|
$commands[] = "touch {$workdir}/.env";
|
|
if ($pullLatestImages) {
|
|
$commands[] = "echo 'Pulling images.'";
|
|
$commands[] = "docker compose --project-directory {$workdir} pull";
|
|
}
|
|
if ($service->networks()->count() > 0) {
|
|
$commands[] = "echo 'Creating Docker network.'";
|
|
$commands[] = "docker network inspect $service->uuid >/dev/null 2>&1 || docker network create --attachable $service->uuid";
|
|
}
|
|
$commands[] = 'echo Starting service.';
|
|
$commands[] = "docker compose --project-directory {$workdir} -f {$workdir}/docker-compose.yml --project-name {$service->uuid} up -d --remove-orphans --force-recreate --build";
|
|
$commands[] = "docker network connect $service->uuid coolify-proxy >/dev/null 2>&1 || true";
|
|
if (data_get($service, 'connect_to_docker_network')) {
|
|
$compose = data_get($service, 'docker_compose', []);
|
|
$safeNetwork = escapeshellarg($service->destination->network);
|
|
$serviceNames = data_get(Yaml::parse($compose), 'services', []);
|
|
foreach ($serviceNames as $serviceName => $serviceConfig) {
|
|
$commands[] = "docker network connect --alias {$serviceName}-{$service->uuid} {$safeNetwork} {$serviceName}-{$service->uuid} >/dev/null 2>&1 || true";
|
|
}
|
|
}
|
|
$commands = array_merge($commands, $this->logDrainNetworkConnectCommands($service));
|
|
|
|
return remote_process($commands, $service->server, type_uuid: $service->uuid, callEventOnFinish: 'ServiceStatusChanged');
|
|
}
|
|
|
|
private function logDrainNetworkConnectCommands(Service $service): array
|
|
{
|
|
if (! data_get($service, 'connect_to_docker_network')) {
|
|
return [];
|
|
}
|
|
|
|
if (! $service->destination?->server?->isLogDrainEnabled()) {
|
|
return [];
|
|
}
|
|
|
|
$network = data_get($service, 'destination.network');
|
|
|
|
if (blank($network)) {
|
|
return [];
|
|
}
|
|
|
|
return [
|
|
'docker network connect '.escapeshellarg($network).' coolify-log-drain >/dev/null 2>&1 || true',
|
|
];
|
|
}
|
|
|
|
private function shouldStopBeforeStarting(bool $pullLatestImages, bool $stopBeforeStart): bool
|
|
{
|
|
return $stopBeforeStart && ! $pullLatestImages;
|
|
}
|
|
}
|