70 lines
2.3 KiB
PHP
70 lines
2.3 KiB
PHP
<?php
|
|
|
|
namespace App\Services;
|
|
|
|
use App\Models\WgTrafficSample;
|
|
|
|
/**
|
|
* Turns per-peer cumulative traffic samples into a bucketed aggregate down/up THROUGHPUT series
|
|
* for the dashboard SVG chart. Per peer, consecutive samples give a delta; negative deltas
|
|
* (counter reset on a wg restart) clamp to 0; deltas are summed into time buckets across peers.
|
|
*/
|
|
class WgTraffic
|
|
{
|
|
/**
|
|
* @return array{window:int, points:array<int,array{t:int,down:int,up:int}>,
|
|
* total_down:int, total_up:int, peak_down:int, peak_up:int}
|
|
*/
|
|
public function series(int $windowSeconds, int $buckets = 60): array
|
|
{
|
|
$windowSeconds = max(60, $windowSeconds);
|
|
$buckets = max(1, $buckets);
|
|
$now = time();
|
|
$from = $now - $windowSeconds;
|
|
$width = $windowSeconds / $buckets;
|
|
|
|
$down = array_fill(0, $buckets, 0);
|
|
$up = array_fill(0, $buckets, 0);
|
|
|
|
$rows = WgTrafficSample::query()
|
|
->where('sampled_at', '>=', now()->subSeconds($windowSeconds + (int) ceil($width) + 5))
|
|
->orderBy('peer_pubkey')
|
|
->orderBy('sampled_at')
|
|
->get(['peer_pubkey', 'rx', 'tx', 'sampled_at']);
|
|
|
|
$prev = [];
|
|
foreach ($rows as $r) {
|
|
$pk = $r->peer_pubkey;
|
|
$t = $r->sampled_at->getTimestamp();
|
|
if (isset($prev[$pk])) {
|
|
$dRx = max(0, (int) $r->rx - $prev[$pk]['rx']);
|
|
$dTx = max(0, (int) $r->tx - $prev[$pk]['tx']);
|
|
$idx = (int) floor(($t - $from) / $width);
|
|
if ($idx >= 0 && $idx < $buckets) {
|
|
$down[$idx] += $dRx;
|
|
$up[$idx] += $dTx;
|
|
}
|
|
}
|
|
$prev[$pk] = ['rx' => (int) $r->rx, 'tx' => (int) $r->tx];
|
|
}
|
|
|
|
$points = [];
|
|
for ($i = 0; $i < $buckets; $i++) {
|
|
$points[] = [
|
|
't' => (int) round($from + ($i + 0.5) * $width),
|
|
'down' => $down[$i],
|
|
'up' => $up[$i],
|
|
];
|
|
}
|
|
|
|
return [
|
|
'window' => $windowSeconds,
|
|
'points' => $points,
|
|
'total_down' => array_sum($down),
|
|
'total_up' => array_sum($up),
|
|
'peak_down' => $down === [] ? 0 : max($down),
|
|
'peak_up' => $up === [] ? 0 : max($up),
|
|
];
|
|
}
|
|
}
|