import 'dart:convert'; import 'package:cake_wallet/buy/buy_provider.dart'; import 'package:cake_wallet/generated/i18n.dart'; import 'package:cake_wallet/routes.dart'; import 'package:cake_wallet/src/widgets/alert_with_one_action.dart'; import 'package:cake_wallet/utils/device_info.dart'; import 'package:cake_wallet/utils/show_pop_up.dart'; import 'package:cw_core/wallet_base.dart'; import 'package:cw_core/wallet_type.dart'; import 'package:flutter/material.dart'; import 'package:http/http.dart' as http; import 'package:url_launcher/url_launcher.dart'; class DFXBuyProvider extends BuyProvider { DFXBuyProvider({required WalletBase wallet, bool isTestEnvironment = false}) : super(wallet: wallet, isTestEnvironment: isTestEnvironment); static const _baseUrl = 'api.dfx.swiss'; static const _authPath = '/v1/auth/signMessage'; static const _signUpPath = '/v1/auth/signUp'; static const _signInPath = '/v1/auth/signIn'; static const walletName = 'CakeWallet'; @override String get title => 'DFX Connect'; @override String get providerDescription => S.current.dfx_option_description; @override String get lightIcon => 'assets/images/dfx_light.png'; @override String get darkIcon => 'assets/images/dfx_dark.png'; String get assetOut { switch (wallet.type) { case WalletType.bitcoin: return 'BTC'; case WalletType.bitcoinCash: return 'BCH'; case WalletType.litecoin: return 'LTC'; case WalletType.monero: return 'XMR'; case WalletType.ethereum: return 'ETH'; default: throw Exception("WalletType is not available for DFX ${wallet.type}"); } } String get blockchain { switch (wallet.type) { case WalletType.bitcoin: case WalletType.bitcoinCash: case WalletType.litecoin: return 'Bitcoin'; case WalletType.monero: return 'Monero'; case WalletType.ethereum: return 'Ethereum'; default: throw Exception("WalletType is not available for DFX ${wallet.type}"); } } Future getSignMessage() async { final walletAddress = wallet.walletAddresses.address; final uri = Uri.https(_baseUrl, _authPath, {'address': walletAddress}); var response = await http.get(uri, headers: {'accept': 'application/json'}); if (response.statusCode == 200) { final responseBody = jsonDecode(response.body); return responseBody['message'] as String; } else { throw Exception( 'Failed to get sign message. Status: ${response.statusCode} ${response.body}'); } } Future signUp() async { final signMessage = getSignature(await getSignMessage()); final walletAddress = wallet.walletAddresses.address; final requestBody = jsonEncode({ 'wallet': walletName, 'address': walletAddress, 'signature': signMessage, }); final uri = Uri.https(_baseUrl, _signUpPath); var response = await http.post(uri, headers: {'Content-Type': 'application/json'}, body: requestBody); if (response.statusCode == 201) { final responseBody = jsonDecode(response.body); return responseBody['accessToken'] as String; } else if (response.statusCode == 403) { final responseBody = jsonDecode(response.body); final message = responseBody['message'] ?? 'Service unavailable in your country'; throw Exception(message); } else { throw Exception( 'Failed to sign up. Status: ${response.statusCode} ${response.body}'); } } Future signIn() async { final signMessage = getSignature(await getSignMessage()); final walletAddress = wallet.walletAddresses.address; final requestBody = jsonEncode({ 'address': walletAddress, 'signature': signMessage, }); final uri = Uri.https(_baseUrl, _signInPath); var response = await http.post(uri, headers: {'Content-Type': 'application/json'}, body: requestBody); if (response.statusCode == 201) { final responseBody = jsonDecode(response.body); return responseBody['accessToken'] as String; } else if (response.statusCode == 403) { final responseBody = jsonDecode(response.body); final message = responseBody['message'] ?? 'Service unavailable in your country'; throw Exception(message); } else { throw Exception( 'Failed to sign in. Status: ${response.statusCode} ${response.body}'); } } String getSignature(String message) { switch (wallet.type) { case WalletType.ethereum: return wallet.signMessage(message); case WalletType.monero: case WalletType.litecoin: case WalletType.bitcoin: case WalletType.bitcoinCash: return wallet.signMessage(message, address: wallet.walletAddresses.address); default: throw Exception("WalletType is not available for DFX ${wallet.type}"); } } @override Future launchProvider(BuildContext context, bool? isBuyAction) async { try { final assetOut = this.assetOut; final blockchain = this.blockchain; final actionType = isBuyAction == true ? '/buy' : '/sell'; String accessToken; try { accessToken = await signUp(); } on Exception catch (e) { if (e.toString().contains('409')) { accessToken = await signIn(); } else { rethrow; } } final uri = Uri.https('services.dfx.swiss', actionType, { 'session': accessToken, 'lang': 'en', 'asset-out': assetOut, 'blockchain': blockchain, 'asset-in': 'EUR', }); if (await canLaunchUrl(uri)) { if (DeviceInfo.instance.isMobile) { Navigator.of(context) .pushNamed(Routes.webViewPage, arguments: ["DFX Connect", uri]); } else { await launchUrl(uri, mode: LaunchMode.externalApplication); } } else { throw Exception('Could not launch URL'); } } catch (e) { await showPopUp( context: context, builder: (BuildContext context) { return AlertWithOneAction( alertTitle: "DFX Connect", alertContent: S.of(context).buy_provider_unavailable + ': $e', buttonText: S.of(context).ok, buttonAction: () => Navigator.of(context).pop()); }); } } }