chore: 🐛 Fix Oracle subscription

.dart_tool/extension_discovery/vs_code.json

@@ -1 +1 @@
-{"version":2,"entries":[{"package":"archethic_dapp_framework_flutter","rootUri":"../","packageUri":"lib/"}]}
+{"version":2,"entries":[{"package":"archethic_dapp_framework_flutter","rootUri":"../","packageUri":"lib/"},{"package":"flutter_gen","rootUri":"flutter_gen/","packageUri":"flutter_gen/"}]}

lib/src/application/oracle/provider.dart

@@ -1,47 +1,62 @@
 /// SPDX-License-Identifier: AGPL-3.0-or-later
+
 import 'dart:async';
+
 import 'package:archethic_dapp_framework_flutter/src/application/oracle/state.dart';
 import 'package:archethic_dapp_framework_flutter/src/util/generic/get_it_instance.dart';
 import 'package:archethic_lib_dart/archethic_lib_dart.dart';
+import 'package:logging/logging.dart';
 import 'package:riverpod_annotation/riverpod_annotation.dart';
 
 part 'provider.g.dart';
 
 @Riverpod(keepAlive: true)
 class _ArchethicOracleUCONotifier extends Notifier<ArchethicOracleUCO> {
-  ArchethicOracle? archethicOracle;
+  ArchethicOracle? archethicOracleSubscription;
+
+  static final _logger = Logger('ArchethicOracleUCONotifier');
 
   @override
   ArchethicOracleUCO build() {
-    ref.onDispose(() {
-      if (archethicOracle != null) {
-        sl
-            .get<OracleService>()
-            .closeOracleUpdatesSubscription(archethicOracle!);
-      }
-    });
+    ref.onDispose(stopSubscription);
+
+    _getValue();
+
+    startSubscription();
     return const ArchethicOracleUCO();
   }
 
-  Future<void> init() async {
-    await _getValue();
+  Future<void> startSubscription() async {
+    if (archethicOracleSubscription != null) return;
+
+    _logger.info('Start listening to Oracle');
     await _subscribe();
   }
 
+  Future<void> stopSubscription() async {
+    _logger.info('Stop listening to Oracle');
+    if (archethicOracleSubscription == null) return;
+    sl
+        .get<OracleService>()
+        .closeOracleUpdatesSubscription(archethicOracleSubscription!);
+    archethicOracleSubscription = null;
+  }
+
   Future<void> _getValue() async {
     final oracleUcoPrice = await sl.get<OracleService>().getOracleData();
     _fillInfo(oracleUcoPrice);
   }
 
   Future<void> _subscribe() async {
-    archethicOracle = await sl
+    archethicOracleSubscription = await sl
         .get<OracleService>()
         .subscribeToOracleUpdates((oracleUcoPrice) {
       _fillInfo(oracleUcoPrice!);
     });
   }
 
   void _fillInfo(OracleUcoPrice oracleUcoPrice) {
+    _logger.info('Oracle: ${oracleUcoPrice.timestamp}, ${oracleUcoPrice.uco}');
     state = state.copyWith(
       timestamp: oracleUcoPrice.timestamp ?? 0,
       eur: oracleUcoPrice.uco!.eur ?? 0,

lib/src/application/oracle/state.dart

@@ -1,4 +1,5 @@
 /// SPDX-License-Identifier: AGPL-3.0-or-later
+
 import 'package:freezed_annotation/freezed_annotation.dart';
 
 part 'state.freezed.dart';

pubspec.lock

@@ -44,10 +44,9 @@ packages:
   archethic_wallet_client:
     dependency: "direct main"
     description:
-      name: archethic_wallet_client
-      sha256: "7d9ef9f23b285d4d5fc95bec08b3e4c51e8e636e1755f863426c5706ada2c175"
-      url: "https://pub.dev"
-    source: hosted
+      path: "../archethic-wallet-client-dart"
+      relative: true
+    source: path
     version: "2.0.4"
   archive:
     dependency: "direct main"

pubspec.yaml

@@ -19,9 +19,9 @@ dependencies:
   #  path: ../libdart-2
 
   # A client dart library to interact with Archethic Wallet RPC API.
-  archethic_wallet_client: ^2.0.4
-  #archethic_wallet_client:
-  #  path: ../archethic-wallet-client-dart
+  #archethic_wallet_client: ^2.0.4
+  archethic_wallet_client:
+    path: ../archethic-wallet-client-dart
 
   # Compression
   archive: ^3.4.10