Implement failed swap resolving methods

Author: danielgranhao

examples/3l-node/cli.rs

@@ -112,6 +112,16 @@ pub(crate) fn poll_for_user_input(node: &LightningNode, log_file_path: &str) {
                         println!("{}", message.red());
                     }
                 }
+                "listfailedswaps" => {
+                    if let Err(message) = list_failed_swaps(node) {
+                        println!("{}", message.red());
+                    }
+                }
+                "refundfailedswap" => {
+                    if let Err(message) = refund_failed_swap(node, &mut words) {
+                        println!("{}", message.red());
+                    }
+                }
                 "registertopup" => {
                     if let Err(message) = register_topup(node, &mut words) {
                         println!("{}", message.red());
@@ -219,6 +229,12 @@ fn setup_editor(history_path: &Path) -> Editor<CommandHinter, DefaultHistory> {
         "payopeninvoice ",
     ));
 
+    hints.insert(CommandHint::new("listfailedswaps>", "listfailedswaps "));
+    hints.insert(CommandHint::new(
+        "refundfailedswap <swap address> <to address>",
+        "refundfailedswap ",
+    ));
+
     hints.insert(CommandHint::new(
         "registertopup <IBAN> <currency> [email]",
         "registertopup ",
@@ -261,6 +277,9 @@ fn help() {
     println!("  payinvoice <invoice>");
     println!("  payopeninvoice <invoice> <amount in SAT>");
     println!();
+    println!("  listfailedswaps");
+    println!("  refundfailedswap <swap address> <to address>");
+    println!();
     println!("  registertopup <IBAN> <currency> [email]");
     println!("  listoffers");
     println!();
@@ -548,6 +567,52 @@ fn pay_open_invoice(
     Ok(())
 }
 
+fn list_failed_swaps(node: &LightningNode) -> Result<(), String> {
+    let failed_swaps = match node.get_unresolved_failed_swaps() {
+        Ok(s) => s,
+        Err(e) => return Err(e.to_string()),
+    };
+
+    println!(
+        "Total of {} failed swaps\n",
+        failed_swaps.len().to_string().bold()
+    );
+    for swap in failed_swaps {
+        let created_at: DateTime<Local> = swap.created_at.into();
+        println!("Failed swap created at {created_at}:");
+        println!("      Address         {}", swap.address);
+        println!("      Amount:         {}", amount_to_string(swap.amount));
+    }
+
+    Ok(())
+}
+
+fn refund_failed_swap(
+    node: &LightningNode,
+    words: &mut dyn Iterator<Item = &str>,
+) -> Result<(), String> {
+    let swap_address = words
+        .next()
+        .ok_or_else(|| "swap address is required".to_string())?;
+    let to_address = words
+        .next()
+        .ok_or_else(|| "to address is required".to_string())?;
+
+    let fee_rate = match node.query_onchain_fee() {
+        Ok(r) => r,
+        Err(e) => return Err(e.to_string()),
+    };
+
+    match node.refund_failed_swap(swap_address.into(), to_address.into(), fee_rate) {
+        Ok(txid) => {
+            println!("Successfully broadcasted refund transaction - txid: {txid}")
+        }
+        Err(e) => return Err(e.to_string()),
+    }
+
+    Ok(())
+}
+
 fn register_topup(
     node: &LightningNode,
     words: &mut dyn Iterator<Item = &str>,

src/lib.rs

@@ -252,6 +252,7 @@ pub struct FailedSwapInfo {
     /// The amount that is available to be refunded. The refund will involve paying some
     /// onchain fees so it isn't possible to recover the entire amount.
     pub amount: Amount,
+    pub created_at: SystemTime,
 }
 
 #[derive(Clone, PartialEq, Debug)]
@@ -1087,6 +1088,7 @@ impl LightningNode {
             .map(|s| FailedSwapInfo {
                 address: s.bitcoin_address.clone(),
                 amount: (s.confirmed_sats * 1000).to_amount_down(&self.get_exchange_rate()),
+                created_at: unix_timestamp_to_system_time(s.created_at as u64),
             })
             .collect())
     }

src/lipalightninglib.udl

@@ -324,6 +324,7 @@ enum OfferStatus {
 dictionary FailedSwapInfo {
     string address;
     Amount amount;
+    timestamp created_at;
 };
 
 //