import 'dart:async'; import 'dart:developer'; import 'package:firebase_core/firebase_core.dart'; import 'package:firebase_remote_config/firebase_remote_config.dart'; import 'package:flutter/foundation.dart'; import 'package:lightmeter/data/analytics/analytics.dart'; import 'package:lightmeter/data/models/feature.dart'; abstract class IRemoteConfigService { const IRemoteConfigService(); Future activeAndFetchFeatures(); Future fetchConfig(); dynamic getValue(Feature feature); Map getAll(); Stream> onConfigUpdated(); bool isEnabled(Feature feature); } class RemoteConfigService implements IRemoteConfigService { final LightmeterAnalytics analytics; const RemoteConfigService(this.analytics); @override Future activeAndFetchFeatures() async { final FirebaseRemoteConfig remoteConfig = FirebaseRemoteConfig.instance; const cacheStaleDuration = kDebugMode ? Duration(minutes: 1) : Duration(hours: 12); try { await remoteConfig.setConfigSettings( RemoteConfigSettings( fetchTimeout: const Duration(seconds: 15), minimumFetchInterval: cacheStaleDuration, ), ); await remoteConfig.setDefaults(featuresDefaultValues.map((key, value) => MapEntry(key.name, value))); await remoteConfig.activate(); await remoteConfig.ensureInitialized(); log('Firebase remote config initialized successfully'); } on FirebaseException catch (e) { _logError('Firebase exception during Firebase Remote Config initialization: $e'); } catch (e) { _logError('Error during Firebase Remote Config initialization: $e'); } } @override Future fetchConfig() async { try { // https://github.com/firebase/flutterfire/issues/6196#issuecomment-927751667 await Future.delayed(const Duration(seconds: 1)); await FirebaseRemoteConfig.instance.fetch(); } on FirebaseException catch (e) { _logError('Firebase exception during Firebase Remote Config fetch: $e'); } catch (e) { _logError('Error during Firebase Remote Config fetch: $e'); } } @override dynamic getValue(Feature feature) => FirebaseRemoteConfig.instance.getValue(feature.name).toValue(feature); @override Map getAll() { final Map result = {}; for (final value in FirebaseRemoteConfig.instance.getAll().entries) { try { final feature = Feature.values.firstWhere((f) => f.name == value.key); result[feature] = value.value.toValue(feature); } catch (e, stackTrace) { _logError(e, stackTrace: stackTrace); } } return result; } @override Stream> onConfigUpdated() => FirebaseRemoteConfig.instance.onConfigUpdated.asyncMap( (event) async { await FirebaseRemoteConfig.instance.activate(); final Set updatedFeatures = {}; for (final key in event.updatedKeys) { try { updatedFeatures.add(Feature.values.firstWhere((element) => element.name == key)); } catch (e, stackTrace) { _logError(e, stackTrace: stackTrace); } } return updatedFeatures; }, ); @override bool isEnabled(Feature feature) => FirebaseRemoteConfig.instance.getBool(feature.name); void _logError(dynamic throwable, {StackTrace? stackTrace}) => analytics.logCrash(throwable, stackTrace); } class MockRemoteConfigService implements IRemoteConfigService { const MockRemoteConfigService(); @override Future activeAndFetchFeatures() async {} @override Future fetchConfig() async {} @override Map getAll() => featuresDefaultValues; @override dynamic getValue(Feature feature) => featuresDefaultValues[feature]; @override // ignore: cast_nullable_to_non_nullable bool isEnabled(Feature feature) => featuresDefaultValues[feature] as bool; @override Stream> onConfigUpdated() => const Stream.empty(); } extension on RemoteConfigValue { dynamic toValue(Feature feature) { switch (feature) { case Feature.showUnlockProOnMainScreen: return asBool(); } } }