feat: IoT Admin Stats page — /iot-admin (v0.1.70)

- GET /iot-admin — HTML страница администратора (go:embed) - GET /iot-admin/stats — JSON API с данными (Bearer ADMIN_STATS_TOKEN) - Источники: Kafka consumer lag, K8s pod statuses, PostgreSQL per-tenant stats - Авторизация: ADMIN_STATS_TOKEN env var - Auto-refresh каждые 30 секунд - Nubes brand style
2026-04-06 19:14:57 +03:00
parent 69451007f6
commit 7220fe5b8b
8 changed files with 906 additions and 9 deletions
@@ -225,6 +225,99 @@ func (s *IoTPostgresStore) QueryTelemetry(ctx context.Context, namespace, device
 	return result, rows.Err()
 }

+// TenantPGStats — статистика телеметрии одного tenant за разные периоды.
+type TenantPGStats struct {
+	Namespace string         `json:"namespace"`
+	DBName    string         `json:"db_name"`
+	Total     int64          `json:"total"`
+	Last1h    int64          `json:"last_1h"`
+	Last24h   int64          `json:"last_24h"`
+	Latest    []TelemetryRow `json:"latest"`
+	Error     string         `json:"error,omitempty"`
+}
+
+// PostgresAdminStats — агрегированная статистика по всем tenant для страницы администратора.
+type PostgresAdminStats struct {
+	Tenants   []TenantPGStats `json:"tenants"`
+	TotalAll  int64           `json:"total_all"`
+	Reachable bool            `json:"reachable"`
+}
+
+// GetAdminStats собирает статистику по всем tenant из management DB.
+// Используется только страницей администратора — не для tenant API.
+func (s *IoTPostgresStore) GetAdminStats(ctx context.Context) (*PostgresAdminStats, error) {
+	// Список всех тенантов из management DB
+	nsRows, err := s.adminDB.QueryContext(ctx, `SELECT namespace FROM tenant_credentials ORDER BY namespace`)
+	if err != nil {
+		return nil, fmt.Errorf("iotpg: list tenants: %w", err)
+	}
+	defer nsRows.Close()
+
+	var namespaces []string
+	for nsRows.Next() {
+		var ns string
+		if err := nsRows.Scan(&ns); err != nil {
+			return nil, err
+		}
+		namespaces = append(namespaces, ns)
+	}
+	if err := nsRows.Err(); err != nil {
+		return nil, err
+	}
+
+	result := &PostgresAdminStats{
+		Reachable: true,
+		Tenants:   make([]TenantPGStats, 0, len(namespaces)),
+	}
+
+	for _, ns := range namespaces {
+		stats := TenantPGStats{
+			Namespace: ns,
+			DBName:    tenantDBName(ns),
+		}
+
+		tenantDB, err := s.getTenantDB(ctx, ns)
+		if err != nil {
+			stats.Error = err.Error()
+			result.Tenants = append(result.Tenants, stats)
+			continue
+		}
+
+		// Counts: total, last 1h, last 24h — одним запросом
+		err = tenantDB.QueryRowContext(ctx, `
+SELECT
+  COUNT(*),
+  COUNT(*) FILTER (WHERE ts > NOW() - INTERVAL '1 hour'),
+  COUNT(*) FILTER (WHERE ts > NOW() - INTERVAL '24 hours')
+FROM iot_telemetry`).Scan(&stats.Total, &stats.Last1h, &stats.Last24h)
+		if err != nil {
+			stats.Error = err.Error()
+			result.Tenants = append(result.Tenants, stats)
+			continue
+		}
+		result.TotalAll += stats.Total
+
+		// Последние 5 сообщений для предпросмотра
+		latestRows, err := tenantDB.QueryContext(ctx,
+			`SELECT id, device_id, ts, payload FROM iot_telemetry ORDER BY ts DESC LIMIT 5`)
+		if err == nil {
+			defer latestRows.Close()
+			for latestRows.Next() {
+				var r TelemetryRow
+				var rawPayload []byte
+				if err := latestRows.Scan(&r.ID, &r.DeviceID, &r.Ts, &rawPayload); err == nil {
+					r.Payload = json.RawMessage(rawPayload)
+					stats.Latest = append(stats.Latest, r)
+				}
+			}
+		}
+
+		result.Tenants = append(result.Tenants, stats)
+	}
+
+	return result, nil
+}
+
 // isDBNotExistErr проверяет что ошибка — «database does not exist» (PostgreSQL code 3D000).
 // Используется в QueryTelemetry: если DB нет — просто нет данных, не ошибка системы.
 func isDBNotExistErr(err error) bool {