Add function to get address utxos

Author: peacekeeper

src/main/java/com/danubetech/btc/connection/BitcoinConnection.java

@@ -2,6 +2,7 @@
 
 import com.danubetech.btc.connection.records.Block;
 import com.danubetech.btc.connection.records.Tx;
+import com.danubetech.btc.connection.records.TxOut;
 
 import java.util.List;
 import java.util.Map;
@@ -16,6 +17,7 @@ public interface BitcoinConnection {
     Block getBlockByTargetTime(Long targetTime);
     Block getBlockByMinConfirmations(Integer confirmations);
     List<Tx> getAddressTransactions(String address);
+    List<TxOut> getAddressUtxos(String address);
     Block getBlockByTransaction(Tx tx);
     void broadcastRawTransaction(byte[] rawTransaction);
 }

src/main/java/com/danubetech/btc/connection/impl/AbstractBitcoinConnection.java

@@ -4,6 +4,7 @@
 import com.danubetech.btc.connection.Network;
 import com.danubetech.btc.connection.records.Block;
 import com.danubetech.btc.connection.records.Tx;
+import com.danubetech.btc.connection.records.TxOut;
 
 import java.util.Collections;
 import java.util.List;
@@ -52,6 +53,11 @@ public List<Tx> getAddressTransactions(String address) {
         throw new RuntimeException("Not implemented");
     }
 
+    @Override
+    public List<TxOut> getAddressUtxos(String address) {
+        throw new RuntimeException("Not implemented");
+    }
+
     @Override
     public Block getBlockByTransaction(Tx tx) {
         throw new RuntimeException("Not implemented");

src/main/java/com/danubetech/btc/connection/impl/EsploraElectrsRESTBitcoinConnection.java

@@ -69,6 +69,15 @@ public List<Tx> getAddressTransactions(String address) {
 		return txs;
 	}
 
+	@Override
+	public List<TxOut> getAddressUtxos(String address) {
+		URI apiEndpoint = URI.create(this.apiEndpointBase + "address/" + address + "/utxo");
+		List<Object> response = readArray(apiEndpoint);
+		List<TxOut> txOuts = response.stream().map(Map.class::cast).map(EsploraElectrsRESTBitcoinConnection::txOutFromMap).toList();
+		if (log.isDebugEnabled()) log.debug("getAddressUtxos for {}: {}", address, txOuts);
+		return txOuts;
+	}
+
 	@Override
 	public Block getBlockByTransaction(Tx tx) {
 		URI apiEndpoint = URI.create(this.apiEndpointBase + "tx/" + tx.txId());