reject(fn ($line) => empty($line)) ->map(fn ($outputLine) => json_decode($outputLine, true, flags: JSON_THROW_ON_ERROR)); } function format_docker_labels_to_json(string|array $rawOutput): Collection { if (is_array($rawOutput)) { return collect($rawOutput); } $outputLines = explode(PHP_EOL, $rawOutput); return collect($outputLines) ->reject(fn ($line) => empty($line)) ->map(function ($outputLine) { $outputArray = explode(',', $outputLine); return collect($outputArray) ->map(function ($outputLine) { return explode('=', $outputLine); }) ->mapWithKeys(function ($outputLine) { return [$outputLine[0] => $outputLine[1]]; }); })[0]; } function format_docker_envs_to_json($rawOutput) { try { $outputLines = json_decode($rawOutput, true, flags: JSON_THROW_ON_ERROR); return collect(data_get($outputLines[0], 'Config.Env', []))->mapWithKeys(function ($env) { $env = explode('=', $env); return [$env[0] => $env[1]]; }); } catch (\Throwable $e) { return collect([]); } } function checkMinimumDockerEngineVersion($dockerVersion) { $majorDockerVersion = Str::of($dockerVersion)->before('.')->value(); if ($majorDockerVersion <= 22) { $dockerVersion = null; } return $dockerVersion; } function executeInDocker(string $containerId, string $command) { return "docker exec {$containerId} bash -c '{$command}'"; // return "docker exec {$this->deployment_uuid} bash -c '{$command} |& tee -a /proc/1/fd/1; [ \$PIPESTATUS -eq 0 ] || exit \$PIPESTATUS'"; } function getApplicationContainerStatus(Application $application) { $server = data_get($application, 'destination.server'); $id = $application->id; if (!$server) { return 'exited'; } $containers = getCurrentApplicationContainerStatus($server, $id); if ($containers->count() > 0) { $status = data_get($containers[0], 'State', 'exited'); return $status; } return 'exited'; } function getContainerStatus(Server $server, string $container_id, bool $all_data = false, bool $throwError = false) { $container = instant_remote_process(["docker inspect --format '{{json .}}' {$container_id}"], $server, $throwError); if (!$container) { return 'exited'; } $container = format_docker_command_output_to_json($container); if ($all_data) { return $container[0]; } return data_get($container[0], 'State.Status', 'exited'); } function generateApplicationContainerName(Application $application) { $now = now()->format('Hisu'); if ($application->pull_request_id !== 0 && $application->pull_request_id !== null) { return $application->uuid . '-pr-' . $application->pull_request_id; } else { return $application->uuid . '-' . $now; } } function get_port_from_dockerfile($dockerfile): int { $dockerfile_array = explode("\n", $dockerfile); $found_exposed_port = null; foreach ($dockerfile_array as $line) { $line_str = Str::of($line)->trim(); if ($line_str->startsWith('EXPOSE')) { $found_exposed_port = $line_str->replace('EXPOSE', '')->trim(); break; } } if ($found_exposed_port) { return (int)$found_exposed_port->value(); } return 80; } function defaultLabels($id, $name, $pull_request_id = 0, string $type = 'application') { ray($type); $labels = collect([]); $labels->push('coolify.managed=true'); $labels->push('coolify.version=' . config('version')); $labels->push("coolify." . $type . "Id=" . $id); $labels->push("coolify.type=$type"); $labels->push('coolify.name=' . $name); if ($pull_request_id !== 0) { $labels->push('coolify.pullRequestId=' . $pull_request_id); } return $labels; } function fqdnLabelsForTraefik($domain, $container_name, $is_force_https_enabled) { $labels = collect([]); $labels->push('traefik.enable=true'); $url = Url::fromString($domain); $host = $url->getHost(); $path = $url->getPath(); $schema = $url->getScheme(); $slug = Str::slug($host . $path); $http_label = "{$container_name}-{$slug}-http"; $https_label = "{$container_name}-{$slug}-https"; if ($schema === 'https') { // Set labels for https $labels->push("traefik.http.routers.{$https_label}.rule=Host(`{$host}`) && PathPrefix(`{$path}`)"); $labels->push("traefik.http.routers.{$https_label}.entryPoints=https"); $labels->push("traefik.http.routers.{$https_label}.middlewares=gzip"); if ($path !== '/') { $labels->push("traefik.http.routers.{$https_label}.middlewares={$https_label}-stripprefix"); $labels->push("traefik.http.middlewares.{$https_label}-stripprefix.stripprefix.prefixes={$path}"); } $labels->push("traefik.http.routers.{$https_label}.tls=true"); $labels->push("traefik.http.routers.{$https_label}.tls.certresolver=letsencrypt"); // Set labels for http (redirect to https) $labels->push("traefik.http.routers.{$http_label}.rule=Host(`{$host}`) && PathPrefix(`{$path}`)"); $labels->push("traefik.http.routers.{$http_label}.entryPoints=http"); if ($is_force_https_enabled) { $labels->push("traefik.http.routers.{$http_label}.middlewares=redirect-to-https"); } } else { // Set labels for http $labels->push("traefik.http.routers.{$http_label}.rule=Host(`{$host}`) && PathPrefix(`{$path}`)"); $labels->push("traefik.http.routers.{$http_label}.entryPoints=http"); $labels->push("traefik.http.routers.{$http_label}.middlewares=gzip"); if ($path !== '/') { $labels->push("traefik.http.routers.{$http_label}.middlewares={$http_label}-stripprefix"); $labels->push("traefik.http.middlewares.{$http_label}-stripprefix.stripprefix.prefixes={$path}"); } } return $labels; } function generateLabelsApplication(Application $application, ?ApplicationPreview $preview = null): array { $pull_request_id = data_get($preview, 'pull_request_id', 0); $container_name = generateApplicationContainerName($application); $appId = $application->id; if ($pull_request_id !== 0) { $appId = $appId . '-pr-' . $application->pull_request_id; } $labels = collect([]); $labels = $labels->merge(defaultLabels($appId, $container_name, $pull_request_id)); if ($application->fqdn) { if ($pull_request_id !== 0) { $domains = Str::of(data_get($preview, 'fqdn'))->explode(','); } else { $domains = Str::of(data_get($application, 'fqdn'))->explode(','); } if ($application->destination->server->proxy->type === ProxyTypes::TRAEFIK_V2->value) { foreach ($domains as $domain) { $labels = $labels->merge(fqdnLabelsForTraefik($domain, $container_name, $application->settings->is_force_https_enabled)); // $url = Url::fromString($domain); // $host = $url->getHost(); // $path = $url->getPath(); // $schema = $url->getScheme(); // $slug = Str::slug($host . $path); // $http_label = "{$container_name}-{$slug}-http"; // $https_label = "{$container_name}-{$slug}-https"; // if ($schema === 'https') { // // Set labels for https // $labels[] = "traefik.http.routers.{$https_label}.rule=Host(`{$host}`) && PathPrefix(`{$path}`)"; // $labels[] = "traefik.http.routers.{$https_label}.entryPoints=https"; // $labels[] = "traefik.http.routers.{$https_label}.middlewares=gzip"; // if ($path !== '/') { // $labels[] = "traefik.http.routers.{$https_label}.middlewares={$https_label}-stripprefix"; // $labels[] = "traefik.http.middlewares.{$https_label}-stripprefix.stripprefix.prefixes={$path}"; // } // $labels[] = "traefik.http.routers.{$https_label}.tls=true"; // $labels[] = "traefik.http.routers.{$https_label}.tls.certresolver=letsencrypt"; // // Set labels for http (redirect to https) // $labels[] = "traefik.http.routers.{$http_label}.rule=Host(`{$host}`) && PathPrefix(`{$path}`)"; // $labels[] = "traefik.http.routers.{$http_label}.entryPoints=http"; // if ($application->settings->is_force_https_enabled) { // $labels[] = "traefik.http.routers.{$http_label}.middlewares=redirect-to-https"; // } // } else { // // Set labels for http // $labels[] = "traefik.http.routers.{$http_label}.rule=Host(`{$host}`) && PathPrefix(`{$path}`)"; // $labels[] = "traefik.http.routers.{$http_label}.entryPoints=http"; // $labels[] = "traefik.http.routers.{$http_label}.middlewares=gzip"; // if ($path !== '/') { // $labels[] = "traefik.http.routers.{$http_label}.middlewares={$http_label}-stripprefix"; // $labels[] = "traefik.http.middlewares.{$http_label}-stripprefix.stripprefix.prefixes={$path}"; // } // } } } } return $labels->all(); }