Speed up initial wallet sync attempts
This commit is contained in:
+7
-7
@@ -170,18 +170,18 @@ class _PeyaAppState extends ConsumerState<PeyaApp> {
|
||||
await ref
|
||||
.read(walletControllerProvider.notifier)
|
||||
.connectNode(config.nodeConfig);
|
||||
await ref.read(walletControllerProvider.notifier).syncNow();
|
||||
final syncedState = ref.read(walletControllerProvider);
|
||||
if (syncedState.syncStatus.lastSync != null) {
|
||||
return true;
|
||||
}
|
||||
} catch (_) {}
|
||||
final connected = await ref.read(walletRepositoryProvider).isConnected();
|
||||
if (connected) {
|
||||
await ref.read(walletControllerProvider.notifier).syncNow();
|
||||
final syncedState = ref.read(walletControllerProvider);
|
||||
if (syncedState.syncStatus.lastSync != null ||
|
||||
await ref.read(walletRepositoryProvider).isConnected()) {
|
||||
return true;
|
||||
}
|
||||
return true;
|
||||
}
|
||||
if (attempt + 1 < attempts) {
|
||||
await Future.delayed(const Duration(seconds: 1));
|
||||
await Future.delayed(const Duration(milliseconds: 500));
|
||||
}
|
||||
}
|
||||
return false;
|
||||
|
||||
@@ -448,21 +448,20 @@ class _LocalNodeControlsState extends ConsumerState<_LocalNodeControls> {
|
||||
for (var attempt = 0; attempt < 10; attempt++) {
|
||||
try {
|
||||
await ref.read(walletControllerProvider.notifier).connectNode(nodeConfig);
|
||||
} catch (_) {
|
||||
}
|
||||
final connected = await ref.read(walletRepositoryProvider).isConnected();
|
||||
if (connected) {
|
||||
await ref.read(walletControllerProvider.notifier).syncNow();
|
||||
final state = ref.read(walletControllerProvider);
|
||||
if (state.syncStatus.lastSync != null ||
|
||||
await ref.read(walletRepositoryProvider).isConnected()) {
|
||||
if (state.syncStatus.lastSync != null) {
|
||||
break;
|
||||
}
|
||||
} catch (_) {}
|
||||
final connected = await ref.read(walletRepositoryProvider).isConnected();
|
||||
if (connected) {
|
||||
break;
|
||||
}
|
||||
if (attempt == 9) {
|
||||
break;
|
||||
}
|
||||
await Future.delayed(const Duration(seconds: 1));
|
||||
await Future.delayed(const Duration(milliseconds: 500));
|
||||
}
|
||||
unawaited(
|
||||
ref.read(syncSchedulerProvider).burstSync(
|
||||
|
||||
Reference in New Issue
Block a user