import config from "$config"; import { db } from "$lib/db"; import { err, warn } from "$lib/logging"; import { mail, templates } from "$lib/mail"; import mqtt from "$lib/mqtt"; import { emit } from "$lib/sockets"; import { f, fiat, fmt, link, t } from "$lib/utils"; import webpush from "web-push"; if (config.vapid) { webpush.setVapidDetails( `mailto:${config.support}`, config.vapid.pk, config.vapid.sk, ); } export const notify = async (p, user, withdrawal) => { emit(user.id, "payment", p); let { username } = user; const { paymentReceived } = t(user); username = username.replace(/\s/g, ""); try { if (user.verified && user.notify) { mail(user, paymentReceived, templates.paymentReceived, { ...t(user), username, payment: { amount: fmt(p.amount), link: link(p.id), tip: p.tip ? fmt(p.tip) : undefined, fiat: f(fiat(p.amount, p.rate), p.currency), fiatTip: p.tip ? f(fiat(p.tip, p.rate), p.currency) : undefined, memo: p.memo, items: p.items?.map((i) => { return { quantity: i.quantity, name: i.name, total: i.quantity * i.price, totalFiat: f(i.quantity * i.price, p.currency), }; }), }, withdrawal, }); } } catch (e) { err("problem emailing", e.message); } const subscriptions = await db.sMembers(`${user.id}:subscriptions`); const payload = { title: paymentReceived, body: `${fmt(p.amount)} ${f(fiat(p.amount, p.rate), p.currency)}`, url: `/payment/${p.id}`, }; for (const s of subscriptions) { webpush .sendNotification(JSON.parse(s), JSON.stringify(payload)) .catch((e) => { warn("sub failed", e.message); db.sRem(`${user.id}:subscriptions`, s); }); } if (config.mqtt) { if (!mqtt.connected) await mqtt.reconnect(); mqtt.publish( username, `pay:${p.amount}:${p.tip}:${p.rate}:${p.created}:${p.id}:${p.memo}:${p.items}`, ); } }; option> coinos server — legacy coinos.io backend (Lightning, on-chain, Liquid)coinos
aboutsummaryrefslogtreecommitdiffstats
path: root/lib/buildtx.js
blob: 5e0fe29f7787c0a31985c80bfa3ea0603b3b5803 (plain) (blame) 
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

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" : "http://localhost:3095";
const SATS = 100000000;
const network = prod
  ? bitcoin.networks["bitcoin"]
  : bitcoin.networks["regtest"];

module.exports = 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) {
      l.error("problem fetching utxos", e.message);
    }
  } 

  let targets = [
    {
      address,
      value: amount
    }
  ];

  let { inputs, outputs, fee } = coinselect(utxos, targets, feeRate);

  if (!inputs || !outputs) {
    l.info("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;
      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 };
};