github-such-software/hash-wallet
1
0
Fork 1
mirror of https://github.com/Such-Software/hash-wallet.git synced 2026-10-17 05:41:29 +02:00
Code Issues Packages Projects Releases Wiki Activity

Migrate to new Chainflip endpoints (#2386)

Browse Source 
* feat: migrate to new chainflip endpoints

* chore: remove debug comments
This commit is contained in:
David Cumps
2025-07-16 06:49:12 +03:00
committed by GitHub
parent 1a5774da40
commit 28eb83cc8f
1 changed files with 29 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/exchange/provider/chainflip_exchange_provider.dart
+29 -6
View File
@@ -37,7 +37,7 @@ class ChainflipExchangeProvider extends ExchangeProvider {
static const _baseURL = 'chainflip-broker.io';
static const _assetsPath = '/assets';
static const _quotePath = '/quote-native';
static const _quotePath = '/quotes-native';
static const _swapPath = '/swap';
static const _txInfoPath = '/status-by-deposit-channel';
static const _affiliateBps = secrets.chainflipAffiliateFee;
@@ -145,6 +145,13 @@ class ChainflipExchangeProvider extends ExchangeProvider {
'retryDurationInBlocks': '150'
};
if (quoteResponse.containsKey('numberOfChunks') && quoteResponse.containsKey('chunkIntervalBlocks')) {
swapParams.addAll({
'numberOfChunks': quoteResponse['numberOfChunks'].toString(),
'chunkIntervalBlocks': quoteResponse['chunkIntervalBlocks'].toString(),
});
}
final swapResponse = await _openDepositChannel(swapParams);
final id = '${swapResponse['issuedBlock']}-${swapResponse['network'].toString().toUpperCase()}-${swapResponse['channelId']}';
@@ -266,9 +273,6 @@ class ChainflipExchangeProvider extends ExchangeProvider {
Future<Map<String, dynamic>> _getAssets() async =>
_getRequest(_assetsPath, {});
Future<Map<String, dynamic>> _getSwapQuote(Map<String, String> params) async =>
_getRequest(_quotePath, params);
Future<Map<String, dynamic>> _openDepositChannel(Map<String, String> params) async =>
_getRequest(_swapPath, params);
@@ -276,7 +280,6 @@ class ChainflipExchangeProvider extends ExchangeProvider {
final uri = Uri.https(_baseURL, path, params);
final response = await ProxyWrapper().get(clearnetUri: uri);
if ((response.statusCode != 200) || (response.body.contains('error'))) {
throw Exception('Unexpected response: ${response.statusCode} / ${uri.toString()} / ${response.body}');
@@ -285,11 +288,31 @@ class ChainflipExchangeProvider extends ExchangeProvider {
return json.decode(response.body) as Map<String, dynamic>;
}
Future<Map<String, dynamic>> _getSwapQuote(Map<String, String> params) async {
final uri = Uri.https(_baseURL, _quotePath, params);
final response = await ProxyWrapper().get(clearnetUri: uri);
if ((response.statusCode != 200) || (response.body.contains('error'))) {
throw Exception('Unexpected response: ${response.statusCode} / ${uri.toString()} / ${response.body}');
}
final quotes = json.decode(response.body) as List<dynamic>;
Map<String, dynamic> highestQuote = quotes.reduce((current, next) {
double currentAmount = current['egressAmount'];
double nextAmount = next['egressAmount'];
return currentAmount > nextAmount ? current : next;
});
return highestQuote;
}
Future<Map<String, dynamic>?> _getStatus(Map<String, String> params) async {
final uri = Uri.https(_baseURL, _txInfoPath, params);
final response = await ProxyWrapper().get(clearnetUri: uri);
if (response.statusCode == 404) return null;