diff --git a/src/routers/sources.py b/src/routers/sources.py
index ef3522c..7a3f8d7 100644
--- a/src/routers/sources.py
+++ b/src/routers/sources.py
@@ -594,14 +594,25 @@ async def get_health(
"limit": limit, "offset": offset, "has_more": False,
}
- # Aggregate über GESAMTEN Bestand (eine GROUP-BY-Query, billig)
+ # Aggregate über GESAMTEN Bestand. Eine GROUP-BY-Query nach (check_type, status)
+ # liefert sowohl die Top-Counters als auch das feine Breakdown für die UI.
cursor = await db.execute(
- "SELECT status, COUNT(*) AS n FROM source_health_checks GROUP BY status"
+ "SELECT check_type, status, COUNT(*) AS n FROM source_health_checks GROUP BY check_type, status"
)
- counts = {row["status"]: row["n"] for row in await cursor.fetchall()}
- error_count = counts.get("error", 0)
- warning_count = counts.get("warning", 0)
- ok_count = counts.get("ok", 0)
+ breakdown = {} # {check_type: {status: count}}
+ error_count = 0
+ warning_count = 0
+ ok_count = 0
+ for row in await cursor.fetchall():
+ ct = row["check_type"]
+ st = row["status"]
+ breakdown.setdefault(ct, {})[st] = row["n"]
+ if st == "error":
+ error_count += row["n"]
+ elif st == "warning":
+ warning_count += row["n"]
+ elif st == "ok":
+ ok_count += row["n"]
total_checks = error_count + warning_count + ok_count
# Paginierte Daten
@@ -641,6 +652,7 @@ async def get_health(
"errors": error_count,
"warnings": warning_count,
"ok": ok_count,
+ "breakdown": breakdown,
"checks": checks,
"all_orgs": all_orgs,
"limit": limit,
diff --git a/src/static/dashboard.html b/src/static/dashboard.html
index 02fc726..421014e 100644
--- a/src/static/dashboard.html
+++ b/src/static/dashboard.html
@@ -715,7 +715,7 @@
-
+
diff --git a/src/static/js/source-health.js b/src/static/js/source-health.js
index 36c225a..2927c94 100644
--- a/src/static/js/source-health.js
+++ b/src/static/js/source-health.js
@@ -3,7 +3,9 @@
let healthData = null;
let suggestionsCache = [];
-let healthFilters = { status: "", check_type: "", org: "all" };
+// Default-Filter zeigt nur Probleme (errors + warnings); OK ist meistens Rauschen.
+// "issues" ist ein virtueller Status-Wert, den nur das Frontend versteht (siehe applyHealthFilter).
+let healthFilters = { status: "issues", check_type: "", org: "all" };
let healthHistoryCache = [];
// 60-Sekunden-Cache, damit Tab-Wechsel nicht jedes Mal die volle Antwort neu lädt.
@@ -91,7 +93,9 @@ function loadAllHealth() {
function applyHealthFilter(checks) {
return checks.filter(c => {
- if (healthFilters.status && c.status !== healthFilters.status) return false;
+ // "issues" = Sammelfilter für errors + warnings (Default)
+ if (healthFilters.status === "issues" && c.status === "ok") return false;
+ if (healthFilters.status && healthFilters.status !== "issues" && c.status !== healthFilters.status) return false;
if (healthFilters.check_type && c.check_type !== healthFilters.check_type) return false;
if (healthFilters.org === "global" && c.tenant_id !== null) return false;
if (healthFilters.org !== "all" && healthFilters.org !== "global"
@@ -208,6 +212,21 @@ function renderHealthDashboard() {
const checkTypes = Array.from(new Set(allChecks.map(c => c.check_type)));
+ // Counter-Aufgliederung aus Backend-Breakdown (pro check_type x status).
+ // Beispiel: { reachability: {ok: 281, error: 3, warning: 1}, feed_validity: {...}, stale: {...}, duplicate: {...} }
+ const breakdown = healthData.breakdown || {};
+ function breakdownLine(statusKey, cssClass) {
+ const entries = Object.entries(breakdown)
+ .map(([ct, byStatus]) => [ct, byStatus[statusKey] || 0])
+ .filter(([_, n]) => n > 0)
+ .sort((a, b) => b[1] - a[1]);
+ if (entries.length === 0) return "";
+ const total = entries.reduce((s, [, n]) => s + n, 0);
+ const detail = entries.map(([ct, n]) => `${n} ${CHECK_TYPE_LABELS[ct] || ct}`).join(", ");
+ const label = statusKey === "error" ? "Fehler" : (statusKey === "warning" ? "Warnungen" : "OK");
+ return `