refactor send to use satpoints instead of ranges

src/main.rs

@@ -34,7 +34,7 @@ use {
   serde::{Deserialize, Serialize},
   std::{
     cmp::Ordering,
-    collections::VecDeque,
+    collections::{BTreeMap, VecDeque},
     env,
     fmt::{self, Display, Formatter},
     fs, io,

src/sat_point.rs

@@ -1,6 +1,6 @@
 use super::*;
 
-#[derive(Debug, PartialEq)]
+#[derive(Debug, PartialEq, Copy, Clone)]
 pub(crate) struct SatPoint {
   pub(crate) outpoint: OutPoint,
   pub(crate) offset: u64,
@@ -29,3 +29,53 @@ impl Decodable for SatPoint {
     })
   }
 }
+
+impl FromStr for SatPoint {
+  type Err = Error;
+
+  fn from_str(s: &str) -> Result<Self, Self::Err> {
+    let (outpoint, offset) = s
+      .rsplit_once(':')
+      .ok_or_else(|| anyhow!("invalid satpoint: {s}"))?;
+
+    Ok(SatPoint {
+      outpoint: outpoint.parse()?,
+      offset: offset.parse()?,
+    })
+  }
+}
+
+#[cfg(test)]
+mod tests {
+  use super::*;
+
+  #[test]
+  fn from_str_ok() {
+    assert_eq!(
+      "1111111111111111111111111111111111111111111111111111111111111111:1:1"
+        .parse::<SatPoint>()
+        .unwrap(),
+      SatPoint {
+        outpoint: "1111111111111111111111111111111111111111111111111111111111111111:1"
+          .parse()
+          .unwrap(),
+        offset: 1,
+      }
+    );
+  }
+
+  #[test]
+  fn from_str_err() {
+    "abc".parse::<SatPoint>().unwrap_err();
+
+    "abc:xyz".parse::<SatPoint>().unwrap_err();
+
+    "1111111111111111111111111111111111111111111111111111111111111111:1"
+      .parse::<SatPoint>()
+      .unwrap_err();
+
+    "1111111111111111111111111111111111111111111111111111111111111111:1:foo"
+      .parse::<SatPoint>()
+      .unwrap_err();
+  }
+}

src/subcommand/wallet.rs

@@ -22,6 +22,43 @@ fn list_unspent(options: &Options, index: &Index) -> Result<Vec<(OutPoint, Vec<(
     .collect()
 }
 
+#[allow(dead_code)]
+fn list_utxos(options: &Options) -> Result<BTreeMap<OutPoint, Amount>> {
+  let client = options.bitcoin_rpc_client()?;
+
+  Ok(
+    client
+      .list_unspent(None, None, None, None, None)?
+      .iter()
+      .map(|utxo| {
+        let outpoint = OutPoint::new(utxo.txid, utxo.vout);
+        let amount = utxo.amount;
+
+        (outpoint, amount)
+      })
+      .collect(),
+  )
+}
+
+fn ordinal_to_satpoint(
+  ordinal: Ordinal,
+  utxos: BTreeMap<OutPoint, Vec<(u64, u64)>>,
+) -> Option<SatPoint> {
+  for (outpoint, ranges) in utxos {
+    let mut offset = 0;
+    for (start, end) in ranges {
+      if ordinal.0 >= start && ordinal.0 < end {
+        return Some(SatPoint {
+          outpoint,
+          offset: offset + (ordinal.0 - start),
+        });
+      }
+      offset += end - start;
+    }
+  }
+  None
+}
+
 fn get_change_addresses(options: &Options, n: usize) -> Result<Vec<Address>> {
   let client = options.bitcoin_rpc_client()?;
 

src/subcommand/wallet/inscribe.rs

@@ -95,9 +95,19 @@ impl Inscribe {
 
     let commit_tx_address = Address::p2tr_tweaked(taproot_spend_info.output_key(), network);
 
+    let satpoint = ordinal_to_satpoint(ordinal, utxos.clone().into_iter().collect()).unwrap();
+
     let unsigned_commit_tx = TransactionBuilder::build_transaction(
-      utxos.into_iter().collect(),
-      ordinal,
+      satpoint,
+      utxos
+        .into_iter()
+        .map(|(outpoint, ranges)| {
+          (
+            outpoint,
+            Amount::from_sat(ranges.iter().map(|(start, end)| end - start).sum()),
+          )
+        })
+        .collect(),
       commit_tx_address.clone(),
       change,
     )?;

src/subcommand/wallet/send.rs

@@ -2,7 +2,7 @@ use super::*;
 
 #[derive(Debug, Parser)]
 pub(crate) struct Send {
-  ordinal: Ordinal,
+  satpoint: SatPoint,
   address: Address,
 }
 
@@ -18,15 +18,12 @@ impl Send {
       );
     }
 
-    let index = Index::open(&options)?;
-    index.update()?;
-
-    let utxos = list_unspent(&options, &index)?.into_iter().collect();
+    let utxos = list_utxos(&options)?;
 
     let change = get_change_addresses(&options, 2)?;
 
     let unsigned_transaction =
-      TransactionBuilder::build_transaction(utxos, self.ordinal, self.address, change)?;
+      TransactionBuilder::build_transaction(self.satpoint, utxos, self.address, change)?;
 
     let signed_tx = client
       .sign_raw_transaction_with_wallet(&unsigned_transaction, None, None)?