2023-09-20 15:42:41 +02:00
|
|
|
<?php
|
|
|
|
|
|
|
|
|
|
namespace App\Models;
|
|
|
|
|
|
|
|
|
|
use Illuminate\Database\Eloquent\Factories\HasFactory;
|
|
|
|
|
use Illuminate\Database\Eloquent\Relations\HasMany;
|
|
|
|
|
use Illuminate\Support\Collection;
|
2023-09-26 15:07:33 +02:00
|
|
|
use Illuminate\Support\Facades\Cache;
|
2023-09-20 15:42:41 +02:00
|
|
|
use Symfony\Component\Yaml\Yaml;
|
|
|
|
|
use Illuminate\Support\Str;
|
2023-09-22 21:31:47 +02:00
|
|
|
use Spatie\Url\Url;
|
2023-09-20 15:42:41 +02:00
|
|
|
|
|
|
|
|
class Service extends BaseModel
|
|
|
|
|
{
|
|
|
|
|
use HasFactory;
|
|
|
|
|
protected $guarded = [];
|
|
|
|
|
|
2023-09-22 11:23:49 +02:00
|
|
|
protected static function booted()
|
|
|
|
|
{
|
|
|
|
|
static::deleted(function ($service) {
|
2023-09-22 11:34:27 +02:00
|
|
|
$storagesToDelete = collect([]);
|
2023-09-22 14:47:25 +02:00
|
|
|
foreach ($service->applications()->get() as $application) {
|
2023-09-22 11:34:27 +02:00
|
|
|
$storages = $application->persistentStorages()->get();
|
|
|
|
|
foreach ($storages as $storage) {
|
|
|
|
|
$storagesToDelete->push($storage);
|
|
|
|
|
}
|
2023-09-22 11:23:49 +02:00
|
|
|
$application->persistentStorages()->delete();
|
|
|
|
|
}
|
2023-09-22 14:47:25 +02:00
|
|
|
foreach ($service->databases()->get() as $database) {
|
2023-09-22 11:34:27 +02:00
|
|
|
$storages = $database->persistentStorages()->get();
|
|
|
|
|
foreach ($storages as $storage) {
|
|
|
|
|
$storagesToDelete->push($storage);
|
|
|
|
|
}
|
2023-09-22 11:23:49 +02:00
|
|
|
$database->persistentStorages()->delete();
|
|
|
|
|
}
|
|
|
|
|
$service->environment_variables()->delete();
|
|
|
|
|
$service->applications()->delete();
|
|
|
|
|
$service->databases()->delete();
|
2023-09-22 11:34:27 +02:00
|
|
|
if ($storagesToDelete->count() > 0) {
|
|
|
|
|
$storagesToDelete->each(function ($storage) use ($service) {
|
|
|
|
|
instant_remote_process(["docker volume rm -f $storage->name"], $service->server, false);
|
|
|
|
|
});
|
|
|
|
|
}
|
2023-09-22 11:23:49 +02:00
|
|
|
});
|
2023-09-20 15:42:41 +02:00
|
|
|
}
|
2023-09-22 11:23:49 +02:00
|
|
|
public function type()
|
2023-09-20 15:42:41 +02:00
|
|
|
{
|
2023-09-22 11:23:49 +02:00
|
|
|
return 'service';
|
2023-09-20 15:42:41 +02:00
|
|
|
}
|
2023-09-22 11:23:49 +02:00
|
|
|
|
2023-09-26 15:07:33 +02:00
|
|
|
public function documentation()
|
|
|
|
|
{
|
|
|
|
|
$services = Cache::get('services', []);
|
|
|
|
|
$service = data_get($services, Str::of($this->name)->beforeLast('-')->value, []);
|
|
|
|
|
return data_get($service, 'documentation', 'https://coolify.io/docs');
|
|
|
|
|
}
|
2023-09-20 15:42:41 +02:00
|
|
|
public function applications()
|
|
|
|
|
{
|
|
|
|
|
return $this->hasMany(ServiceApplication::class);
|
|
|
|
|
}
|
|
|
|
|
public function databases()
|
|
|
|
|
{
|
|
|
|
|
return $this->hasMany(ServiceDatabase::class);
|
|
|
|
|
}
|
2023-09-21 17:48:31 +02:00
|
|
|
public function environment()
|
|
|
|
|
{
|
|
|
|
|
return $this->belongsTo(Environment::class);
|
|
|
|
|
}
|
2023-09-22 11:23:49 +02:00
|
|
|
public function server()
|
|
|
|
|
{
|
2023-09-21 17:48:31 +02:00
|
|
|
return $this->belongsTo(Server::class);
|
|
|
|
|
}
|
|
|
|
|
public function byName(string $name)
|
|
|
|
|
{
|
|
|
|
|
$app = $this->applications()->whereName($name)->first();
|
|
|
|
|
if ($app) {
|
|
|
|
|
return $app;
|
|
|
|
|
}
|
|
|
|
|
$db = $this->databases()->whereName($name)->first();
|
|
|
|
|
if ($db) {
|
|
|
|
|
return $db;
|
|
|
|
|
}
|
|
|
|
|
return null;
|
|
|
|
|
}
|
2023-09-20 15:42:41 +02:00
|
|
|
public function environment_variables(): HasMany
|
|
|
|
|
{
|
|
|
|
|
return $this->hasMany(EnvironmentVariable::class)->orderBy('key', 'asc');
|
|
|
|
|
}
|
2023-09-25 15:48:43 +02:00
|
|
|
public function workdir()
|
|
|
|
|
{
|
2023-09-25 12:49:55 +02:00
|
|
|
return service_configuration_dir() . "/{$this->uuid}";
|
|
|
|
|
}
|
|
|
|
|
public function saveComposeConfigs()
|
|
|
|
|
{
|
|
|
|
|
$workdir = $this->workdir();
|
|
|
|
|
$commands[] = "mkdir -p $workdir";
|
|
|
|
|
$commands[] = "cd $workdir";
|
|
|
|
|
|
|
|
|
|
$docker_compose_base64 = base64_encode($this->docker_compose);
|
|
|
|
|
$commands[] = "echo $docker_compose_base64 | base64 -d > docker-compose.yml";
|
|
|
|
|
$envs = $this->environment_variables()->get();
|
|
|
|
|
$commands[] = "rm -f .env || true";
|
|
|
|
|
foreach ($envs as $env) {
|
|
|
|
|
$commands[] = "echo '{$env->key}={$env->value}' >> .env";
|
|
|
|
|
}
|
2023-09-26 14:45:52 +02:00
|
|
|
if ($envs->count() === 0) {
|
|
|
|
|
$commands[] = "touch .env";
|
|
|
|
|
}
|
2023-09-25 12:49:55 +02:00
|
|
|
instant_remote_process($commands, $this->server);
|
|
|
|
|
}
|
2023-09-26 14:45:52 +02:00
|
|
|
private function sslip(Server $server)
|
|
|
|
|
{
|
|
|
|
|
if (isDev()) {
|
|
|
|
|
return "127.0.0.1.sslip.io";
|
|
|
|
|
}
|
|
|
|
|
return "{$server->ip}.sslip.io";
|
|
|
|
|
}
|
2023-09-27 21:14:13 +02:00
|
|
|
// private function generateFqdn($serviceVariables, $serviceName, Collection $configuration)
|
|
|
|
|
// {
|
|
|
|
|
// // Add sslip.io to the service
|
|
|
|
|
// $defaultUsableFqdn = null;
|
|
|
|
|
// $sslip = $this->sslip($this->server);
|
|
|
|
|
// if (Str::of($serviceVariables)->contains('SERVICE_FQDN') || Str::of($serviceVariables)->contains('SERVICE_URL')) {
|
|
|
|
|
// $defaultUsableFqdn = "http://$serviceName-{$this->uuid}.{$sslip}";
|
|
|
|
|
// }
|
|
|
|
|
// if ($configuration->count() > 0) {
|
|
|
|
|
// foreach ($configuration as $requiredFqdn) {
|
|
|
|
|
// $requiredFqdn = (array)$requiredFqdn;
|
|
|
|
|
// $name = data_get($requiredFqdn, 'name');
|
|
|
|
|
// $path = data_get($requiredFqdn, 'path');
|
|
|
|
|
// $customFqdn = data_get($requiredFqdn, 'customFqdn');
|
|
|
|
|
// if ($serviceName === $name) {
|
|
|
|
|
// $defaultUsableFqdn = "http://$serviceName-{$this->uuid}.{$sslip}{$path}";
|
|
|
|
|
// if ($customFqdn) {
|
|
|
|
|
// $defaultUsableFqdn = "http://$customFqdn-{$this->uuid}.{$sslip}{$path}";
|
|
|
|
|
// }
|
|
|
|
|
// }
|
|
|
|
|
// }
|
|
|
|
|
// }
|
|
|
|
|
// return $defaultUsableFqdn ?? null;
|
|
|
|
|
// }
|
2023-09-27 12:45:53 +02:00
|
|
|
public function parse(bool $isNew = false): Collection
|
2023-09-20 15:42:41 +02:00
|
|
|
{
|
2023-09-27 15:48:19 +02:00
|
|
|
// ray()->clearAll();
|
2023-09-20 15:42:41 +02:00
|
|
|
if ($this->docker_compose_raw) {
|
2023-09-22 21:31:47 +02:00
|
|
|
try {
|
|
|
|
|
$yaml = Yaml::parse($this->docker_compose_raw);
|
|
|
|
|
} catch (\Exception $e) {
|
|
|
|
|
throw new \Exception($e->getMessage());
|
|
|
|
|
}
|
2023-09-20 15:42:41 +02:00
|
|
|
|
2023-09-27 12:45:53 +02:00
|
|
|
$topLevelVolumes = collect(data_get($yaml, 'volumes', []));
|
|
|
|
|
$topLevelNetworks = collect(data_get($yaml, 'networks', []));
|
2023-09-21 17:48:31 +02:00
|
|
|
$dockerComposeVersion = data_get($yaml, 'version') ?? '3.8';
|
2023-09-20 15:42:41 +02:00
|
|
|
$services = data_get($yaml, 'services');
|
2023-09-21 17:48:31 +02:00
|
|
|
$definedNetwork = $this->uuid;
|
2023-09-20 15:42:41 +02:00
|
|
|
|
2023-09-27 15:48:19 +02:00
|
|
|
$generatedServiceFQDNS = collect([]);
|
|
|
|
|
|
|
|
|
|
$services = collect($services)->map(function ($service, $serviceName) use ($topLevelVolumes, $topLevelNetworks, $definedNetwork, $isNew, $generatedServiceFQDNS) {
|
2023-09-27 12:45:53 +02:00
|
|
|
$serviceVolumes = collect(data_get($service, 'volumes', []));
|
|
|
|
|
$servicePorts = collect(data_get($service, 'ports', []));
|
|
|
|
|
$serviceNetworks = collect(data_get($service, 'networks', []));
|
2023-09-22 12:08:51 +02:00
|
|
|
$serviceVariables = collect(data_get($service, 'environment', []));
|
2023-09-27 12:45:53 +02:00
|
|
|
$serviceLabels = collect(data_get($service, 'labels', []));
|
2023-09-22 12:08:51 +02:00
|
|
|
|
2023-09-27 12:45:53 +02:00
|
|
|
$containerName = "$serviceName-{$this->uuid}";
|
|
|
|
|
|
|
|
|
|
// Decide if the service is a database
|
|
|
|
|
$isDatabase = false;
|
|
|
|
|
$image = data_get_str($service, 'image');
|
|
|
|
|
if ($image->contains(':')) {
|
|
|
|
|
$image = Str::of($image);
|
2023-09-26 14:45:52 +02:00
|
|
|
} else {
|
2023-09-27 12:45:53 +02:00
|
|
|
$image = Str::of($image)->append(':latest');
|
2023-09-26 14:45:52 +02:00
|
|
|
}
|
2023-09-27 12:45:53 +02:00
|
|
|
$imageName = $image->before(':');
|
2023-09-26 14:45:52 +02:00
|
|
|
|
2023-09-27 12:45:53 +02:00
|
|
|
if (collect(DATABASE_DOCKER_IMAGES)->contains($imageName)) {
|
|
|
|
|
$isDatabase = true;
|
2023-09-20 15:42:41 +02:00
|
|
|
}
|
2023-09-27 12:45:53 +02:00
|
|
|
data_set($service, 'is_database', $isDatabase);
|
|
|
|
|
|
|
|
|
|
// Create new serviceApplication or serviceDatabase
|
2023-09-25 15:48:43 +02:00
|
|
|
if ($isDatabase) {
|
2023-09-27 12:45:53 +02:00
|
|
|
if ($isNew) {
|
2023-09-20 15:42:41 +02:00
|
|
|
$savedService = ServiceDatabase::create([
|
|
|
|
|
'name' => $serviceName,
|
2023-09-26 14:45:52 +02:00
|
|
|
'image' => $image,
|
2023-09-20 15:42:41 +02:00
|
|
|
'service_id' => $this->id
|
|
|
|
|
]);
|
|
|
|
|
} else {
|
2023-09-27 12:45:53 +02:00
|
|
|
$savedService = ServiceDatabase::where([
|
|
|
|
|
'name' => $serviceName,
|
|
|
|
|
'service_id' => $this->id
|
|
|
|
|
])->first();
|
|
|
|
|
}
|
|
|
|
|
} else {
|
|
|
|
|
if ($isNew) {
|
2023-09-20 15:42:41 +02:00
|
|
|
$savedService = ServiceApplication::create([
|
|
|
|
|
'name' => $serviceName,
|
2023-09-26 14:45:52 +02:00
|
|
|
'image' => $image,
|
2023-09-20 15:42:41 +02:00
|
|
|
'service_id' => $this->id
|
|
|
|
|
]);
|
2023-09-21 17:48:31 +02:00
|
|
|
} else {
|
2023-09-27 12:45:53 +02:00
|
|
|
$savedService = ServiceApplication::where([
|
|
|
|
|
'name' => $serviceName,
|
|
|
|
|
'service_id' => $this->id
|
|
|
|
|
])->first();
|
2023-09-21 17:48:31 +02:00
|
|
|
}
|
2023-09-20 15:42:41 +02:00
|
|
|
}
|
2023-09-27 15:48:19 +02:00
|
|
|
if (is_null($savedService)) {
|
|
|
|
|
if ($isDatabase) {
|
|
|
|
|
$savedService = ServiceDatabase::create([
|
|
|
|
|
'name' => $serviceName,
|
|
|
|
|
'image' => $image,
|
|
|
|
|
'service_id' => $this->id
|
|
|
|
|
]);
|
|
|
|
|
} else {
|
|
|
|
|
$savedService = ServiceApplication::create([
|
|
|
|
|
'name' => $serviceName,
|
|
|
|
|
'image' => $image,
|
|
|
|
|
'service_id' => $this->id
|
|
|
|
|
]);
|
|
|
|
|
}
|
|
|
|
|
}
|
2023-09-25 17:51:04 +02:00
|
|
|
|
2023-09-27 12:45:53 +02:00
|
|
|
// Collect/create/update networks
|
|
|
|
|
if ($serviceNetworks->count() > 0) {
|
|
|
|
|
foreach ($serviceNetworks as $networkName => $networkDetails) {
|
|
|
|
|
$networkExists = $topLevelNetworks->contains(function ($value, $key) use ($networkName) {
|
|
|
|
|
return $value == $networkName || $key == $networkName;
|
|
|
|
|
});
|
|
|
|
|
if (!$networkExists) {
|
|
|
|
|
$topLevelNetworks->put($networkDetails, null);
|
|
|
|
|
}
|
|
|
|
|
}
|
2023-09-22 14:47:25 +02:00
|
|
|
}
|
2023-09-27 12:45:53 +02:00
|
|
|
|
|
|
|
|
// Collect/create/update ports
|
2023-09-22 14:47:25 +02:00
|
|
|
$collectedPorts = collect([]);
|
|
|
|
|
if ($servicePorts->count() > 0) {
|
|
|
|
|
foreach ($servicePorts as $sport) {
|
|
|
|
|
if (is_string($sport) || is_numeric($sport)) {
|
|
|
|
|
$collectedPorts->push($sport);
|
|
|
|
|
}
|
|
|
|
|
if (is_array($sport)) {
|
|
|
|
|
$target = data_get($sport, 'target');
|
|
|
|
|
$published = data_get($sport, 'published');
|
2023-09-27 12:45:53 +02:00
|
|
|
$protocol = data_get($sport, 'protocol');
|
|
|
|
|
$collectedPorts->push("$target:$published/$protocol");
|
2023-09-21 17:48:31 +02:00
|
|
|
}
|
|
|
|
|
}
|
2023-09-20 15:42:41 +02:00
|
|
|
}
|
2023-09-22 14:47:25 +02:00
|
|
|
$savedService->ports = $collectedPorts->implode(',');
|
|
|
|
|
$savedService->save();
|
2023-09-26 14:45:52 +02:00
|
|
|
|
2023-09-27 12:45:53 +02:00
|
|
|
// Add Coolify specific networks
|
|
|
|
|
$definedNetworkExists = $topLevelNetworks->contains(function ($value, $_) use ($definedNetwork) {
|
|
|
|
|
return $value == $definedNetwork;
|
|
|
|
|
});
|
|
|
|
|
if (!$definedNetworkExists) {
|
|
|
|
|
$topLevelNetworks->put($definedNetwork, [
|
|
|
|
|
'name' => $definedNetwork,
|
|
|
|
|
'external' => false
|
|
|
|
|
]);
|
|
|
|
|
}
|
|
|
|
|
$networks = $serviceNetworks->toArray();
|
|
|
|
|
$networks = array_merge($networks, [$definedNetwork]);
|
|
|
|
|
data_set($service, 'networks', $networks);
|
|
|
|
|
|
|
|
|
|
// Collect/create/update volumes
|
2023-09-20 15:42:41 +02:00
|
|
|
if ($serviceVolumes->count() > 0) {
|
|
|
|
|
foreach ($serviceVolumes as $volume) {
|
2023-09-27 12:45:53 +02:00
|
|
|
$type = null;
|
|
|
|
|
$source = null;
|
|
|
|
|
$target = null;
|
2023-09-27 15:48:19 +02:00
|
|
|
$content = null;
|
2023-09-20 15:42:41 +02:00
|
|
|
if (is_string($volume)) {
|
2023-09-27 12:45:53 +02:00
|
|
|
$source = Str::of($volume)->before(':');
|
|
|
|
|
$target = Str::of($volume)->after(':')->beforeLast(':');
|
|
|
|
|
if ($source->startsWith('./') || $source->startsWith('/') || $source->startsWith('~')) {
|
|
|
|
|
$type = Str::of('bind');
|
|
|
|
|
} else {
|
|
|
|
|
$type = Str::of('volume');
|
2023-09-25 12:49:55 +02:00
|
|
|
}
|
2023-09-27 12:45:53 +02:00
|
|
|
} else if (is_array($volume)) {
|
|
|
|
|
$type = data_get_str($volume, 'type');
|
|
|
|
|
$source = data_get_str($volume, 'source');
|
|
|
|
|
$target = data_get_str($volume, 'target');
|
2023-09-27 15:48:19 +02:00
|
|
|
$content = data_get($volume, 'content');
|
2023-09-20 15:42:41 +02:00
|
|
|
}
|
2023-09-27 12:45:53 +02:00
|
|
|
if ($type->value() === 'bind') {
|
2023-09-27 15:48:19 +02:00
|
|
|
if ($source->value() === "/var/run/docker.sock") {
|
|
|
|
|
continue;
|
|
|
|
|
}
|
|
|
|
|
if ($source->value() === '/tmp' || $source->value() === '/tmp/' ) {
|
|
|
|
|
continue;
|
|
|
|
|
}
|
2023-09-27 12:45:53 +02:00
|
|
|
LocalFileVolume::updateOrCreate(
|
|
|
|
|
[
|
|
|
|
|
'mount_path' => $target,
|
2023-09-25 12:49:55 +02:00
|
|
|
'resource_id' => $savedService->id,
|
|
|
|
|
'resource_type' => get_class($savedService)
|
2023-09-27 12:45:53 +02:00
|
|
|
],
|
|
|
|
|
[
|
|
|
|
|
'fs_path' => $source,
|
|
|
|
|
'mount_path' => $target,
|
2023-09-27 15:48:19 +02:00
|
|
|
'content' => $content,
|
2023-09-27 12:45:53 +02:00
|
|
|
'resource_id' => $savedService->id,
|
|
|
|
|
'resource_type' => get_class($savedService)
|
|
|
|
|
]
|
|
|
|
|
);
|
|
|
|
|
} else if ($type->value() === 'volume') {
|
|
|
|
|
$topLevelVolumes->put($source->value(), null);
|
|
|
|
|
LocalPersistentVolume::updateOrCreate(
|
|
|
|
|
[
|
|
|
|
|
'mount_path' => $target,
|
|
|
|
|
'resource_id' => $savedService->id,
|
|
|
|
|
'resource_type' => get_class($savedService)
|
|
|
|
|
],
|
|
|
|
|
[
|
|
|
|
|
'name' => Str::slug($source, '-'),
|
|
|
|
|
'mount_path' => $target,
|
|
|
|
|
'resource_id' => $savedService->id,
|
|
|
|
|
'resource_type' => get_class($savedService)
|
|
|
|
|
]
|
|
|
|
|
);
|
2023-09-20 15:42:41 +02:00
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
2023-09-27 12:45:53 +02:00
|
|
|
// Add env_file with at least .env to the service
|
2023-09-27 15:48:19 +02:00
|
|
|
// $envFile = collect(data_get($service, 'env_file', []));
|
|
|
|
|
// if ($envFile->count() > 0) {
|
|
|
|
|
// if (!$envFile->contains('.env')) {
|
|
|
|
|
// $envFile->push('.env');
|
|
|
|
|
// }
|
|
|
|
|
// } else {
|
|
|
|
|
// $envFile = collect(['.env']);
|
|
|
|
|
// }
|
|
|
|
|
// data_set($service, 'env_file', $envFile->toArray());
|
2023-09-20 15:42:41 +02:00
|
|
|
|
2023-09-26 16:21:55 +02:00
|
|
|
|
2023-09-21 17:48:31 +02:00
|
|
|
// Get variables from the service
|
2023-09-27 12:45:53 +02:00
|
|
|
foreach ($serviceVariables as $variableName => $variable) {
|
|
|
|
|
if (is_numeric($variableName)) {
|
|
|
|
|
$variable = Str::of($variable);
|
|
|
|
|
if ($variable->contains('=')) {
|
|
|
|
|
// - SESSION_SECRET=123
|
|
|
|
|
// - SESSION_SECRET=
|
|
|
|
|
$key = $variable->before('=');
|
|
|
|
|
$value = $variable->after('=');
|
2023-09-20 15:42:41 +02:00
|
|
|
} else {
|
2023-09-27 12:45:53 +02:00
|
|
|
// - SESSION_SECRET
|
|
|
|
|
$key = $variable;
|
|
|
|
|
$value = null;
|
2023-09-20 15:42:41 +02:00
|
|
|
}
|
2023-09-27 12:45:53 +02:00
|
|
|
} else {
|
|
|
|
|
// SESSION_SECRET: 123
|
|
|
|
|
// SESSION_SECRET:
|
2023-09-27 15:48:19 +02:00
|
|
|
$key = Str::of($variableName);
|
2023-09-27 12:45:53 +02:00
|
|
|
$value = Str::of($variable);
|
|
|
|
|
}
|
2023-09-27 15:48:19 +02:00
|
|
|
if ($key->startsWith('SERVICE_FQDN')) {
|
|
|
|
|
if (is_null(data_get($savedService, 'fqdn'))) {
|
|
|
|
|
$sslip = $this->sslip($this->server);
|
|
|
|
|
$fqdn = "http://$containerName.$sslip";
|
|
|
|
|
if (substr_count($key->value(),'_') === 2) {
|
|
|
|
|
$path = $value->value();
|
|
|
|
|
if ($generatedServiceFQDNS->count() > 0) {
|
|
|
|
|
$alreadyGenerated = $generatedServiceFQDNS->has($key->value());
|
|
|
|
|
if ($alreadyGenerated) {
|
|
|
|
|
$fqdn = $generatedServiceFQDNS->get($key->value());
|
|
|
|
|
} else {
|
|
|
|
|
$generatedServiceFQDNS->put($key->value(), $fqdn);
|
|
|
|
|
}
|
|
|
|
|
} else {
|
|
|
|
|
$generatedServiceFQDNS->put($key->value(), $fqdn);
|
|
|
|
|
}
|
|
|
|
|
$fqdn = "http://$containerName.$sslip$path";
|
|
|
|
|
}
|
|
|
|
|
if (!$isDatabase) {
|
|
|
|
|
$savedService->fqdn = $fqdn;
|
|
|
|
|
$savedService->save();
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
continue;
|
|
|
|
|
}
|
2023-09-27 12:45:53 +02:00
|
|
|
if ($value?->startsWith('$')) {
|
|
|
|
|
$value = Str::of(replaceVariables($value));
|
|
|
|
|
$key = $value;
|
|
|
|
|
$foundEnv = EnvironmentVariable::where([
|
|
|
|
|
'key' => $key,
|
|
|
|
|
'service_id' => $this->id,
|
|
|
|
|
])->first();
|
|
|
|
|
if ($value->startsWith('SERVICE_')) {
|
|
|
|
|
$command = $value->after('SERVICE_')->beforeLast('_');
|
|
|
|
|
$forService = $value->afterLast('_');
|
|
|
|
|
$generatedValue = null;
|
|
|
|
|
if ($command->value() === 'FQDN' || $command->value() === 'URL') {
|
|
|
|
|
$sslip = $this->sslip($this->server);
|
|
|
|
|
$fqdn = "http://$containerName.$sslip";
|
|
|
|
|
if ($foundEnv) {
|
|
|
|
|
$fqdn = data_get($foundEnv, 'value');
|
|
|
|
|
} else {
|
|
|
|
|
EnvironmentVariable::create([
|
|
|
|
|
'key' => $key,
|
|
|
|
|
'value' => $fqdn,
|
2023-09-22 11:23:49 +02:00
|
|
|
'is_build_time' => false,
|
|
|
|
|
'service_id' => $this->id,
|
|
|
|
|
'is_preview' => false,
|
|
|
|
|
]);
|
2023-09-20 15:42:41 +02:00
|
|
|
}
|
2023-09-27 12:45:53 +02:00
|
|
|
|
|
|
|
|
if (!$isDatabase) {
|
|
|
|
|
$savedService->fqdn = $fqdn;
|
|
|
|
|
$savedService->save();
|
2023-09-20 15:42:41 +02:00
|
|
|
}
|
2023-09-22 15:46:30 +02:00
|
|
|
} else {
|
2023-09-27 12:45:53 +02:00
|
|
|
switch ($command) {
|
|
|
|
|
case 'PASSWORD':
|
|
|
|
|
$generatedValue = Str::password(symbols: false);
|
|
|
|
|
break;
|
|
|
|
|
case 'PASSWORD_64':
|
|
|
|
|
$generatedValue = Str::password(length: 64, symbols: false);
|
|
|
|
|
break;
|
|
|
|
|
case 'BASE64_64':
|
|
|
|
|
$generatedValue = Str::random(64);
|
|
|
|
|
break;
|
|
|
|
|
case 'BASE64_128':
|
|
|
|
|
$generatedValue = Str::random(128);
|
|
|
|
|
break;
|
|
|
|
|
case 'BASE64':
|
|
|
|
|
$generatedValue = Str::random(32);
|
|
|
|
|
break;
|
|
|
|
|
case 'USER':
|
|
|
|
|
$generatedValue = Str::random(16);
|
|
|
|
|
break;
|
2023-09-26 16:21:55 +02:00
|
|
|
}
|
2023-09-27 12:45:53 +02:00
|
|
|
|
|
|
|
|
if (!$foundEnv) {
|
|
|
|
|
EnvironmentVariable::create([
|
|
|
|
|
'key' => $key,
|
|
|
|
|
'value' => $generatedValue,
|
|
|
|
|
'is_build_time' => false,
|
|
|
|
|
'service_id' => $this->id,
|
|
|
|
|
'is_preview' => false,
|
|
|
|
|
]);
|
2023-09-22 14:47:25 +02:00
|
|
|
}
|
2023-09-21 17:48:31 +02:00
|
|
|
}
|
2023-09-27 12:45:53 +02:00
|
|
|
} else {
|
|
|
|
|
if ($value->contains(':-')) {
|
|
|
|
|
$key = $value->before(':');
|
|
|
|
|
$defaultValue = $value->after(':-');
|
|
|
|
|
} else if ($value->contains('-')) {
|
|
|
|
|
$key = $value->before('-');
|
|
|
|
|
$defaultValue = $value->after('-');
|
|
|
|
|
} else if ($value->contains(':?')) {
|
|
|
|
|
$key = $value->before(':');
|
|
|
|
|
$defaultValue = $value->after(':?');
|
|
|
|
|
} else if ($value->contains('?')) {
|
|
|
|
|
$key = $value->before('?');
|
|
|
|
|
$defaultValue = $value->after('?');
|
|
|
|
|
} else {
|
|
|
|
|
$key = $value;
|
|
|
|
|
$defaultValue = null;
|
2023-09-21 17:48:31 +02:00
|
|
|
}
|
2023-09-27 15:48:19 +02:00
|
|
|
if ($foundEnv) {
|
|
|
|
|
$defaultValue = data_get($foundEnv, 'value');
|
|
|
|
|
}
|
2023-09-27 12:45:53 +02:00
|
|
|
EnvironmentVariable::updateOrCreate([
|
|
|
|
|
'key' => $key,
|
|
|
|
|
'service_id' => $this->id,
|
|
|
|
|
], [
|
|
|
|
|
'value' => $defaultValue,
|
|
|
|
|
'is_build_time' => false,
|
|
|
|
|
'service_id' => $this->id,
|
|
|
|
|
'is_preview' => false,
|
|
|
|
|
]);
|
2023-09-20 15:42:41 +02:00
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
2023-09-26 14:45:52 +02:00
|
|
|
|
2023-09-25 09:17:42 +02:00
|
|
|
// Add labels to the service
|
2023-09-27 15:48:19 +02:00
|
|
|
$fqdns = collect(data_get($savedService, 'fqdns'));
|
2023-09-27 12:45:53 +02:00
|
|
|
$defaultLabels = defaultLabels($this->id, $containerName, type: 'service', subType: $isDatabase ? 'database' : 'application', subId: $savedService->id);
|
|
|
|
|
$serviceLabels = $serviceLabels->merge($defaultLabels);
|
|
|
|
|
if (!$isDatabase && $fqdns->count() > 0) {
|
2023-09-25 09:17:42 +02:00
|
|
|
if ($fqdns) {
|
2023-09-27 12:45:53 +02:00
|
|
|
$serviceLabels = $serviceLabels->merge(fqdnLabelsForTraefik($fqdns, $containerName, true));
|
2023-09-21 17:48:31 +02:00
|
|
|
}
|
|
|
|
|
}
|
2023-09-25 17:51:04 +02:00
|
|
|
|
2023-09-27 12:45:53 +02:00
|
|
|
data_set($service, 'labels', $serviceLabels->toArray());
|
2023-09-20 15:42:41 +02:00
|
|
|
data_forget($service, 'is_database');
|
2023-09-21 17:48:31 +02:00
|
|
|
data_set($service, 'restart', RESTART_MODE);
|
2023-09-27 12:45:53 +02:00
|
|
|
data_set($service, 'container_name', $containerName);
|
2023-09-25 12:49:55 +02:00
|
|
|
data_forget($service, 'volumes.*.content');
|
2023-09-27 15:48:19 +02:00
|
|
|
|
|
|
|
|
// Remove unnecessary variables from service.environment
|
|
|
|
|
$withoutServiceEnvs = collect([]);
|
|
|
|
|
collect(data_get($service, 'environment'))->each(function ($value, $key) use ($withoutServiceEnvs) {
|
|
|
|
|
if (!Str::of($key)->startsWith('$SERVICE_')) {
|
|
|
|
|
$withoutServiceEnvs->put($key, $value);
|
|
|
|
|
}
|
|
|
|
|
});
|
|
|
|
|
data_set($service, 'environment', $withoutServiceEnvs->toArray());
|
2023-09-20 15:42:41 +02:00
|
|
|
return $service;
|
|
|
|
|
});
|
2023-09-21 17:48:31 +02:00
|
|
|
$finalServices = [
|
|
|
|
|
'version' => $dockerComposeVersion,
|
|
|
|
|
'services' => $services->toArray(),
|
2023-09-27 12:45:53 +02:00
|
|
|
'volumes' => $topLevelVolumes->toArray(),
|
|
|
|
|
'networks' => $topLevelNetworks->toArray(),
|
2023-09-21 17:48:31 +02:00
|
|
|
];
|
2023-09-25 12:49:55 +02:00
|
|
|
data_forget($yaml, 'services.*.volumes.*.content');
|
|
|
|
|
$this->docker_compose_raw = Yaml::dump($yaml, 10, 2);
|
2023-09-21 17:48:31 +02:00
|
|
|
$this->docker_compose = Yaml::dump($finalServices, 10, 2);
|
|
|
|
|
$this->save();
|
2023-09-25 12:49:55 +02:00
|
|
|
$this->saveComposeConfigs();
|
2023-09-27 12:45:53 +02:00
|
|
|
return collect([]);
|
|
|
|
|
// $services = collect($services)->map(function ($service, $serviceName) use ($composeVolumes, $composeNetworks, $definedNetwork, $envs, $volumes, $ports, $isNew, $configuration) {
|
|
|
|
|
// $container_name = "$serviceName-{$this->uuid}";
|
|
|
|
|
// $isDatabase = false;
|
|
|
|
|
// $serviceVariables = collect(data_get($service, 'environment', []));
|
|
|
|
|
|
|
|
|
|
// // Add env_file with at least .env to the service
|
|
|
|
|
// $envFile = collect(data_get($service, 'env_file', []));
|
|
|
|
|
// if ($envFile->count() > 0) {
|
|
|
|
|
// if (!$envFile->contains('.env')) {
|
|
|
|
|
// $envFile->push('.env');
|
|
|
|
|
// }
|
|
|
|
|
// } else {
|
|
|
|
|
// $envFile = collect(['.env']);
|
|
|
|
|
// }
|
|
|
|
|
// data_set($service, 'env_file', $envFile->toArray());
|
|
|
|
|
|
|
|
|
|
// // Decide if the service is a database
|
|
|
|
|
// $image = data_get($service, 'image');
|
|
|
|
|
// if ($image) {
|
|
|
|
|
// $imageName = Str::of($image)->before(':');
|
|
|
|
|
// if (collect(DATABASE_DOCKER_IMAGES)->contains($imageName)) {
|
|
|
|
|
// $isDatabase = true;
|
|
|
|
|
// data_set($service, 'is_database', true);
|
|
|
|
|
// }
|
|
|
|
|
// }
|
|
|
|
|
// if ($isDatabase) {
|
|
|
|
|
// $savedService = ServiceDatabase::where([
|
|
|
|
|
// 'name' => $serviceName,
|
|
|
|
|
// 'service_id' => $this->id
|
|
|
|
|
// ])->first();
|
|
|
|
|
// } else {
|
|
|
|
|
// $savedService = ServiceApplication::where([
|
|
|
|
|
// 'name' => $serviceName,
|
|
|
|
|
// 'service_id' => $this->id
|
|
|
|
|
// ])->first();
|
|
|
|
|
// }
|
|
|
|
|
// if ($isNew || is_null($savedService)) {
|
|
|
|
|
// if ($isDatabase) {
|
|
|
|
|
// $savedService = ServiceDatabase::create([
|
|
|
|
|
// 'name' => $serviceName,
|
|
|
|
|
// 'image' => $image,
|
|
|
|
|
// 'service_id' => $this->id
|
|
|
|
|
// ]);
|
|
|
|
|
// } else {
|
|
|
|
|
// $savedService = ServiceApplication::create([
|
|
|
|
|
// 'name' => $serviceName,
|
|
|
|
|
// 'fqdn' => $this->generateFqdn($serviceVariables, $serviceName, $configuration),
|
|
|
|
|
// 'image' => $image,
|
|
|
|
|
// 'service_id' => $this->id
|
|
|
|
|
// ]);
|
|
|
|
|
// }
|
|
|
|
|
// if ($configuration->count() > 0) {
|
|
|
|
|
// foreach ($configuration as $requiredFqdn) {
|
|
|
|
|
// $requiredFqdn = (array)$requiredFqdn;
|
|
|
|
|
// $name = data_get($requiredFqdn, 'name');
|
|
|
|
|
// if ($serviceName === $name) {
|
|
|
|
|
// $savedService->required_fqdn = true;
|
|
|
|
|
// $savedService->save();
|
|
|
|
|
// break;
|
|
|
|
|
// }
|
|
|
|
|
// }
|
|
|
|
|
// }
|
|
|
|
|
// } else {
|
|
|
|
|
// if ($isDatabase) {
|
|
|
|
|
// $savedService = $this->databases()->whereName($serviceName)->first();
|
|
|
|
|
// } else {
|
|
|
|
|
// $savedService = $this->applications()->whereName($serviceName)->first();
|
|
|
|
|
// if (data_get($savedService, 'fqdn')) {
|
|
|
|
|
// $defaultUsableFqdn = data_get($savedService, 'fqdn', null);
|
|
|
|
|
// } else {
|
|
|
|
|
// $defaultUsableFqdn = $this->generateFqdn($serviceVariables, $serviceName, $configuration);
|
|
|
|
|
// }
|
|
|
|
|
// $savedService->fqdn = $defaultUsableFqdn;
|
|
|
|
|
// $savedService->save();
|
|
|
|
|
// }
|
|
|
|
|
// }
|
|
|
|
|
|
|
|
|
|
// $fqdns = data_get($savedService, 'fqdn');
|
|
|
|
|
// if ($fqdns) {
|
|
|
|
|
// $fqdns = collect(Str::of($fqdns)->explode(','));
|
|
|
|
|
// }
|
|
|
|
|
// // Collect ports
|
|
|
|
|
// $servicePorts = collect(data_get($service, 'ports', []));
|
|
|
|
|
// $ports->put($serviceName, $servicePorts);
|
|
|
|
|
// $collectedPorts = collect([]);
|
|
|
|
|
// if ($servicePorts->count() > 0) {
|
|
|
|
|
// foreach ($servicePorts as $sport) {
|
|
|
|
|
// if (is_string($sport) || is_numeric($sport)) {
|
|
|
|
|
// $collectedPorts->push($sport);
|
|
|
|
|
// }
|
|
|
|
|
// if (is_array($sport)) {
|
|
|
|
|
// $target = data_get($sport, 'target');
|
|
|
|
|
// $published = data_get($sport, 'published');
|
|
|
|
|
// $collectedPorts->push("$target:$published");
|
|
|
|
|
// }
|
|
|
|
|
// }
|
|
|
|
|
// }
|
|
|
|
|
// $savedService->ports = $collectedPorts->implode(',');
|
|
|
|
|
// $savedService->save();
|
|
|
|
|
|
|
|
|
|
// // Collect volumes
|
|
|
|
|
// $serviceVolumes = collect(data_get($service, 'volumes', []));
|
|
|
|
|
// if ($serviceVolumes->count() > 0) {
|
|
|
|
|
// LocalPersistentVolume::whereResourceId($savedService->id)->whereResourceType(get_class($savedService))->delete();
|
|
|
|
|
// foreach ($serviceVolumes as $volume) {
|
|
|
|
|
// if (is_string($volume)) {
|
|
|
|
|
// if (Str::startsWith($volume, './')) {
|
|
|
|
|
// $fsPath = Str::before($volume, ':');
|
|
|
|
|
// $volumePath = Str::of($volume)->after(':')->beforeLast(':');
|
|
|
|
|
// LocalFileVolume::updateOrCreate(
|
|
|
|
|
// [
|
|
|
|
|
// 'mount_path' => $volumePath,
|
|
|
|
|
// 'resource_id' => $savedService->id,
|
|
|
|
|
// 'resource_type' => get_class($savedService)
|
|
|
|
|
// ],
|
|
|
|
|
// [
|
|
|
|
|
// 'fs_path' => $fsPath,
|
|
|
|
|
// 'mount_path' => $volumePath,
|
|
|
|
|
// 'resource_id' => $savedService->id,
|
|
|
|
|
// 'resource_type' => get_class($savedService)
|
|
|
|
|
// ]
|
|
|
|
|
// );
|
|
|
|
|
// $savedService->saveFileVolumes();
|
|
|
|
|
// continue;
|
|
|
|
|
// }
|
|
|
|
|
// $volumeName = Str::before($volume, ':');
|
|
|
|
|
// $volumePath = Str::after($volume, ':');
|
|
|
|
|
// }
|
|
|
|
|
// if (is_array($volume)) {
|
|
|
|
|
// $volumeName = data_get($volume, 'source');
|
|
|
|
|
// $volumePath = data_get($volume, 'target');
|
|
|
|
|
// $volumeContent = data_get($volume, 'content');
|
|
|
|
|
// if (Str::startsWith($volumeName, './')) {
|
|
|
|
|
// $payload = [
|
|
|
|
|
// 'fs_path' => $volumeName,
|
|
|
|
|
// 'mount_path' => $volumePath,
|
|
|
|
|
|
|
|
|
|
// 'resource_id' => $savedService->id,
|
|
|
|
|
// 'resource_type' => get_class($savedService)
|
|
|
|
|
// ];
|
|
|
|
|
// if ($volumeContent) {
|
|
|
|
|
// $payload['content'] = $volumeContent;
|
|
|
|
|
// }
|
|
|
|
|
// LocalFileVolume::updateOrCreate(
|
|
|
|
|
// [
|
|
|
|
|
// 'mount_path' => $volumePath,
|
|
|
|
|
// 'resource_id' => $savedService->id,
|
|
|
|
|
// 'resource_type' => get_class($savedService)
|
|
|
|
|
// ],
|
|
|
|
|
// $payload
|
|
|
|
|
// );
|
|
|
|
|
// if ($volumeContent) {
|
|
|
|
|
// $volume = data_forget($volume, 'content');
|
|
|
|
|
// }
|
|
|
|
|
// $savedService->saveFileVolumes();
|
|
|
|
|
// continue;
|
|
|
|
|
// }
|
|
|
|
|
// }
|
|
|
|
|
|
|
|
|
|
// $volumeExists = $serviceVolumes->contains(function ($_, $key) use ($volumeName) {
|
|
|
|
|
// return $key == $volumeName;
|
|
|
|
|
// });
|
|
|
|
|
// if (!$volumeExists) {
|
|
|
|
|
// if (Str::startsWith($volumeName, '/')) {
|
|
|
|
|
// $volumes->put($volumeName, $volumePath);
|
|
|
|
|
// LocalPersistentVolume::updateOrCreate(
|
|
|
|
|
// [
|
|
|
|
|
// 'mount_path' => $volumePath,
|
|
|
|
|
// 'resource_id' => $savedService->id,
|
|
|
|
|
// 'resource_type' => get_class($savedService)
|
|
|
|
|
// ],
|
|
|
|
|
// [
|
|
|
|
|
// 'name' => Str::slug($volumeName, '-'),
|
|
|
|
|
// 'mount_path' => $volumePath,
|
|
|
|
|
// 'host_path' => $volumeName,
|
|
|
|
|
// 'resource_id' => $savedService->id,
|
|
|
|
|
// 'resource_type' => get_class($savedService)
|
|
|
|
|
// ]
|
|
|
|
|
// );
|
|
|
|
|
// } else {
|
|
|
|
|
// $composeVolumes->put($volumeName, null);
|
|
|
|
|
// LocalPersistentVolume::updateOrCreate(
|
|
|
|
|
// [
|
|
|
|
|
// 'name' => $volumeName,
|
|
|
|
|
// 'resource_id' => $savedService->id,
|
|
|
|
|
// 'resource_type' => get_class($savedService)
|
|
|
|
|
// ],
|
|
|
|
|
// [
|
|
|
|
|
// 'name' => $volumeName,
|
|
|
|
|
// 'mount_path' => $volumePath,
|
|
|
|
|
// 'host_path' => null,
|
|
|
|
|
// 'resource_id' => $savedService->id,
|
|
|
|
|
// 'resource_type' => get_class($savedService)
|
|
|
|
|
// ]
|
|
|
|
|
// );
|
|
|
|
|
// }
|
|
|
|
|
// }
|
|
|
|
|
// }
|
|
|
|
|
// }
|
|
|
|
|
|
|
|
|
|
// // Collect and add networks
|
|
|
|
|
// $serviceNetworks = collect(data_get($service, 'networks', []));
|
|
|
|
|
// if ($serviceNetworks->count() > 0) {
|
|
|
|
|
// foreach ($serviceNetworks as $networkName => $networkDetails) {
|
|
|
|
|
// $networkExists = $composeNetworks->contains(function ($value, $key) use ($networkName) {
|
|
|
|
|
// return $value == $networkName || $key == $networkName;
|
|
|
|
|
// });
|
|
|
|
|
// if (!$networkExists) {
|
|
|
|
|
// $composeNetworks->put($networkDetails, null);
|
|
|
|
|
// }
|
|
|
|
|
// }
|
|
|
|
|
// }
|
|
|
|
|
// // Add Coolify specific networks
|
|
|
|
|
// $definedNetworkExists = $composeNetworks->contains(function ($value, $_) use ($definedNetwork) {
|
|
|
|
|
// return $value == $definedNetwork;
|
|
|
|
|
// });
|
|
|
|
|
// if (!$definedNetworkExists) {
|
|
|
|
|
// $composeNetworks->put($definedNetwork, [
|
|
|
|
|
// 'name' => $definedNetwork,
|
|
|
|
|
// 'external' => false
|
|
|
|
|
// ]);
|
|
|
|
|
// }
|
|
|
|
|
// $networks = $serviceNetworks->toArray();
|
|
|
|
|
// $networks = array_merge($networks, [$definedNetwork]);
|
|
|
|
|
// data_set($service, 'networks', $networks);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// // Get variables from the service
|
|
|
|
|
// foreach ($serviceVariables as $variable) {
|
|
|
|
|
// $value = Str::after($variable, '=');
|
|
|
|
|
// // if (!Str::of($val)->contains($value)) {
|
|
|
|
|
// // EnvironmentVariable::updateOrCreate([
|
|
|
|
|
// // 'key' => $variable,
|
|
|
|
|
// // 'service_id' => $this->id,
|
|
|
|
|
// // ], [
|
|
|
|
|
// // 'value' => $val,
|
|
|
|
|
// // 'is_build_time' => false,
|
|
|
|
|
// // 'service_id' => $this->id,
|
|
|
|
|
// // 'is_preview' => false,
|
|
|
|
|
// // ]);
|
|
|
|
|
// // continue;
|
|
|
|
|
// // }
|
|
|
|
|
// if (!Str::startsWith($value, '$SERVICE_') && !Str::startsWith($value, '${SERVICE_') && Str::startsWith($value, '$')) {
|
|
|
|
|
// $value = Str::of(replaceVariables(Str::of($value)));
|
|
|
|
|
// $nakedName = $nakedValue = null;
|
|
|
|
|
// if ($value->contains(':')) {
|
|
|
|
|
// $nakedName = $value->before(':');
|
|
|
|
|
// $nakedValue = $value->after(':');
|
|
|
|
|
// } else if ($value->contains('-')) {
|
|
|
|
|
// $nakedName = $value->before('-');
|
|
|
|
|
// $nakedValue = $value->after('-');
|
|
|
|
|
// } else if ($value->contains('+')) {
|
|
|
|
|
// $nakedName = $value->before('+');
|
|
|
|
|
// $nakedValue = $value->after('+');
|
|
|
|
|
// } else {
|
|
|
|
|
// $nakedName = $value;
|
|
|
|
|
// }
|
|
|
|
|
// if (isset($nakedName)) {
|
|
|
|
|
// if (isset($nakedValue)) {
|
|
|
|
|
// if ($nakedValue->startsWith('-')) {
|
|
|
|
|
// $nakedValue = Str::of($nakedValue)->after('-');
|
|
|
|
|
// }
|
|
|
|
|
// if ($nakedValue->startsWith('+')) {
|
|
|
|
|
// $nakedValue = Str::of($nakedValue)->after('+');
|
|
|
|
|
// }
|
|
|
|
|
// if (!$envs->has($nakedName->value())) {
|
|
|
|
|
// $envs->put($nakedName->value(), $nakedValue->value());
|
|
|
|
|
// EnvironmentVariable::updateOrCreate([
|
|
|
|
|
// 'key' => $nakedName->value(),
|
|
|
|
|
// 'service_id' => $this->id,
|
|
|
|
|
// ], [
|
|
|
|
|
// 'value' => $nakedValue->value(),
|
|
|
|
|
// 'is_build_time' => false,
|
|
|
|
|
// 'service_id' => $this->id,
|
|
|
|
|
// 'is_preview' => false,
|
|
|
|
|
// ]);
|
|
|
|
|
// }
|
|
|
|
|
// } else {
|
|
|
|
|
// if (!$envs->has($nakedName->value())) {
|
|
|
|
|
// $envs->put($nakedName->value(), null);
|
|
|
|
|
// $envExists = EnvironmentVariable::where('service_id', $this->id)->where('key', $nakedName->value())->exists();
|
|
|
|
|
// if (!$envExists) {
|
|
|
|
|
// EnvironmentVariable::create([
|
|
|
|
|
// 'key' => $nakedName->value(),
|
|
|
|
|
// 'value' => null,
|
|
|
|
|
// 'service_id' => $this->id,
|
|
|
|
|
// 'is_build_time' => false,
|
|
|
|
|
// 'is_preview' => false,
|
|
|
|
|
// ]);
|
|
|
|
|
// }
|
|
|
|
|
// }
|
|
|
|
|
// }
|
|
|
|
|
// }
|
|
|
|
|
// } else {
|
|
|
|
|
// $variableName = Str::of(replaceVariables(Str::of($value)));
|
|
|
|
|
// $generatedValue = null;
|
|
|
|
|
// if ($variableName->startsWith('SERVICE_USER')) {
|
|
|
|
|
// $variableDefined = EnvironmentVariable::whereServiceId($this->id)->where('key', $variableName->value())->first();
|
|
|
|
|
// if (!$variableDefined) {
|
|
|
|
|
// $generatedValue = Str::random(10);
|
|
|
|
|
// } else {
|
|
|
|
|
// $generatedValue = $variableDefined->value;
|
|
|
|
|
// }
|
|
|
|
|
// if (!$envs->has($variableName->value())) {
|
|
|
|
|
// $envs->put($variableName->value(), $generatedValue);
|
|
|
|
|
// EnvironmentVariable::updateOrCreate([
|
|
|
|
|
// 'key' => $variableName->value(),
|
|
|
|
|
// 'service_id' => $this->id,
|
|
|
|
|
// ], [
|
|
|
|
|
// 'value' => $generatedValue,
|
|
|
|
|
// 'is_build_time' => false,
|
|
|
|
|
// 'service_id' => $this->id,
|
|
|
|
|
// 'is_preview' => false,
|
|
|
|
|
// ]);
|
|
|
|
|
// }
|
|
|
|
|
// } else if ($variableName->startsWith('SERVICE_PASSWORD')) {
|
|
|
|
|
// $variableDefined = EnvironmentVariable::whereServiceId($this->id)->where('key', $variableName->value())->first();
|
|
|
|
|
// if (!$variableDefined) {
|
|
|
|
|
// if ($variableName->startsWith('SERVICE_PASSWORD64')) {
|
|
|
|
|
// $generatedValue = Str::password(length: 64, symbols: false);
|
|
|
|
|
// } else {
|
|
|
|
|
// $generatedValue = Str::password(symbols: false);
|
|
|
|
|
// }
|
|
|
|
|
// } else {
|
|
|
|
|
// $generatedValue = $variableDefined->value;
|
|
|
|
|
// }
|
|
|
|
|
// if (!$envs->has($variableName->value())) {
|
|
|
|
|
// $envs->put($variableName->value(), $generatedValue);
|
|
|
|
|
// EnvironmentVariable::updateOrCreate([
|
|
|
|
|
// 'key' => $variableName->value(),
|
|
|
|
|
// 'service_id' => $this->id,
|
|
|
|
|
// ], [
|
|
|
|
|
// 'value' => $generatedValue,
|
|
|
|
|
// 'is_build_time' => false,
|
|
|
|
|
// 'service_id' => $this->id,
|
|
|
|
|
// 'is_preview' => false,
|
|
|
|
|
// ]);
|
|
|
|
|
// }
|
|
|
|
|
// } else if ($variableName->startsWith('SERVICE_BASE64')) {
|
|
|
|
|
// $variableDefined = EnvironmentVariable::whereServiceId($this->id)->where('key', $variableName->value())->first();
|
|
|
|
|
// $length = Str::of($variableName)->after('SERVICE_BASE64_')->beforeLast('_')->value();
|
|
|
|
|
// if (is_numeric($length)) {
|
|
|
|
|
// $length = (int) $length;
|
|
|
|
|
// } else {
|
|
|
|
|
// $length = 1;
|
|
|
|
|
// }
|
|
|
|
|
// if (!$variableDefined) {
|
|
|
|
|
// $generatedValue = base64_encode(Str::password(length: $length, symbols: false));
|
|
|
|
|
// } else {
|
|
|
|
|
// $generatedValue = $variableDefined->value;
|
|
|
|
|
// }
|
|
|
|
|
// if (!$envs->has($variableName->value())) {
|
|
|
|
|
// $envs->put($variableName->value(), $generatedValue);
|
|
|
|
|
// EnvironmentVariable::updateOrCreate([
|
|
|
|
|
// 'key' => $variableName->value(),
|
|
|
|
|
// 'service_id' => $this->id,
|
|
|
|
|
// ], [
|
|
|
|
|
// 'value' => $generatedValue,
|
|
|
|
|
// 'is_build_time' => false,
|
|
|
|
|
// 'service_id' => $this->id,
|
|
|
|
|
// 'is_preview' => false,
|
|
|
|
|
// ]);
|
|
|
|
|
// }
|
|
|
|
|
// } else if ($variableName->startsWith('SERVICE_FQDN')) {
|
|
|
|
|
// if ($fqdns) {
|
|
|
|
|
// $number = Str::of($variableName)->after('SERVICE_FQDN')->afterLast('_')->value();
|
|
|
|
|
// if (is_numeric($number)) {
|
|
|
|
|
// $number = (int) $number - 1;
|
|
|
|
|
// } else {
|
|
|
|
|
// $number = 0;
|
|
|
|
|
// }
|
|
|
|
|
// $fqdn = getFqdnWithoutPort(data_get($fqdns, $number, $fqdns->first()));
|
|
|
|
|
// $environments = collect(data_get($service, 'environment'));
|
|
|
|
|
// $environments = $environments->map(function ($envValue) use ($value, $fqdn) {
|
|
|
|
|
// $envValue = Str::of($envValue)->replace($value, $fqdn);
|
|
|
|
|
// return $envValue->value();
|
|
|
|
|
// });
|
|
|
|
|
// $service['environment'] = $environments->toArray();
|
|
|
|
|
// }
|
|
|
|
|
// } else if ($variableName->startsWith('SERVICE_URL')) {
|
|
|
|
|
// if ($fqdns) {
|
|
|
|
|
// $number = Str::of($variableName)->after('SERVICE_URL')->afterLast('_')->value();
|
|
|
|
|
// if (is_numeric($number)) {
|
|
|
|
|
// $number = (int) $number - 1;
|
|
|
|
|
// } else {
|
|
|
|
|
// $number = 0;
|
|
|
|
|
// }
|
|
|
|
|
// $fqdn = getFqdnWithoutPort(data_get($fqdns, $number, $fqdns->first()));
|
|
|
|
|
// $url = Url::fromString($fqdn)->getHost();
|
|
|
|
|
// $environments = collect(data_get($service, 'environment'));
|
|
|
|
|
// $environments = $environments->map(function ($envValue) use ($value, $url) {
|
|
|
|
|
// $envValue = Str::of($envValue)->replace($value, $url);
|
|
|
|
|
// return $envValue->value();
|
|
|
|
|
// });
|
|
|
|
|
// $service['environment'] = $environments->toArray();
|
|
|
|
|
// }
|
|
|
|
|
// }
|
|
|
|
|
// }
|
|
|
|
|
// }
|
|
|
|
|
|
|
|
|
|
// // Add labels to the service
|
|
|
|
|
// $labels = collect(data_get($service, 'labels', []));
|
|
|
|
|
// $labels = collect([]);
|
|
|
|
|
// $labels = $labels->merge(defaultLabels($this->id, $container_name, type: 'service', subType: $isDatabase ? 'database' : 'application', subId: $savedService->id));
|
|
|
|
|
// if (!$isDatabase) {
|
|
|
|
|
// if ($fqdns) {
|
|
|
|
|
// $labels = $labels->merge(fqdnLabelsForTraefik($fqdns, $container_name, true));
|
|
|
|
|
// }
|
|
|
|
|
// }
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// data_set($service, 'labels', $labels->toArray());
|
|
|
|
|
// data_forget($service, 'is_database');
|
|
|
|
|
// data_set($service, 'restart', RESTART_MODE);
|
|
|
|
|
// data_set($service, 'container_name', $container_name);
|
|
|
|
|
// data_forget($service, 'volumes.*.content');
|
|
|
|
|
// return $service;
|
|
|
|
|
// });
|
|
|
|
|
// $finalServices = [
|
|
|
|
|
// 'version' => $dockerComposeVersion,
|
|
|
|
|
// 'services' => $services->toArray(),
|
|
|
|
|
// 'volumes' => $composeVolumes->toArray(),
|
|
|
|
|
// 'networks' => $composeNetworks->toArray(),
|
|
|
|
|
// ];
|
|
|
|
|
// data_forget($yaml, 'services.*.volumes.*.content');
|
|
|
|
|
// $this->docker_compose_raw = Yaml::dump($yaml, 10, 2);
|
|
|
|
|
// $this->docker_compose = Yaml::dump($finalServices, 10, 2);
|
|
|
|
|
// $this->save();
|
|
|
|
|
// $this->saveComposeConfigs();
|
|
|
|
|
// $shouldBeDefined = collect([
|
|
|
|
|
// 'envs' => $envs,
|
|
|
|
|
// 'volumes' => $volumes,
|
|
|
|
|
// 'ports' => $ports
|
|
|
|
|
// ]);
|
|
|
|
|
// $parsedCompose = collect([
|
|
|
|
|
// 'dockerCompose' => $finalServices,
|
|
|
|
|
// 'shouldBeDefined' => $shouldBeDefined
|
|
|
|
|
// ]);
|
|
|
|
|
// return $parsedCompose;
|
2023-09-20 15:42:41 +02:00
|
|
|
} else {
|
|
|
|
|
return collect([]);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
