mirror of
				https://github.com/pelican-dev/panel.git
				synced 2025-11-04 04:16:52 +01:00 
			
		
		
		
	* fix notify in transfer service * remove magical array * fix phpstan * better validation for allocation_additional and better docs generation * update transfer ui * update request body
		
			
				
	
	
		
			138 lines
		
	
	
		
			3.8 KiB
		
	
	
	
		
			PHP
		
	
	
	
	
	
			
		
		
	
	
			138 lines
		
	
	
		
			3.8 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 Dedoc\Scramble\Attributes\Group;
 | 
						|
use Illuminate\Http\Client\ConnectionException;
 | 
						|
use Illuminate\Http\Response;
 | 
						|
use Illuminate\Support\Arr;
 | 
						|
 | 
						|
#[Group('Server', weight: 4)]
 | 
						|
class ServerManagementController extends ApplicationApiController
 | 
						|
{
 | 
						|
    /**
 | 
						|
     * ServerManagementController constructor.
 | 
						|
     */
 | 
						|
    public function __construct(
 | 
						|
        private ReinstallServerService $reinstallServerService,
 | 
						|
        private SuspensionService $suspensionService,
 | 
						|
        private TransferServerService $transferServerService,
 | 
						|
        private DaemonServerRepository $daemonServerRepository,
 | 
						|
    ) {
 | 
						|
        parent::__construct();
 | 
						|
    }
 | 
						|
 | 
						|
    /**
 | 
						|
     * Suspsend
 | 
						|
     *
 | 
						|
     * 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();
 | 
						|
    }
 | 
						|
 | 
						|
    /**
 | 
						|
     * Unsuspsend
 | 
						|
     *
 | 
						|
     * 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();
 | 
						|
    }
 | 
						|
 | 
						|
    /**
 | 
						|
     * Reinstall
 | 
						|
     *
 | 
						|
     * 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();
 | 
						|
    }
 | 
						|
 | 
						|
    /**
 | 
						|
     * Start transfer
 | 
						|
     *
 | 
						|
     * 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|array',
 | 
						|
            'allocation_additional.*' => 'integer|exists:allocations,id',
 | 
						|
        ]);
 | 
						|
 | 
						|
        if ($this->transferServerService->handle($server, Arr::get($validatedData, 'node_id'), Arr::get($validatedData, 'allocation_id'), Arr::get($validatedData, 'allocation_additional', []))) {
 | 
						|
            /**
 | 
						|
             * Transfer started
 | 
						|
             *
 | 
						|
             * @status 204
 | 
						|
             */
 | 
						|
            return $this->returnNoContent();
 | 
						|
        }
 | 
						|
 | 
						|
        /**
 | 
						|
         * Node was not viable
 | 
						|
         *
 | 
						|
         * @status 406
 | 
						|
         */
 | 
						|
        return $this->returnNotAcceptable();
 | 
						|
    }
 | 
						|
 | 
						|
    /**
 | 
						|
     * Cancel transfer
 | 
						|
     *
 | 
						|
     * 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
 | 
						|
             *
 | 
						|
             * @status 406
 | 
						|
             */
 | 
						|
            return $this->returnNotAcceptable();
 | 
						|
        }
 | 
						|
 | 
						|
        $transfer->successful = true;
 | 
						|
        $transfer->save();
 | 
						|
 | 
						|
        $this->daemonServerRepository->setServer($server)->cancelTransfer();
 | 
						|
 | 
						|
        /**
 | 
						|
         * Transfer cancelled
 | 
						|
         *
 | 
						|
         * @status 204
 | 
						|
         */
 | 
						|
        return $this->returnNoContent();
 | 
						|
    }
 | 
						|
}
 |