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
85
86
87
88
89
90
|
import store from "./store";
import { prod } from "./utils";
import axios from "axios";
import bitcoin from "bitcoinjs-lib";
import coinselect from "coinselect";
import split from "coinselect/split";
const api = prod ? "https://blockstream.info/api" : "http://electrsb:3095";
const SATS = 100000000;
const network = prod
? bitcoin.networks["bitcoin"]
: bitcoin.networks["regtest"];
export default async ({ address, amount, feeRate, replaceable, user }) => {
if (!feeRate) feeRate = (await bc.estimateSmartFee(6)).feerate * SATS;
feeRate = Math.round(feeRate / 1000);
const payments = await db.Payment.findAll({
where: {
received: true,
account_id: user.account_id,
network: "bitcoin"
}
});
const addresses = [...new Set(payments.map(p => p.address))];
const utxos = [];
for (let i = 0; i < addresses.length; i++) {
try {
utxos.push(
...(await axios.get(`${api}/address/${addresses[i]}/utxo`)).data
);
} catch (e) {
err("problem fetching utxos", e.message);
}
}
let targets = [
{
address,
value: amount
}
];
let { inputs, outputs, fee } = coinselect(utxos, targets, feeRate);
if (!inputs || !outputs) {
l(
"utxos",
amount,
feeRate,
utxos.map(u => u.value)
);
throw new Error(
"Couldn't find inputs for transaction, check your balance/fee"
);
}
let psbt = new bitcoin.Psbt({ network });
let total = 0;
outputs.map(({ address, value }) => {
total += value;
if (!address) {
address = payments[payments.length - 1].address;
store.change.push(address);
}
psbt = psbt.addOutput({
address,
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
});
}
if (replaceable) psbt.setInputSequence(0, 0xffffffff - 2);
feeRate = Math.round(feeRate * 1000);
psbt = psbt.toBase64();
return { tx: psbt, feeRate };
};
|
