172 lines
7.8 KiB
PHP
172 lines
7.8 KiB
PHP
<?php
|
|
|
|
namespace Paymenter\Extensions\Servers\Proxmox\Console\Commands;
|
|
|
|
use Illuminate\Console\Command;
|
|
use Paymenter\Extensions\Servers\Proxmox\Models\Server;
|
|
use Paymenter\Extensions\Servers\Proxmox\Models\ServerStatistics;
|
|
use Paymenter\Extensions\Servers\Proxmox\Proxmox;
|
|
|
|
class PollServerStatistics extends Command
|
|
{
|
|
/**
|
|
* The name and signature of the console command.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $signature = 'proxmox:poll-statistics';
|
|
|
|
/**
|
|
* The console command description.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $description = 'Poll Proxmox server statistics hourly (runs in background)';
|
|
|
|
/**
|
|
* Execute the console command.
|
|
*/
|
|
public function handle(): void
|
|
{
|
|
// Poll all servers regardless of status or power condition
|
|
$servers = Server::all();
|
|
$this->info('Polling statistics for ' . $servers->count() . ' servers...');
|
|
|
|
$successCount = 0;
|
|
$errorCount = 0;
|
|
$maxAutomaticStatistics = 24;
|
|
|
|
foreach ($servers as $server) {
|
|
try {
|
|
$proxmox = new Proxmox;
|
|
$status = $proxmox->request(
|
|
'/nodes/' . $server->node->name . '/qemu/' . $server->vm_id . '/status/current'
|
|
)->json()['data'] ?? null;
|
|
|
|
if ($status) {
|
|
// Get disk I/O from rrddata (latest point)
|
|
$diskRead = 0;
|
|
$diskWrite = 0;
|
|
$diskUsed = $status['disk'] ?? 0;
|
|
$diskMax = $status['maxdisk'] ?? 0;
|
|
|
|
try {
|
|
$rrdData = $proxmox->request(
|
|
'/nodes/' . $server->node->name . '/qemu/' . $server->vm_id . '/rrddata',
|
|
'get',
|
|
['timeframe' => 'hour', 'cf' => 'AVERAGE']
|
|
)->json()['data'] ?? null;
|
|
|
|
if ($rrdData && is_array($rrdData) && count($rrdData) > 0) {
|
|
$latest = end($rrdData);
|
|
$diskRead = (int)($latest['diskread'] ?? 0);
|
|
$diskWrite = (int)($latest['diskwrite'] ?? 0);
|
|
}
|
|
} catch (\Throwable $e) {
|
|
// If rrddata fails, continue with 0 values
|
|
}
|
|
|
|
// Always try to get diskmax from VM config (more reliable than status endpoint)
|
|
// The status endpoint may not return maxdisk, especially if guest agent is not enabled
|
|
try {
|
|
$config = $proxmox->request(
|
|
'/nodes/' . $server->node->name . '/qemu/' . $server->vm_id . '/config'
|
|
)->json()['data'] ?? null;
|
|
|
|
if ($config) {
|
|
// Try to find disk configuration (scsi0, virtio0, sata0, ide0, scsi1, etc.)
|
|
$diskKeys = ['scsi0', 'scsi1', 'scsi2', 'virtio0', 'virtio1', 'virtio2', 'sata0', 'sata1', 'sata2', 'ide0', 'ide1', 'ide2'];
|
|
$totalDiskSize = 0;
|
|
|
|
foreach ($diskKeys as $diskKey) {
|
|
if (isset($config[$diskKey])) {
|
|
// Parse disk size from format like "local-lvm:vm-100-disk-0,size=32G"
|
|
$diskConfig = $config[$diskKey];
|
|
if (preg_match('/size=(\d+)([TGMK]?)/i', $diskConfig, $matches)) {
|
|
$size = (int)$matches[1];
|
|
$unit = strtoupper($matches[2] ?? 'G');
|
|
|
|
// Convert to bytes
|
|
switch ($unit) {
|
|
case 'T':
|
|
$totalDiskSize += $size * 1024 * 1024 * 1024 * 1024;
|
|
break;
|
|
case 'G':
|
|
$totalDiskSize += $size * 1024 * 1024 * 1024;
|
|
break;
|
|
case 'M':
|
|
$totalDiskSize += $size * 1024 * 1024;
|
|
break;
|
|
case 'K':
|
|
$totalDiskSize += $size * 1024;
|
|
break;
|
|
default:
|
|
$totalDiskSize += $size * 1024 * 1024 * 1024; // Default to GB
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
// Use config disk size if we found it, otherwise keep status value
|
|
if ($totalDiskSize > 0) {
|
|
$diskMax = $totalDiskSize;
|
|
}
|
|
}
|
|
} catch (\Throwable $e) {
|
|
// If config fetch fails, continue with status value
|
|
}
|
|
|
|
// Create the new automatic statistic
|
|
ServerStatistics::create([
|
|
'server_id' => $server->id,
|
|
'netin' => $status['netin'] ?? 0,
|
|
'netout' => $status['netout'] ?? 0,
|
|
'diskread' => $diskRead,
|
|
'diskwrite' => $diskWrite,
|
|
'diskused' => $diskUsed,
|
|
'diskmax' => $diskMax,
|
|
'memoryused' => $status['mem'] ?? 0,
|
|
'memorymax' => $status['maxmem'] ?? 0,
|
|
'cpuused' => $status['cpu'] ?? 0,
|
|
'cpumax' => 1.0, // CPU max is typically 1.0 (100%)
|
|
'uptime' => $status['uptime'] ?? 0,
|
|
'vmstatus' => $status['status'] ?? null,
|
|
'DateTime' => now(),
|
|
'is_automatic' => true,
|
|
]);
|
|
|
|
// Maintain maximum of 24 automatic statistics per server
|
|
// Remove oldest automatic statistics if limit is exceeded
|
|
$automaticStatsCount = ServerStatistics::where('server_id', $server->id)
|
|
->where('is_automatic', true)
|
|
->count();
|
|
|
|
if ($automaticStatsCount > $maxAutomaticStatistics) {
|
|
$excessCount = $automaticStatsCount - $maxAutomaticStatistics;
|
|
$oldestStats = ServerStatistics::where('server_id', $server->id)
|
|
->where('is_automatic', true)
|
|
->orderBy('DateTime', 'asc')
|
|
->limit($excessCount)
|
|
->get();
|
|
|
|
foreach ($oldestStats as $oldStat) {
|
|
$oldStat->delete();
|
|
}
|
|
}
|
|
|
|
$successCount++;
|
|
} else {
|
|
$this->warn('No status data for server ID: ' . $server->id);
|
|
$errorCount++;
|
|
}
|
|
} catch (\Throwable $e) {
|
|
$this->error('Error polling server ID ' . $server->id . ': ' . $e->getMessage());
|
|
$errorCount++;
|
|
}
|
|
}
|
|
|
|
$this->info('Statistics polling completed. Success: ' . $successCount . ', Errors: ' . $errorCount);
|
|
}
|
|
}
|
|
|