319 lines
12 KiB
PHP
319 lines
12 KiB
PHP
<?php
|
|
|
|
use App\Actions\CoolifyTask\PrepareCoolifyTask;
|
|
use App\Data\CoolifyTaskArgs;
|
|
use App\Models\GithubApp;
|
|
use App\Models\Server;
|
|
use Illuminate\Database\Eloquent\Model;
|
|
use Illuminate\Database\QueryException;
|
|
use Illuminate\Support\Collection;
|
|
use Illuminate\Support\Facades\Http;
|
|
use Illuminate\Support\Facades\Log;
|
|
use Illuminate\Support\Facades\Process;
|
|
use Illuminate\Support\Facades\Route;
|
|
use Illuminate\Support\Facades\Storage;
|
|
use Spatie\Activitylog\Contracts\Activity;
|
|
use Illuminate\Support\Str;
|
|
use Visus\Cuid2\Cuid2;
|
|
|
|
if (!function_exists('generalErrorHandler')) {
|
|
function generalErrorHandler(\Throwable $e, $that = null, $isJson = false)
|
|
{
|
|
try {
|
|
if ($e instanceof QueryException) {
|
|
if ($e->errorInfo[0] === '23505') {
|
|
throw new \Exception('Duplicate entry found.', '23505');
|
|
} else if (count($e->errorInfo) === 4) {
|
|
throw new \Exception($e->errorInfo[3]);
|
|
} else {
|
|
throw new \Exception($e->errorInfo[2]);
|
|
}
|
|
} else {
|
|
throw new \Exception($e->getMessage());
|
|
}
|
|
} catch (\Throwable $error) {
|
|
if ($that) {
|
|
$that->emit('error', $error->getMessage());
|
|
} elseif ($isJson) {
|
|
return response()->json([
|
|
'code' => $error->getCode(),
|
|
'error' => $error->getMessage(),
|
|
]);
|
|
} else {
|
|
// dump($error);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
if (!function_exists('remoteProcess')) {
|
|
/**
|
|
* Run a Remote Process, which SSH's asynchronously into a machine to run the command(s).
|
|
* @TODO Change 'root' to 'coolify' when it's able to run Docker commands without sudo
|
|
*
|
|
*/
|
|
function remoteProcess(
|
|
array $command,
|
|
Server $server,
|
|
string $type,
|
|
?string $type_uuid = null,
|
|
?Model $model = null,
|
|
): Activity {
|
|
|
|
$command_string = implode("\n", $command);
|
|
|
|
// @TODO: Check if the user has access to this server
|
|
// checkTeam($server->team_id);
|
|
|
|
$private_key_location = savePrivateKeyForServer($server);
|
|
|
|
return resolve(PrepareCoolifyTask::class, [
|
|
'remoteProcessArgs' => new CoolifyTaskArgs(
|
|
server_ip: $server->ip,
|
|
private_key_location: $private_key_location,
|
|
command: <<<EOT
|
|
{$command_string}
|
|
EOT,
|
|
port: $server->port,
|
|
user: $server->user,
|
|
type: $type,
|
|
type_uuid: $type_uuid,
|
|
model: $model,
|
|
),
|
|
])();
|
|
}
|
|
}
|
|
|
|
// function checkTeam(string $team_id)
|
|
// {
|
|
// $found_team = auth()->user()->teams->pluck('id')->contains($team_id);
|
|
// if (!$found_team) {
|
|
// throw new \RuntimeException('You do not have access to this server.');
|
|
// }
|
|
// }
|
|
|
|
if (!function_exists('savePrivateKeyForServer')) {
|
|
function savePrivateKeyForServer(Server $server)
|
|
{
|
|
$temp_file = "id.root@{$server->ip}";
|
|
Storage::disk('ssh-keys')->put($temp_file, $server->privateKey->private_key);
|
|
return '/var/www/html/storage/app/ssh-keys/' . $temp_file;
|
|
}
|
|
}
|
|
|
|
if (!function_exists('generateSshCommand')) {
|
|
function generateSshCommand(string $private_key_location, string $server_ip, string $user, string $port, string $command, bool $isMux = true)
|
|
{
|
|
Storage::disk('local')->makeDirectory('.ssh');
|
|
|
|
$delimiter = 'EOF-COOLIFY-SSH';
|
|
$ssh_command = "ssh ";
|
|
|
|
if ($isMux && config('coolify.mux_enabled')) {
|
|
$ssh_command .= '-o ControlMaster=auto -o ControlPersist=1m -o ControlPath=/var/www/html/storage/app/.ssh/ssh_mux_%h_%p_%r ';
|
|
}
|
|
$ssh_command .= "-i {$private_key_location} "
|
|
. '-o StrictHostKeyChecking=no -o UserKnownHostsFile=/dev/null '
|
|
. '-o PasswordAuthentication=no '
|
|
. '-o ConnectTimeout=3600 '
|
|
. '-o ServerAliveInterval=60 '
|
|
. '-o RequestTTY=no '
|
|
. '-o LogLevel=ERROR '
|
|
. "-p {$port} "
|
|
. "{$user}@{$server_ip} "
|
|
. " 'bash -se' << \\$delimiter" . PHP_EOL
|
|
. $command . PHP_EOL
|
|
. $delimiter;
|
|
|
|
return $ssh_command;
|
|
}
|
|
}
|
|
if (!function_exists('formatDockerCmdOutputToJson')) {
|
|
function formatDockerCmdOutputToJson($rawOutput): Collection
|
|
{
|
|
$outputLines = explode(PHP_EOL, $rawOutput);
|
|
|
|
return collect($outputLines)
|
|
->reject(fn ($line) => empty($line))
|
|
->map(fn ($outputLine) => json_decode($outputLine, true, flags: JSON_THROW_ON_ERROR));
|
|
}
|
|
}
|
|
if (!function_exists('formatDockerLabelsToJson')) {
|
|
function formatDockerLabelsToJson($rawOutput): Collection
|
|
{
|
|
$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];
|
|
}
|
|
}
|
|
if (!function_exists('instantRemoteProcess')) {
|
|
function instantRemoteProcess(array $command, Server $server, $throwError = true)
|
|
{
|
|
$command_string = implode("\n", $command);
|
|
$private_key_location = savePrivateKeyForServer($server);
|
|
$ssh_command = generateSshCommand($private_key_location, $server->ip, $server->user, $server->port, $command_string);
|
|
$process = Process::run($ssh_command);
|
|
$output = trim($process->output());
|
|
$exitCode = $process->exitCode();
|
|
if ($exitCode !== 0) {
|
|
if (!$throwError) {
|
|
return null;
|
|
}
|
|
throw new \RuntimeException($process->errorOutput());
|
|
}
|
|
return $output;
|
|
}
|
|
}
|
|
|
|
if (!function_exists('getLatestVersionOfCoolify')) {
|
|
function getLatestVersionOfCoolify()
|
|
{
|
|
$response = Http::get('https://coolify-cdn.b-cdn.net/versions.json');
|
|
$versions = $response->json();
|
|
return data_get($versions, 'coolify.v4.version');
|
|
}
|
|
}
|
|
if (!function_exists('generateRandomName')) {
|
|
function generateRandomName()
|
|
{
|
|
$generator = \Nubs\RandomNameGenerator\All::create();
|
|
$cuid = new Cuid2(7);
|
|
return Str::kebab("{$generator->getName()}-{$cuid}");
|
|
}
|
|
}
|
|
|
|
use Lcobucci\JWT\Encoding\ChainedFormatter;
|
|
use Lcobucci\JWT\Encoding\JoseEncoder;
|
|
use Lcobucci\JWT\Signer\Key\InMemory;
|
|
use Lcobucci\JWT\Signer\Rsa\Sha256;
|
|
use Lcobucci\JWT\Token\Builder;
|
|
use Symfony\Component\Yaml\Yaml;
|
|
|
|
if (!function_exists('generate_github_installation_token')) {
|
|
function generate_github_installation_token(GithubApp $source)
|
|
{
|
|
$signingKey = InMemory::plainText($source->privateKey->private_key);
|
|
$algorithm = new Sha256();
|
|
$tokenBuilder = (new Builder(new JoseEncoder(), ChainedFormatter::default()));
|
|
$now = new DateTimeImmutable();
|
|
$now = $now->setTime($now->format('H'), $now->format('i'));
|
|
$issuedToken = $tokenBuilder
|
|
->issuedBy($source->app_id)
|
|
->issuedAt($now)
|
|
->expiresAt($now->modify('+10 minutes'))
|
|
->getToken($algorithm, $signingKey)
|
|
->toString();
|
|
$token = Http::withHeaders([
|
|
'Authorization' => "Bearer $issuedToken",
|
|
'Accept' => 'application/vnd.github.machine-man-preview+json'
|
|
])->post("{$source->api_url}/app/installations/{$source->installation_id}/access_tokens");
|
|
if ($token->failed()) {
|
|
throw new \Exception("Failed to get access token for " . $source->name . " with error: " . $token->json()['message']);
|
|
}
|
|
return $token->json()['token'];
|
|
}
|
|
}
|
|
if (!function_exists('generate_github_jwt_token')) {
|
|
function generate_github_jwt_token(GithubApp $source)
|
|
{
|
|
$signingKey = InMemory::plainText($source->privateKey->private_key);
|
|
$algorithm = new Sha256();
|
|
$tokenBuilder = (new Builder(new JoseEncoder(), ChainedFormatter::default()));
|
|
$now = new DateTimeImmutable();
|
|
$now = $now->setTime($now->format('H'), $now->format('i'));
|
|
$issuedToken = $tokenBuilder
|
|
->issuedBy($source->app_id)
|
|
->issuedAt($now->modify('-1 minute'))
|
|
->expiresAt($now->modify('+10 minutes'))
|
|
->getToken($algorithm, $signingKey)
|
|
->toString();
|
|
return $issuedToken;
|
|
}
|
|
}
|
|
if (!function_exists('getParameters')) {
|
|
function getParameters()
|
|
{
|
|
return Route::current()->parameters();
|
|
}
|
|
}
|
|
if (!function_exists('checkContainerStatus')) {
|
|
function checkContainerStatus(Server $server, string $container_id, bool $throwError = false)
|
|
{
|
|
$container = instantRemoteProcess(["docker inspect --format '{{json .State}}' {$container_id}"], $server, $throwError);
|
|
if (!$container) {
|
|
return 'exited';
|
|
}
|
|
$container = formatDockerCmdOutputToJson($container);
|
|
return $container[0]['Status'];
|
|
}
|
|
}
|
|
if (!function_exists('getProxyConfiguration')) {
|
|
function getProxyConfiguration(Server $server)
|
|
{
|
|
$proxy_config_path = config('coolify.proxy_config_path');
|
|
$networks = collect($server->standaloneDockers)->map(function ($docker) {
|
|
return $docker['network'];
|
|
})->unique();
|
|
if ($networks->count() === 0) {
|
|
$networks = collect(['coolify']);
|
|
}
|
|
$array_of_networks = collect([]);
|
|
$networks->map(function ($network) use ($array_of_networks) {
|
|
$array_of_networks[$network] = [
|
|
"external" => true,
|
|
];
|
|
});
|
|
return Yaml::dump([
|
|
"version" => "3.8",
|
|
"networks" => $array_of_networks->toArray(),
|
|
"services" => [
|
|
"traefik" => [
|
|
"container_name" => "coolify-proxy", # Do not modify this! You will break everything!
|
|
"image" => "traefik:v2.10",
|
|
"restart" => "always",
|
|
"extra_hosts" => [
|
|
"host.docker.internal:host-gateway",
|
|
],
|
|
"networks" => $networks->toArray(), # Do not modify this! You will break everything!
|
|
"ports" => [
|
|
"80:80",
|
|
"443:443",
|
|
"8080:8080",
|
|
],
|
|
"volumes" => [
|
|
"/var/run/docker.sock:/var/run/docker.sock:ro",
|
|
"{$proxy_config_path}/letsencrypt:/letsencrypt", # Do not modify this! You will break everything!
|
|
"{$proxy_config_path}/traefik.auth:/auth/traefik.auth", # Do not modify this! You will break everything!
|
|
],
|
|
"command" => [
|
|
"--api.dashboard=true",
|
|
"--api.insecure=true",
|
|
"--entrypoints.http.address=:80",
|
|
"--entrypoints.https.address=:443",
|
|
"--providers.docker=true",
|
|
"--providers.docker.exposedbydefault=false",
|
|
],
|
|
"labels" => [
|
|
"traefik.enable=true", # Do not modify this! You will break everything!
|
|
"traefik.http.routers.traefik.entrypoints=http",
|
|
'traefik.http.routers.traefik.rule=Host(`${TRAEFIK_DASHBOARD_HOST}`)',
|
|
"traefik.http.routers.traefik.service=api@internal",
|
|
"traefik.http.services.traefik.loadbalancer.server.port=8080",
|
|
"traefik.http.middlewares.redirect-to-https.redirectscheme.scheme=https",
|
|
],
|
|
],
|
|
],
|
|
], 4, 2);
|
|
}
|
|
}
|