76 lines
		
	
	
		
			2.4 KiB
		
	
	
	
		
			PHP
		
	
	
	
	
	
			
		
		
	
	
			76 lines
		
	
	
		
			2.4 KiB
		
	
	
	
		
			PHP
		
	
	
	
	
	
| <?php
 | |
| 
 | |
| namespace App\Actions\Database;
 | |
| 
 | |
| use App\Actions\Server\CleanupDocker;
 | |
| use App\Models\StandaloneClickhouse;
 | |
| use App\Models\StandaloneDragonfly;
 | |
| use App\Models\StandaloneKeydb;
 | |
| use App\Models\StandaloneMariadb;
 | |
| use App\Models\StandaloneMongodb;
 | |
| use App\Models\StandaloneMysql;
 | |
| use App\Models\StandalonePostgresql;
 | |
| use App\Models\StandaloneRedis;
 | |
| use Illuminate\Support\Facades\Process;
 | |
| use Lorisleiva\Actions\Concerns\AsAction;
 | |
| 
 | |
| class StopDatabase
 | |
| {
 | |
|     use AsAction;
 | |
| 
 | |
|     public function handle(StandaloneRedis|StandalonePostgresql|StandaloneMongodb|StandaloneMysql|StandaloneMariadb|StandaloneKeydb|StandaloneDragonfly|StandaloneClickhouse $database, bool $isDeleteOperation = false, bool $dockerCleanup = true)
 | |
|     {
 | |
|         $server = $database->destination->server;
 | |
|         if (! $server->isFunctional()) {
 | |
|             return 'Server is not functional';
 | |
|         }
 | |
| 
 | |
|         $this->stopContainer($database, $database->uuid, 300);
 | |
|         if (! $isDeleteOperation) {
 | |
|             if ($dockerCleanup) {
 | |
|                 CleanupDocker::dispatch($server, true);
 | |
|             }
 | |
|         }
 | |
| 
 | |
|         if ($database->is_public) {
 | |
|             StopDatabaseProxy::run($database);
 | |
|         }
 | |
| 
 | |
|         return 'Database stopped successfully';
 | |
|     }
 | |
| 
 | |
|     private function stopContainer($database, string $containerName, int $timeout = 300): void
 | |
|     {
 | |
|         $server = $database->destination->server;
 | |
| 
 | |
|         $process = Process::timeout($timeout)->start("docker stop --time=$timeout $containerName");
 | |
| 
 | |
|         $startTime = time();
 | |
|         while ($process->running()) {
 | |
|             if (time() - $startTime >= $timeout) {
 | |
|                 $this->forceStopContainer($containerName, $server);
 | |
|                 break;
 | |
|             }
 | |
|             usleep(100000);
 | |
|         }
 | |
| 
 | |
|         $this->removeContainer($containerName, $server);
 | |
|     }
 | |
| 
 | |
|     private function forceStopContainer(string $containerName, $server): void
 | |
|     {
 | |
|         instant_remote_process(command: ["docker kill $containerName"], server: $server, throwError: false);
 | |
|     }
 | |
| 
 | |
|     private function removeContainer(string $containerName, $server): void
 | |
|     {
 | |
|         instant_remote_process(command: ["docker rm -f $containerName"], server: $server, throwError: false);
 | |
|     }
 | |
| 
 | |
|     private function deleteConnectedNetworks($uuid, $server)
 | |
|     {
 | |
|         instant_remote_process(["docker network disconnect {$uuid} coolify-proxy"], $server, false);
 | |
|         instant_remote_process(["docker network rm {$uuid}"], $server, false);
 | |
|     }
 | |
| }
 | 
