+
+
+
+
+
+
## Github Sponsors ($40+)
-
-
diff --git a/app/Actions/Application/StopApplication.php b/app/Actions/Application/StopApplication.php
index 601b8e991..446659e5b 100644
--- a/app/Actions/Application/StopApplication.php
+++ b/app/Actions/Application/StopApplication.php
@@ -3,17 +3,17 @@
namespace App\Actions\Application;
use App\Models\Application;
-use App\Models\StandaloneDocker;
-use App\Notifications\Application\StatusChanged;
use Lorisleiva\Actions\Concerns\AsAction;
class StopApplication
{
use AsAction;
+
public function handle(Application $application)
{
if ($application->destination->server->isSwarm()) {
instant_remote_process(["docker stack rm {$application->uuid}"], $application->destination->server);
+
return;
}
@@ -23,7 +23,7 @@ public function handle(Application $application)
$servers->push($server);
});
foreach ($servers as $server) {
- if (!$server->isFunctional()) {
+ if (! $server->isFunctional()) {
return 'Server is not functional';
}
$containers = getCurrentApplicationContainerStatus($server, $application->id, 0);
diff --git a/app/Actions/Application/StopApplicationOneServer.php b/app/Actions/Application/StopApplicationOneServer.php
index 1945a94bd..da8c700fe 100644
--- a/app/Actions/Application/StopApplicationOneServer.php
+++ b/app/Actions/Application/StopApplicationOneServer.php
@@ -9,12 +9,13 @@
class StopApplicationOneServer
{
use AsAction;
+
public function handle(Application $application, Server $server)
{
if ($application->destination->server->isSwarm()) {
return;
}
- if (!$server->isFunctional()) {
+ if (! $server->isFunctional()) {
return 'Server is not functional';
}
try {
@@ -32,6 +33,7 @@ public function handle(Application $application, Server $server)
}
} catch (\Exception $e) {
ray($e->getMessage());
+
return $e->getMessage();
}
}
diff --git a/app/Actions/CoolifyTask/PrepareCoolifyTask.php b/app/Actions/CoolifyTask/PrepareCoolifyTask.php
index e6a549756..d4cdf64e2 100644
--- a/app/Actions/CoolifyTask/PrepareCoolifyTask.php
+++ b/app/Actions/CoolifyTask/PrepareCoolifyTask.php
@@ -14,6 +14,7 @@
class PrepareCoolifyTask
{
protected Activity $activity;
+
protected CoolifyTaskArgs $remoteProcessArgs;
public function __construct(CoolifyTaskArgs $remoteProcessArgs)
@@ -28,12 +29,12 @@ public function __construct(CoolifyTaskArgs $remoteProcessArgs)
->withProperties($properties)
->performedOn($remoteProcessArgs->model)
->event($remoteProcessArgs->type)
- ->log("[]");
+ ->log('[]');
} else {
$this->activity = activity()
->withProperties($remoteProcessArgs->toArray())
->event($remoteProcessArgs->type)
- ->log("[]");
+ ->log('[]');
}
}
@@ -42,6 +43,7 @@ public function __invoke(): Activity
$job = new CoolifyTask($this->activity, ignore_errors: $this->remoteProcessArgs->ignore_errors, call_event_on_finish: $this->remoteProcessArgs->call_event_on_finish, call_event_data: $this->remoteProcessArgs->call_event_data);
dispatch($job);
$this->activity->refresh();
+
return $this->activity;
}
}
diff --git a/app/Actions/CoolifyTask/RunRemoteProcess.php b/app/Actions/CoolifyTask/RunRemoteProcess.php
index 16924476b..be986a76f 100644
--- a/app/Actions/CoolifyTask/RunRemoteProcess.php
+++ b/app/Actions/CoolifyTask/RunRemoteProcess.php
@@ -69,7 +69,7 @@ public static function decodeOutput(?Activity $activity = null): string
return collect($decoded)
->sortBy(fn ($i) => $i['order'])
->map(fn ($i) => $i['output'])
- ->implode("");
+ ->implode('');
}
public function __invoke(): ProcessResult
@@ -91,7 +91,7 @@ public function __invoke(): ProcessResult
if ($processResult->exitCode() == 0) {
$status = ProcessStatus::FINISHED;
}
- if ($processResult->exitCode() != 0 && !$this->ignore_errors) {
+ if ($processResult->exitCode() != 0 && ! $this->ignore_errors) {
$status = ProcessStatus::ERROR;
}
// if (($processResult->exitCode() == 0 && $this->is_finished) || $this->activity->properties->get('status') === ProcessStatus::FINISHED->value) {
@@ -109,14 +109,14 @@ public function __invoke(): ProcessResult
'status' => $status->value,
]);
$this->activity->save();
- if ($processResult->exitCode() != 0 && !$this->ignore_errors) {
+ if ($processResult->exitCode() != 0 && ! $this->ignore_errors) {
throw new \RuntimeException($processResult->errorOutput(), $processResult->exitCode());
}
if ($this->call_event_on_finish) {
try {
if ($this->call_event_data) {
event(resolve("App\\Events\\$this->call_event_on_finish", [
- "data" => $this->call_event_data,
+ 'data' => $this->call_event_data,
]));
} else {
event(resolve("App\\Events\\$this->call_event_on_finish", [
@@ -127,6 +127,7 @@ public function __invoke(): ProcessResult
ray($e);
}
}
+
return $processResult;
}
@@ -182,6 +183,7 @@ protected function getLatestCounter(): int
if ($description === null || count($description) === 0) {
return 1;
}
+
return end($description)['order'] + 1;
}
diff --git a/app/Actions/Database/StartClickhouse.php b/app/Actions/Database/StartClickhouse.php
index 414d6b407..d9518cd80 100644
--- a/app/Actions/Database/StartClickhouse.php
+++ b/app/Actions/Database/StartClickhouse.php
@@ -4,24 +4,25 @@
use App\Models\StandaloneClickhouse;
use Illuminate\Support\Str;
-use Symfony\Component\Yaml\Yaml;
use Lorisleiva\Actions\Concerns\AsAction;
+use Symfony\Component\Yaml\Yaml;
class StartClickhouse
{
use AsAction;
public StandaloneClickhouse $database;
+
public array $commands = [];
+
public string $configuration_dir;
public function handle(StandaloneClickhouse $database)
{
$this->database = $database;
-
$container_name = $this->database->uuid;
- $this->configuration_dir = database_configuration_dir() . '/' . $container_name;
+ $this->configuration_dir = database_configuration_dir().'/'.$container_name;
$this->commands = [
"echo 'Starting {$database->name}.'",
@@ -57,7 +58,7 @@ public function handle(StandaloneClickhouse $database)
'interval' => '5s',
'timeout' => '5s',
'retries' => 10,
- 'start_period' => '5s'
+ 'start_period' => '5s',
],
'mem_limit' => $this->database->limits_memory,
'memswap_limit' => $this->database->limits_memory_swap,
@@ -65,27 +66,27 @@ public function handle(StandaloneClickhouse $database)
'mem_reservation' => $this->database->limits_memory_reservation,
'cpus' => (float) $this->database->limits_cpus,
'cpu_shares' => $this->database->limits_cpu_shares,
- ]
+ ],
],
'networks' => [
$this->database->destination->network => [
'external' => true,
'name' => $this->database->destination->network,
'attachable' => true,
- ]
- ]
+ ],
+ ],
];
- if (!is_null($this->database->limits_cpuset)) {
+ if (! is_null($this->database->limits_cpuset)) {
data_set($docker_compose, "services.{$container_name}.cpuset", $this->database->limits_cpuset);
}
if ($this->database->destination->server->isLogDrainEnabled() && $this->database->isLogDrainEnabled()) {
$docker_compose['services'][$container_name]['logging'] = [
'driver' => 'fluentd',
'options' => [
- 'fluentd-address' => "tcp://127.0.0.1:24224",
- 'fluentd-async' => "true",
- 'fluentd-sub-second-precision' => "true",
- ]
+ 'fluentd-address' => 'tcp://127.0.0.1:24224',
+ 'fluentd-async' => 'true',
+ 'fluentd-sub-second-precision' => 'true',
+ ],
];
}
if (count($this->database->ports_mappings_array) > 0) {
@@ -111,6 +112,7 @@ public function handle(StandaloneClickhouse $database)
$this->commands[] = "docker compose -f $this->configuration_dir/docker-compose.yml pull";
$this->commands[] = "docker compose -f $this->configuration_dir/docker-compose.yml up -d";
$this->commands[] = "echo 'Database started.'";
+
return remote_process($this->commands, $database->destination->server, callEventOnFinish: 'DatabaseStatusChanged');
}
@@ -119,12 +121,13 @@ private function generate_local_persistent_volumes()
$local_persistent_volumes = [];
foreach ($this->database->persistentStorages as $persistentStorage) {
if ($persistentStorage->host_path !== '' && $persistentStorage->host_path !== null) {
- $local_persistent_volumes[] = $persistentStorage->host_path . ':' . $persistentStorage->mount_path;
+ $local_persistent_volumes[] = $persistentStorage->host_path.':'.$persistentStorage->mount_path;
} else {
$volume_name = $persistentStorage->name;
- $local_persistent_volumes[] = $volume_name . ':' . $persistentStorage->mount_path;
+ $local_persistent_volumes[] = $volume_name.':'.$persistentStorage->mount_path;
}
}
+
return $local_persistent_volumes;
}
@@ -141,6 +144,7 @@ private function generate_local_persistent_volumes_only_volume_names()
'external' => false,
];
}
+
return $local_persistent_volumes_names;
}
diff --git a/app/Actions/Database/StartDatabaseProxy.php b/app/Actions/Database/StartDatabaseProxy.php
index 547884b7a..a514c51b4 100644
--- a/app/Actions/Database/StartDatabaseProxy.php
+++ b/app/Actions/Database/StartDatabaseProxy.php
@@ -69,19 +69,19 @@ public function handle(StandaloneRedis|StandalonePostgresql|StandaloneMongodb|St
}
if ($type === 'App\Models\StandaloneRedis') {
$internalPort = 6379;
- } else if ($type === 'App\Models\StandalonePostgresql') {
+ } elseif ($type === 'App\Models\StandalonePostgresql') {
$internalPort = 5432;
- } else if ($type === 'App\Models\StandaloneMongodb') {
+ } elseif ($type === 'App\Models\StandaloneMongodb') {
$internalPort = 27017;
- } else if ($type === 'App\Models\StandaloneMysql') {
+ } elseif ($type === 'App\Models\StandaloneMysql') {
$internalPort = 3306;
- } else if ($type === 'App\Models\StandaloneMariadb') {
+ } elseif ($type === 'App\Models\StandaloneMariadb') {
$internalPort = 3306;
- } else if ($type === 'App\Models\StandaloneKeydb') {
+ } elseif ($type === 'App\Models\StandaloneKeydb') {
$internalPort = 6379;
- } else if ($type === 'App\Models\StandaloneDragonfly') {
+ } elseif ($type === 'App\Models\StandaloneDragonfly') {
$internalPort = 6379;
- } else if ($type === 'App\Models\StandaloneClickhouse') {
+ } elseif ($type === 'App\Models\StandaloneClickhouse') {
$internalPort = 9000;
}
$configuration_dir = database_proxy_dir($database->uuid);
@@ -101,7 +101,7 @@ public function handle(StandaloneRedis|StandalonePostgresql|StandaloneMongodb|St
}
}
EOF;
- $dockerfile = <<< EOF
+ $dockerfile = <<< 'EOF'
FROM nginx:stable-alpine
COPY nginx.conf /etc/nginx/nginx.conf
@@ -113,7 +113,7 @@ public function handle(StandaloneRedis|StandalonePostgresql|StandaloneMongodb|St
'context' => $configuration_dir,
'dockerfile' => 'Dockerfile',
],
- 'image' => "nginx:stable-alpine",
+ 'image' => 'nginx:stable-alpine',
'container_name' => $proxyContainerName,
'restart' => RESTART_MODE,
'ports' => [
@@ -130,17 +130,17 @@ public function handle(StandaloneRedis|StandalonePostgresql|StandaloneMongodb|St
'interval' => '5s',
'timeout' => '5s',
'retries' => 3,
- 'start_period' => '1s'
+ 'start_period' => '1s',
],
- ]
+ ],
],
'networks' => [
$network => [
'external' => true,
'name' => $network,
'attachable' => true,
- ]
- ]
+ ],
+ ],
];
$dockercompose_base64 = base64_encode(Yaml::dump($docker_compose, 4, 2));
$nginxconf_base64 = base64_encode($nginxconf);
diff --git a/app/Actions/Database/StartDragonfly.php b/app/Actions/Database/StartDragonfly.php
index 04348c40a..19b1c5814 100644
--- a/app/Actions/Database/StartDragonfly.php
+++ b/app/Actions/Database/StartDragonfly.php
@@ -3,19 +3,19 @@
namespace App\Actions\Database;
use App\Models\StandaloneDragonfly;
-use Illuminate\Support\Facades\Storage;
use Illuminate\Support\Str;
-use Symfony\Component\Yaml\Yaml;
use Lorisleiva\Actions\Concerns\AsAction;
+use Symfony\Component\Yaml\Yaml;
class StartDragonfly
{
use AsAction;
public StandaloneDragonfly $database;
- public array $commands = [];
- public string $configuration_dir;
+ public array $commands = [];
+
+ public string $configuration_dir;
public function handle(StandaloneDragonfly $database)
{
@@ -24,7 +24,7 @@ public function handle(StandaloneDragonfly $database)
$startCommand = "dragonfly --requirepass {$this->database->dragonfly_password}";
$container_name = $this->database->uuid;
- $this->configuration_dir = database_configuration_dir() . '/' . $container_name;
+ $this->configuration_dir = database_configuration_dir().'/'.$container_name;
$this->commands = [
"echo 'Starting {$database->name}.'",
@@ -48,7 +48,7 @@ public function handle(StandaloneDragonfly $database)
$this->database->destination->network,
],
'ulimits' => [
- 'memlock'=> '-1'
+ 'memlock' => '-1',
],
'labels' => [
'coolify.managed' => 'true',
@@ -58,7 +58,7 @@ public function handle(StandaloneDragonfly $database)
'interval' => '5s',
'timeout' => '5s',
'retries' => 10,
- 'start_period' => '5s'
+ 'start_period' => '5s',
],
'mem_limit' => $this->database->limits_memory,
'memswap_limit' => $this->database->limits_memory_swap,
@@ -66,27 +66,27 @@ public function handle(StandaloneDragonfly $database)
'mem_reservation' => $this->database->limits_memory_reservation,
'cpus' => (float) $this->database->limits_cpus,
'cpu_shares' => $this->database->limits_cpu_shares,
- ]
+ ],
],
'networks' => [
$this->database->destination->network => [
'external' => true,
'name' => $this->database->destination->network,
'attachable' => true,
- ]
- ]
+ ],
+ ],
];
- if (!is_null($this->database->limits_cpuset)) {
+ if (! is_null($this->database->limits_cpuset)) {
data_set($docker_compose, "services.{$container_name}.cpuset", $this->database->limits_cpuset);
}
if ($this->database->destination->server->isLogDrainEnabled() && $this->database->isLogDrainEnabled()) {
$docker_compose['services'][$container_name]['logging'] = [
'driver' => 'fluentd',
'options' => [
- 'fluentd-address' => "tcp://127.0.0.1:24224",
- 'fluentd-async' => "true",
- 'fluentd-sub-second-precision' => "true",
- ]
+ 'fluentd-address' => 'tcp://127.0.0.1:24224',
+ 'fluentd-async' => 'true',
+ 'fluentd-sub-second-precision' => 'true',
+ ],
];
}
if (count($this->database->ports_mappings_array) > 0) {
@@ -112,6 +112,7 @@ public function handle(StandaloneDragonfly $database)
$this->commands[] = "docker compose -f $this->configuration_dir/docker-compose.yml pull";
$this->commands[] = "docker compose -f $this->configuration_dir/docker-compose.yml up -d";
$this->commands[] = "echo 'Database started.'";
+
return remote_process($this->commands, $database->destination->server, callEventOnFinish: 'DatabaseStatusChanged');
}
@@ -120,12 +121,13 @@ private function generate_local_persistent_volumes()
$local_persistent_volumes = [];
foreach ($this->database->persistentStorages as $persistentStorage) {
if ($persistentStorage->host_path !== '' && $persistentStorage->host_path !== null) {
- $local_persistent_volumes[] = $persistentStorage->host_path . ':' . $persistentStorage->mount_path;
+ $local_persistent_volumes[] = $persistentStorage->host_path.':'.$persistentStorage->mount_path;
} else {
$volume_name = $persistentStorage->name;
- $local_persistent_volumes[] = $volume_name . ':' . $persistentStorage->mount_path;
+ $local_persistent_volumes[] = $volume_name.':'.$persistentStorage->mount_path;
}
}
+
return $local_persistent_volumes;
}
@@ -142,6 +144,7 @@ private function generate_local_persistent_volumes_only_volume_names()
'external' => false,
];
}
+
return $local_persistent_volumes_names;
}
diff --git a/app/Actions/Database/StartKeydb.php b/app/Actions/Database/StartKeydb.php
index 672308d89..a632f6e8c 100644
--- a/app/Actions/Database/StartKeydb.php
+++ b/app/Actions/Database/StartKeydb.php
@@ -5,17 +5,18 @@
use App\Models\StandaloneKeydb;
use Illuminate\Support\Facades\Storage;
use Illuminate\Support\Str;
-use Symfony\Component\Yaml\Yaml;
use Lorisleiva\Actions\Concerns\AsAction;
+use Symfony\Component\Yaml\Yaml;
class StartKeydb
{
use AsAction;
public StandaloneKeydb $database;
- public array $commands = [];
- public string $configuration_dir;
+ public array $commands = [];
+
+ public string $configuration_dir;
public function handle(StandaloneKeydb $database)
{
@@ -24,7 +25,7 @@ public function handle(StandaloneKeydb $database)
$startCommand = "keydb-server --requirepass {$this->database->keydb_password} --appendonly yes";
$container_name = $this->database->uuid;
- $this->configuration_dir = database_configuration_dir() . '/' . $container_name;
+ $this->configuration_dir = database_configuration_dir().'/'.$container_name;
$this->commands = [
"echo 'Starting {$database->name}.'",
@@ -56,7 +57,7 @@ public function handle(StandaloneKeydb $database)
'interval' => '5s',
'timeout' => '5s',
'retries' => 10,
- 'start_period' => '5s'
+ 'start_period' => '5s',
],
'mem_limit' => $this->database->limits_memory,
'memswap_limit' => $this->database->limits_memory_swap,
@@ -64,27 +65,27 @@ public function handle(StandaloneKeydb $database)
'mem_reservation' => $this->database->limits_memory_reservation,
'cpus' => (float) $this->database->limits_cpus,
'cpu_shares' => $this->database->limits_cpu_shares,
- ]
+ ],
],
'networks' => [
$this->database->destination->network => [
'external' => true,
'name' => $this->database->destination->network,
'attachable' => true,
- ]
- ]
+ ],
+ ],
];
- if (!is_null($this->database->limits_cpuset)) {
+ if (! is_null($this->database->limits_cpuset)) {
data_set($docker_compose, "services.{$container_name}.cpuset", $this->database->limits_cpuset);
}
if ($this->database->destination->server->isLogDrainEnabled() && $this->database->isLogDrainEnabled()) {
$docker_compose['services'][$container_name]['logging'] = [
'driver' => 'fluentd',
'options' => [
- 'fluentd-address' => "tcp://127.0.0.1:24224",
- 'fluentd-async' => "true",
- 'fluentd-sub-second-precision' => "true",
- ]
+ 'fluentd-address' => 'tcp://127.0.0.1:24224',
+ 'fluentd-async' => 'true',
+ 'fluentd-sub-second-precision' => 'true',
+ ],
];
}
if (count($this->database->ports_mappings_array) > 0) {
@@ -101,10 +102,10 @@ public function handle(StandaloneKeydb $database)
if (count($volume_names) > 0) {
$docker_compose['volumes'] = $volume_names;
}
- if (!is_null($this->database->keydb_conf) || !empty($this->database->keydb_conf)) {
+ if (! is_null($this->database->keydb_conf) || ! empty($this->database->keydb_conf)) {
$docker_compose['services'][$container_name]['volumes'][] = [
'type' => 'bind',
- 'source' => $this->configuration_dir . '/keydb.conf',
+ 'source' => $this->configuration_dir.'/keydb.conf',
'target' => '/etc/keydb/keydb.conf',
'read_only' => true,
];
@@ -119,6 +120,7 @@ public function handle(StandaloneKeydb $database)
$this->commands[] = "docker compose -f $this->configuration_dir/docker-compose.yml pull";
$this->commands[] = "docker compose -f $this->configuration_dir/docker-compose.yml up -d";
$this->commands[] = "echo 'Database started.'";
+
return remote_process($this->commands, $database->destination->server, callEventOnFinish: 'DatabaseStatusChanged');
}
@@ -127,12 +129,13 @@ private function generate_local_persistent_volumes()
$local_persistent_volumes = [];
foreach ($this->database->persistentStorages as $persistentStorage) {
if ($persistentStorage->host_path !== '' && $persistentStorage->host_path !== null) {
- $local_persistent_volumes[] = $persistentStorage->host_path . ':' . $persistentStorage->mount_path;
+ $local_persistent_volumes[] = $persistentStorage->host_path.':'.$persistentStorage->mount_path;
} else {
$volume_name = $persistentStorage->name;
- $local_persistent_volumes[] = $volume_name . ':' . $persistentStorage->mount_path;
+ $local_persistent_volumes[] = $volume_name.':'.$persistentStorage->mount_path;
}
}
+
return $local_persistent_volumes;
}
@@ -149,6 +152,7 @@ private function generate_local_persistent_volumes_only_volume_names()
'external' => false,
];
}
+
return $local_persistent_volumes_names;
}
@@ -165,6 +169,7 @@ private function generate_environment_variables()
return $environment_variables->all();
}
+
private function add_custom_keydb()
{
if (is_null($this->database->keydb_conf) || empty($this->database->keydb_conf)) {
diff --git a/app/Actions/Database/StartMariadb.php b/app/Actions/Database/StartMariadb.php
index 652d8fa29..31d3f0640 100644
--- a/app/Actions/Database/StartMariadb.php
+++ b/app/Actions/Database/StartMariadb.php
@@ -4,15 +4,17 @@
use App\Models\StandaloneMariadb;
use Illuminate\Support\Str;
-use Symfony\Component\Yaml\Yaml;
use Lorisleiva\Actions\Concerns\AsAction;
+use Symfony\Component\Yaml\Yaml;
class StartMariadb
{
use AsAction;
public StandaloneMariadb $database;
+
public array $commands = [];
+
public string $configuration_dir;
public function handle(StandaloneMariadb $database)
@@ -20,7 +22,7 @@ public function handle(StandaloneMariadb $database)
$this->database = $database;
$container_name = $this->database->uuid;
- $this->configuration_dir = database_configuration_dir() . '/' . $container_name;
+ $this->configuration_dir = database_configuration_dir().'/'.$container_name;
$this->commands = [
"echo 'Starting {$database->name}.'",
@@ -46,11 +48,11 @@ public function handle(StandaloneMariadb $database)
'coolify.managed' => 'true',
],
'healthcheck' => [
- 'test' => ["CMD", "healthcheck.sh", "--connect", "--innodb_initialized"],
+ 'test' => ['CMD', 'healthcheck.sh', '--connect', '--innodb_initialized'],
'interval' => '5s',
'timeout' => '5s',
'retries' => 10,
- 'start_period' => '5s'
+ 'start_period' => '5s',
],
'mem_limit' => $this->database->limits_memory,
'memswap_limit' => $this->database->limits_memory_swap,
@@ -58,27 +60,27 @@ public function handle(StandaloneMariadb $database)
'mem_reservation' => $this->database->limits_memory_reservation,
'cpus' => (float) $this->database->limits_cpus,
'cpu_shares' => $this->database->limits_cpu_shares,
- ]
+ ],
],
'networks' => [
$this->database->destination->network => [
'external' => true,
'name' => $this->database->destination->network,
'attachable' => true,
- ]
- ]
+ ],
+ ],
];
- if (!is_null($this->database->limits_cpuset)) {
+ if (! is_null($this->database->limits_cpuset)) {
data_set($docker_compose, "services.{$container_name}.cpuset", $this->database->limits_cpuset);
}
if ($this->database->destination->server->isLogDrainEnabled() && $this->database->isLogDrainEnabled()) {
$docker_compose['services'][$container_name]['logging'] = [
'driver' => 'fluentd',
'options' => [
- 'fluentd-address' => "tcp://127.0.0.1:24224",
- 'fluentd-async' => "true",
- 'fluentd-sub-second-precision' => "true",
- ]
+ 'fluentd-address' => 'tcp://127.0.0.1:24224',
+ 'fluentd-async' => 'true',
+ 'fluentd-sub-second-precision' => 'true',
+ ],
];
}
if (count($this->database->ports_mappings_array) > 0) {
@@ -95,10 +97,10 @@ public function handle(StandaloneMariadb $database)
if (count($volume_names) > 0) {
$docker_compose['volumes'] = $volume_names;
}
- if (!is_null($this->database->mariadb_conf) || !empty($this->database->mariadb_conf)) {
+ if (! is_null($this->database->mariadb_conf) || ! empty($this->database->mariadb_conf)) {
$docker_compose['services'][$container_name]['volumes'][] = [
'type' => 'bind',
- 'source' => $this->configuration_dir . '/custom-config.cnf',
+ 'source' => $this->configuration_dir.'/custom-config.cnf',
'target' => '/etc/mysql/conf.d/custom-config.cnf',
'read_only' => true,
];
@@ -112,6 +114,7 @@ public function handle(StandaloneMariadb $database)
$this->commands[] = "docker compose -f $this->configuration_dir/docker-compose.yml pull";
$this->commands[] = "docker compose -f $this->configuration_dir/docker-compose.yml up -d";
$this->commands[] = "echo 'Database started.'";
+
return remote_process($this->commands, $database->destination->server, callEventOnFinish: 'DatabaseStatusChanged');
}
@@ -120,12 +123,13 @@ private function generate_local_persistent_volumes()
$local_persistent_volumes = [];
foreach ($this->database->persistentStorages as $persistentStorage) {
if ($persistentStorage->host_path !== '' && $persistentStorage->host_path !== null) {
- $local_persistent_volumes[] = $persistentStorage->host_path . ':' . $persistentStorage->mount_path;
+ $local_persistent_volumes[] = $persistentStorage->host_path.':'.$persistentStorage->mount_path;
} else {
$volume_name = $persistentStorage->name;
- $local_persistent_volumes[] = $volume_name . ':' . $persistentStorage->mount_path;
+ $local_persistent_volumes[] = $volume_name.':'.$persistentStorage->mount_path;
}
}
+
return $local_persistent_volumes;
}
@@ -142,6 +146,7 @@ private function generate_local_persistent_volumes_only_volume_names()
'external' => false,
];
}
+
return $local_persistent_volumes_names;
}
@@ -166,8 +171,10 @@ private function generate_environment_variables()
if ($environment_variables->filter(fn ($env) => Str::of($env)->contains('MARIADB_PASSWORD'))->isEmpty()) {
$environment_variables->push("MARIADB_PASSWORD={$this->database->mariadb_password}");
}
+
return $environment_variables->all();
}
+
private function add_custom_mysql()
{
if (is_null($this->database->mariadb_conf) || empty($this->database->mariadb_conf)) {
diff --git a/app/Actions/Database/StartMongodb.php b/app/Actions/Database/StartMongodb.php
index 38e2621bd..8db34b20f 100644
--- a/app/Actions/Database/StartMongodb.php
+++ b/app/Actions/Database/StartMongodb.php
@@ -4,25 +4,27 @@
use App\Models\StandaloneMongodb;
use Illuminate\Support\Str;
-use Symfony\Component\Yaml\Yaml;
use Lorisleiva\Actions\Concerns\AsAction;
+use Symfony\Component\Yaml\Yaml;
class StartMongodb
{
use AsAction;
public StandaloneMongodb $database;
+
public array $commands = [];
+
public string $configuration_dir;
public function handle(StandaloneMongodb $database)
{
$this->database = $database;
- $startCommand = "mongod";
+ $startCommand = 'mongod';
$container_name = $this->database->uuid;
- $this->configuration_dir = database_configuration_dir() . '/' . $container_name;
+ $this->configuration_dir = database_configuration_dir().'/'.$container_name;
$this->commands = [
"echo 'Starting {$database->name}.'",
@@ -51,14 +53,14 @@ public function handle(StandaloneMongodb $database)
],
'healthcheck' => [
'test' => [
- "CMD",
- "echo",
- "ok"
+ 'CMD',
+ 'echo',
+ 'ok',
],
'interval' => '5s',
'timeout' => '5s',
'retries' => 10,
- 'start_period' => '5s'
+ 'start_period' => '5s',
],
'mem_limit' => $this->database->limits_memory,
'memswap_limit' => $this->database->limits_memory_swap,
@@ -66,27 +68,27 @@ public function handle(StandaloneMongodb $database)
'mem_reservation' => $this->database->limits_memory_reservation,
'cpus' => (float) $this->database->limits_cpus,
'cpu_shares' => $this->database->limits_cpu_shares,
- ]
+ ],
],
'networks' => [
$this->database->destination->network => [
'external' => true,
'name' => $this->database->destination->network,
'attachable' => true,
- ]
- ]
+ ],
+ ],
];
- if (!is_null($this->database->limits_cpuset)) {
+ if (! is_null($this->database->limits_cpuset)) {
data_set($docker_compose, "services.{$container_name}.cpuset", $this->database->limits_cpuset);
}
if ($this->database->destination->server->isLogDrainEnabled() && $this->database->isLogDrainEnabled()) {
$docker_compose['services'][$container_name]['logging'] = [
'driver' => 'fluentd',
'options' => [
- 'fluentd-address' => "tcp://127.0.0.1:24224",
- 'fluentd-async' => "true",
- 'fluentd-sub-second-precision' => "true",
- ]
+ 'fluentd-address' => 'tcp://127.0.0.1:24224',
+ 'fluentd-async' => 'true',
+ 'fluentd-sub-second-precision' => 'true',
+ ],
];
}
if (count($this->database->ports_mappings_array) > 0) {
@@ -103,19 +105,19 @@ public function handle(StandaloneMongodb $database)
if (count($volume_names) > 0) {
$docker_compose['volumes'] = $volume_names;
}
- if (!is_null($this->database->mongo_conf) || !empty($this->database->mongo_conf)) {
+ if (! is_null($this->database->mongo_conf) || ! empty($this->database->mongo_conf)) {
$docker_compose['services'][$container_name]['volumes'][] = [
'type' => 'bind',
- 'source' => $this->configuration_dir . '/mongod.conf',
+ 'source' => $this->configuration_dir.'/mongod.conf',
'target' => '/etc/mongo/mongod.conf',
'read_only' => true,
];
- $docker_compose['services'][$container_name]['command'] = $startCommand . ' --config /etc/mongo/mongod.conf';
+ $docker_compose['services'][$container_name]['command'] = $startCommand.' --config /etc/mongo/mongod.conf';
}
$this->add_default_database();
$docker_compose['services'][$container_name]['volumes'][] = [
'type' => 'bind',
- 'source' => $this->configuration_dir . '/docker-entrypoint-initdb.d',
+ 'source' => $this->configuration_dir.'/docker-entrypoint-initdb.d',
'target' => '/docker-entrypoint-initdb.d',
'read_only' => true,
];
@@ -129,6 +131,7 @@ public function handle(StandaloneMongodb $database)
$this->commands[] = "docker compose -f $this->configuration_dir/docker-compose.yml pull";
$this->commands[] = "docker compose -f $this->configuration_dir/docker-compose.yml up -d";
$this->commands[] = "echo 'Database started.'";
+
return remote_process($this->commands, $database->destination->server, callEventOnFinish: 'DatabaseStatusChanged');
}
@@ -137,12 +140,13 @@ private function generate_local_persistent_volumes()
$local_persistent_volumes = [];
foreach ($this->database->persistentStorages as $persistentStorage) {
if ($persistentStorage->host_path !== '' && $persistentStorage->host_path !== null) {
- $local_persistent_volumes[] = $persistentStorage->host_path . ':' . $persistentStorage->mount_path;
+ $local_persistent_volumes[] = $persistentStorage->host_path.':'.$persistentStorage->mount_path;
} else {
$volume_name = $persistentStorage->name;
- $local_persistent_volumes[] = $volume_name . ':' . $persistentStorage->mount_path;
+ $local_persistent_volumes[] = $volume_name.':'.$persistentStorage->mount_path;
}
}
+
return $local_persistent_volumes;
}
@@ -159,6 +163,7 @@ private function generate_local_persistent_volumes_only_volume_names()
'external' => false,
];
}
+
return $local_persistent_volumes_names;
}
@@ -180,8 +185,10 @@ private function generate_environment_variables()
if ($environment_variables->filter(fn ($env) => Str::of($env)->contains('MONGO_INITDB_DATABASE'))->isEmpty()) {
$environment_variables->push("MONGO_INITDB_DATABASE={$this->database->mongo_initdb_database}");
}
+
return $environment_variables->all();
}
+
private function add_custom_mongo_conf()
{
if (is_null($this->database->mongo_conf) || empty($this->database->mongo_conf)) {
@@ -192,6 +199,7 @@ private function add_custom_mongo_conf()
$content_base64 = base64_encode($content);
$this->commands[] = "echo '{$content_base64}' | base64 -d | tee $this->configuration_dir/{$filename} > /dev/null";
}
+
private function add_default_database()
{
$content = "db = db.getSiblingDB(\"{$this->database->mongo_initdb_database}\");db.createCollection('init_collection');db.createUser({user: \"{$this->database->mongo_initdb_root_username}\", pwd: \"{$this->database->mongo_initdb_root_password}\",roles: [{role:\"readWrite\",db:\"{$this->database->mongo_initdb_database}\"}]});";
diff --git a/app/Actions/Database/StartMysql.php b/app/Actions/Database/StartMysql.php
index 604e72fde..8280faa56 100644
--- a/app/Actions/Database/StartMysql.php
+++ b/app/Actions/Database/StartMysql.php
@@ -4,15 +4,17 @@
use App\Models\StandaloneMysql;
use Illuminate\Support\Str;
-use Symfony\Component\Yaml\Yaml;
use Lorisleiva\Actions\Concerns\AsAction;
+use Symfony\Component\Yaml\Yaml;
class StartMysql
{
use AsAction;
public StandaloneMysql $database;
+
public array $commands = [];
+
public string $configuration_dir;
public function handle(StandaloneMysql $database)
@@ -20,7 +22,7 @@ public function handle(StandaloneMysql $database)
$this->database = $database;
$container_name = $this->database->uuid;
- $this->configuration_dir = database_configuration_dir() . '/' . $container_name;
+ $this->configuration_dir = database_configuration_dir().'/'.$container_name;
$this->commands = [
"echo 'Starting {$database->name}.'",
@@ -46,11 +48,11 @@ public function handle(StandaloneMysql $database)
'coolify.managed' => 'true',
],
'healthcheck' => [
- 'test' => ["CMD", "mysqladmin", "ping", "-h", "localhost", "-u", "root", "-p{$this->database->mysql_root_password}"],
+ 'test' => ['CMD', 'mysqladmin', 'ping', '-h', 'localhost', '-u', 'root', "-p{$this->database->mysql_root_password}"],
'interval' => '5s',
'timeout' => '5s',
'retries' => 10,
- 'start_period' => '5s'
+ 'start_period' => '5s',
],
'mem_limit' => $this->database->limits_memory,
'memswap_limit' => $this->database->limits_memory_swap,
@@ -58,27 +60,27 @@ public function handle(StandaloneMysql $database)
'mem_reservation' => $this->database->limits_memory_reservation,
'cpus' => (float) $this->database->limits_cpus,
'cpu_shares' => $this->database->limits_cpu_shares,
- ]
+ ],
],
'networks' => [
$this->database->destination->network => [
'external' => true,
'name' => $this->database->destination->network,
'attachable' => true,
- ]
- ]
+ ],
+ ],
];
- if (!is_null($this->database->limits_cpuset)) {
+ if (! is_null($this->database->limits_cpuset)) {
data_set($docker_compose, "services.{$container_name}.cpuset", $this->database->limits_cpuset);
}
if ($this->database->destination->server->isLogDrainEnabled() && $this->database->isLogDrainEnabled()) {
$docker_compose['services'][$container_name]['logging'] = [
'driver' => 'fluentd',
'options' => [
- 'fluentd-address' => "tcp://127.0.0.1:24224",
- 'fluentd-async' => "true",
- 'fluentd-sub-second-precision' => "true",
- ]
+ 'fluentd-address' => 'tcp://127.0.0.1:24224',
+ 'fluentd-async' => 'true',
+ 'fluentd-sub-second-precision' => 'true',
+ ],
];
}
if (count($this->database->ports_mappings_array) > 0) {
@@ -95,10 +97,10 @@ public function handle(StandaloneMysql $database)
if (count($volume_names) > 0) {
$docker_compose['volumes'] = $volume_names;
}
- if (!is_null($this->database->mysql_conf) || !empty($this->database->mysql_conf)) {
+ if (! is_null($this->database->mysql_conf) || ! empty($this->database->mysql_conf)) {
$docker_compose['services'][$container_name]['volumes'][] = [
'type' => 'bind',
- 'source' => $this->configuration_dir . '/custom-config.cnf',
+ 'source' => $this->configuration_dir.'/custom-config.cnf',
'target' => '/etc/mysql/conf.d/custom-config.cnf',
'read_only' => true,
];
@@ -112,7 +114,8 @@ public function handle(StandaloneMysql $database)
$this->commands[] = "docker compose -f $this->configuration_dir/docker-compose.yml pull";
$this->commands[] = "docker compose -f $this->configuration_dir/docker-compose.yml up -d";
$this->commands[] = "echo 'Database started.'";
- return remote_process($this->commands, $database->destination->server,callEventOnFinish: 'DatabaseStatusChanged');
+
+ return remote_process($this->commands, $database->destination->server, callEventOnFinish: 'DatabaseStatusChanged');
}
private function generate_local_persistent_volumes()
@@ -120,12 +123,13 @@ private function generate_local_persistent_volumes()
$local_persistent_volumes = [];
foreach ($this->database->persistentStorages as $persistentStorage) {
if ($persistentStorage->host_path !== '' && $persistentStorage->host_path !== null) {
- $local_persistent_volumes[] = $persistentStorage->host_path . ':' . $persistentStorage->mount_path;
+ $local_persistent_volumes[] = $persistentStorage->host_path.':'.$persistentStorage->mount_path;
} else {
$volume_name = $persistentStorage->name;
- $local_persistent_volumes[] = $volume_name . ':' . $persistentStorage->mount_path;
+ $local_persistent_volumes[] = $volume_name.':'.$persistentStorage->mount_path;
}
}
+
return $local_persistent_volumes;
}
@@ -142,6 +146,7 @@ private function generate_local_persistent_volumes_only_volume_names()
'external' => false,
];
}
+
return $local_persistent_volumes_names;
}
@@ -166,8 +171,10 @@ private function generate_environment_variables()
if ($environment_variables->filter(fn ($env) => Str::of($env)->contains('MYSQL_PASSWORD'))->isEmpty()) {
$environment_variables->push("MYSQL_PASSWORD={$this->database->mysql_password}");
}
+
return $environment_variables->all();
}
+
private function add_custom_mysql()
{
if (is_null($this->database->mysql_conf) || empty($this->database->mysql_conf)) {
diff --git a/app/Actions/Database/StartPostgresql.php b/app/Actions/Database/StartPostgresql.php
index 554e347d9..23b9742c7 100644
--- a/app/Actions/Database/StartPostgresql.php
+++ b/app/Actions/Database/StartPostgresql.php
@@ -4,28 +4,31 @@
use App\Models\StandalonePostgresql;
use Illuminate\Support\Str;
-use Symfony\Component\Yaml\Yaml;
use Lorisleiva\Actions\Concerns\AsAction;
+use Symfony\Component\Yaml\Yaml;
class StartPostgresql
{
use AsAction;
public StandalonePostgresql $database;
+
public array $commands = [];
+
public array $init_scripts = [];
+
public string $configuration_dir;
public function handle(StandalonePostgresql $database)
{
$this->database = $database;
$container_name = $this->database->uuid;
- $this->configuration_dir = database_configuration_dir() . '/' . $container_name;
+ $this->configuration_dir = database_configuration_dir().'/'.$container_name;
$this->commands = [
"echo 'Starting {$database->name}.'",
"mkdir -p $this->configuration_dir",
- "mkdir -p $this->configuration_dir/docker-entrypoint-initdb.d/"
+ "mkdir -p $this->configuration_dir/docker-entrypoint-initdb.d/",
];
$persistent_storages = $this->generate_local_persistent_volumes();
@@ -50,13 +53,13 @@ public function handle(StandalonePostgresql $database)
],
'healthcheck' => [
'test' => [
- "CMD-SHELL",
- "psql -U {$this->database->postgres_user} -d {$this->database->postgres_db} -c 'SELECT 1' || exit 1"
+ 'CMD-SHELL',
+ "psql -U {$this->database->postgres_user} -d {$this->database->postgres_db} -c 'SELECT 1' || exit 1",
],
'interval' => '5s',
'timeout' => '5s',
'retries' => 10,
- 'start_period' => '5s'
+ 'start_period' => '5s',
],
'mem_limit' => $this->database->limits_memory,
'memswap_limit' => $this->database->limits_memory_swap,
@@ -64,27 +67,27 @@ public function handle(StandalonePostgresql $database)
'mem_reservation' => $this->database->limits_memory_reservation,
'cpus' => (float) $this->database->limits_cpus,
'cpu_shares' => $this->database->limits_cpu_shares,
- ]
+ ],
],
'networks' => [
$this->database->destination->network => [
'external' => true,
'name' => $this->database->destination->network,
'attachable' => true,
- ]
- ]
+ ],
+ ],
];
- if (!is_null($this->database->limits_cpuset)) {
+ if (! is_null($this->database->limits_cpuset)) {
data_set($docker_compose, "services.{$container_name}.cpuset", $this->database->limits_cpuset);
}
if ($this->database->destination->server->isLogDrainEnabled() && $this->database->isLogDrainEnabled()) {
$docker_compose['services'][$container_name]['logging'] = [
'driver' => 'fluentd',
'options' => [
- 'fluentd-address' => "tcp://127.0.0.1:24224",
- 'fluentd-async' => "true",
- 'fluentd-sub-second-precision' => "true",
- ]
+ 'fluentd-address' => 'tcp://127.0.0.1:24224',
+ 'fluentd-async' => 'true',
+ 'fluentd-sub-second-precision' => 'true',
+ ],
];
}
if (count($this->database->ports_mappings_array) > 0) {
@@ -106,15 +109,15 @@ public function handle(StandalonePostgresql $database)
$docker_compose['services'][$container_name]['volumes'][] = [
'type' => 'bind',
'source' => $init_script,
- 'target' => '/docker-entrypoint-initdb.d/' . basename($init_script),
+ 'target' => '/docker-entrypoint-initdb.d/'.basename($init_script),
'read_only' => true,
];
}
}
- if (!is_null($this->database->postgres_conf) && !empty($this->database->postgres_conf)) {
+ if (! is_null($this->database->postgres_conf) && ! empty($this->database->postgres_conf)) {
$docker_compose['services'][$container_name]['volumes'][] = [
'type' => 'bind',
- 'source' => $this->configuration_dir . '/custom-postgres.conf',
+ 'source' => $this->configuration_dir.'/custom-postgres.conf',
'target' => '/etc/postgresql/postgresql.conf',
'read_only' => true,
];
@@ -133,6 +136,7 @@ public function handle(StandalonePostgresql $database)
$this->commands[] = "docker compose -f $this->configuration_dir/docker-compose.yml pull";
$this->commands[] = "docker compose -f $this->configuration_dir/docker-compose.yml up -d";
$this->commands[] = "echo 'Database started.'";
+
return remote_process($this->commands, $database->destination->server, callEventOnFinish: 'DatabaseStatusChanged');
}
@@ -141,12 +145,13 @@ private function generate_local_persistent_volumes()
$local_persistent_volumes = [];
foreach ($this->database->persistentStorages as $persistentStorage) {
if ($persistentStorage->host_path !== '' && $persistentStorage->host_path !== null) {
- $local_persistent_volumes[] = $persistentStorage->host_path . ':' . $persistentStorage->mount_path;
+ $local_persistent_volumes[] = $persistentStorage->host_path.':'.$persistentStorage->mount_path;
} else {
$volume_name = $persistentStorage->name;
- $local_persistent_volumes[] = $volume_name . ':' . $persistentStorage->mount_path;
+ $local_persistent_volumes[] = $volume_name.':'.$persistentStorage->mount_path;
}
}
+
return $local_persistent_volumes;
}
@@ -163,6 +168,7 @@ private function generate_local_persistent_volumes_only_volume_names()
'external' => false,
];
}
+
return $local_persistent_volumes_names;
}
@@ -187,6 +193,7 @@ private function generate_environment_variables()
if ($environment_variables->filter(fn ($env) => Str::of($env)->contains('POSTGRES_DB'))->isEmpty()) {
$environment_variables->push("POSTGRES_DB={$this->database->postgres_db}");
}
+
return $environment_variables->all();
}
@@ -203,6 +210,7 @@ private function generate_init_scripts()
$this->init_scripts[] = "$this->configuration_dir/docker-entrypoint-initdb.d/{$filename}";
}
}
+
private function add_custom_conf()
{
if (is_null($this->database->postgres_conf) || empty($this->database->postgres_conf)) {
@@ -210,7 +218,7 @@ private function add_custom_conf()
}
$filename = 'custom-postgres.conf';
$content = $this->database->postgres_conf;
- if (!str($content)->contains('listen_addresses')) {
+ if (! str($content)->contains('listen_addresses')) {
$content .= "\nlisten_addresses = '*'";
$this->database->postgres_conf = $content;
$this->database->save();
diff --git a/app/Actions/Database/StartRedis.php b/app/Actions/Database/StartRedis.php
index 055d82600..065df5e52 100644
--- a/app/Actions/Database/StartRedis.php
+++ b/app/Actions/Database/StartRedis.php
@@ -5,17 +5,18 @@
use App\Models\StandaloneRedis;
use Illuminate\Support\Facades\Storage;
use Illuminate\Support\Str;
-use Symfony\Component\Yaml\Yaml;
use Lorisleiva\Actions\Concerns\AsAction;
+use Symfony\Component\Yaml\Yaml;
class StartRedis
{
use AsAction;
public StandaloneRedis $database;
- public array $commands = [];
- public string $configuration_dir;
+ public array $commands = [];
+
+ public string $configuration_dir;
public function handle(StandaloneRedis $database)
{
@@ -24,7 +25,7 @@ public function handle(StandaloneRedis $database)
$startCommand = "redis-server --requirepass {$this->database->redis_password} --appendonly yes";
$container_name = $this->database->uuid;
- $this->configuration_dir = database_configuration_dir() . '/' . $container_name;
+ $this->configuration_dir = database_configuration_dir().'/'.$container_name;
$this->commands = [
"echo 'Starting {$database->name}.'",
@@ -55,12 +56,12 @@ public function handle(StandaloneRedis $database)
'test' => [
'CMD-SHELL',
'redis-cli',
- 'ping'
+ 'ping',
],
'interval' => '5s',
'timeout' => '5s',
'retries' => 10,
- 'start_period' => '5s'
+ 'start_period' => '5s',
],
'mem_limit' => $this->database->limits_memory,
'memswap_limit' => $this->database->limits_memory_swap,
@@ -68,27 +69,27 @@ public function handle(StandaloneRedis $database)
'mem_reservation' => $this->database->limits_memory_reservation,
'cpus' => (float) $this->database->limits_cpus,
'cpu_shares' => $this->database->limits_cpu_shares,
- ]
+ ],
],
'networks' => [
$this->database->destination->network => [
'external' => true,
'name' => $this->database->destination->network,
'attachable' => true,
- ]
- ]
+ ],
+ ],
];
- if (!is_null($this->database->limits_cpuset)) {
+ if (! is_null($this->database->limits_cpuset)) {
data_set($docker_compose, "services.{$container_name}.cpuset", $this->database->limits_cpuset);
}
if ($this->database->destination->server->isLogDrainEnabled() && $this->database->isLogDrainEnabled()) {
$docker_compose['services'][$container_name]['logging'] = [
'driver' => 'fluentd',
'options' => [
- 'fluentd-address' => "tcp://127.0.0.1:24224",
- 'fluentd-async' => "true",
- 'fluentd-sub-second-precision' => "true",
- ]
+ 'fluentd-address' => 'tcp://127.0.0.1:24224',
+ 'fluentd-async' => 'true',
+ 'fluentd-sub-second-precision' => 'true',
+ ],
];
}
if (count($this->database->ports_mappings_array) > 0) {
@@ -105,10 +106,10 @@ public function handle(StandaloneRedis $database)
if (count($volume_names) > 0) {
$docker_compose['volumes'] = $volume_names;
}
- if (!is_null($this->database->redis_conf) || !empty($this->database->redis_conf)) {
+ if (! is_null($this->database->redis_conf) || ! empty($this->database->redis_conf)) {
$docker_compose['services'][$container_name]['volumes'][] = [
'type' => 'bind',
- 'source' => $this->configuration_dir . '/redis.conf',
+ 'source' => $this->configuration_dir.'/redis.conf',
'target' => '/usr/local/etc/redis/redis.conf',
'read_only' => true,
];
@@ -123,6 +124,7 @@ public function handle(StandaloneRedis $database)
$this->commands[] = "docker compose -f $this->configuration_dir/docker-compose.yml pull";
$this->commands[] = "docker compose -f $this->configuration_dir/docker-compose.yml up -d";
$this->commands[] = "echo 'Database started.'";
+
return remote_process($this->commands, $database->destination->server, callEventOnFinish: 'DatabaseStatusChanged');
}
@@ -131,12 +133,13 @@ private function generate_local_persistent_volumes()
$local_persistent_volumes = [];
foreach ($this->database->persistentStorages as $persistentStorage) {
if ($persistentStorage->host_path !== '' && $persistentStorage->host_path !== null) {
- $local_persistent_volumes[] = $persistentStorage->host_path . ':' . $persistentStorage->mount_path;
+ $local_persistent_volumes[] = $persistentStorage->host_path.':'.$persistentStorage->mount_path;
} else {
$volume_name = $persistentStorage->name;
- $local_persistent_volumes[] = $volume_name . ':' . $persistentStorage->mount_path;
+ $local_persistent_volumes[] = $volume_name.':'.$persistentStorage->mount_path;
}
}
+
return $local_persistent_volumes;
}
@@ -153,6 +156,7 @@ private function generate_local_persistent_volumes_only_volume_names()
'external' => false,
];
}
+
return $local_persistent_volumes_names;
}
@@ -169,6 +173,7 @@ private function generate_environment_variables()
return $environment_variables->all();
}
+
private function add_custom_redis()
{
if (is_null($this->database->redis_conf) || empty($this->database->redis_conf)) {
diff --git a/app/Actions/Database/StopDatabase.php b/app/Actions/Database/StopDatabase.php
index 408c5a69e..66a32e811 100644
--- a/app/Actions/Database/StopDatabase.php
+++ b/app/Actions/Database/StopDatabase.php
@@ -19,7 +19,7 @@ class StopDatabase
public function handle(StandaloneRedis|StandalonePostgresql|StandaloneMongodb|StandaloneMysql|StandaloneMariadb|StandaloneKeydb|StandaloneDragonfly|StandaloneClickhouse $database)
{
$server = $database->destination->server;
- if (!$server->isFunctional()) {
+ if (! $server->isFunctional()) {
return 'Server is not functional';
}
instant_remote_process(
diff --git a/app/Actions/Docker/GetContainersStatus.php b/app/Actions/Docker/GetContainersStatus.php
index a8a9185ba..9b32e89f3 100644
--- a/app/Actions/Docker/GetContainersStatus.php
+++ b/app/Actions/Docker/GetContainersStatus.php
@@ -17,7 +17,9 @@
class GetContainersStatus
{
use AsAction;
+
public $applications;
+
public $server;
public function handle(Server $server)
@@ -26,9 +28,9 @@ public function handle(Server $server)
// $server = Server::find(0);
// }
$this->server = $server;
- if (!$this->server->isFunctional()) {
+ if (! $this->server->isFunctional()) {
return 'Server is not ready.';
- };
+ }
$this->applications = $this->server->applications();
$skip_these_applications = collect([]);
foreach ($this->applications as $application) {
@@ -41,7 +43,7 @@ public function handle(Server $server)
}
}
$this->applications = $this->applications->filter(function ($value, $key) use ($skip_these_applications) {
- return !$skip_these_applications->pluck('id')->contains($value->id);
+ return ! $skip_these_applications->pluck('id')->contains($value->id);
});
$this->old_way();
// if ($this->server->isSwarm()) {
@@ -133,7 +135,7 @@ private function sentinel()
return data_get($value, 'name') === "$uuid-proxy";
}
})->first();
- if (!$foundTcpProxy) {
+ if (! $foundTcpProxy) {
StartDatabaseProxy::run($service_db);
// $this->server->team?->notify(new ContainerRestarted("TCP Proxy for {$service_db->service->name}", $this->server));
}
@@ -158,7 +160,7 @@ private function sentinel()
return data_get($value, 'name') === "$uuid-proxy";
}
})->first();
- if (!$foundTcpProxy) {
+ if (! $foundTcpProxy) {
StartDatabaseProxy::run($database);
$this->server->team?->notify(new ContainerRestarted("TCP Proxy for {$database->name}", $this->server));
}
@@ -177,13 +179,13 @@ private function sentinel()
$subType = data_get($labels, 'coolify.service.subType');
$subId = data_get($labels, 'coolify.service.subId');
$service = $services->where('id', $serviceLabelId)->first();
- if (!$service) {
+ if (! $service) {
continue;
}
if ($subType === 'application') {
- $service = $service->applications()->where('id', $subId)->first();
+ $service = $service->applications()->where('id', $subId)->first();
} else {
- $service = $service->databases()->where('id', $subId)->first();
+ $service = $service->databases()->where('id', $subId)->first();
}
if ($service) {
$foundServices[] = "$service->id-$service->name";
@@ -239,7 +241,7 @@ private function sentinel()
$environmentName = data_get($service, 'environment.name');
if ($projectUuid && $serviceUuid && $environmentName) {
- $url = base_url() . '/project/' . $projectUuid . "/" . $environmentName . "/service/" . $serviceUuid;
+ $url = base_url().'/project/'.$projectUuid.'/'.$environmentName.'/service/'.$serviceUuid;
} else {
$url = null;
}
@@ -265,7 +267,7 @@ private function sentinel()
$environment = data_get($application, 'environment.name');
if ($projectUuid && $applicationUuid && $environment) {
- $url = base_url() . '/project/' . $projectUuid . "/" . $environment . "/application/" . $applicationUuid;
+ $url = base_url().'/project/'.$projectUuid.'/'.$environment.'/application/'.$applicationUuid;
} else {
$url = null;
}
@@ -290,7 +292,7 @@ private function sentinel()
$applicationUuid = data_get($preview, 'application.uuid');
if ($projectUuid && $applicationUuid && $environmentName) {
- $url = base_url() . '/project/' . $projectUuid . "/" . $environmentName . "/application/" . $applicationUuid;
+ $url = base_url().'/project/'.$projectUuid.'/'.$environmentName.'/application/'.$applicationUuid;
} else {
$url = null;
}
@@ -315,7 +317,7 @@ private function sentinel()
$databaseUuid = data_get($database, 'uuid');
if ($projectUuid && $databaseUuid && $environmentName) {
- $url = base_url() . '/project/' . $projectUuid . "/" . $environmentName . "/database/" . $databaseUuid;
+ $url = base_url().'/project/'.$projectUuid.'/'.$environmentName.'/database/'.$databaseUuid;
} else {
$url = null;
}
@@ -332,7 +334,7 @@ private function sentinel()
return data_get($value, 'name') === 'coolify-proxy';
}
})->first();
- if (!$foundProxyContainer) {
+ if (! $foundProxyContainer) {
try {
$shouldStart = CheckProxy::run($this->server);
if ($shouldStart) {
@@ -351,9 +353,11 @@ private function sentinel()
} catch (\Exception $e) {
// send_internal_notification("ContainerStatusJob failed on ({$this->server->id}) with: " . $e->getMessage());
ray($e->getMessage());
+
return handleError($e);
}
}
+
private function old_way()
{
if ($this->server->isSwarm()) {
@@ -361,8 +365,8 @@ private function old_way()
$containerReplicates = instant_remote_process(["docker service ls --format '{{json .}}'"], $this->server, false);
} else {
// Precheck for containers
- $containers = instant_remote_process(["docker container ls -q"], $this->server, false);
- if (!$containers) {
+ $containers = instant_remote_process(['docker container ls -q'], $this->server, false);
+ if (! $containers) {
return;
}
$containers = instant_remote_process(["docker container inspect $(docker container ls -q) --format '{{json .}}'"], $this->server, false);
@@ -390,6 +394,7 @@ private function old_way()
data_set($container, 'State.Health.Status', 'unhealthy');
}
}
+
return $container;
});
}
@@ -463,7 +468,7 @@ private function old_way()
return data_get($value, 'Name') === "/$uuid-proxy";
}
})->first();
- if (!$foundTcpProxy) {
+ if (! $foundTcpProxy) {
StartDatabaseProxy::run($service_db);
// $this->server->team?->notify(new ContainerRestarted("TCP Proxy for {$service_db->service->name}", $this->server));
}
@@ -488,7 +493,7 @@ private function old_way()
return data_get($value, 'Name') === "/$uuid-proxy";
}
})->first();
- if (!$foundTcpProxy) {
+ if (! $foundTcpProxy) {
StartDatabaseProxy::run($database);
$this->server->team?->notify(new ContainerRestarted("TCP Proxy for {$database->name}", $this->server));
}
@@ -507,13 +512,13 @@ private function old_way()
$subType = data_get($labels, 'coolify.service.subType');
$subId = data_get($labels, 'coolify.service.subId');
$service = $services->where('id', $serviceLabelId)->first();
- if (!$service) {
+ if (! $service) {
continue;
}
if ($subType === 'application') {
- $service = $service->applications()->where('id', $subId)->first();
+ $service = $service->applications()->where('id', $subId)->first();
} else {
- $service = $service->databases()->where('id', $subId)->first();
+ $service = $service->databases()->where('id', $subId)->first();
}
if ($service) {
$foundServices[] = "$service->id-$service->name";
@@ -569,7 +574,7 @@ private function old_way()
$environmentName = data_get($service, 'environment.name');
if ($projectUuid && $serviceUuid && $environmentName) {
- $url = base_url() . '/project/' . $projectUuid . "/" . $environmentName . "/service/" . $serviceUuid;
+ $url = base_url().'/project/'.$projectUuid.'/'.$environmentName.'/service/'.$serviceUuid;
} else {
$url = null;
}
@@ -595,7 +600,7 @@ private function old_way()
$environment = data_get($application, 'environment.name');
if ($projectUuid && $applicationUuid && $environment) {
- $url = base_url() . '/project/' . $projectUuid . "/" . $environment . "/application/" . $applicationUuid;
+ $url = base_url().'/project/'.$projectUuid.'/'.$environment.'/application/'.$applicationUuid;
} else {
$url = null;
}
@@ -620,7 +625,7 @@ private function old_way()
$applicationUuid = data_get($preview, 'application.uuid');
if ($projectUuid && $applicationUuid && $environmentName) {
- $url = base_url() . '/project/' . $projectUuid . "/" . $environmentName . "/application/" . $applicationUuid;
+ $url = base_url().'/project/'.$projectUuid.'/'.$environmentName.'/application/'.$applicationUuid;
} else {
$url = null;
}
@@ -645,7 +650,7 @@ private function old_way()
$databaseUuid = data_get($database, 'uuid');
if ($projectUuid && $databaseUuid && $environmentName) {
- $url = base_url() . '/project/' . $projectUuid . "/" . $environmentName . "/database/" . $databaseUuid;
+ $url = base_url().'/project/'.$projectUuid.'/'.$environmentName.'/database/'.$databaseUuid;
} else {
$url = null;
}
@@ -661,7 +666,7 @@ private function old_way()
return data_get($value, 'Name') === '/coolify-proxy';
}
})->first();
- if (!$foundProxyContainer) {
+ if (! $foundProxyContainer) {
try {
$shouldStart = CheckProxy::run($this->server);
if ($shouldStart) {
diff --git a/app/Actions/Fortify/CreateNewUser.php b/app/Actions/Fortify/CreateNewUser.php
index 7950bd4f7..f8882d12a 100644
--- a/app/Actions/Fortify/CreateNewUser.php
+++ b/app/Actions/Fortify/CreateNewUser.php
@@ -16,12 +16,12 @@ class CreateNewUser implements CreatesNewUsers
/**
* Validate and create a newly registered user.
*
- * @param array