115 lines
4.4 KiB
PHP
115 lines
4.4 KiB
PHP
<?php
|
|
|
|
namespace Pterodactyl\Http\Controllers\Admin\Servers;
|
|
|
|
use Carbon\CarbonImmutable;
|
|
use Illuminate\Http\Request;
|
|
use Pterodactyl\Models\Node;
|
|
use Pterodactyl\Models\Server;
|
|
use Illuminate\Http\RedirectResponse;
|
|
use Prologue\Alerts\AlertsMessageBag;
|
|
use Pterodactyl\Models\ServerTransfer;
|
|
use Illuminate\Database\ConnectionInterface;
|
|
use Pterodactyl\Http\Controllers\Controller;
|
|
use Pterodactyl\Services\Nodes\NodeJWTService;
|
|
use Pterodactyl\Repositories\Wings\DaemonTransferRepository;
|
|
use Pterodactyl\Contracts\Repository\AllocationRepositoryInterface;
|
|
|
|
class ServerTransferController extends Controller
|
|
{
|
|
/**
|
|
* ServerTransferController constructor.
|
|
*/
|
|
public function __construct(
|
|
private AlertsMessageBag $alert,
|
|
private AllocationRepositoryInterface $allocationRepository,
|
|
private ConnectionInterface $connection,
|
|
private DaemonTransferRepository $daemonTransferRepository,
|
|
private NodeJWTService $nodeJWTService
|
|
) {
|
|
}
|
|
|
|
/**
|
|
* Starts a transfer of a server to a new node.
|
|
*
|
|
* @throws \Throwable
|
|
*/
|
|
public function transfer(Request $request, Server $server): RedirectResponse
|
|
{
|
|
$validatedData = $request->validate([
|
|
'node_id' => 'required|exists:nodes,id',
|
|
'allocation_id' => 'required|bail|unique:servers|exists:allocations,id',
|
|
'allocation_additional' => 'nullable',
|
|
]);
|
|
|
|
$node_id = $validatedData['node_id'];
|
|
$allocation_id = intval($validatedData['allocation_id']);
|
|
$additional_allocations = array_map('intval', $validatedData['allocation_additional'] ?? []);
|
|
|
|
// Check if the node is viable for the transfer.
|
|
$node = Node::query()->findOrFail($node_id);
|
|
if (!$node->isViable($server->memory, $server->disk)) {
|
|
$this->alert->danger(trans('admin/server.alerts.transfer_not_viable'))->flash();
|
|
|
|
return redirect()->route('admin.servers.view.manage', $server->id);
|
|
}
|
|
|
|
$server->validateTransferState();
|
|
|
|
$this->connection->transaction(function () use ($server, $node_id, $allocation_id, $additional_allocations) {
|
|
$transfer = new ServerTransfer();
|
|
|
|
$transfer->server_id = $server->id;
|
|
$transfer->old_node = $server->node_id;
|
|
$transfer->new_node = $node_id;
|
|
$transfer->old_allocation = $server->allocation_id;
|
|
$transfer->new_allocation = $allocation_id;
|
|
$transfer->old_additional_allocations = $server->allocations->where('id', '!=', $server->allocation_id)->pluck('id')->all();
|
|
$transfer->new_additional_allocations = $additional_allocations;
|
|
|
|
$transfer->save();
|
|
|
|
// Add the allocations to the server, so they cannot be automatically assigned while the transfer is in progress.
|
|
$this->assignAllocationsToServer($server, $node_id, $allocation_id, $additional_allocations);
|
|
|
|
// Generate a token for the destination node that the source node can use to authenticate with.
|
|
$token = $this->nodeJWTService
|
|
->setExpiresAt(CarbonImmutable::now()->addMinutes(15))
|
|
->setSubject($server->uuid)
|
|
->handle($transfer->newNode, $server->uuid, 'sha256');
|
|
|
|
// Notify the source node of the pending outgoing transfer.
|
|
$this->daemonTransferRepository->setServer($server)->notify($transfer->newNode, $token);
|
|
|
|
return $transfer;
|
|
});
|
|
|
|
$this->alert->success(trans('admin/server.alerts.transfer_started'))->flash();
|
|
|
|
return redirect()->route('admin.servers.view.manage', $server->id);
|
|
}
|
|
|
|
/**
|
|
* Assigns the specified allocations to the specified server.
|
|
*/
|
|
private function assignAllocationsToServer(Server $server, int $node_id, int $allocation_id, array $additional_allocations)
|
|
{
|
|
$allocations = $additional_allocations;
|
|
$allocations[] = $allocation_id;
|
|
|
|
$unassigned = $this->allocationRepository->getUnassignedAllocationIds($node_id);
|
|
|
|
$updateIds = [];
|
|
foreach ($allocations as $allocation) {
|
|
if (!in_array($allocation, $unassigned)) {
|
|
continue;
|
|
}
|
|
|
|
$updateIds[] = $allocation;
|
|
}
|
|
|
|
if (!empty($updateIds)) {
|
|
$this->allocationRepository->updateWhereIn('id', $updateIds, ['server_id' => $server->id]);
|
|
}
|
|
}
|
|
}
|