Ecosystem/stack_wallet
1
0
Fork 0
mirror of https://github.com/cypherstack/stack_wallet.git synced 2024-11-17 09:47:37 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

WIP subscribe to block headers in order to fetch chain height

Browse source 
not working because SubscribableElectrumXClient isn't initialized
This commit is contained in:
sneurlax 2024-02-02 15:51:31 -06:00
parent 3c23b0491c
commit b896337d64
2 changed files with 74 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

29
lib/electrumx_rpc/subscribable_electrumx_client.dart
View file

@ -13,6 +13,7 @@ import 'dart:convert';
import 'dart:io';
import 'package:flutter/foundation.dart';
import 'package:stackwallet/electrumx_rpc/electrumx_client.dart';
import 'package:stackwallet/utilities/logger.dart';
class ElectrumXSubscription with ChangeNotifier {
@ -60,6 +61,29 @@ class SubscribableElectrumXClient {
_keepAlive = keepAlive;
}
factory SubscribableElectrumXClient.from({
required ElectrumXNode node,
// TorService? torService,
}) {
return SubscribableElectrumXClient(
useSSL: node.useSSL,
);
}
// Example for returning a future which completes upon connection.
// static Future<SubscribableElectrumXClient> from({
// required ElectrumXNode node,
// TorService? torService,
// }) async {
// final client = SubscribableElectrumXClient(
// useSSL: node.useSSL,
// );
//
// await client.connect(host: node.address, port: node.port);
//
// return client;
// }
Future<void> connect({required String host, required int port}) async {
try {
await _socket?.close();
@ -75,7 +99,10 @@ class SubscribableElectrumXClient {
true, // TODO do not automatically trust bad certificates.
);
} catch (e, s) {
print(s);
Logging.instance.log(
"Error connecting in SubscribableElectrumXClient"
"\nError: $e\nStack trace: $s",
level: LogLevel.Error);
}
} else {
_socket = await Socket.connect(

49
lib/wallets/wallet/wallet_mixin_interfaces/electrumx_interface.dart
View file

@ -7,6 +7,7 @@ import 'package:coinlib_flutter/coinlib_flutter.dart' as coinlib;
import 'package:isar/isar.dart';
import 'package:stackwallet/electrumx_rpc/cached_electrumx_client.dart';
import 'package:stackwallet/electrumx_rpc/electrumx_client.dart';
import 'package:stackwallet/electrumx_rpc/subscribable_electrumx_client.dart';
import 'package:stackwallet/models/isar/models/blockchain_data/v2/input_v2.dart';
import 'package:stackwallet/models/isar/models/blockchain_data/v2/output_v2.dart';
import 'package:stackwallet/models/isar/models/blockchain_data/v2/transaction_v2.dart';
@ -30,6 +31,7 @@ import 'package:uuid/uuid.dart';
mixin ElectrumXInterface<T extends Bip39HDCurrency> on Bip39HDWallet<T> {
late ElectrumXClient electrumXClient;
late CachedElectrumXClient electrumXCachedClient;
late SubscribableElectrumXClient subscribableElectrumXClient;
int? get maximumFeerate => null;
@ -793,10 +795,47 @@ mixin ElectrumXInterface<T extends Bip39HDCurrency> on Bip39HDWallet<T> {
}
Future<int> fetchChainHeight() async {
final Completer<int> completer = Completer<int>();
try {
final result = await electrumXClient.getBlockHeadTip();
return result["height"] as int;
} catch (e) {
// Subscribe to block headers.
final subscription =
subscribableElectrumXClient.subscribeToBlockHeaders();
// Make sure we only complete once.
bool isFirstResponse = true;
// Add listener.
subscription.addListener(() {
final response = subscription.response;
if (response != null &&
response is Map &&
response.containsKey('height')) {
final int chainHeight = response['height'] as int;
// print("Current chain height: $chainHeight");
if (isFirstResponse) {
isFirstResponse = false;
// Return the chain height.
completer.complete(chainHeight);
}
} else {
Logging.instance.log(
"blockchain.headers.subscribe returned malformed response\n"
"Response: $response",
level: LogLevel.Error);
}
});
// Wait for first response.
return completer.future;
} catch (e, s) {
Logging.instance.log(
"Exception rethrown in fetchChainHeight\nError: $e\nStack trace: $s",
level: LogLevel.Error);
// completer.completeError(e, s);
// return Future.error(e, s);
rethrow;
}
}
@ -865,6 +904,10 @@ mixin ElectrumXInterface<T extends Bip39HDCurrency> on Bip39HDWallet<T> {
electrumXCachedClient = CachedElectrumXClient.from(
electrumXClient: electrumXClient,
);
subscribableElectrumXClient = SubscribableElectrumXClient.from(
node: newNode,
// torService: torService,
);
}
//============================================================================