mirror of
				https://github.com/pelican-dev/panel.git
				synced 2025-11-01 00:46:52 +01:00 
			
		
		
		
	 9c3f47590c
			
		
	
	
		9c3f47590c
		
			
		
	
	
	
	
		
			
			* 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();
 | |
|     }
 | |
| }
 |