107 lines
		
	
	
		
			3.1 KiB
		
	
	
	
		
			PHP
		
	
	
	
	
	
			
		
		
	
	
			107 lines
		
	
	
		
			3.1 KiB
		
	
	
	
		
			PHP
		
	
	
	
	
	
<?php
 | 
						|
 | 
						|
namespace App\Http\Controllers\Api\Application\Servers;
 | 
						|
 | 
						|
use App\Enums\SuspendAction;
 | 
						|
use App\Http\Controllers\Api\Application\ApplicationApiController;
 | 
						|
use App\Http\Requests\Api\Application\Servers\ServerWriteRequest;
 | 
						|
use App\Models\Server;
 | 
						|
use App\Repositories\Daemon\DaemonServerRepository;
 | 
						|
use App\Services\Servers\ReinstallServerService;
 | 
						|
use App\Services\Servers\SuspensionService;
 | 
						|
use App\Services\Servers\TransferServerService;
 | 
						|
use Illuminate\Http\Client\ConnectionException;
 | 
						|
use Illuminate\Http\Response;
 | 
						|
 | 
						|
class ServerManagementController extends ApplicationApiController
 | 
						|
{
 | 
						|
    /**
 | 
						|
     * ServerManagementController constructor.
 | 
						|
     */
 | 
						|
    public function __construct(
 | 
						|
        private ReinstallServerService $reinstallServerService,
 | 
						|
        private SuspensionService $suspensionService,
 | 
						|
        private TransferServerService $transferServerService,
 | 
						|
        private DaemonServerRepository $daemonServerRepository,
 | 
						|
    ) {
 | 
						|
        parent::__construct();
 | 
						|
    }
 | 
						|
 | 
						|
    /**
 | 
						|
     * Suspend a server on the Panel.
 | 
						|
     *
 | 
						|
     * @throws \Throwable
 | 
						|
     */
 | 
						|
    public function suspend(ServerWriteRequest $request, Server $server): Response
 | 
						|
    {
 | 
						|
        $this->suspensionService->handle($server, SuspendAction::Suspend);
 | 
						|
 | 
						|
        return $this->returnNoContent();
 | 
						|
    }
 | 
						|
 | 
						|
    /**
 | 
						|
     * Unsuspend a server on the Panel.
 | 
						|
     *
 | 
						|
     * @throws \Throwable
 | 
						|
     */
 | 
						|
    public function unsuspend(ServerWriteRequest $request, Server $server): Response
 | 
						|
    {
 | 
						|
        $this->suspensionService->handle($server, SuspendAction::Unsuspend);
 | 
						|
 | 
						|
        return $this->returnNoContent();
 | 
						|
    }
 | 
						|
 | 
						|
    /**
 | 
						|
     * Mark a server as needing to be reinstalled.
 | 
						|
     *
 | 
						|
     * @throws \App\Exceptions\DisplayException
 | 
						|
     * @throws \App\Exceptions\Model\DataValidationException
 | 
						|
     */
 | 
						|
    public function reinstall(ServerWriteRequest $request, Server $server): Response
 | 
						|
    {
 | 
						|
        $this->reinstallServerService->handle($server);
 | 
						|
 | 
						|
        return $this->returnNoContent();
 | 
						|
    }
 | 
						|
 | 
						|
    /**
 | 
						|
     * Starts a transfer of a server to a new node.
 | 
						|
     */
 | 
						|
    public function startTransfer(ServerWriteRequest $request, Server $server): Response
 | 
						|
    {
 | 
						|
        $validatedData = $request->validate([
 | 
						|
            'node_id' => 'required|exists:nodes,id',
 | 
						|
            'allocation_id' => 'required|bail|unique:servers|exists:allocations,id',
 | 
						|
            'allocation_additional' => 'nullable',
 | 
						|
        ]);
 | 
						|
 | 
						|
        if ($this->transferServerService->handle($server, $validatedData)) {
 | 
						|
            // Transfer started
 | 
						|
            return $this->returnNoContent();
 | 
						|
        }
 | 
						|
 | 
						|
        // Node was not viable
 | 
						|
        return $this->returnNotAcceptable();
 | 
						|
    }
 | 
						|
 | 
						|
    /**
 | 
						|
     * Cancels a transfer of a server to a new node.
 | 
						|
     *
 | 
						|
     * @throws ConnectionException
 | 
						|
     */
 | 
						|
    public function cancelTransfer(ServerWriteRequest $request, Server $server): Response
 | 
						|
    {
 | 
						|
        if (!$transfer = $server->transfer) {
 | 
						|
            // Server is not transferring
 | 
						|
            return $this->returnNotAcceptable();
 | 
						|
        }
 | 
						|
 | 
						|
        $transfer->successful = true;
 | 
						|
        $transfer->save();
 | 
						|
 | 
						|
        $this->daemonServerRepository->setServer($server)->cancelTransfer();
 | 
						|
 | 
						|
        return $this->returnNoContent();
 | 
						|
    }
 | 
						|
}
 |