1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
|
const axios = require("axios");
const bitcoin = require("bitcoinjs-lib");
const coinselect = require("coinselect");
const split = require("coinselect/split");
const api = prod ? "https://blockstream.info/api" : config.bitcoin.electrs;
const SATS = 100000000;
const network = prod
? bitcoin.networks["bitcoin"]
: bitcoin.networks["regtest"];
module.exports = ah(async (req, res) => {
let { address: from, amount, feeRate, target } = req.body;
let utxos;
if (!feeRate) feeRate = (await bc.estimateSmartFee(6)).feerate * SATS;
feeRate = Math.round(feeRate / 1000);
l.info("sweeping", req.user.username, from, amount, feeRate);
try {
let {
data: {
chain_stats: { funded_txo_sum: funded, spent_txo_sum: spent }
}
} = await axios.get(`${api}/address/${from}`);
let balance = funded - spent;
console.log("boom");
try {
console.log("fetching utxo");
({ data: utxos } = await axios.get(`${api}/address/${from}/utxo`));
console.log("got utxos", utxos);
} catch (e) {
l.error("problem fetching utxos", e.message);
}
let targets = [
{
address: target,
value: amount
}
];
let { inputs, outputs, fee } = coinselect(utxos, targets, feeRate);
if (balance === amount) {
delete targets[0].value;
({ inputs, outputs, fee } = split(utxos, targets, feeRate));
l.info("split", inputs, outputs, fee);
}
if (!inputs || !outputs)
return res
.status(500)
.send("Unable to construct sweep transaction, try a lower fee rate?");
let psbt = new bitcoin.Psbt({ network });
let total = 0;
outputs.map(({ address, value }) => {
total += value;
psbt = psbt.addOutput({
address: address || from,
value
});
});
for (let i = 0; i < inputs.length; i++) {
let { txid, vout } = inputs[i];
let nonWitnessUtxo = Buffer.from(await bc.getRawTransaction(txid), "hex");
psbt = psbt.addInput({
hash: txid,
index: vout,
nonWitnessUtxo
});
}
feeRate = Math.round(feeRate * 1000);
psbt = psbt.toBase64();
if (balance !== amount) total = 0;
res.send({ feeRate, psbt, total });
} catch (e) {
l.error("problem getting address stats", from, e.message);
}
});
|
