feat: enhance dashboard and engine functionality with improved notification handling, alert history management, and navigation integration

Author: AsieduDevelopmentHub

dashboard/lib/main.dart

@@ -1,15 +1,24 @@
 import 'package:flutter/material.dart';
+import 'package:flutter_local_notifications/flutter_local_notifications.dart';
 import 'package:provider/provider.dart';
 import 'package:sentracore_dashboard/providers/engine_provider.dart';
 import 'package:sentracore_dashboard/providers/settings_provider.dart';
+import 'package:sentracore_dashboard/navigation/dashboard_navigation.dart';
 import 'package:sentracore_dashboard/screens/dashboard_screen.dart';
 import 'package:sentracore_dashboard/services/desktop_notification_service.dart';
 import 'package:sentracore_dashboard/theme/app_theme.dart';
 
 Future<void> main() async {
   WidgetsFlutterBinding.ensureInitialized();
   final notifications = DesktopNotificationService();
-  await notifications.init();
+  await notifications.init(
+    onDidReceiveNotificationResponse: (response) {
+      if (response.notificationResponseType ==
+          NotificationResponseType.selectedNotification) {
+        DashboardNavigation.openAlertsFromNotification();
+      }
+    },
+  );
   final settings = SettingsProvider();
   await settings.load();
   runApp(SentraCoreApp(

dashboard/lib/models/system_state.dart

@@ -251,12 +251,18 @@ class AlertInfo {
           json['last_alert'] != null && json['last_alert']['root_cause'] != null
               ? RootCauseAnalysis.fromJson(json['last_alert']['root_cause'])
               : null,
-      recentAlerts: recent is List
-          ? recent
-              .whereType<Map>()
-              .map((e) => AlertRecord.fromJson(Map<String, dynamic>.from(e)))
-              .toList()
-          : const [],
+      recentAlerts: () {
+        if (recent is! List) return const <AlertRecord>[];
+        final out = <AlertRecord>[];
+        for (final e in recent) {
+          if (e is Map<String, dynamic>) {
+            out.add(AlertRecord.fromJson(e));
+          } else if (e is Map) {
+            out.add(AlertRecord.fromJson(Map<String, dynamic>.from(e)));
+          }
+        }
+        return out;
+      }(),
     );
   }
 }

dashboard/lib/navigation/dashboard_navigation.dart

@@ -0,0 +1,19 @@
+import 'package:flutter/scheduler.dart';
+
+/// Registered by [DashboardScreen] / [DiagnosticsScreen] for cross-widget jumps.
+class DashboardNavigation {
+  DashboardNavigation._();
+
+  /// Switch main rail: 0 Overview … 3 Diagnostics … 4 Settings.
+  static void Function(int index)? selectMainTab;
+
+  /// Switches Diagnostics inner tab to "Alerts & RCA" (index 1).
+  static VoidCallback? focusDiagnosticsAlertsTab;
+
+  static void openAlertsFromNotification() {
+    selectMainTab?.call(3);
+    SchedulerBinding.instance.addPostFrameCallback((_) {
+      focusDiagnosticsAlertsTab?.call();
+    });
+  }
+}

dashboard/lib/providers/engine_provider.dart

@@ -76,6 +76,27 @@ class EngineProvider extends ChangeNotifier {
   List<SystemEvent> _events = [];
   List<SystemEvent> get events => _events;
 
+  /// Each [/ws/alerts] push (one per fired alert). Merged with engine [recent_alerts] for UI.
+  static const int _maxAlertFeed = 120;
+  final List<AlertRecord> _alertFeedFromWs = [];
+
+  /// Newest-first list for Diagnostics; deduped against live state history.
+  List<AlertRecord> get mergedAlertHistory {
+    final fromEngine =
+        _currentState?.alert.recentAlerts ?? const <AlertRecord>[];
+    final seen = <String>{};
+    String dedupeKey(AlertRecord r) =>
+        '${r.timestamp.toStringAsFixed(3)}::${r.message}';
+    final merged = <AlertRecord>[];
+    for (final r in [..._alertFeedFromWs, ...fromEngine]) {
+      if (seen.add(dedupeKey(r))) {
+        merged.add(r);
+      }
+    }
+    merged.sort((a, b) => b.timestamp.compareTo(a.timestamp));
+    return merged;
+  }
+
   // ── Subscriptions ──
   StreamSubscription? _liveSub;
   StreamSubscription? _alertSub;
@@ -96,6 +117,7 @@ class EngineProvider extends ChangeNotifier {
   }
 
   Future<void> reconnect() async {
+    _alertFeedFromWs.clear();
     _liveSub?.cancel();
     _alertSub?.cancel();
     _processFetchTimer?.cancel();
@@ -208,6 +230,12 @@ class EngineProvider extends ChangeNotifier {
   }
 
   void _onAlertPayload(Map<String, dynamic> payload) {
+    try {
+      _alertFeedFromWs.insert(0, AlertRecord.fromJson(payload));
+      if (_alertFeedFromWs.length > _maxAlertFeed) {
+        _alertFeedFromWs.removeRange(_maxAlertFeed, _alertFeedFromWs.length);
+      }
+    } catch (_) {}
     final message = payload['message'] as String? ?? 'System stress alert';
     if (_settings.desktopNotificationsEnabled) {
       unawaited(_notifications.show(
@@ -216,6 +244,7 @@ class EngineProvider extends ChangeNotifier {
             message.length > 256 ? '${message.substring(0, 253)}...' : message,
       ));
     }
+    notifyListeners();
   }
 
   void _syncCooldownTicker(SystemState state) {

dashboard/lib/screens/dashboard_screen.dart

@@ -1,5 +1,6 @@
 import 'package:flutter/material.dart';
 import 'package:provider/provider.dart';
+import 'package:sentracore_dashboard/navigation/dashboard_navigation.dart';
 import 'package:sentracore_dashboard/providers/engine_provider.dart';
 import 'package:sentracore_dashboard/screens/overview_screen.dart';
 import 'package:sentracore_dashboard/screens/performance_screen.dart';
@@ -22,6 +23,21 @@ class _DashboardScreenState extends State<DashboardScreen> {
   int _selectedIndex = 0;
   bool _navExpanded = false;
 
+  @override
+  void initState() {
+    super.initState();
+    DashboardNavigation.selectMainTab = (i) {
+      if (!mounted) return;
+      setState(() => _selectedIndex = i.clamp(0, 4));
+    };
+  }
+
+  @override
+  void dispose() {
+    DashboardNavigation.selectMainTab = null;
+    super.dispose();
+  }
+
   static const _pages = [
     OverviewScreen(),
     PerformanceScreen(),

dashboard/lib/screens/diagnostics_screen.dart

@@ -1,6 +1,7 @@
 import 'package:flutter/material.dart';
 import 'package:provider/provider.dart';
 import 'package:sentracore_dashboard/models/system_state.dart';
+import 'package:sentracore_dashboard/navigation/dashboard_navigation.dart';
 import 'package:sentracore_dashboard/providers/engine_provider.dart';
 import 'package:sentracore_dashboard/theme/app_theme.dart';
 import 'package:sentracore_dashboard/widgets/responsive_builder.dart';
@@ -18,14 +19,21 @@ class _DiagnosticsScreenState extends State<DiagnosticsScreen>
   late final TabController _tabController;
   String _eventSeverityFilter = 'all';
 
+  void _focusAlertsTab() {
+    if (!mounted || _tabController.length < 2) return;
+    _tabController.animateTo(1);
+  }
+
   @override
   void initState() {
     super.initState();
     _tabController = TabController(length: 2, vsync: this);
+    DashboardNavigation.focusDiagnosticsAlertsTab = _focusAlertsTab;
   }
 
   @override
   void dispose() {
+    DashboardNavigation.focusDiagnosticsAlertsTab = null;
     _tabController.dispose();
     super.dispose();
   }
@@ -369,7 +377,7 @@ class _AlertsRcaTab extends StatelessWidget {
     }
 
     final rca = alert.lastRootCause;
-    final history = alert.recentAlerts;
+    final history = provider.mergedAlertHistory;
 
     return SingleChildScrollView(
       padding: const EdgeInsets.all(16),

dashboard/lib/services/desktop_notification_service.dart

@@ -1,7 +1,14 @@
 import 'dart:io' show Platform;
 
 import 'package:flutter/foundation.dart' show kIsWeb;
-import 'package:flutter_local_notifications/flutter_local_notifications.dart';
+import 'package:flutter_local_notifications/flutter_local_notifications.dart'
+    show
+        FlutterLocalNotificationsPlugin,
+        InitializationSettings,
+        NotificationResponse,
+        WindowsInitializationSettings,
+        WindowsNotificationDetails,
+        NotificationDetails;
 
 /// Windows toast-style alerts via flutter_local_notifications.
 class DesktopNotificationService {
@@ -11,7 +18,10 @@ class DesktopNotificationService {
       FlutterLocalNotificationsPlugin();
   bool _ready = false;
 
-  Future<void> init() async {
+  Future<void> init({
+    void Function(NotificationResponse response)?
+        onDidReceiveNotificationResponse,
+  }) async {
     if (kIsWeb || !Platform.isWindows) {
       _ready = false;
       return;
@@ -25,6 +35,7 @@ class DesktopNotificationService {
             guid: 'c3d4e5f6-a7b8-4c9d-0e1f-223344556677',
           ),
         ),
+        onDidReceiveNotificationResponse: onDidReceiveNotificationResponse,
       );
       _ready = true;
     } catch (_) {

engine/alerts/alert_manager.py

@@ -50,6 +50,15 @@ def to_dict(self) -> dict:
             "root_cause": self.root_cause,
         }
 
+    def to_summary_dict(self) -> dict:
+        """Compact form for live-state history lists (smaller WebSocket payloads)."""
+        return {
+            "timestamp": self.timestamp,
+            "stress_score": round(self.stress_score, 2),
+            "level": self.level,
+            "message": self.message,
+        }
+
 
 AlertCallback = Callable[["Alert"], None]
 

engine/config.py

@@ -132,7 +132,7 @@ def _writable_datastore_dir() -> Path:
 
 # Drop a PID from the tracker after this many snapshots without appearing in
 # the collector's top-N process list (exited, or fell out of the top list).
-PROCESS_MISS_SNAPSHOTS_BEFORE_PRUNE: int = 5
+PROCESS_MISS_SNAPSHOTS_BEFORE_PRUNE: int = 1
 
 # ---------------------------------------------------------------------------
 # Event Logger

engine/main.py

@@ -122,7 +122,8 @@ def get_current_state(self) -> dict:
                 "consecutive_high": self.alert_manager.consecutive_high_count,
                 "last_alert": self._last_alert.to_dict() if self._last_alert else None,
                 "recent_alerts": [
-                    a.to_dict() for a in self.alert_manager.get_recent_alerts(30)
+                    a.to_summary_dict()
+                    for a in self.alert_manager.get_recent_alerts(50)
                 ],
             },
             "buffers": {
@@ -206,6 +207,37 @@ def set_user_preferences(self, body: dict) -> dict:
             return {"ok": False, "error": str(exc)}
         return {"ok": True, "preferences": prefs.to_dict()}
 
+    @staticmethod
+    def _safeguard_target_keys(names: list[str]) -> set[str]:
+        """Expand user-entered / UI-picked names for loose matching to psutil names."""
+        out: set[str] = set()
+        for raw in names:
+            s = str(raw).strip().lower()
+            if not s:
+                continue
+            out.add(canonical_process_name(s))
+            out.add(s)
+            base = s.removesuffix(".exe")
+            out.add(base)
+            out.add(f"{base}.exe")
+        return {x for x in out if x}
+
+    @staticmethod
+    def _process_name_matches_safeguard(process_name: str, targets: set[str]) -> bool:
+        p = process_name.strip().lower()
+        if not p:
+            return False
+        if canonical_process_name(process_name) in targets:
+            return True
+        if p in targets:
+            return True
+        base = p.removesuffix(".exe")
+        if base in targets:
+            return True
+        if f"{base}.exe" in targets:
+            return True
+        return False
+
     def _apply_safeguard(
         self,
         prefs: UserPreferences,
@@ -219,11 +251,7 @@ def _apply_safeguard(
         """
         if not prefs.safeguard_enabled:
             return
-        targets = {
-            canonical_process_name(str(n))
-            for n in prefs.safeguard_process_names
-            if str(n).strip()
-        }
+        targets = self._safeguard_target_keys(prefs.safeguard_process_names)
         if not targets:
             return
 
@@ -241,8 +269,7 @@ def _apply_safeguard(
 
         terminated = 0
         for pid, name in ordered:
-            key = canonical_process_name(name)
-            if key not in targets:
+            if not self._process_name_matches_safeguard(name, targets):
                 continue
             res = self.process_action(pid, "terminate")
             if res.get("ok"):