Ecosystem/cake_wallet
1
0
Fork 0
mirror of https://github.com/cake-tech/cake_wallet.git synced 2025-04-02 20:49:10 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

bg sync PoC working! (but crashes lol)

Browse source
This commit is contained in:
Matthew Fosse 2024-08-29 14:29:37 -04:00
parent 4d5e3b7f0b
commit 879c29fe7c
6 changed files with 438 additions and 154 deletions

8
android/app/src/main/AndroidManifestBase.xml
View file

@ -102,11 +102,11 @@
<category android:name="android.intent.category.BROWSABLE" />
<data android:scheme="nano-gpt" />
</intent-filter>
<service
android:name="id.flutter.flutter_background_service.BackgroundService"
android:foregroundServiceType="dataSync"
/>
</activity>
<service
android:name="id.flutter.flutter_background_service.BackgroundService"
android:foregroundServiceType="dataSync"
/>
<meta-data
android:name="flutterEmbedding"
android:value="2" />

1
cw_bitcoin/lib/litecoin_wallet.dart
View file

@ -303,6 +303,7 @@ abstract class LitecoinWalletBase extends ElectrumWallet with Store {
_syncTimer?.cancel();
_utxoStream?.cancel();
await CwMweb.stop();
syncStatus = NotSyncingSyncStatus();
}
Future<void> initMwebUtxosBox() async {

8
cw_core/lib/sync_status.dart
View file

@ -82,3 +82,11 @@ class LostConnectionSyncStatus extends NotConnectedSyncStatus {
@override
String toString() => 'Reconnecting';
}
class NotSyncingSyncStatus extends SyncStatus {
@override
double progress() => 0.0;
@override
String toString() => 'stopped';
}

573
lib/entities/background_tasks.dart
View file

@ -1,9 +1,11 @@
import 'dart:async';
import 'dart:io';
import 'dart:ui';
import 'package:cake_wallet/bitcoin/bitcoin.dart';
import 'package:cake_wallet/core/wallet_loading_service.dart';
import 'package:cake_wallet/entities/preferences_key.dart';
import 'package:cake_wallet/store/app_store.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';
@ -14,7 +16,9 @@ import 'package:cw_bitcoin/electrum_wallet.dart';
import 'package:cw_core/wallet_base.dart';
import 'package:cw_core/wallet_type.dart';
import 'package:flutter/foundation.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:shared_preferences/shared_preferences.dart';
import 'package:workmanager/workmanager.dart';
import 'package:cake_wallet/main.dart';
@ -26,178 +30,445 @@ const mwebSyncTaskKey = "com.fotolockr.cakewallet.mweb_sync_task";
@pragma('vm:entry-point')
void callbackDispatcher() {
Workmanager().executeTask((task, inputData) async {
try {
switch (task) {
case mwebSyncTaskKey:
// Workmanager().executeTask((task, inputData) async {
// try {
// switch (task) {
// case mwebSyncTaskKey:
/// The work manager runs on a separate isolate from the main flutter isolate.
/// thus we initialize app configs first; hive, getIt, etc...
await initializeAppConfigs();
// /// The work manager runs on a separate isolate from the main flutter isolate.
// /// thus we initialize app configs first; hive, getIt, etc...
// await initializeAppConfigs();
final List<WalletListItem> ltcWallets = getIt
.get<WalletListViewModel>()
.wallets
.where((element) => [WalletType.litecoin].contains(element.type))
.toList();
// final List<WalletListItem> ltcWallets = getIt
// .get<WalletListViewModel>()
// .wallets
// .where((element) => [WalletType.litecoin].contains(element.type))
// .toList();
if (ltcWallets.isEmpty) {
return Future.error("No ltc wallets found");
}
// if (ltcWallets.isEmpty) {
// return Future.error("No ltc wallets found");
// }
final walletLoadingService = getIt.get<WalletLoadingService>();
// final walletLoadingService = getIt.get<WalletLoadingService>();
var wallet =
await walletLoadingService.load(ltcWallets.first.type, ltcWallets.first.name);
// var wallet =
// await walletLoadingService.load(ltcWallets.first.type, ltcWallets.first.name);
print("STARTING SYNC FROM BG!!");
// print("STARTING SYNC FROM BG!!");
final url = Uri.parse("https://webhook.site/a81e49d8-f5bd-4e57-8b1d-5d2c80c43f2a");
final response = await http.get(url);
// final url = Uri.parse("https://webhook.site/a81e49d8-f5bd-4e57-8b1d-5d2c80c43f2a");
// final response = await http.get(url);
if (response.statusCode == 200) {
print("Background task starting: ${response.body}");
} else {
print("Failed to post webhook.site");
}
// if (response.statusCode == 200) {
// print("Background task starting: ${response.body}");
// } else {
// print("Failed to post webhook.site");
// }
// await wallet.startSync();
// // await wallet.startSync();
// RpcClient _stub = bitcoin!.getMwebStub();
// // RpcClient _stub = bitcoin!.getMwebStub();
double syncStatus = 0.0;
// double syncStatus = 0.0;
Timer? _syncTimer;
// Timer? _syncTimer;
// dynamic _stub = await bitcoin!.getMwebStub(wallet);
// // dynamic _stub = await bitcoin!.getMwebStub(wallet);
_syncTimer = Timer.periodic(const Duration(milliseconds: 1500), (timer) async {
// if (syncStatus is FailedSyncStatus) return;
// TODO: use the proxy layer:
// final height = await (wallet as ElectrumWallet).electrumClient.getCurrentBlockChainTip() ?? 0;
final height = 2726590;
// final height = 0;
dynamic resp = await bitcoin!.getStatusRequest(wallet);
int blockHeaderHeight = resp.blockHeaderHeight as int;
int mwebHeaderHeight = resp.mwebHeaderHeight as int;
int mwebUtxosHeight = resp.mwebUtxosHeight as int;
// _syncTimer = Timer.periodic(const Duration(milliseconds: 1500), (timer) async {
// // if (syncStatus is FailedSyncStatus) return;
// // TODO: use the proxy layer:
// // final height = await (wallet as ElectrumWallet).electrumClient.getCurrentBlockChainTip() ?? 0;
// final height = 2726590;
// // final height = 0;
// dynamic resp = await bitcoin!.getStatusRequest(wallet);
// int blockHeaderHeight = resp.blockHeaderHeight as int;
// int mwebHeaderHeight = resp.mwebHeaderHeight as int;
// int mwebUtxosHeight = resp.mwebUtxosHeight as int;
print("blockHeaderHeight: $blockHeaderHeight");
print("mwebHeaderHeight: $mwebHeaderHeight");
print("mwebUtxosHeight: $mwebUtxosHeight");
// print("blockHeaderHeight: $blockHeaderHeight");
// print("mwebHeaderHeight: $mwebHeaderHeight");
// print("mwebUtxosHeight: $mwebUtxosHeight");
if (blockHeaderHeight < height) {
syncStatus = blockHeaderHeight / height;
} else if (mwebHeaderHeight < height) {
syncStatus = mwebHeaderHeight / height;
} else if (mwebUtxosHeight < height) {
syncStatus = 0.999;
} else {
syncStatus = 1;
}
print("Sync status ${syncStatus}");
});
// if (blockHeaderHeight < height) {
// syncStatus = blockHeaderHeight / height;
// } else if (mwebHeaderHeight < height) {
// syncStatus = mwebHeaderHeight / height;
// } else if (mwebUtxosHeight < height) {
// syncStatus = 0.999;
// } else {
// syncStatus = 1;
// }
// print("Sync status ${syncStatus}");
// });
for (int i = 0;; i++) {
await Future<void>.delayed(const Duration(seconds: 1));
if (syncStatus == 1) {
print("sync done!");
break;
}
if (i > 600) {
return Future.error("Synchronization Timed out");
}
}
_syncTimer?.cancel();
// for (int i = 0;; i++) {
// await Future<void>.delayed(const Duration(seconds: 1));
// if (syncStatus == 1) {
// print("sync done!");
// break;
// }
// if (i > 600) {
// return Future.error("Synchronization Timed out");
// }
// }
// _syncTimer?.cancel();
break;
// break;
case moneroSyncTaskKey:
// case moneroSyncTaskKey:
/// The work manager runs on a separate isolate from the main flutter isolate.
/// thus we initialize app configs first; hive, getIt, etc...
await initializeAppConfigs();
// /// The work manager runs on a separate isolate from the main flutter isolate.
// /// thus we initialize app configs first; hive, getIt, etc...
// await initializeAppConfigs();
final walletLoadingService = getIt.get<WalletLoadingService>();
// final walletLoadingService = getIt.get<WalletLoadingService>();
final typeRaw = getIt.get<SharedPreferences>().getInt(PreferencesKey.currentWalletType);
// final typeRaw = getIt.get<SharedPreferences>().getInt(PreferencesKey.currentWalletType);
WalletBase? wallet;
// WalletBase? wallet;
if (inputData!['sync_all'] as bool) {
/// get all Monero wallets of the user and sync them
final List<WalletListItem> moneroWallets = getIt
.get<WalletListViewModel>()
.wallets
.where((element) => [WalletType.monero, WalletType.wownero].contains(element.type))
.toList();
// if (inputData!['sync_all'] as bool) {
// /// get all Monero wallets of the user and sync them
// final List<WalletListItem> moneroWallets = getIt
// .get<WalletListViewModel>()
// .wallets
// .where((element) => [WalletType.monero, WalletType.wownero].contains(element.type))
// .toList();
for (int i = 0; i < moneroWallets.length; i++) {
wallet =
await walletLoadingService.load(moneroWallets[i].type, moneroWallets[i].name);
final node = getIt.get<SettingsStore>().getCurrentNode(moneroWallets[i].type);
await wallet.connectToNode(node: node);
await wallet.startSync();
}
} else {
/// if the user chose to sync only active wallet
/// if the current wallet is monero; sync it only
if (typeRaw == WalletType.monero.index || typeRaw == WalletType.wownero.index) {
final name =
getIt.get<SharedPreferences>().getString(PreferencesKey.currentWalletName);
// for (int i = 0; i < moneroWallets.length; i++) {
// wallet =
// await walletLoadingService.load(moneroWallets[i].type, moneroWallets[i].name);
// final node = getIt.get<SettingsStore>().getCurrentNode(moneroWallets[i].type);
// await wallet.connectToNode(node: node);
// await wallet.startSync();
// }
// } else {
// /// if the user chose to sync only active wallet
// /// if the current wallet is monero; sync it only
// if (typeRaw == WalletType.monero.index || typeRaw == WalletType.wownero.index) {
// final name =
// getIt.get<SharedPreferences>().getString(PreferencesKey.currentWalletName);
wallet = await walletLoadingService.load(WalletType.values[typeRaw!], name!);
final node = getIt.get<SettingsStore>().getCurrentNode(WalletType.values[typeRaw]);
// wallet = await walletLoadingService.load(WalletType.values[typeRaw!], name!);
// final node = getIt.get<SettingsStore>().getCurrentNode(WalletType.values[typeRaw]);
await wallet.connectToNode(node: node);
await wallet.startSync();
}
}
// await wallet.connectToNode(node: node);
// await wallet.startSync();
// }
// }
if (wallet?.syncStatus.progress() == null) {
return Future.error("No Monero/Wownero wallet found");
}
// if (wallet?.syncStatus.progress() == null) {
// return Future.error("No Monero/Wownero wallet found");
// }
for (int i = 0;; i++) {
await Future<void>.delayed(const Duration(seconds: 1));
if (wallet?.syncStatus.progress() == 1.0) {
break;
}
if (i > 600) {
return Future.error("Synchronization Timed out");
}
}
break;
}
// for (int i = 0;; i++) {
// await Future<void>.delayed(const Duration(seconds: 1));
// if (wallet?.syncStatus.progress() == 1.0) {
// break;
// }
// if (i > 600) {
// return Future.error("Synchronization Timed out");
// }
// }
// break;
// }
return Future.value(true);
} catch (error, stackTrace) {
print(error);
print(stackTrace);
return Future.error(error);
// return Future.value(true);
// } catch (error, stackTrace) {
// print(error);
// print(stackTrace);
// return Future.error(error);
// }
// });
}
@pragma('vm:entry-point')
Future<void> onStart(ServiceInstance service) async {
print("BACKGROUND SERVICE STARTED!");
// Only available for flutter 3.0.0 and later
DartPluginRegistrant.ensureInitialized();
final FlutterLocalNotificationsPlugin flutterLocalNotificationsPlugin =
FlutterLocalNotificationsPlugin();
// this will be used as notification channel id
const notificationChannelId = 'my_foreground';
// this will be used for notification id, So you can update your custom notification with this id.
const notificationId = 888;
if (service is AndroidServiceInstance) {
service.on('setAsForeground').listen((event) {
service.setAsForegroundService();
});
service.on('setAsBackground').listen((event) {
service.setAsBackgroundService();
});
}
service.on('stopService').listen((event) {
service.stopSelf();
});
// // bring to foreground
// Timer.periodic(const Duration(seconds: 1), (timer) async {
// if (service is AndroidServiceInstance) {
// if (await service.isForegroundService()) {
// flutterLocalNotificationsPlugin.show(
// notificationId,
// 'COOL SERVICE',
// 'Awesome ${DateTime.now()}',
// const NotificationDetails(
// android: AndroidNotificationDetails(
// notificationChannelId,
// 'MY FOREGROUND SERVICE',
// icon: 'ic_bg_service_small',
// ongoing: true,
// ),
// ),
// );
// } else {
// flutterLocalNotificationsPlugin.show(
// notificationId,
// 'BACKGROUND SERVICE?',
// 'Awesome ${DateTime.now()}',
// const NotificationDetails(
// android: AndroidNotificationDetails(
// notificationChannelId,
// 'MY FOREGROUND SERVICE',
// icon: 'ic_bg_service_small',
// ongoing: true,
// ),
// ),
// );
// }
// }
// });
// /// The work manager runs on a separate isolate from the main flutter isolate.
// /// thus we initialize app configs first; hive, getIt, etc...
// await initializeAppConfigs();
service.on('status').listen((event) async {
print(event);
});
bool bgSyncStarted = false;
service.on('startBgSync').listen((event) async {
if (bgSyncStarted) {
return;
}
bgSyncStarted = true;
print("STARTING SYNC FROM BG!!");
await initializeAppConfigs();
print("initialized app configs");
Timer.periodic(const Duration(milliseconds: 1500), (timer) {
final wallet = getIt.get<AppStore>().wallet;
final syncProgress = wallet?.syncStatus.progress();
flutterLocalNotificationsPlugin.show(
notificationId,
"${syncProgress}",
'Awesome ${DateTime.now()}',
const NotificationDetails(
android: AndroidNotificationDetails(
notificationChannelId,
'MY FOREGROUND SERVICE',
icon: 'ic_bg_service_small',
ongoing: true,
),
),
);
});
});
// final List<WalletListItem> ltcWallets = getIt
// .get<WalletListViewModel>()
// .wallets
// .where((element) => [WalletType.litecoin].contains(element.type))
// .toList();
// if (ltcWallets.isEmpty) {
// return Future.error("No ltc wallets found");
// }
// final walletLoadingService = getIt.get<WalletLoadingService>();
// var wallet = await walletLoadingService.load(ltcWallets.first.type, ltcWallets.first.name);
// var wallet = getIt.get<AppStore>().wallet;
// if (wallet?.type != WalletType.litecoin) {
// return;
// }
// print("STARTING SYNC FROM BG!!");
// final url = Uri.parse("https://webhook.site/a81e49d8-f5bd-4e57-8b1d-5d2c80c43f2a");
// final response = await http.get(url);
// if (response.statusCode == 200) {
// print("Background task starting: ${response.body}");
// } else {
// print("Failed to post webhook.site");
// }
// Timer.periodic(Duration(milliseconds: 5000), (timer) async {
// print(wallet!.syncStatus);
// });
// await wallet.startSync();
// RpcClient _stub = bitcoin!.getMwebStub();
// double syncStatus = 0.0;
// Timer? _syncTimer;
// dynamic _stub = await bitcoin!.getMwebStub(wallet);
// _syncTimer = Timer.periodic(const Duration(milliseconds: 1500), (timer) async {
// // if (syncStatus is FailedSyncStatus) return;
// // TODO: use the proxy layer:
// // final height = await (wallet as ElectrumWallet).electrumClient.getCurrentBlockChainTip() ?? 0;
// final height = 2726590;
// // final height = 0;
// dynamic resp = await bitcoin!.getStatusRequest(wallet);
// int blockHeaderHeight = resp.blockHeaderHeight as int;
// int mwebHeaderHeight = resp.mwebHeaderHeight as int;
// int mwebUtxosHeight = resp.mwebUtxosHeight as int;
// print("blockHeaderHeight: $blockHeaderHeight");
// print("mwebHeaderHeight: $mwebHeaderHeight");
// print("mwebUtxosHeight: $mwebUtxosHeight");
// if (blockHeaderHeight < height) {
// syncStatus = blockHeaderHeight / height;
// } else if (mwebHeaderHeight < height) {
// syncStatus = mwebHeaderHeight / height;
// } else if (mwebUtxosHeight < height) {
// syncStatus = 0.999;
// } else {
// syncStatus = 1;
// }
// print("Sync status ${syncStatus}");
// flutterLocalNotificationsPlugin.show(
// notificationId,
// '${syncStatus}',
// 'Awesome ${DateTime.now()}',
// const NotificationDetails(
// android: AndroidNotificationDetails(
// notificationChannelId,
// 'MY FOREGROUND SERVICE',
// icon: 'ic_bg_service_small',
// ongoing: true,
// ),
// ),
// );
// });
}
@pragma('vm:entry-point')
Future<bool> onIosBackground(ServiceInstance service) async {
WidgetsFlutterBinding.ensureInitialized();
DartPluginRegistrant.ensureInitialized();
return true;
}
Future<void> initializeService(FlutterBackgroundService bgService) async {
// final service = FlutterBackgroundService();
// await service.configure(
// iosConfiguration: IosConfiguration(
// autoStart: true,
// onForeground: onStart,
// onBackground: onIosBackground,
// ),
// androidConfiguration: AndroidConfiguration(
// autoStart: true,
// onStart: onStart,
// isForegroundMode: false,
// autoStartOnBoot: true,
// ),
// );
/// OPTIONAL, using custom notification channel id
const AndroidNotificationChannel channel = AndroidNotificationChannel(
'my_foreground', // id
'MY FOREGROUND SERVICE', // title
description: 'This channel is used for important notifications.', // description
importance: Importance.low, // importance must be at low or higher level
);
final FlutterLocalNotificationsPlugin flutterLocalNotificationsPlugin =
FlutterLocalNotificationsPlugin();
if (Platform.isIOS || Platform.isAndroid) {
await flutterLocalNotificationsPlugin.initialize(
const InitializationSettings(
iOS: DarwinInitializationSettings(),
android: AndroidInitializationSettings('ic_bg_service_small'),
),
);
}
await flutterLocalNotificationsPlugin
.resolvePlatformSpecificImplementation<AndroidFlutterLocalNotificationsPlugin>()
?.createNotificationChannel(channel);
flutterLocalNotificationsPlugin
.resolvePlatformSpecificImplementation<AndroidFlutterLocalNotificationsPlugin>()
?.requestNotificationsPermission();
await bgService.configure(
androidConfiguration: AndroidConfiguration(
// this will be executed when app is in foreground or background in separated isolate
onStart: onStart,
// auto start service
autoStart: true,
isForegroundMode: true,
notificationChannelId: 'my_foreground',
initialNotificationTitle: 'AWESOME SERVICE',
initialNotificationContent: 'Initializing',
foregroundServiceNotificationId: 888,
foregroundServiceTypes: [AndroidForegroundType.dataSync],
),
iosConfiguration: IosConfiguration(
// auto start service
autoStart: true,
// this will be executed when app is in foreground in separated isolate
onForeground: onStart,
// you have to enable background fetch capability on xcode project
onBackground: onIosBackground,
),
);
var wallet = getIt.get<AppStore>().wallet;
Timer.periodic(const Duration(milliseconds: 1000), (timer) {
if (wallet?.syncStatus.toString() == "stopped") {
bgService.invoke("startBgSync");
}
// bgService.invoke("status", {"status": wallet?.syncStatus.toString()});
});
}
Future<void> initializeService() async {
final service = FlutterBackgroundService();
await service.configure(
// iosConfiguration: IosConfiguration(
// autoStart: true,
// onForeground: onStart,
// onBackground: onIosBackground,
// ),
androidConfiguration: AndroidConfiguration(
autoStart: true,
onStart: onStart,
isForegroundMode: false,
autoStartOnBoot: true,
),
);
}
class BackgroundTasks {
FlutterBackgroundService bgService = FlutterBackgroundService();
void registerSyncTask({bool changeExisting = false}) async {
try {
bool hasMonero = getIt
@ -221,10 +492,12 @@ class BackgroundTasks {
final bool syncAll = settingsStore.currentSyncAll;
if (syncMode.type == SyncType.disabled || !FeatureFlag.isBackgroundSyncEnabled) {
cancelSyncTask();
bgService.invoke('stopService');
return;
}
await initializeService(bgService);
// await service.configure(
// androidConfiguration: AndroidConfiguration(
// // this will be executed when app is in foreground or background in separated isolate
@ -299,17 +572,17 @@ class BackgroundTasks {
}
void cancelSyncTask() {
try {
Workmanager().cancelByUniqueName(moneroSyncTaskKey);
} catch (error, stackTrace) {
print(error);
print(stackTrace);
}
try {
Workmanager().cancelByUniqueName(mwebSyncTaskKey);
} catch (error, stackTrace) {
print(error);
print(stackTrace);
}
// try {
// Workmanager().cancelByUniqueName(moneroSyncTaskKey);
// } catch (error, stackTrace) {
// print(error);
// print(stackTrace);
// }
// try {
// Workmanager().cancelByUniqueName(mwebSyncTaskKey);
// } catch (error, stackTrace) {
// print(error);
// print(stackTrace);
// }
}
}

1
lib/entities/load_current_wallet.dart
View file

@ -27,5 +27,6 @@ Future<void> loadCurrentWallet({String? password}) async {
password: password);
await appStore.changeCurrentWallet(wallet);
// TODO: potential for infinite loop here since this is run when the wallet is loaded for syncing from the bg:
// getIt.get<BackgroundTasks>().registerSyncTask();
}

1
pubspec_base.yaml
View file

@ -66,6 +66,7 @@ dependencies:
ref: master
workmanager: ^0.5.1
flutter_background_service: ^5.0.9
flutter_local_notifications: ^17.2.2
wakelock_plus: ^1.2.5
flutter_mailer: ^2.0.2
device_info_plus: ^9.1.0