135 lines
		
	
	
		
			3.9 KiB
		
	
	
	
		
			PHP
		
	
	
	
	
	
			
		
		
	
	
			135 lines
		
	
	
		
			3.9 KiB
		
	
	
	
		
			PHP
		
	
	
	
	
	
<?php
 | 
						|
 | 
						|
namespace App\Models;
 | 
						|
 | 
						|
use Illuminate\Database\Eloquent\Casts\Attribute;
 | 
						|
use Illuminate\Database\Eloquent\Factories\HasFactory;
 | 
						|
use Illuminate\Database\Eloquent\Relations\HasMany;
 | 
						|
use Illuminate\Database\Eloquent\SoftDeletes;
 | 
						|
 | 
						|
class StandalonePostgresql extends BaseModel
 | 
						|
{
 | 
						|
    use HasFactory, SoftDeletes;
 | 
						|
 | 
						|
    protected $guarded = [];
 | 
						|
    protected $casts = [
 | 
						|
        'init_scripts' => 'array',
 | 
						|
        'postgres_password' => 'encrypted',
 | 
						|
    ];
 | 
						|
 | 
						|
    protected static function booted()
 | 
						|
    {
 | 
						|
        static::created(function ($database) {
 | 
						|
            LocalPersistentVolume::create([
 | 
						|
                'name' => 'postgres-data-' . $database->uuid,
 | 
						|
                'mount_path' => '/var/lib/postgresql/data',
 | 
						|
                'host_path' => null,
 | 
						|
                'resource_id' => $database->id,
 | 
						|
                'resource_type' => $database->getMorphClass(),
 | 
						|
                'is_readonly' => true
 | 
						|
            ]);
 | 
						|
        });
 | 
						|
        static::deleting(function ($database) {
 | 
						|
            $storages = $database->persistentStorages()->get();
 | 
						|
            $server = data_get($database, 'destination.server');
 | 
						|
            if ($server) {
 | 
						|
                foreach ($storages as $storage) {
 | 
						|
                    instant_remote_process(["docker volume rm -f $storage->name"], $server, false);
 | 
						|
                }
 | 
						|
            }
 | 
						|
            $database->scheduledBackups()->delete();
 | 
						|
            $database->persistentStorages()->delete();
 | 
						|
            $database->environment_variables()->delete();
 | 
						|
            $database->tags()->detach();
 | 
						|
        });
 | 
						|
    }
 | 
						|
 | 
						|
    public function tags()
 | 
						|
    {
 | 
						|
        return $this->morphToMany(Tag::class, 'taggable');
 | 
						|
    }
 | 
						|
    public function link()
 | 
						|
    {
 | 
						|
        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;
 | 
						|
    }
 | 
						|
    public function isLogDrainEnabled()
 | 
						|
    {
 | 
						|
        return data_get($this, 'is_log_drain_enabled', false);
 | 
						|
    }
 | 
						|
 | 
						|
    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 team()
 | 
						|
    {
 | 
						|
        return data_get($this, 'environment.project.team');
 | 
						|
    }
 | 
						|
    public function type(): string
 | 
						|
    {
 | 
						|
        return 'standalone-postgresql';
 | 
						|
    }
 | 
						|
    public function getDbUrl(bool $useInternal = false): string
 | 
						|
    {
 | 
						|
        if ($this->is_public && !$useInternal) {
 | 
						|
            return "postgres://{$this->postgres_user}:{$this->postgres_password}@{$this->destination->server->getIp}:{$this->public_port}/{$this->postgres_db}";
 | 
						|
        } else {
 | 
						|
            return "postgres://{$this->postgres_user}:{$this->postgres_password}@{$this->uuid}:5432/{$this->postgres_db}";
 | 
						|
        }
 | 
						|
    }
 | 
						|
 | 
						|
    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');
 | 
						|
    }
 | 
						|
}
 |