Fix multi-WAN speed test reporting (issue #841)

Speed tests were not being reported correctly for multi-WAN setups
because the device-level speedtest-status field was returning zeros.
The data has moved to a new aggregated dashboard API endpoint.

Changes:
- Add GetSpeedTests() and GetSiteSpeedTests() methods to fetch from
  /v2/api/site/{site}/aggregated-dashboard endpoint
- Create SpeedTestResult data structures to capture per-WAN metrics
- Update Prometheus exporter with new speedtest_* metrics per interface
- Update InfluxDB exporter to write speedtest measurements per WAN
- Update Datadog exporter with unifi.speedtest.* metrics per WAN
- Update metrics collection to include speed test data for all sites

Metrics now include labels/tags for:
- wan_interface: Physical interface (eth8, eth9, etc.)
- wan_group: Logical WAN name (WAN, WAN2, etc.)
- site_name: Site identifier
- source: Controller URL

Gracefully handles older controllers without the new API endpoint.

Fixes #841

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>
This commit is contained in:
Cody Lee
2025-12-09 16:46:14 -06:00
parent 9b5dbef869
commit 0ffe6152ab
11 changed files with 157 additions and 12 deletions

View File

@@ -414,6 +414,10 @@ func (u *InfluxUnifi) loopPoints(r report) {
u.switchExport(r, s)
}
for _, st := range m.SpeedTests {
u.switchExport(r, st)
}
for _, s := range r.events().Logs {
u.switchExport(r, s)
}
@@ -460,6 +464,8 @@ func (u *InfluxUnifi) switchExport(r report, v any) { //nolint:cyclop
u.batchAlarms(r, v)
case *unifi.Anomaly:
u.batchAnomaly(r, v)
case *unifi.SpeedTestResult:
u.batchSpeedTest(r, v)
default:
u.LogErrorf("invalid export type: %T", v)
}

View File

@@ -0,0 +1,35 @@
package influxunifi
import (
"github.com/unpoller/unifi/v5"
)
// batchSpeedTest generates Unifi Speed Test datapoints for InfluxDB.
// These points can be passed directly to influx.
func (u *InfluxUnifi) batchSpeedTest(r report, st *unifi.SpeedTestResult) {
if st == nil {
return
}
tags := map[string]string{
"site_name": st.SiteName,
"source": st.SourceName,
"wan_interface": st.InterfaceName,
"wan_group": st.WANNetworkGroup,
"network_conf_id": st.NetworkConfID,
}
fields := map[string]any{
"download_mbps": st.DownloadMbps.Val,
"upload_mbps": st.UploadMbps.Val,
"latency_ms": st.LatencyMs.Val,
"timestamp": st.Time.Val,
}
if st.WANProviderCapabilities != nil {
fields["provider_download_kbps"] = st.WANProviderCapabilities.DownloadKbps.Val
fields["provider_upload_kbps"] = st.WANProviderCapabilities.UploadKbps.Val
}
r.send(&metric{Table: "speedtest", Tags: tags, Fields: fields})
}