feat(joinstr): repin bindings to the #40 merge and consume the coinjoin progress stream

Author: kwsantiago

lib/features/joinstr/data/joinstr_datasource.dart

@@ -73,7 +73,9 @@ class JoinstrDatasource {
         denominationSat: pool.denominationSat,
         proxy: proxy,
       );
-      return jns.joinCoinjoin(poolRawJson: pool.rawJson, peer: peer);
+      return _awaitBroadcast(
+        jns.joinCoinjoin(poolRawJson: pool.rawJson, peer: peer),
+      );
     });
   }
 
@@ -99,19 +101,45 @@ class JoinstrDatasource {
         denominationSat: denominationSat,
         proxy: proxy,
       );
-      return jns.initiateCoinjoin(
-        config: jns.FfiPoolConfig(
-          denominationBtc: Joinstr.denominationBtc(denominationSat),
-          fee: feeRateSatPerVb,
-          maxDuration: BigInt.from(maxDuration.inSeconds),
-          peers: peers,
-          network: _network(wallet.network),
+      return _awaitBroadcast(
+        jns.initiateCoinjoin(
+          config: jns.FfiPoolConfig(
+            denominationBtc: Joinstr.denominationBtc(denominationSat),
+            fee: feeRateSatPerVb,
+            maxDuration: BigInt.from(maxDuration.inSeconds),
+            peers: peers,
+            network: _network(wallet.network),
+          ),
+          peer: peer,
         ),
-        peer: peer,
       );
     });
   }
 
+  /// Collapses the bindings' progress stream to the single result the rest of
+  /// the app consumes: the txid once the coinjoin broadcasts. The intermediate
+  /// steps are for a progress UI the domain layer does not model yet, so they
+  /// are drained silently; the terminal `failed` step (and a stream that closes
+  /// without any terminal step) surface as a [JoinstrException].
+  Future<String> _awaitBroadcast(Stream<jns.FfiCoinjoinUpdate> updates) async {
+    await for (final update in updates) {
+      switch (update.step) {
+        case jns.FfiCoinjoinStep.done:
+          final txid = update.txid;
+          if (txid != null) return txid;
+          throw JoinstrException(JoinstrIssue.coinjoinFailed);
+        case jns.FfiCoinjoinStep.failed:
+          throw JoinstrException(
+            JoinstrIssue.coinjoinFailed,
+            detail: update.error,
+          );
+        default:
+          continue;
+      }
+    }
+    throw JoinstrException(JoinstrIssue.coinjoinFailed);
+  }
+
   Future<jns.FfiPeerConfig> _peerConfig({
     required Wallet wallet,
     required String mnemonic,

pubspec.lock

@@ -1232,8 +1232,8 @@ packages:
     dependency: "direct main"
     description:
       path: dart
-      ref: d1bb9f8
-      resolved-ref: d1bb9f867aa40af7d4480e5d09e2196e5e9b0203
+      ref: "6e4e2e3"
+      resolved-ref: "6e4e2e387249678424add40c881c6aaba32dcd7d"
       url: "https://github.com/rust-joinstr/joinstr"
     source: git
     version: "0.1.0"

pubspec.yaml

@@ -43,7 +43,7 @@ dependencies:
   joinstr_flutter:
     git:
       url: https://github.com/rust-joinstr/joinstr
-      ref: d1bb9f8
+      ref: 6e4e2e3
       path: dart
   qr_flutter: ^4.1.0
   dio: ^5.9.0