Refactor notifications to new API changes

Gold872 · Jun 25, 2024 · 0f43387 · 0f43387
1 parent 9e8d40c
commit 0f43387
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 4 deletions.
diff --git a/lib/pages/dashboard_page.dart b/lib/pages/dashboard_page.dart
@@ -224,7 +224,7 @@ class _DashboardPageState extends State<DashboardPage> with WindowListener {
     Future(() => _checkForUpdates(notifyIfLatest: false, notifyIfError: false));
 
     _robotNotificationListener = RobotNotificationsListener(
-        connection: ntConnection,
+        ntConnection: widget.ntConnection,
         onNotification: (title, description, icon) {
           setState(() {
             ColorScheme colorScheme = Theme.of(context).colorScheme;

diff --git a/lib/services/nt_connection.dart b/lib/services/nt_connection.dart
@@ -173,7 +173,12 @@ class NTConnection {
   }
 
   NT4Subscription subscribeAll(String topic, [double period = 0.1]) {
-    return _ntClient.subscribeAll(topic, period);
+    return _ntClient.subscribe(
+        topic: topic,
+        options: NT4SubscriptionOptions(
+          periodicRateSeconds: period,
+          all: true,
+        ));
   }
 
   void unSubscribe(NT4Subscription subscription) {

diff --git a/lib/services/robot_notifications_listener.dart b/lib/services/robot_notifications_listener.dart
@@ -8,11 +8,11 @@ import 'package:elastic_dashboard/services/nt_connection.dart';
 
 class RobotNotificationsListener {
   bool _alertFirstRun = true;
-  final NTConnection connection;
+  final NTConnection ntConnection;
   final Function(String title, String description, Icon icon) onNotification;
 
   RobotNotificationsListener({
-    required this.connection,
+    required this.ntConnection,
     required this.onNotification,
   });