feat(joinstr): route relay and electrum over the app Tor when available

Signed-off-by: Kyle 🐆 <kyle@privkey.io>

Author: kwsantiago

lib/features/joinstr/data/joinstr_datasource.dart

@@ -1,3 +1,4 @@
+import 'package:bb_mobile/core/tor/domain/ports/tor_config_port.dart';
 import 'package:bb_mobile/core/wallet/domain/entities/wallet.dart';
 import 'package:bb_mobile/features/joinstr/domain/joinstr.dart';
 import 'package:joinstr_flutter/joinstr_flutter.dart' as jns;
@@ -6,7 +7,19 @@ import 'package:joinstr_flutter/joinstr_flutter.dart' as jns;
 /// and domain entities; the `Ffi*` types and the BTC-denominated pool config
 /// do not escape it.
 class JoinstrDatasource {
-  const JoinstrDatasource();
+  final TorConfigPort _torConfig;
+
+  const JoinstrDatasource(this._torConfig);
+
+  /// The app's local SOCKS5 proxy (`host:port`) when Tor is available, so every
+  /// relay and electrum connection the bindings make routes over Tor and the
+  /// participating IP is not exposed alongside the coin being mixed. Returns
+  /// null when Tor is not running, which the bindings treat as a direct
+  /// connection, keeping the flow usable without Tor.
+  Future<String?> _proxy() async {
+    final config = await _torConfig.getAvailableExternalTorConfig();
+    return config == null ? null : '127.0.0.1:${config.port}';
+  }
 
   /// Runs an FFI call, translating the binding's `JoinstrError` into a domain
   /// [JoinstrException] that carries its real message. Without this the error
@@ -24,11 +37,13 @@ class JoinstrDatasource {
     required Duration back,
     required Duration wait,
   }) async {
+    final proxy = await _proxy();
     final pools = await _call(
       () => jns.listPools(
         back: BigInt.from(back.inSeconds),
         timeout: BigInt.from(wait.inMicroseconds),
         relay: relay,
+        proxy: proxy,
       ),
     );
 
@@ -116,6 +131,7 @@ class JoinstrDatasource {
   }) async {
     final endpoint = Joinstr.parseElectrumUrl(electrumUrl);
     final network = _network(wallet.network);
+    final proxy = await _proxy();
 
     final coins = await jns.listCoins(
       mnemonic: mnemonic,
@@ -124,6 +140,7 @@ class JoinstrDatasource {
       rangeStart: 0,
       rangeEnd: Joinstr.scanDepth,
       network: network,
+      proxy: proxy,
     );
 
     // The window is enforced by every other peer only *after* we broadcast a
@@ -148,6 +165,7 @@ class JoinstrDatasource {
       outputAddress: outputAddress,
       relay: relay,
       network: network,
+      proxy: proxy,
     );
   }
 

lib/features/joinstr/joinstr_locator.dart

@@ -1,6 +1,7 @@
 import 'package:bb_mobile/core/electrum/domain/repositories/electrum_server_repository.dart';
 import 'package:bb_mobile/core/seed/data/repository/seed_repository.dart';
 import 'package:bb_mobile/core/storage/data/datasources/key_value_storage/key_value_storage_datasource.dart';
+import 'package:bb_mobile/core/tor/domain/ports/tor_config_port.dart';
 import 'package:bb_mobile/core/utils/constants.dart';
 import 'package:bb_mobile/core/wallet/domain/usecases/get_receive_address_usecase.dart';
 import 'package:bb_mobile/core/wallet/domain/usecases/get_wallets_usecase.dart';
@@ -18,7 +19,7 @@ import 'package:get_it/get_it.dart';
 class JoinstrLocator {
   static void setup(GetIt locator) {
     locator.registerLazySingleton<JoinstrDatasource>(
-      () => const JoinstrDatasource(),
+      () => JoinstrDatasource(locator<TorConfigPort>()),
     );
     locator.registerLazySingleton<JoinstrStore>(
       () => JoinstrStore(