chore: support native default value and listen for update

Author: bradly0cjw

ios/Podfile.lock

@@ -259,10 +259,10 @@ EXTERNAL SOURCES:
 
 SPEC CHECKSUMS:
   Firebase: 065f2bb395062046623036d8e6dc857bc2521d56
-  firebase_analytics: 756f4dfe60543c4703cee7b8e4a599604b1a86d4
-  firebase_core: 8e6f58412ca227827c366b92e7cee047a2148c60
-  firebase_crashlytics: d3a550f0132b59d886eca10448df04afd38b18cf
-  firebase_remote_config: cd42a29a61e8610230e7f74d5646d6392fd7368d
+  firebase_analytics: ee2db99f55715656363e5d7cbed4f4ddac6b9c31
+  firebase_core: 98bcc1bd1a097bcb8b1ed6e091de3039802527c4
+  firebase_crashlytics: 0e7f4fc37ad7ce137ca890b208f562baf8f85de5
+  firebase_remote_config: 0d060eef0fdfb288ffc41903ba9a60bb963755ea
   FirebaseABTesting: a399ffe546392a39b19a5c2fb28bd8ea178a6f47
   FirebaseAnalytics: cd7d01d352f3c237c9a0e31552c257cd0b0c0352
   FirebaseCore: 428912f751178b06bef0a1793effeb4a5e09a9b8
@@ -275,24 +275,24 @@ SPEC CHECKSUMS:
   FirebaseSessions: a2d06fd980431fda934c7a543901aca05fc4edcc
   FirebaseSharedSwift: 9d2fa84a46676302b89dbd5e6e62bce2fe376909
   Flutter: cabc95a1d2626b1b06e7179b784ebcf0c0cde467
-  flutter_image_compress_common: 1697a328fd72bfb335507c6bca1a65fa5ad87df1
-  flutter_secure_storage_darwin: acdb3f316ed05a3e68f856e0353b133eec373a23
+  flutter_image_compress_common: ec1d45c362c9d30a3f6a0426c297f47c52007e3e
+  flutter_secure_storage_darwin: 557817588b80e60213cbecb573c45c76b788018d
   GoogleAdsOnDeviceConversion: d68c69dd9581a0f5da02617b6f377e5be483970f
   GoogleAppMeasurement: fce7c1c90640d2f9f5c56771f71deacb2ba3f98c
   GoogleDataTransport: aae35b7ea0c09004c3797d53c8c41f66f219d6a7
   GoogleUtilities: 00c88b9a86066ef77f0da2fab05f65d7768ed8e1
-  image_picker_ios: e0ece4aa2a75771a7de3fa735d26d90817041326
+  image_picker_ios: 4f2f91b01abdb52842a8e277617df877e40f905b
   libwebp: 02b23773aedb6ff1fd38cec7a77b81414c6842a8
   Mantle: c5aa8794a29a022dfbbfc9799af95f477a69b62d
   nanopb: fad817b59e0457d11a5dfbde799381cd727c1275
-  package_info_plus: af8e2ca6888548050f16fa2f1938db7b5a5df499
-  path_provider_foundation: bb55f6dbba17d0dccd6737fe6f7f34fbd0376880
+  package_info_plus: c0502532a26c7662a62a356cebe2692ec5fe4ec4
+  path_provider_foundation: 0b743cbb62d8e47eab856f09262bb8c1ddcfe6ba
   PromisesObjC: f5707f49cb48b9636751c5b2e7d227e43fba9f47
   PromisesSwift: 9d77319bbe72ebf6d872900551f7eeba9bce2851
   SDWebImage: e9fc87c1aab89a8ab1bbd74eba378c6f53be8abf
   SDWebImageWebPCoder: 0e06e365080397465cc73a7a9b472d8a3bd0f377
-  shared_preferences_foundation: 7036424c3d8ec98dfe75ff1667cb0cd531ec82bb
-  url_launcher_ios: 7a95fa5b60cc718a708b8f2966718e93db0cef1b
+  shared_preferences_foundation: 5086985c1d43c5ba4d5e69a4e8083a389e2909e6
+  url_launcher_ios: bb13df5870e8c4234ca12609d04010a21be43dfa
 
 PODFILE CHECKSUM: ce2a4dd764e1c7aeed6a7cdc5e61d092b6dc6d32
 

lib/repositories/feature_flag_providers.dart

@@ -10,7 +10,12 @@ final featureFlagsProvider =
 class FeatureFlagsNotifier extends AsyncNotifier<List<FeatureFlag>> {
   @override
   Future<List<FeatureFlag>> build() async {
-    return ref.watch(featureFlagRepositoryProvider).getAllFlags();
+    final repo = ref.watch(featureFlagRepositoryProvider);
+    // Listen for real-time updates from Remote Config/Repository
+    final subscription = repo.onUpdated.listen((_) => ref.invalidateSelf());
+    ref.onDispose(subscription.cancel);
+
+    return repo.getAllFlags();
   }
 
   Future<void> refreshFlags() async {

lib/repositories/feature_flag_repository.dart

@@ -61,6 +61,7 @@ final featureFlagRepositoryProvider = Provider<FeatureFlagRepository>((ref) {
 class FeatureFlagRepository {
   final FeatureFlagService _service;
   final SharedPreferencesAsync _prefs;
+  final _updateController = StreamController<void>.broadcast();
   Map<String, FeatureFlagData>? _defaultsCache;
   List<FeatureFlag>? _flagsCache;
 
@@ -70,6 +71,9 @@ class FeatureFlagRepository {
   }) : _service = service,
        _prefs = prefs;
 
+  /// A stream that emits whenever feature flags are updated from a remote source.
+  Stream<void> get onUpdated => _updateController.stream;
+
   Future<Map<String, FeatureFlagData>> _getDefaults({
     bool forceRefresh = false,
   }) async {
@@ -79,6 +83,28 @@ class FeatureFlagRepository {
 
   /// Initializes the repository by warming up the cache.
   Future<void> init() async {
+    // Initialize Remote Config with local defaults
+    try {
+      final localJson = await _service.loadLocalJson();
+      await firebaseService.init(defaults: {'feature_flags': localJson});
+
+      // Listen for remote updates
+      firebaseService.onConfigUpdated.listen((_) {
+        log(
+          'Remote Config updated, invalidating feature flag cache',
+          name: 'FeatureFlagRepository',
+        );
+        _defaultsCache = null;
+        _flagsCache = null;
+        _updateController.add(null);
+      });
+    } catch (e) {
+      log(
+        'Failed to initialize Remote Config defaults: $e',
+        name: 'FeatureFlagRepository',
+      );
+    }
+
     await getAllFlags();
     log('FeatureFlagRepository initialized', name: 'FeatureFlagRepository');
   }

lib/services/feature_flag/feature_flag_service.dart

@@ -13,8 +13,12 @@ final featureFlagServiceProvider = Provider<FeatureFlagService>((ref) {
 /// Service for fetching default feature flags from the local JSON config.
 /// Extended with Firebase Remote Config to allow remote overrides.
 class FeatureFlagService {
+  Future<String> loadLocalJson() async {
+    return await rootBundle.loadString('assets/feature_flags.json');
+  }
+
   Future<Map<String, FeatureFlagData>> fetchDefaultFlags() async {
-    final jsonString = await rootBundle.loadString('assets/feature_flags.json');
+    final jsonString = await loadLocalJson();
     final localDefaults = jsonDecode(jsonString) as Map<String, dynamic>;
 
     final result = firebaseService.getRemoteConfigString('feature_flags');

lib/services/firebase_service.dart

@@ -1,6 +1,7 @@
 import 'package:firebase_analytics/firebase_analytics.dart';
 import 'package:firebase_crashlytics/firebase_crashlytics.dart';
 import 'package:firebase_remote_config/firebase_remote_config.dart';
+import 'dart:async';
 import 'dart:developer' as dev;
 
 /// Global toggle for Firebase features.
@@ -25,8 +26,14 @@ var firebaseService = const FirebaseService();
 /// firebase.crashlytics?.recordError(e, stack);
 /// ```
 class FirebaseService {
+  static final _updateController = StreamController<void>.broadcast();
+  static bool _isInitialized = false;
+
   const FirebaseService();
 
+  /// A stream that emits whenever the Remote Config is updated and activated.
+  Stream<void> get onConfigUpdated => _updateController.stream;
+
   /// The [FirebaseAnalytics] instance, or `null` if Firebase is disabled.
   FirebaseAnalytics? get analytics =>
       useFirebase ? FirebaseAnalytics.instance : null;
@@ -64,15 +71,44 @@ class FirebaseService {
   /// Initializes Firebase Remote Config.
   ///
   /// Call this at app start to fetch and activate the latest configuration.
-  Future<void> init() async {
+  /// Optionally provide [defaults] for in-app default values.
+  Future<void> init({Map<String, dynamic>? defaults}) async {
     final rc = remoteConfig;
     if (rc == null) return;
 
+    if (_isInitialized) {
+      if (defaults != null) await setDefaults(defaults);
+      return;
+    }
+
+    if (defaults != null) {
+      await rc.setDefaults(defaults);
+    }
+
+    _setupUpdateListener(rc);
+
     await _fetchAndActivate(
       rc,
       context: 'initialized',
       setupSettings: true,
     );
+    _isInitialized = true;
+  }
+
+  /// Updates the in-app default values for Remote Config.
+  Future<void> setDefaults(Map<String, dynamic> defaults) async {
+    await remoteConfig?.setDefaults(defaults);
+  }
+
+  void _setupUpdateListener(FirebaseRemoteConfig rc) {
+    rc.onConfigUpdated.listen((event) async {
+      dev.log(
+        'Remote Config updated: ${event.updatedKeys}',
+        name: 'FirebaseService',
+      );
+      await rc.activate();
+      _updateController.add(null);
+    });
   }
 
   /// Forces a fresh fetch and activation of Remote Config.