187 lines
6.4 KiB
PHP
187 lines
6.4 KiB
PHP
|
||
<?php
|
||
// status_api.php — public, read-only JSON status pulled from OGP Agents.
|
||
// Drop into your OGP panel root. Protect with a token (query: ?token=...).
|
||
// Caches results for 30s to avoid hammering agents.
|
||
|
||
define('IN_OGP', true);
|
||
require_once __DIR__.'/includes/config.inc.php';
|
||
require_once __DIR__.'/includes/functions.php';
|
||
require_once __DIR__.'/includes/lib_remote.php'; // OGPRemoteLibrary
|
||
require_once __DIR__.'/includes/classes/db.php'; // $db
|
||
|
||
/* ========== CONFIG ========== */
|
||
$PUBLIC_TOKEN = 'CHANGE_ME_LONG_RANDOM'; // set a random token and pass ?token=... from the website
|
||
$CACHE_TTL = 30; // seconds
|
||
$LOCATION_MAP = [ // optional: map hostnames/IPs to friendly names
|
||
'nyc.iaregamer.com' => 'NYC',
|
||
'kc.iaregamer.com' => 'KC',
|
||
'kc2.iaregamer.com' => 'KC2',
|
||
'la.iaregamer.com' => 'LA',
|
||
'france.iaregamer.com' => 'France',
|
||
'ireland.iaregamer.com' => 'Ireland',
|
||
'atl.iaregamer.com' => 'Atlanta',
|
||
'lab.iaregamer.com' => 'Lab',
|
||
];
|
||
/* ============================ */
|
||
|
||
if (!isset($_GET['token']) || $_GET['token'] !== $PUBLIC_TOKEN) {
|
||
http_response_code(403);
|
||
header('Content-Type: application/json');
|
||
echo json_encode(['error'=>'forbidden']);
|
||
exit;
|
||
}
|
||
|
||
header('Content-Type: application/json; charset=utf-8');
|
||
|
||
// Simple cache file (panel-local)
|
||
$cache_dir = __DIR__.'/_cache';
|
||
@mkdir($cache_dir, 0775, true);
|
||
$cache_file = $cache_dir.'/status_api.json';
|
||
|
||
if (is_file($cache_file) && (time() - filemtime($cache_file) <= $CACHE_TTL)) {
|
||
readfile($cache_file);
|
||
exit;
|
||
}
|
||
|
||
// Helper: quick TCP test to agent
|
||
function agent_up($ip, $port, $timeout=1.0) {
|
||
$errno=0; $err=''; $s = @fsockopen($ip, (int)$port, $errno, $err, $timeout);
|
||
if ($s) { fclose($s); return true; }
|
||
return false;
|
||
}
|
||
|
||
// Try to pull system stats from the agent using known method names.
|
||
// Different OGP versions/agents expose slightly different method names/keys.
|
||
function fetch_agent_stats($remote) {
|
||
$methods = [
|
||
'get_system_stats', // preferred if available
|
||
'system_stats',
|
||
'get_agent_stats',
|
||
'sysinfo',
|
||
'agent_status',
|
||
'monitor_get_stats',
|
||
];
|
||
foreach ($methods as $m) {
|
||
if (method_exists($remote, $m)) {
|
||
$out = @call_user_func([$remote, $m]);
|
||
if (is_array($out) && !empty($out)) return $out;
|
||
}
|
||
}
|
||
return null;
|
||
}
|
||
|
||
// Normalize various shapes into cpu%, mem%, disk%
|
||
function normalize_stats($raw) {
|
||
$cpu = null; $mem = null; $disk = null;
|
||
|
||
// CPU
|
||
foreach (['cpu_percent','cpu_used','cpu_usage','cpu'] as $k) {
|
||
if (isset($raw[$k]) && is_numeric($raw[$k])) { $cpu = (float)$raw[$k]; break; }
|
||
}
|
||
// Some agents return load avg (0.00–N cores). Convert approx to %
|
||
if ($cpu === null && isset($raw['load'])) {
|
||
$ld = (float)$raw['load']; $cores = (int)@shell_exec('nproc 2>/dev/null') ?: 1;
|
||
$cpu = max(0.0, min(100.0, ($ld / max(1,$cores))*100.0));
|
||
}
|
||
|
||
// MEM
|
||
foreach (['mem_percent','mem_used_percent','memory_percent','mem'] as $k) {
|
||
if (isset($raw[$k]) && is_numeric($raw[$k])) { $mem = (float)$raw[$k]; break; }
|
||
}
|
||
if ($mem === null && isset($raw['mem_used']) && isset($raw['mem_total'])) {
|
||
$u = (float)$raw['mem_used']; $t=(float)$raw['mem_total'];
|
||
if ($t>0) $mem = ($u/$t)*100.0;
|
||
} elseif ($mem === null && isset($raw['mem_free']) && isset($raw['mem_total'])) {
|
||
$f = (float)$raw['mem_free']; $t=(float)$raw['mem_total'];
|
||
if ($t>0) $mem = (1.0 - $f/$t)*100.0;
|
||
}
|
||
|
||
// DISK (pick root or the highest-used mount)
|
||
// Common shapes: disk_percent / hdd_used_percent / arrays with total/free per mount
|
||
foreach (['disk_percent','hdd_used_percent'] as $k) {
|
||
if (isset($raw[$k]) && is_numeric($raw[$k])) { $disk = (float)$raw[$k]; break; }
|
||
}
|
||
if ($disk === null) {
|
||
// try totals
|
||
$candidates = [
|
||
['used'=>'disk_used','total'=>'disk_total'],
|
||
['used'=>'hdd_used','total'=>'hdd_total'],
|
||
['used'=>'fs_used','total'=>'fs_total'],
|
||
];
|
||
foreach ($candidates as $pair) {
|
||
$u = $raw[$pair['used']] ?? null;
|
||
$t = $raw[$pair['total']] ?? null;
|
||
if (is_numeric($u) && is_numeric($t) && $t>0) { $disk = ((float)$u/(float)$t)*100.0; break; }
|
||
}
|
||
// if agent returns array of mounts, pick max %
|
||
if ($disk === null && isset($raw['filesystems']) && is_array($raw['filesystems'])) {
|
||
$mx = null;
|
||
foreach ($raw['filesystems'] as $fs) {
|
||
if (isset($fs['used']) && isset($fs['total']) && $fs['total']>0) {
|
||
$pct = ($fs['used']/$fs['total'])*100.0;
|
||
if ($mx === null || $pct>$mx) $mx = $pct;
|
||
} elseif (isset($fs['percent'])) {
|
||
$mx = max($mx??0, (float)$fs['percent']);
|
||
}
|
||
}
|
||
if ($mx !== null) $disk = $mx;
|
||
}
|
||
}
|
||
|
||
return [
|
||
'cpu_percent' => ($cpu !== null) ? round($cpu,1) : null,
|
||
'mem_percent' => ($mem !== null) ? round($mem,1) : null,
|
||
'disk_percent' => ($disk!== null) ? round($disk,1): null,
|
||
];
|
||
}
|
||
|
||
// Pull remote hosts list (OGP DB)
|
||
$rows = [];
|
||
if (method_exists($db, 'getRemoteServers')) {
|
||
$rows = $db->getRemoteServers();
|
||
} else {
|
||
// Fallback SQL (prefix best-effort)
|
||
$prefix = defined('OGP_DB_PREFIX') ? OGP_DB_PREFIX : (defined('OGP_DB_TABLE_PREFIX') ? OGP_DB_TABLE_PREFIX : 'ogp_');
|
||
$rows = $db->resultQuery("SELECT remote_server_id, hostname, agent_ip, agent_port FROM {$prefix}remote_servers ORDER BY hostname");
|
||
}
|
||
|
||
$out = ['generated_at'=>gmdate('c'), 'nodes'=>[]];
|
||
|
||
foreach ((array)$rows as $h) {
|
||
$agent_ip = $h['agent_ip'] ?? $h['hostname'] ?? '127.0.0.1';
|
||
$agent_port = (int)($h['agent_port'] ?? 12679);
|
||
$label_key = $h['hostname'] ?? $agent_ip;
|
||
$name = $LOCATION_MAP[$label_key] ?? $label_key;
|
||
|
||
$up = agent_up($agent_ip, $agent_port);
|
||
$stats = null;
|
||
|
||
if ($up) {
|
||
try {
|
||
// OGPRemoteLibrary signature normally: (ip, port, encryption_key) — falls back to global if omitted.
|
||
$remote = new OGPRemoteLibrary($agent_ip, $agent_port);
|
||
$raw = fetch_agent_stats($remote);
|
||
if (is_array($raw)) $stats = normalize_stats($raw);
|
||
} catch (Throwable $e) {
|
||
$stats = null;
|
||
}
|
||
}
|
||
|
||
$out['nodes'][] = [
|
||
'name' => $name,
|
||
'host' => $label_key,
|
||
'agent_port' => $agent_port,
|
||
'online' => $up,
|
||
'cpu_percent' => $stats['cpu_percent'] ?? null,
|
||
'mem_percent' => $stats['mem_percent'] ?? null,
|
||
'disk_percent' => $stats['disk_percent'] ?? null,
|
||
];
|
||
}
|
||
|
||
// Cache & print
|
||
$tmp = $cache_file.'.tmp';
|
||
file_put_contents($tmp, json_encode($out, JSON_PRETTY_PRINT|JSON_UNESCAPED_SLASHES));
|
||
@rename($tmp, $cache_file);
|
||
echo json_encode($out, JSON_PRETTY_PRINT|JSON_UNESCAPED_SLASHES);
|
||
|