Update ldk_node.dart

Author: BitcoinZavior

CHANGELOG.md

@@ -1,20 +1,4 @@
 ## [0.3.0]
-Updated `flutter_rust_bridge` to `2.0.0`.
-#### APIs added
-- `buildWithFsStore` method is added in the `Builder` class allowing to use the filesystem storage backend.
-- Exposed `setLiquiditySourceLsps2` method to `Builder` to configure the `Node` instance to source the inbound liquidity. 
-- `nextEventAsync` method is added to `Node` class that allows polling the event queue asynchronously.
-- `status` method has been added to `Node` allowing to retrieve information about the Node's status.
-- `config` method added to get the config with which the `Node` was initialized.
-- The payment APIs have been restructured to use per-type (bolt11, onchain, bolt12) payment handlers which can be accessed via `node.{type}Payment`.
-- Support for sourcing inbound liquidity via LSPS2 just-in-time (JIT) channels has been added.
-- Support for creating and paying BOLT12 offers and refunds has been added.
-- Added `networkGraph` handler method allowing to query the network graph.
-- Added `forceCloseChannel` to `Node` class.
-#### API changed
-- All available balances outside of channel balances are now exposed via a unified `listBalances` interface method.
-#### Fixed
-Persisted peers are now correctly reconnected after startup.
 
 ## [0.2.2-dev]
 Updated Rust and Flutter dependencies.

example/lib/main.dart

@@ -36,31 +36,46 @@ class _MyAppState extends State<MyApp> {
       'http://10.0.2.2:30000'
       : 'http://127.0.0.1:30000';*/
 
+
   @override
   void initState() {
     initAliceNode();
     super.initState();
   }
 
-  Future<ldk.Builder> createBuilder(
-      String path, ldk.SocketAddress address, String mnemonic) async {
+  Future<ldk.Config> initLdkConfig(
+      String path, ldk.SocketAddress address) async {
     final directory = await getApplicationDocumentsDirectory();
-    final nodeStorageDir = "${directory.path}/ldk_cache/$path";
-    print(nodeStorageDir);
-    // For a node on the mutiny network with default config and service
-    ldk.Builder builder = ldk.Builder.mutinynet()
-        .setEntropyBip39Mnemonic(mnemonic: ldk.Mnemonic(seedPhrase: mnemonic))
-        .setEsploraServer(esploraUrl)
-        .setStorageDirPath(nodeStorageDir)
-        .setListeningAddresses([address]);
-    return builder;
+    final nodePath = "${directory.path}/ldk_cache/$path";
+    final config = ldk.Config(
+        probingLiquidityLimitMultiplier: BigInt.from(3),
+        trustedPeers0Conf: [],
+        storageDirPath: nodePath,
+        network: ldk.Network.regtest,
+        listeningAddresses: [address],
+        onchainWalletSyncIntervalSecs: BigInt.from(60),
+        walletSyncIntervalSecs: BigInt.from(20),
+        feeRateCacheUpdateIntervalSecs: BigInt.from(600),
+        logLevel: ldk.LogLevel.debug,
+        defaultCltvExpiryDelta: 144);
+    return config;
+  }
+
+  closeChannel() async {
+    await aliceNode.closeChannel(
+        userChannelId: userChannelId!, counterpartyNodeId: bobNodeId!);
   }
 
   Future initAliceNode() async {
-    aliceNode = await (await createBuilder(
-            'alice_mutinynet',
-            ldk.SocketAddress.hostname(addr: "0.0.0.0", port: 3003),
-            "cart super leaf clinic pistol plug replace close super tooth wealth usage"))
+    final aliceConfig = await initLdkConfig('alice_mutinynet',
+        ldk.SocketAddress.hostname(addr: "0.0.0.0", port: 3003));
+    ldk.Builder aliceBuilder = ldk.Builder.fromConfig(config: aliceConfig);
+    aliceNode = await aliceBuilder
+        .setEntropyBip39Mnemonic(
+            mnemonic: ldk.Mnemonic(
+                seedPhrase:
+                    "cart super leaf clinic pistol plug replace close super tooth wealth usage"))
+        .setEsploraServer(esploraUrl)
         .build();
     await startNode(aliceNode);
     final res = await aliceNode.nodeId();
@@ -70,11 +85,22 @@ class _MyAppState extends State<MyApp> {
     });
   }
 
+  startNode(ldk.Node node) async {
+    try {
+      node.start();
+    } on ldk.NodeException catch (e) {
+      print(e.toString());
+    }
+  }
+
   initBobNode() async {
-    bobNode = await (await createBuilder(
-            'bob_mutinynet',
-            ldk.SocketAddress.hostname(addr: "0.0.0.0", port: 3004),
-            "puppy interest whip tonight dad never sudden response push zone pig patch"))
+    ldk.Builder bobBuilder = ldk.Builder
+        .mutinynet(); // For a node on the mutiny network with default config and services
+    bobNode = await bobBuilder
+        .setEntropyBip39Mnemonic(
+            mnemonic: ldk.Mnemonic(
+                seedPhrase:
+                    'puppy interest whip tonight dad never sudden response push zone pig patch'))
         .build();
     await startNode(bobNode);
     final res = await bobNode.nodeId();
@@ -84,14 +110,6 @@ class _MyAppState extends State<MyApp> {
     });
   }
 
-  startNode(ldk.Node node) async {
-    try {
-      node.start();
-    } on ldk.NodeException catch (e) {
-      print(e.toString());
-    }
-  }
-
   totalOnchainBalanceSats() async {
     final alice = await aliceNode.listBalances();
     final bob = await bobNode.listBalances();
@@ -122,7 +140,7 @@ class _MyAppState extends State<MyApp> {
         for (var e in res) {
           print("nodeId: ${aliceNodeId!.hex}");
           print("userChannelId: ${e.userChannelId.data}");
-          print("confirmations required: ${e.confirmationsRequired}");
+          print("channelId: ${e.channelId.data}");
           print("isChannelReady: ${e.isChannelReady}");
           print("isUsable: ${e.isUsable}");
           print("outboundCapacityMsat: ${e.outboundCapacityMsat}");
@@ -187,15 +205,6 @@ class _MyAppState extends State<MyApp> {
     }
   }
 
-  closeChannel() async {
-    await aliceNode.closeChannel(
-        userChannelId: userChannelId!,
-        counterpartyNodeId: ldk.PublicKey(
-          hex:
-              '02465ed5be53d04fde66c9418ff14a5f2267723810176c9212b722e542dc1afb1b',
-        ));
-  }
-
   connectOpenChannel() async {
     final funding_amount_sat = 80000;
     final push_msat = (funding_amount_sat / 2) * 1000;
@@ -223,9 +232,8 @@ class _MyAppState extends State<MyApp> {
         amountMsat: BigInt.from(25000 * 1000),
         description: 'asdf',
         expirySecs: 9217);
-    print(invoice!.signedRawInvoice);
     setState(() {
-      displayText = invoice!.signedRawInvoice;
+      displayText = invoice.toString();
     });
     final paymentId = await aliceBolt11Handler.send(invoice: invoice!);
     final res = await aliceNode.payment(paymentId: paymentId);

lib/ldk_node.dart

@@ -29,5 +29,6 @@ export './src/generated/api/types.dart'
         GossipSourceConfig,
         EntropySourceConfig_SeedFile;
 export 'src/root.dart';
+export 'src/generated/lib.dart' show U8Array4, U8Array12, U8Array64, U8Array32;
 export 'src/utils/utils.dart'
     hide ExceptionBase, mapLdkBuilderError, mapLdkNodeError, Frb;