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
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
|
const asset = "LNBTC";
const handlePayment = async msg => {
try {
await db.transaction(async transaction => {
if (!msg.settled) return;
const invoice = await db.Invoice.findOne({
where: {
text: msg.payment_request
}
});
if (!invoice) return l.warn("received lightning with no invoice", msg.payment_request);
const { text: hash, currency, rate, tip, user_id } = invoice;
const amount = parseInt(msg.amt_paid_sat) - tip;
const account = await db.Account.findOne({
where: {
user_id,
asset: config.liquid.btcasset
},
lock: transaction.LOCK.UPDATE,
transaction
});
let preimage = msg.r_preimage.toString("hex");
let payment = await db.Payment.create({
account_id: account.id,
user_id,
hash,
amount,
currency,
preimage,
rate,
received: true,
confirmed: true,
network: "LNBTC",
tip
},
{ transaction });
invoice.received += amount + tip;
account.balance += amount + tip;
await account.save({ transaction });
await invoice.save({ transaction });
await payment.save({ transaction });
payments.push(msg.payment_request);
let user = await getUserById(user_id, transaction);
payment = payment.get({ plain: true });
payment.account = account.get({ plain: true });
emit(user.username, "payment", payment);
emit(user.username, "user", user);
l.info(
"lightning payment received",
user.username,
payment.amount,
payment.tip
);
});
} catch(e) {
l.error("problem receiving lightning payment", e.message);
}
};
if (config.lna.clightning) {
const poll = async ln => {
const wait = async i => {
const {
bolt11: payment_request,
pay_index,
status,
msatoshi_received,
payment_preimage: r_preimage
} = await ln.waitanyinvoice(i);
let settled = status === "paid";
let amt_paid_sat = parseInt(msatoshi_received / 1000);
await handlePayment({
payment_request,
settled,
amt_paid_sat,
r_preimage
});
wait(pay_index);
};
const { invoices } = await ln.listinvoices();
wait(Math.max(...invoices.map(i => i.pay_index).filter(n => n)));
};
poll(lna);
poll(lnb);
} else {
const invoices = lna.subscribeInvoices({});
invoices.on("data", handlePayment);
const invoicesb = lnb.subscribeInvoices({});
invoicesb.on("data", handlePayment);
}
|
