import 'dart:async'; import 'dart:io'; import 'dart:ui'; import 'package:cake_wallet/core/wallet_loading_service.dart'; import 'package:cake_wallet/store/settings_store.dart'; import 'package:cake_wallet/utils/device_info.dart'; import 'package:cake_wallet/utils/feature_flag.dart'; import 'package:cake_wallet/view_model/settings/sync_mode.dart'; import 'package:cake_wallet/view_model/wallet_list/wallet_list_item.dart'; import 'package:cake_wallet/view_model/wallet_list/wallet_list_view_model.dart'; import 'package:cw_bitcoin/electrum_wallet.dart'; import 'package:cw_core/sync_status.dart'; import 'package:cw_core/wallet_base.dart'; import 'package:cw_core/wallet_type.dart'; import 'package:flutter/widgets.dart'; import 'package:flutter_background_service/flutter_background_service.dart'; import 'package:flutter_local_notifications/flutter_local_notifications.dart'; import 'package:cake_wallet/main.dart'; import 'package:cake_wallet/di.dart'; const moneroSyncTaskKey = "com.fotolockr.cakewallet.monero_sync_task"; const mwebSyncTaskKey = "com.fotolockr.cakewallet.mweb_sync_task"; const initialNotificationTitle = 'Cake Background Sync'; const standbyMessage = 'On standby - app is in the foreground'; const readyMessage = 'Ready to sync - waiting until the app has been in the background for a while'; const notificationId = 888; const notificationChannelId = 'cake_service'; const notificationChannelName = 'CAKE BACKGROUND SERVICE'; const notificationChannelDescription = 'Cake Wallet Background Service'; const DELAY_SECONDS_BEFORE_SYNC_START = 15; const spNodeNotificationMessage = "Currently configured Bitcoin node does not support Silent Payments. skipping wallet"; void setMainNotification( FlutterLocalNotificationsPlugin flutterLocalNotificationsPlugin, { required String title, required String content, }) async { flutterLocalNotificationsPlugin.show( notificationId, title, content, const NotificationDetails( android: AndroidNotificationDetails( notificationChannelId, notificationChannelName, icon: 'ic_bg_service_small', ongoing: true, ), ), ); } void setNotificationStandby(FlutterLocalNotificationsPlugin flutterLocalNotificationsPlugin) async { flutterLocalNotificationsPlugin.cancelAll(); setMainNotification( flutterLocalNotificationsPlugin, title: initialNotificationTitle, content: standbyMessage, ); } void setNotificationReady(FlutterLocalNotificationsPlugin flutterLocalNotificationsPlugin) async { flutterLocalNotificationsPlugin.cancelAll(); setMainNotification( flutterLocalNotificationsPlugin, title: initialNotificationTitle, content: readyMessage, ); } void setSpNodeWarningNotification( FlutterLocalNotificationsPlugin flutterLocalNotificationsPlugin, int walletNum) async { flutterLocalNotificationsPlugin.show( notificationId + walletNum, initialNotificationTitle, spNodeNotificationMessage, NotificationDetails( android: AndroidNotificationDetails( "${notificationChannelId}_$walletNum", "${notificationChannelName}_$walletNum", icon: 'ic_bg_service_small', ongoing: false, ), ), ); } @pragma('vm:entry-point') Future onStart(ServiceInstance service) async { print("BACKGROUND SERVICE STARTED"); bool bgSyncStarted = false; Timer? _syncTimer; // commented because the behavior appears to be bugged: // DartPluginRegistrant.ensureInitialized(); final FlutterLocalNotificationsPlugin flutterLocalNotificationsPlugin = FlutterLocalNotificationsPlugin(); service.on('stopService').listen((event) async { print("STOPPING BACKGROUND SERVICE"); _syncTimer?.cancel(); await service.stopSelf(); }); service.on('status').listen((event) async { print(event); }); service.on('setForeground').listen((event) async { bgSyncStarted = false; _syncTimer?.cancel(); setNotificationStandby(flutterLocalNotificationsPlugin); }); service.on('setReady').listen((event) async { setNotificationReady(flutterLocalNotificationsPlugin); }); // we have entered the background, start the sync: service.on('setBackground').listen((event) async { if (bgSyncStarted) { return; } bgSyncStarted = true; await Future.delayed(const Duration(seconds: DELAY_SECONDS_BEFORE_SYNC_START)); print("STARTING SYNC FROM BG"); try { await initializeAppConfigs(loadWallet: false); } catch (_) { // these errors still show up in logs which doesn't really make sense to me } print("INITIALIZED APP CONFIGS"); // final currentWallet = getIt.get().wallet; // // don't start syncing immediately: // await currentWallet?.stopSync(); final walletLoadingService = getIt.get(); final settingsStore = getIt.get(); final walletListViewModel = getIt.get(); List syncingWallets = []; // get all Monero / Wownero wallets and sync them final List moneroWallets = walletListViewModel.wallets .where((element) => [WalletType.monero, WalletType.wownero].contains(element.type)) .toList(); for (int i = 0; i < moneroWallets.length; i++) { final wallet = await walletLoadingService.load(moneroWallets[i].type, moneroWallets[i].name); final node = settingsStore.getCurrentNode(moneroWallets[i].type); await wallet.connectToNode(node: node); wallet.startSync(); syncingWallets.add(wallet); } // get all litecoin wallets and sync them: final List litecoinWallets = walletListViewModel.wallets .where((element) => element.type == WalletType.litecoin) .toList(); // we only need to sync the first litecoin wallet since they share the same collection of blocks if (litecoinWallets.isNotEmpty) { try { final firstWallet = litecoinWallets.first; final wallet = await walletLoadingService.load(firstWallet.type, firstWallet.name); final node = settingsStore.getCurrentNode(WalletType.litecoin); wallet.connectToNode(node: node); // calling start sync isn't necessary since it's called after connecting to the node syncingWallets.add(wallet); } catch (e) { // couldn't connect to mwebd (most likely) print("error syncing litecoin wallet: $e"); } } // get all bitcoin wallets and sync them: final List bitcoinWallets = walletListViewModel.wallets.where((element) => element.type == WalletType.bitcoin).toList(); bool spSupported = true; for (int i = 0; i < bitcoinWallets.length; i++) { try { if (!spSupported) continue; final wallet = await walletLoadingService.load(bitcoinWallets[i].type, bitcoinWallets[i].name); final node = settingsStore.getCurrentNode(WalletType.bitcoin); bool nodeSupportsSP = await (wallet as ElectrumWallet).getNodeSupportsSilentPayments(); if (!nodeSupportsSP) { print("Configured node does not support silent payments, skipping wallet"); syncingWallets.add(null); setSpNodeWarningNotification(flutterLocalNotificationsPlugin, syncingWallets.length - 1); spSupported = false; continue; } await wallet.connectToNode(node: node); syncingWallets.add(wallet); } catch (e) { print("error syncing bitcoin wallet_$i: $e"); } } print("STARTING SYNC TIMER"); _syncTimer?.cancel(); _syncTimer = Timer.periodic(const Duration(milliseconds: 2000), (timer) { if (syncingWallets.isEmpty) { return; } for (int i = 0; i < syncingWallets.length; i++) { final wallet = syncingWallets[i]; if (wallet == null) continue; final syncProgress = ((wallet.syncStatus.progress()) * 100).toStringAsPrecision(5); String prefix = walletTypeToCryptoCurrency(wallet.type).title; String title = "$prefix - ${wallet.name}"; late String content; try { final blocksLeft = (wallet.syncStatus as SyncingSyncStatus).blocksLeft; content = "${blocksLeft} Blocks Left"; } catch (e) { content = "${syncProgress}% Synced"; } content += " - ${DateTime.now().toIso8601String()}"; flutterLocalNotificationsPlugin.show( notificationId + i, title, content, NotificationDetails( android: AndroidNotificationDetails( "${notificationChannelId}_$i", "${notificationChannelName}_$i", icon: 'ic_bg_service_small', ongoing: true, ), ), ); } }); }); } @pragma('vm:entry-point') Future onIosBackground(ServiceInstance service) async { WidgetsFlutterBinding.ensureInitialized(); DartPluginRegistrant.ensureInitialized(); return true; } Future initializeService(FlutterBackgroundService bgService, bool useNotifications) async { if (useNotifications) { FlutterLocalNotificationsPlugin flutterLocalNotificationsPlugin = FlutterLocalNotificationsPlugin(); if (Platform.isIOS || Platform.isAndroid) { await flutterLocalNotificationsPlugin.initialize( const InitializationSettings( iOS: DarwinInitializationSettings(), android: AndroidInitializationSettings('ic_bg_service_small'), ), ); } for (int i = 0; i < 10; i++) { AndroidNotificationChannel channel = AndroidNotificationChannel( "${notificationChannelId}_$i", "${notificationChannelName}_$i", description: notificationChannelDescription, importance: Importance.low, ); await flutterLocalNotificationsPlugin .resolvePlatformSpecificImplementation() ?.createNotificationChannel(channel); } setNotificationStandby(flutterLocalNotificationsPlugin); } // notify the service that we are in the foreground: bgService.invoke("setForeground"); try { bool isServiceRunning = await bgService.isRunning(); if (isServiceRunning) { print("Service is ALREADY running!"); return; } } catch (_) {} print("INITIALIZING SERVICE"); await bgService.configure( androidConfiguration: AndroidConfiguration( onStart: onStart, autoStart: true, isForegroundMode: true, notificationChannelId: notificationChannelId, initialNotificationTitle: initialNotificationTitle, initialNotificationContent: standbyMessage, foregroundServiceNotificationId: notificationId, foregroundServiceTypes: [AndroidForegroundType.dataSync], ), iosConfiguration: IosConfiguration( autoStart: true, onForeground: onStart, onBackground: onIosBackground, ), ); } class BackgroundTasks { FlutterBackgroundService bgService = FlutterBackgroundService(); FlutterLocalNotificationsPlugin flutterLocalNotificationsPlugin = FlutterLocalNotificationsPlugin(); void serviceBackground() { bgService.invoke("setBackground"); } Future serviceForeground() async { final settingsStore = getIt.get(); bool showNotifications = settingsStore.showSyncNotification; bgService.invoke('stopService'); await Future.delayed(const Duration(seconds: 2)); initializeService(bgService, showNotifications); } void serviceReady() { final settingsStore = getIt.get(); bool showNotifications = settingsStore.showSyncNotification; if (showNotifications) { bgService.invoke('setReady'); } } void registerBackgroundService() async { print("REGISTER BACKGROUND SERVICE"); try { final settingsStore = getIt.get(); final walletListViewModel = getIt.get(); bool hasMonero = walletListViewModel.wallets.any((element) => element.type == WalletType.monero); bool hasLitecoin = walletListViewModel.wallets.any((element) => element.type == WalletType.litecoin); bool hasBitcoin = walletListViewModel.wallets.any((element) => element.type == WalletType.bitcoin); if (!settingsStore.silentPaymentsAlwaysScan) { hasBitcoin = false; } if (!settingsStore.mwebAlwaysScan) { hasLitecoin = false; } /// if its not android nor ios, or the user has no monero wallets; exit if (!DeviceInfo.instance.isMobile || (!hasMonero && !hasLitecoin && !hasBitcoin)) { return; } final SyncMode syncMode = settingsStore.currentSyncMode; final bool useNotifications = settingsStore.showSyncNotification; if (useNotifications) { flutterLocalNotificationsPlugin .resolvePlatformSpecificImplementation() ?.requestNotificationsPermission(); } bgService.invoke("stopService"); if (syncMode.type == SyncType.disabled || !FeatureFlag.isBackgroundSyncEnabled) { return; } await initializeService(bgService, useNotifications); } catch (error, stackTrace) { print(error); print(stackTrace); } } }