2023-10-19 11:32:03 +00:00
|
|
|
<?php
|
|
|
|
|
|
|
|
namespace App\Models;
|
|
|
|
|
|
|
|
use Illuminate\Database\Eloquent\Casts\Attribute;
|
|
|
|
use Illuminate\Database\Eloquent\Factories\HasFactory;
|
|
|
|
use Illuminate\Database\Eloquent\Relations\HasMany;
|
2023-12-13 11:08:12 +00:00
|
|
|
use Illuminate\Database\Eloquent\SoftDeletes;
|
2023-10-19 11:32:03 +00:00
|
|
|
|
|
|
|
class StandaloneMongodb extends BaseModel
|
|
|
|
{
|
2023-12-13 11:08:12 +00:00
|
|
|
use HasFactory, SoftDeletes;
|
2023-10-19 11:32:03 +00:00
|
|
|
protected $guarded = [];
|
|
|
|
|
|
|
|
protected static function booted()
|
|
|
|
{
|
|
|
|
static::created(function ($database) {
|
|
|
|
LocalPersistentVolume::create([
|
2023-10-24 07:34:35 +00:00
|
|
|
'name' => 'mongodb-configdb-' . $database->uuid,
|
|
|
|
'mount_path' => '/data/configdb',
|
|
|
|
'host_path' => null,
|
|
|
|
'resource_id' => $database->id,
|
|
|
|
'resource_type' => $database->getMorphClass(),
|
|
|
|
'is_readonly' => true
|
|
|
|
]);
|
|
|
|
LocalPersistentVolume::create([
|
|
|
|
'name' => 'mongodb-db-' . $database->uuid,
|
|
|
|
'mount_path' => '/data/db',
|
2023-10-19 11:32:03 +00:00
|
|
|
'host_path' => null,
|
|
|
|
'resource_id' => $database->id,
|
|
|
|
'resource_type' => $database->getMorphClass(),
|
|
|
|
'is_readonly' => true
|
|
|
|
]);
|
|
|
|
});
|
|
|
|
static::deleting(function ($database) {
|
|
|
|
$storages = $database->persistentStorages()->get();
|
2023-11-06 17:04:18 +00:00
|
|
|
$server = data_get($database, 'destination.server');
|
|
|
|
if ($server) {
|
|
|
|
foreach ($storages as $storage) {
|
|
|
|
instant_remote_process(["docker volume rm -f $storage->name"], $server, false);
|
|
|
|
}
|
2023-10-19 11:32:03 +00:00
|
|
|
}
|
2023-11-06 09:45:06 +00:00
|
|
|
$database->scheduledBackups()->delete();
|
2023-10-19 11:32:03 +00:00
|
|
|
$database->persistentStorages()->delete();
|
|
|
|
$database->environment_variables()->delete();
|
2024-02-02 10:50:28 +00:00
|
|
|
$database->tags()->detach();
|
2023-10-19 11:32:03 +00:00
|
|
|
});
|
|
|
|
}
|
2024-02-07 13:55:06 +00:00
|
|
|
public function realStatus()
|
|
|
|
{
|
|
|
|
return $this->getRawOriginal('status');
|
|
|
|
}
|
|
|
|
public function status(): Attribute
|
|
|
|
{
|
|
|
|
return Attribute::make(
|
|
|
|
set: function ($value) {
|
|
|
|
if (str($value)->contains('(')) {
|
|
|
|
$status = str($value)->before('(')->trim()->value();
|
|
|
|
$health = str($value)->after('(')->before(')')->trim()->value() ?? 'unhealthy';
|
|
|
|
} else if (str($value)->contains(':')) {
|
|
|
|
$status = str($value)->before(':')->trim()->value();
|
|
|
|
$health = str($value)->after(':')->trim()->value() ?? 'unhealthy';
|
|
|
|
} else {
|
|
|
|
$status = $value;
|
|
|
|
$health = 'unhealthy';
|
|
|
|
}
|
|
|
|
return "$status:$health";
|
|
|
|
},
|
|
|
|
get: function ($value) {
|
|
|
|
if (str($value)->contains('(')) {
|
|
|
|
$status = str($value)->before('(')->trim()->value();
|
|
|
|
$health = str($value)->after('(')->before(')')->trim()->value() ?? 'unhealthy';
|
|
|
|
} else if (str($value)->contains(':')) {
|
|
|
|
$status = str($value)->before(':')->trim()->value();
|
|
|
|
$health = str($value)->after(':')->trim()->value() ?? 'unhealthy';
|
|
|
|
} else {
|
|
|
|
$status = $value;
|
|
|
|
$health = 'unhealthy';
|
|
|
|
}
|
|
|
|
return "$status:$health";
|
|
|
|
},
|
|
|
|
);
|
|
|
|
}
|
2024-02-02 10:50:28 +00:00
|
|
|
public function tags()
|
|
|
|
{
|
|
|
|
return $this->morphToMany(Tag::class, 'taggable');
|
|
|
|
}
|
2024-02-16 20:56:38 +00:00
|
|
|
public function project() {
|
|
|
|
return data_get($this, 'environment.project');
|
|
|
|
}
|
2024-01-23 16:13:23 +00:00
|
|
|
public function team()
|
|
|
|
{
|
|
|
|
return data_get($this, 'environment.project.team');
|
|
|
|
}
|
2024-03-04 10:01:14 +00:00
|
|
|
public function isLogDrainEnabled()
|
2023-11-17 19:08:21 +00:00
|
|
|
{
|
|
|
|
return data_get($this, 'is_log_drain_enabled', false);
|
|
|
|
}
|
2023-11-27 08:39:43 +00:00
|
|
|
public function link()
|
|
|
|
{
|
2023-11-30 11:21:53 +00:00
|
|
|
if (data_get($this, 'environment.project.uuid')) {
|
|
|
|
return route('project.database.configuration', [
|
|
|
|
'project_uuid' => data_get($this, 'environment.project.uuid'),
|
|
|
|
'environment_name' => data_get($this, 'environment.name'),
|
|
|
|
'database_uuid' => data_get($this, 'uuid')
|
|
|
|
]);
|
|
|
|
}
|
|
|
|
return null;
|
2023-11-27 08:39:43 +00:00
|
|
|
}
|
2023-10-24 13:40:29 +00:00
|
|
|
public function mongoInitdbRootPassword(): Attribute
|
|
|
|
{
|
|
|
|
return Attribute::make(
|
|
|
|
get: function ($value) {
|
|
|
|
try {
|
|
|
|
return decrypt($value);
|
|
|
|
} catch (\Throwable $th) {
|
|
|
|
$this->mongo_initdb_root_password = encrypt($value);
|
|
|
|
$this->save();
|
|
|
|
return $value;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
);
|
|
|
|
}
|
2023-10-19 11:32:03 +00:00
|
|
|
public function portsMappings(): Attribute
|
|
|
|
{
|
|
|
|
return Attribute::make(
|
|
|
|
set: fn ($value) => $value === "" ? null : $value,
|
|
|
|
);
|
|
|
|
}
|
|
|
|
|
|
|
|
public function portsMappingsArray(): Attribute
|
|
|
|
{
|
|
|
|
return Attribute::make(
|
|
|
|
get: fn () => is_null($this->ports_mappings)
|
|
|
|
? []
|
|
|
|
: explode(',', $this->ports_mappings),
|
|
|
|
|
|
|
|
);
|
|
|
|
}
|
|
|
|
|
|
|
|
public function type(): string
|
|
|
|
{
|
|
|
|
return 'standalone-mongodb';
|
|
|
|
}
|
2024-03-04 09:46:13 +00:00
|
|
|
public function get_db_url(bool $useInternal = false)
|
2023-10-24 13:40:29 +00:00
|
|
|
{
|
2023-10-24 07:34:35 +00:00
|
|
|
if ($this->is_public && !$useInternal) {
|
2023-10-19 15:17:38 +00:00
|
|
|
return "mongodb://{$this->mongo_initdb_root_username}:{$this->mongo_initdb_root_password}@{$this->destination->server->getIp}:{$this->public_port}/?directConnection=true";
|
|
|
|
} else {
|
|
|
|
return "mongodb://{$this->mongo_initdb_root_username}:{$this->mongo_initdb_root_password}@{$this->uuid}:27017/?directConnection=true";
|
|
|
|
}
|
|
|
|
}
|
2023-10-19 11:32:03 +00:00
|
|
|
public function environment()
|
|
|
|
{
|
|
|
|
return $this->belongsTo(Environment::class);
|
|
|
|
}
|
|
|
|
|
|
|
|
public function fileStorages()
|
|
|
|
{
|
|
|
|
return $this->morphMany(LocalFileVolume::class, 'resource');
|
|
|
|
}
|
|
|
|
|
|
|
|
public function destination()
|
|
|
|
{
|
|
|
|
return $this->morphTo();
|
|
|
|
}
|
|
|
|
|
|
|
|
public function environment_variables(): HasMany
|
|
|
|
{
|
|
|
|
return $this->hasMany(EnvironmentVariable::class);
|
|
|
|
}
|
|
|
|
|
|
|
|
public function runtime_environment_variables(): HasMany
|
|
|
|
{
|
|
|
|
return $this->hasMany(EnvironmentVariable::class);
|
|
|
|
}
|
|
|
|
|
|
|
|
public function persistentStorages()
|
|
|
|
{
|
|
|
|
return $this->morphMany(LocalPersistentVolume::class, 'resource');
|
|
|
|
}
|
|
|
|
|
|
|
|
public function scheduledBackups()
|
|
|
|
{
|
|
|
|
return $this->morphMany(ScheduledDatabaseBackup::class, 'database');
|
|
|
|
}
|
|
|
|
}
|