147 lines
		
	
	
		
			3.7 KiB
		
	
	
	
		
			PHP
		
	
	
	
	
	
			
		
		
	
	
			147 lines
		
	
	
		
			3.7 KiB
		
	
	
	
		
			PHP
		
	
	
	
	
	
<?php
 | 
						|
 | 
						|
namespace App\Models;
 | 
						|
 | 
						|
use Illuminate\Database\Eloquent\Factories\HasFactory;
 | 
						|
use Illuminate\Database\Eloquent\SoftDeletes;
 | 
						|
 | 
						|
class ServiceDatabase extends BaseModel
 | 
						|
{
 | 
						|
    use HasFactory, SoftDeletes;
 | 
						|
 | 
						|
    protected $guarded = [];
 | 
						|
 | 
						|
    protected static function booted()
 | 
						|
    {
 | 
						|
        static::deleting(function ($service) {
 | 
						|
            $service->persistentStorages()->delete();
 | 
						|
            $service->fileStorages()->delete();
 | 
						|
        });
 | 
						|
        static::saving(function ($service) {
 | 
						|
            if ($service->isDirty('status')) {
 | 
						|
                $service->forceFill(['last_online_at' => now()]);
 | 
						|
            }
 | 
						|
        });
 | 
						|
    }
 | 
						|
 | 
						|
    public static function ownedByCurrentTeamAPI(int $teamId)
 | 
						|
    {
 | 
						|
        return ServiceDatabase::whereRelation('service.environment.project.team', 'id', $teamId)->orderBy('name');
 | 
						|
    }
 | 
						|
 | 
						|
    public static function ownedByCurrentTeam()
 | 
						|
    {
 | 
						|
        return ServiceDatabase::whereRelation('service.environment.project.team', 'id', currentTeam()->id)->orderBy('name');
 | 
						|
    }
 | 
						|
 | 
						|
    public function restart()
 | 
						|
    {
 | 
						|
        $container_id = $this->name.'-'.$this->service->uuid;
 | 
						|
        remote_process(["docker restart {$container_id}"], $this->service->server);
 | 
						|
    }
 | 
						|
 | 
						|
    public function isRunning()
 | 
						|
    {
 | 
						|
        return str($this->status)->contains('running');
 | 
						|
    }
 | 
						|
 | 
						|
    public function isExited()
 | 
						|
    {
 | 
						|
        return str($this->status)->contains('exited');
 | 
						|
    }
 | 
						|
 | 
						|
    public function isLogDrainEnabled()
 | 
						|
    {
 | 
						|
        return data_get($this, 'is_log_drain_enabled', false);
 | 
						|
    }
 | 
						|
 | 
						|
    public function isStripprefixEnabled()
 | 
						|
    {
 | 
						|
        return data_get($this, 'is_stripprefix_enabled', true);
 | 
						|
    }
 | 
						|
 | 
						|
    public function isGzipEnabled()
 | 
						|
    {
 | 
						|
        return data_get($this, 'is_gzip_enabled', true);
 | 
						|
    }
 | 
						|
 | 
						|
    public function type()
 | 
						|
    {
 | 
						|
        return 'service';
 | 
						|
    }
 | 
						|
 | 
						|
    public function serviceType()
 | 
						|
    {
 | 
						|
        return null;
 | 
						|
    }
 | 
						|
 | 
						|
    public function databaseType()
 | 
						|
    {
 | 
						|
        $image = str($this->image)->before(':');
 | 
						|
        if ($image->contains('supabase/postgres')) {
 | 
						|
            $finalImage = 'supabase/postgres';
 | 
						|
        } elseif ($image->contains('postgres') || $image->contains('postgis')) {
 | 
						|
            $finalImage = 'postgresql';
 | 
						|
        } else {
 | 
						|
            $finalImage = $image;
 | 
						|
        }
 | 
						|
 | 
						|
        return "standalone-$finalImage";
 | 
						|
    }
 | 
						|
 | 
						|
    public function getServiceDatabaseUrl()
 | 
						|
    {
 | 
						|
        $port = $this->public_port;
 | 
						|
        $realIp = $this->service->server->ip;
 | 
						|
        if ($this->service->server->isLocalhost() || isDev()) {
 | 
						|
            $realIp = base_ip();
 | 
						|
        }
 | 
						|
 | 
						|
        return "{$realIp}:{$port}";
 | 
						|
    }
 | 
						|
 | 
						|
    public function team()
 | 
						|
    {
 | 
						|
        return data_get($this, 'environment.project.team');
 | 
						|
    }
 | 
						|
 | 
						|
    public function workdir()
 | 
						|
    {
 | 
						|
        return service_configuration_dir()."/{$this->service->uuid}";
 | 
						|
    }
 | 
						|
 | 
						|
    public function service()
 | 
						|
    {
 | 
						|
        return $this->belongsTo(Service::class);
 | 
						|
    }
 | 
						|
 | 
						|
    public function persistentStorages()
 | 
						|
    {
 | 
						|
        return $this->morphMany(LocalPersistentVolume::class, 'resource');
 | 
						|
    }
 | 
						|
 | 
						|
    public function fileStorages()
 | 
						|
    {
 | 
						|
        return $this->morphMany(LocalFileVolume::class, 'resource');
 | 
						|
    }
 | 
						|
 | 
						|
    public function getFilesFromServer(bool $isInit = false)
 | 
						|
    {
 | 
						|
        getFilesystemVolumesFromServer($this, $isInit);
 | 
						|
    }
 | 
						|
 | 
						|
    public function scheduledBackups()
 | 
						|
    {
 | 
						|
        return $this->morphMany(ScheduledDatabaseBackup::class, 'database');
 | 
						|
    }
 | 
						|
 | 
						|
    public function isBackupSolutionAvailable()
 | 
						|
    {
 | 
						|
        return str($this->databaseType())->contains('mysql') ||
 | 
						|
            str($this->databaseType())->contains('postgres') ||
 | 
						|
            str($this->databaseType())->contains('postgis') ||
 | 
						|
            str($this->databaseType())->contains('mariadb') ||
 | 
						|
            str($this->databaseType())->contains('mongo');
 | 
						|
    }
 | 
						|
}
 |