import 'dart:async'; import 'package:flutter/material.dart'; import 'package:flutter_riverpod/flutter_riverpod.dart'; import 'package:flutter_svg/svg.dart'; import 'package:stackwallet/electrumx_rpc/electrumx.dart'; import 'package:stackwallet/models/node_model.dart'; import 'package:stackwallet/notifications/show_flush_bar.dart'; import 'package:stackwallet/pages/settings_views/global_settings_view/manage_nodes_views/add_edit_node_view.dart'; import 'package:stackwallet/pages/settings_views/global_settings_view/manage_nodes_views/node_details_view.dart'; import 'package:stackwallet/providers/providers.dart'; import 'package:stackwallet/utilities/assets.dart'; import 'package:stackwallet/utilities/constants.dart'; import 'package:stackwallet/utilities/default_nodes.dart'; import 'package:stackwallet/utilities/enums/coin_enum.dart'; import 'package:stackwallet/utilities/enums/sync_type_enum.dart'; import 'package:stackwallet/utilities/logger.dart'; import 'package:stackwallet/utilities/test_epic_box_connection.dart'; import 'package:stackwallet/utilities/test_monero_node_connection.dart'; import 'package:stackwallet/utilities/text_styles.dart'; import 'package:stackwallet/utilities/theme/stack_colors.dart'; import 'package:stackwallet/widgets/rounded_white_container.dart'; import 'package:tuple/tuple.dart'; class NodeOptionsSheet extends ConsumerWidget { const NodeOptionsSheet({ Key? key, required this.nodeId, required this.coin, required this.popBackToRoute, }) : super(key: key); final String nodeId; final Coin coin; final String popBackToRoute; Future _notifyWalletsOfUpdatedNode(WidgetRef ref) async { final managers = ref .read(walletsChangeNotifierProvider) .managers .where((e) => e.coin == coin); final prefs = ref.read(prefsChangeNotifierProvider); switch (prefs.syncType) { case SyncingType.currentWalletOnly: for (final manager in managers) { if (manager.isActiveWallet) { manager.updateNode(true); } else { manager.updateNode(false); } } break; case SyncingType.selectedWalletsAtStartup: final List walletIdsToSync = prefs.walletIdsSyncOnStartup; for (final manager in managers) { if (walletIdsToSync.contains(manager.walletId)) { manager.updateNode(true); } else { manager.updateNode(false); } } break; case SyncingType.allWalletsOnStartup: for (final manager in managers) { manager.updateNode(true); } break; } } Future _testConnection( NodeModel node, BuildContext context, WidgetRef ref) async { bool testPassed = false; switch (coin) { case Coin.epicCash: try { testPassed = await testEpicNodeConnection( NodeFormData() ..host = node.host ..useSSL = node.useSSL ..port = node.port, ) != null; } catch (e, s) { Logging.instance.log("$e\n$s", level: LogLevel.Warning); } break; case Coin.monero: case Coin.wownero: try { final uri = Uri.parse(node.host); if (uri.scheme.startsWith("http")) { final String path = uri.path.isEmpty ? "/json_rpc" : uri.path; String uriString = "${uri.scheme}://${uri.host}:${node.port}$path"; final response = await testMoneroNodeConnection( Uri.parse(uriString), false, ); if (response.cert != null) { // if (mounted) { final shouldAllowBadCert = await showBadX509CertificateDialog( response.cert!, response.url!, response.port!, context, ); if (shouldAllowBadCert) { final response = await testMoneroNodeConnection(Uri.parse(uriString), true); testPassed = response.success; } // } } else { testPassed = response.success; } } } catch (e, s) { Logging.instance.log("$e\n$s", level: LogLevel.Warning); } break; case Coin.bitcoin: case Coin.litecoin: case Coin.dogecoin: case Coin.firo: case Coin.particl: case Coin.bitcoinTestNet: case Coin.firoTestNet: case Coin.dogecoinTestNet: case Coin.bitcoincash: case Coin.litecoinTestNet: case Coin.namecoin: case Coin.bitcoincashTestnet: final client = ElectrumX( host: node.host, port: node.port, useSSL: node.useSSL, failovers: [], prefs: ref.read(prefsChangeNotifierProvider), ); try { testPassed = await client.ping(); } catch (_) { testPassed = false; } break; } if (testPassed) { // showFloatingFlushBar( // type: FlushBarType.success, // message: "Server ping success", // context: context, // ); } else { unawaited(showFloatingFlushBar( type: FlushBarType.warning, iconAsset: Assets.svg.circleAlert, message: "Could not connect to node", context: context, )); } return testPassed; } @override Widget build(BuildContext context, WidgetRef ref) { final maxHeight = MediaQuery.of(context).size.height * 0.60; final node = ref.watch(nodeServiceChangeNotifierProvider .select((value) => value.getNodeById(id: nodeId)))!; final status = ref .watch(nodeServiceChangeNotifierProvider .select((value) => value.getPrimaryNodeFor(coin: coin))) ?.id != nodeId ? "Disconnected" : "Connected"; return Container( decoration: BoxDecoration( color: Theme.of(context).extension()!.popupBG, borderRadius: const BorderRadius.vertical( top: Radius.circular(20), ), ), child: LimitedBox( maxHeight: maxHeight, child: Padding( padding: const EdgeInsets.only( left: 24, right: 24, top: 10, bottom: 0, ), child: SingleChildScrollView( child: Column( mainAxisSize: MainAxisSize.min, crossAxisAlignment: CrossAxisAlignment.start, children: [ Center( child: Container( decoration: BoxDecoration( color: Theme.of(context) .extension()! .textFieldDefaultBG, borderRadius: BorderRadius.circular( Constants.size.circularBorderRadius, ), ), width: 60, height: 4, ), ), const SizedBox( height: 36, ), Text( "Node options", style: STextStyles.pageTitleH2(context), textAlign: TextAlign.left, ), RoundedWhiteContainer( padding: const EdgeInsets.symmetric(vertical: 38), child: Row( children: [ Container( width: 32, height: 32, decoration: BoxDecoration( color: node.id .startsWith(DefaultNodes.defaultNodeIdPrefix) ? Theme.of(context) .extension()! .textSubtitle4 : Theme.of(context) .extension()! .infoItemIcons .withOpacity(0.2), borderRadius: BorderRadius.circular(100), ), child: Center( child: SvgPicture.asset( Assets.svg.node, height: 15, width: 19, color: node.id.startsWith( DefaultNodes.defaultNodeIdPrefix) ? Theme.of(context) .extension()! .accentColorDark : Theme.of(context) .extension()! .infoItemIcons, ), ), ), const SizedBox( width: 12, ), Column( crossAxisAlignment: CrossAxisAlignment.start, children: [ Text( node.name, style: STextStyles.titleBold12(context), ), const SizedBox( height: 2, ), Text( status, style: STextStyles.label(context), ), ], ), const Spacer(), SvgPicture.asset( Assets.svg.network, color: status == "Connected" ? Theme.of(context) .extension()! .accentColorGreen : Theme.of(context) .extension()! .buttonBackSecondary, width: 18, ), ], ), ), Row( children: [ // if (!node.id.startsWith("default")) Expanded( child: TextButton( style: Theme.of(context) .extension()! .getSecondaryEnabledButtonStyle(context), onPressed: () { Navigator.pop(context); Navigator.of(context).pushNamed( NodeDetailsView.routeName, arguments: Tuple3( coin, node.id, popBackToRoute, ), ); }, child: Text( "Details", style: STextStyles.button(context).copyWith( color: Theme.of(context) .extension()! .accentColorDark), ), ), ), // if (!node.id.startsWith("default")) const SizedBox( width: 12, ), Expanded( child: TextButton( style: status == "Connected" ? Theme.of(context) .extension()! .getPrimaryDisabledButtonStyle(context) : Theme.of(context) .extension()! .getPrimaryEnabledButtonStyle(context), onPressed: status == "Connected" ? null : () async { final canConnect = await _testConnection(node, context, ref); if (!canConnect) { return; } await ref .read(nodeServiceChangeNotifierProvider) .setPrimaryNodeFor( coin: coin, node: node, shouldNotifyListeners: true, ); await _notifyWalletsOfUpdatedNode(ref); }, child: Text( // status == "Connected" ? "Disconnect" : "Connect", "Connect", style: STextStyles.button(context), ), ), ), ], ), const SizedBox( height: 24, ), ], ), ), ), ), ); } }