/repo/pakiety/morsgui/1.0.0/mors-gui-web
drwxr-xr-x 4 bastuser bastuser    46 Feb 13 17:49 ..
-rw-r--r-- 1 bastuser bastuser   565 Feb 13 17:51 cm-mors-gui-web.yaml
-rw-r--r-- 1 bastuser bastuser   380 Feb 13 18:00 Dockerfile
-rw-r--r-- 1 bastuser bastuser 23030 Feb 13 18:18 index.php

apiVersion: v1
kind: ConfigMap
metadata:
  name: cm-mors-gui-web
  namespace: morsgui-prod
data:
  # UI / wykresy
  PAGE_TITLE: "morsusl-gui • mors-gui-web"
  DEFAULT_RANGE_HOURS: "2"     # domyślne okno czasu po wejściu na stronę
  MAX_RANGE_HOURS: "72"        # twardy limit na zakres (żeby nie zajechać DB i frontu)
  MAX_POINTS: "1500"           # downsampling: max punktów na serię
  REFRESH_SECONDS: "10"        # co ile sekund odświeżać (zapisy są co 5s; 10s jest sensowne)
  DEBUG: "0"                   # 1 pokaże trochę info na dole strony

FROM php:8.2-cli-alpine
# Runtime libs dla pdo_pgsql (libpq.so.5)
RUN apk add --no-cache libpq
# Build deps tylko na czas kompilacji rozszerzenia
RUN apk add --no-cache --virtual .build-deps postgresql-dev \
  && docker-php-ext-install pdo_pgsql \
  && apk del .build-deps
WORKDIR /app
COPY index.php /app/index.php
EXPOSE 8080
CMD ["php", "-S", "0.0.0.0:8080", "-t", "/app"]

oc new-project morsgui-prod

# Build binarny z Dockerfile
oc new-build --strategy=docker --binary --name=mors-gui-web-build

cd /repo/pakiety/morsgui/1.0.0/mors-gui-web/
oc start-build mors-gui-web-build --from-dir=. --follow

# ConfigMap web (tuning UI)
oc apply -f cm-mors-gui-web.yaml

# Tworzy deployment+svc z imagestream
oc new-app mors-gui-web-build:latest --name=mors-gui-web

# Wstrzyknij ustawienia UI
oc set env deployment/mors-gui-web --from=configmap/cm-mors-gui-web

# Wstrzyknij dane DB z istniejącej configmapy (TO JEST KLUCZOWE)
oc set env deployment/mors-gui-web --from=configmap/cm-mors-gui-api

# Route (żeby wejść w przeglądarce)
oc -n morsgui-prod create route edge mors-gui-web --service=mors-gui-web --port=8080

# Restart
oc rollout restart deployment/mors-gui-web

# Logi
oc logs -f deployment/mors-gui-web

cd /repo/pakiety/morsgui/1.0.0/mors-gui-web/
oc start-build mors-gui-web-build --from-dir=. --follow
oc -n morsgui-prod rollout restart deployment/mors-gui-web
oc -n morsgui-prod logs -f deployment/mors-gui-web

getTimestamp() - $start->getTimestamp();
    if ($diff > $maxSeconds) {
        $start = $end->sub(new DateInterval('PT' . $maxSeconds . 'S'));
    }
    return [$start, $end];
}

function pdo(): PDO {
    $host = env('DBA_SERVER');
    $port = env('DBA_PORT', '5432');
    $db   = env('DBA_NAME');
    $user = env('DBA_USER');
    $pass = env('DBA_PASSWORD', '');
    $sslmode = env('DBA_SSLMODE', 'prefer'); // disable|allow|prefer|require|verify-ca|verify-full

    if ($host === '' || $db === '' || $user === '') {
        jsonOut([
            'error' => 'Brak wymaganych zmiennych środowiskowych DBA_SERVER/DBA_NAME/DBA_USER (sprawdź cm-mors-gui-api i oc set env).'
        ], 500);
    }

    $dsn = "pgsql:host={$host};port={$port};dbname={$db};sslmode={$sslmode}";

    $pdo = new PDO($dsn, $user, $pass, [
        PDO::ATTR_ERRMODE            => PDO::ERRMODE_EXCEPTION,
        PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
    ]);

    // Wymuś sensowne formaty dat/czasu (opcjonalnie)
    $pdo->exec("SET TIME ZONE 'UTC'");

    return $pdo;
}

function downsampleRows(array $rows, int $maxPoints): array {
    $n = count($rows);
    if ($maxPoints <= 0 || $n <= $maxPoints) return $rows;

    $step = (int)ceil($n / $maxPoints);
    $out = [];
    for ($i = 0; $i < $n; $i += $step) {
        $out[] = $rows[$i];
    }
    return $out;
}

function toIsoUtc(string $ts): string {
    // $ts może mieć mikrosekundy; i tak da się to sparsować
    try {
        $dt = new DateTimeImmutable($ts, new DateTimeZone('UTC'));
    } catch (Throwable) {
        $dt = new DateTimeImmutable('now', new DateTimeZone('UTC'));
    }
    return $dt->setTimezone(new DateTimeZone('UTC'))->format(DateTimeInterface::ATOM);
}

function apiProxmox(DateTimeImmutable $start, DateTimeImmutable $end, int $maxPoints): void {
    $pdo = pdo();
    $stmt = $pdo->prepare("
        SELECT created_at, cpu_usage, cpu_temp_c, sys_load, ram_usage_prc, swap_usage_prc,
               gpu_busy_prc, gpu_temp_c, nvme_temp_c
        FROM proxmox
        WHERE created_at BETWEEN :start AND :end
        ORDER BY created_at ASC
    ");
    $stmt->execute([
        ':start' => $start->format('Y-m-d H:i:sP'),
        ':end'   => $end->format('Y-m-d H:i:sP'),
    ]);

    $rows = $stmt->fetchAll();
    $rows = downsampleRows($rows, $maxPoints);

    $out = [];
    foreach ($rows as $r) {
        $load = [null, null, null];
        if (isset($r['sys_load']) && $r['sys_load'] !== null) {
            // oczekiwany format: "5.87,5.92,6.07"
            $parts = array_map('trim', explode(',', (string)$r['sys_load']));
            for ($i = 0; $i < 3; $i++) {
                if (isset($parts[$i]) && $parts[$i] !== '') {
                    $load[$i] = (float)$parts[$i];
                }
            }
        }

        $out[] = [
            't' => toIsoUtc((string)$r['created_at']),
            'cpu_usage'      => isset($r['cpu_usage']) ? (float)$r['cpu_usage'] : null,
            'cpu_temp_c'     => isset($r['cpu_temp_c']) ? (float)$r['cpu_temp_c'] : null,
            'sys_load_1'      => $load[0],
            'sys_load_5'      => $load[1],
            'sys_load_15'     => $load[2],
            'ram_usage_prc'  => isset($r['ram_usage_prc']) ? (float)$r['ram_usage_prc'] : null,
            'swap_usage_prc' => isset($r['swap_usage_prc']) ? (float)$r['swap_usage_prc'] : null,
            'gpu_busy_prc'   => isset($r['gpu_busy_prc']) ? (float)$r['gpu_busy_prc'] : null,
            'gpu_temp_c'     => isset($r['gpu_temp_c']) ? (float)$r['gpu_temp_c'] : null,
            'nvme_temp_c'    => isset($r['nvme_temp_c']) ? (float)$r['nvme_temp_c'] : null,
        ];
    }

    jsonOut([
        'meta' => [
            'table' => 'proxmox',
            'start' => $start->format(DateTimeInterface::ATOM),
            'end'   => $end->format(DateTimeInterface::ATOM),
            'points' => count($out),
        ],
        'rows' => $out,
    ]);
}

function apiOkd(DateTimeImmutable $start, DateTimeImmutable $end, int $maxPoints): void {
    $pdo = pdo();
    $stmt = $pdo->prepare("
        SELECT created_at,
               compute_1_cpu_prc, compute_2_cpu_prc, compute_3_cpu_prc,
               control_1_cpu_prc, control_2_cpu_prc, control_3_cpu_prc,
               compute_1_ram_prc, compute_2_ram_prc, compute_3_ram_prc,
               control_1_ram_prc, control_2_ram_prc, control_3_ram_prc
        FROM okd
        WHERE created_at BETWEEN :start AND :end
        ORDER BY created_at ASC
    ");
    $stmt->execute([
        ':start' => $start->format('Y-m-d H:i:sP'),
        ':end'   => $end->format('Y-m-d H:i:sP'),
    ]);

    $rows = $stmt->fetchAll();
    $rows = downsampleRows($rows, $maxPoints);

    $out = [];
    foreach ($rows as $r) {
        $out[] = [
            't' => toIsoUtc((string)$r['created_at']),
            'compute_1_cpu_prc' => isset($r['compute_1_cpu_prc']) ? (float)$r['compute_1_cpu_prc'] : null,
            'compute_2_cpu_prc' => isset($r['compute_2_cpu_prc']) ? (float)$r['compute_2_cpu_prc'] : null,
            'compute_3_cpu_prc' => isset($r['compute_3_cpu_prc']) ? (float)$r['compute_3_cpu_prc'] : null,
            'control_1_cpu_prc' => isset($r['control_1_cpu_prc']) ? (float)$r['control_1_cpu_prc'] : null,
            'control_2_cpu_prc' => isset($r['control_2_cpu_prc']) ? (float)$r['control_2_cpu_prc'] : null,
            'control_3_cpu_prc' => isset($r['control_3_cpu_prc']) ? (float)$r['control_3_cpu_prc'] : null,
            'compute_1_ram_prc' => isset($r['compute_1_ram_prc']) ? (float)$r['compute_1_ram_prc'] : null,
            'compute_2_ram_prc' => isset($r['compute_2_ram_prc']) ? (float)$r['compute_2_ram_prc'] : null,
            'compute_3_ram_prc' => isset($r['compute_3_ram_prc']) ? (float)$r['compute_3_ram_prc'] : null,
            'control_1_ram_prc' => isset($r['control_1_ram_prc']) ? (float)$r['control_1_ram_prc'] : null,
            'control_2_ram_prc' => isset($r['control_2_ram_prc']) ? (float)$r['control_2_ram_prc'] : null,
            'control_3_ram_prc' => isset($r['control_3_ram_prc']) ? (float)$r['control_3_ram_prc'] : null,
        ];
    }

    jsonOut([
        'meta' => [
            'table' => 'okd',
            'start' => $start->format(DateTimeInterface::ATOM),
            'end'   => $end->format(DateTimeInterface::ATOM),
            'points' => count($out),
        ],
        'rows' => $out,
    ]);
}

/* ---------------------------
   API mode
----------------------------*/
if (isset($_GET['api'])) {
    $defaultHours = envInt('DEFAULT_RANGE_HOURS', 2);
    $maxRangeHours = envInt('MAX_RANGE_HOURS', 72);
    $maxPoints = envInt('MAX_POINTS', 1500);

    $now = new DateTimeImmutable('now', new DateTimeZone('UTC'));
    $fallbackStart = $now->sub(new DateInterval('PT' . max(1, $defaultHours) . 'H'));

    $start = parseDt($_GET['start'] ?? null, $fallbackStart);
    $end   = parseDt($_GET['end'] ?? null, $now);

    [$start, $end] = clampRange($start, $end, $maxRangeHours);

    $reqMaxPoints = isset($_GET['max_points']) && is_numeric($_GET['max_points']) ? (int)$_GET['max_points'] : $maxPoints;
    $reqMaxPoints = max(200, min($reqMaxPoints, $maxPoints)); // dolny limit, górny limit

    $api = (string)$_GET['api'];
    if ($api === 'proxmox') apiProxmox($start, $end, $reqMaxPoints);
    if ($api === 'okd')     apiOkd($start, $end, $reqMaxPoints);

    jsonOut(['error' => 'Nieznane api. Użyj: ?api=proxmox albo ?api=okd'], 400);
}

/* ---------------------------
   UI mode (HTML)
----------------------------*/
$title = env('PAGE_TITLE', 'morsusl-gui • mors-gui-web');
$defaultHours = envInt('DEFAULT_RANGE_HOURS', 2);
$refreshSec   = envInt('REFRESH_SECONDS', 10);
$maxPoints    = envInt('MAX_POINTS', 1500);
$debug        = envInt('DEBUG', 0);
?>



  
  
  

  
  

  
  
  

  



  

    

      

      

        2 wykresy: proxmox i okd •
        domyślnie ostatnie h • auto-refresh co s • max  punktów na serię
      
    

    

      

        Szybki zakres
        
          Ostatnia 1h
          Ostatnie 2h
          Ostatnie 6h
          Ostatnie 12h
          Ostatnie 24h
          Ostatnie 48h
          Ostatnie 72h
        
      

      

        Od
        
      
      

        Do
        
      

      

        
        auto-refresh
      

      Zastosuj
      Teraz
    
  

  
  

    

      

        

          
Proxmox
          
…
        
        

      

      

      

      
Serie (checkbox = pokaż/ukryj):
      

    
  

  
  

    

      

        

          
OKD
          
…
        
        

      

      

      

      
Serie (checkbox = pokaż/ukryj):
      

    
  

  
  

    DEBUG=1 • DBA_SERVER= • DBA_NAME=