baodev0
5d3ed57b32
- Added methods to ResourceService for fetching resource pools and updated existing methods to include datacenter filtering. - Modified CreateVirtualMachine to accept folder and resource pool parameters from product data. - Updated various jobs to synchronize resource pools and include them in the provisioning process. - Introduced new ModuleResourcePool model and migration for resource pool management. - Enhanced existing models (ModuleDatastore, ModuleNetwork, Os) to include relationships with vCenter and resource pools. - Added netmask field to IpPool and updated related logic for IP reservation. - Improved error handling and logging in VM creation and IP reservation processes. - Updated API routes to include sync functionality for vCenter.
99 lines
3.3 KiB
PHP
99 lines
3.3 KiB
PHP
<?php
|
|
|
|
declare(strict_types=1);
|
|
|
|
namespace App\Services\VirtualMachine;
|
|
|
|
use App\Models\IpPool;
|
|
use App\Models\ModuleIpAddress;
|
|
use Illuminate\Support\Facades\DB;
|
|
use Illuminate\Support\Facades\Log;
|
|
|
|
/**
|
|
* Reserves and releases IPs from ip_pools / module_ip_addresses with row-level locking.
|
|
*
|
|
* Extracted so CreateVirtualMachineJob can pick an IP BEFORE cloning the VM
|
|
* (the IP is baked into the VM name), and AssignIpToGuestJob can later use
|
|
* the same reservation instead of picking its own.
|
|
*/
|
|
class VmIpReservationService
|
|
{
|
|
/**
|
|
* @return array{reservation:ModuleIpAddress,ip_pool_id:int,gateway:string,cidr:int}|null
|
|
*/
|
|
public function reserve(int $networkId, int $hostId, string $dns): ?array
|
|
{
|
|
return DB::transaction(function () use ($networkId, $hostId, $dns) {
|
|
// ip_pools.status is the single source of truth for availability.
|
|
$ipPool = IpPool::where('module_network_id', $networkId)
|
|
->whereIn('status', ['free', 'reserved'])
|
|
->lockForUpdate()
|
|
->inRandomOrder()
|
|
->first();
|
|
|
|
if (!$ipPool) {
|
|
return null;
|
|
}
|
|
|
|
$ipPool->update(['status' => 'reserved']);
|
|
|
|
$cidr = (int) ($ipPool->cidr ?: 24);
|
|
$gateway = (string) ($ipPool->gateway ?? '');
|
|
$netmask = $ipPool->netmask ?: $this->cidrToNetmask($cidr);
|
|
|
|
// module_ip_address mirrors ip_pools — update the existing synced row
|
|
// (created when the IP was added to ip_pools) instead of inserting a new one.
|
|
$reservation = ModuleIpAddress::where('ip', $ipPool->ip_address)
|
|
->where('module_network_id', $networkId)
|
|
->lockForUpdate()
|
|
->first();
|
|
|
|
$attrs = [
|
|
'vm_name' => '__pending__',
|
|
'module_host_id' => $hostId,
|
|
'module_network_id' => $networkId,
|
|
'ip' => $ipPool->ip_address,
|
|
'gateway' => $gateway,
|
|
'netmask' => $netmask,
|
|
'dns' => $dns,
|
|
'status' => 0,
|
|
];
|
|
|
|
if ($reservation) {
|
|
$reservation->update($attrs);
|
|
} else {
|
|
$reservation = ModuleIpAddress::create($attrs);
|
|
}
|
|
|
|
return [
|
|
'reservation' => $reservation,
|
|
'ip_pool_id' => $ipPool->id,
|
|
'gateway' => $gateway,
|
|
'cidr' => $cidr,
|
|
];
|
|
});
|
|
}
|
|
|
|
public function release(ModuleIpAddress $reservation, ?int $ipPoolId): void
|
|
{
|
|
try {
|
|
$reservation->update(['vm_name' => null, 'status' => 0]);
|
|
if ($ipPoolId) {
|
|
IpPool::where('id', $ipPoolId)->update(['status' => 'free']);
|
|
}
|
|
Log::info('VmIpReservationService: IP released', ['ip' => $reservation->ip]);
|
|
} catch (\Throwable $e) {
|
|
Log::warning('VmIpReservationService: release failed', [
|
|
'ip' => $reservation->ip,
|
|
'error' => $e->getMessage(),
|
|
]);
|
|
}
|
|
}
|
|
|
|
public function cidrToNetmask(int $cidr): string
|
|
{
|
|
$cidr = max(0, min(32, $cidr));
|
|
return long2ip(-1 << (32 - $cidr));
|
|
}
|
|
}
|