kosmos/lndhub
8
0
Fork 0
Code Issues Pull Requests Releases Activity

REF

Browse Source
This commit is contained in:
Overtorment 2019-01-06 13:37:37 +00:00
parent 4f345b20a8
commit 6a57559b16
1 changed files with 64 additions and 69 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

133
controllers/api.js
View File

@ -116,81 +116,76 @@ router.post('/payinvoice', async function(req, res) {
let userBalance = await u.getBalance(); let userBalance = await u.getBalance();
try { lightning.decodePayReq({ pay_req: req.body.invoice }, async function(err, info) {
// TODO: refactor if (err) return errorNotAValidInvoice(res);
lightning.decodePayReq({ pay_req: req.body.invoice }, async function(err, info) {
if (err) return errorNotAValidInvoice(res);
if (+info.num_satoshis === 0) { if (+info.num_satoshis === 0) {
// 'tip' invoices // 'tip' invoices
info.num_satoshis = freeAmount; info.num_satoshis = freeAmount;
}
if (userBalance >= info.num_satoshis) {
// got enough balance
if (identity_pubkey === info.destination) {
// this is internal invoice
// now, receiver add balance
let userid_payee = await u.getUseridByPaymentHash(info.payment_hash);
if (!userid_payee) return errorGeneralServerError(res);
let UserPayee = new User(redis);
UserPayee._userid = userid_payee; // hacky, fixme
let payee_balance = await UserPayee.getBalance();
payee_balance += info.num_satoshis * 1;
await UserPayee.saveBalance(payee_balance);
// sender spent his balance:
userBalance -= info.num_satoshis * 1;
await u.saveBalance(userBalance);
await u.savePaidLndInvoice({
timestamp: parseInt(+new Date() / 1000),
type: 'paid_invoice',
value: info.num_satoshis * 1,
fee: 0, // internal invoices are free
memo: decodeURIComponent(info.description),
});
await UserPayee.setPaymentHashPaid(info.payment_hash);
return res.send(info);
} }
if (userBalance >= info.num_satoshis) { var call = lightning.sendPayment();
// got enough balance call.on('data', function(payment) {
// payment callback
if (identity_pubkey === info.destination) { if (payment && payment.payment_route && payment.payment_route.total_amt_msat) {
// this is internal invoice userBalance -= +payment.payment_route.total_fees + +payment.payment_route.total_amt;
// now, receiver add balance u.saveBalance(userBalance);
let userid_payee = await u.getUseridByPaymentHash(info.payment_hash); payment.pay_req = req.body.invoice;
if (!userid_payee) return errorGeneralServerError(res); payment.decoded = info;
u.savePaidLndInvoice(payment);
let UserPayee = new User(redis); res.send(payment);
UserPayee._userid = userid_payee; // hacky, fixme } else {
let payee_balance = await UserPayee.getBalance(); // payment failed
payee_balance += info.num_satoshis * 1;
await UserPayee.saveBalance(payee_balance);
// sender spent his balance:
userBalance -= info.num_satoshis * 1;
await u.saveBalance(userBalance);
await u.savePaidLndInvoice({
timestamp: parseInt(+new Date() / 1000),
type: 'paid_invoice',
value: info.num_satoshis * 1,
fee: 0, // internal invoices are free
memo: decodeURIComponent(info.description),
});
await UserPayee.setPaymentHashPaid(info.payment_hash);
return res.send(info);
}
var call = lightning.sendPayment();
call.on('data', function(payment) {
// payment callback
if (payment && payment.payment_route && payment.payment_route.total_amt_msat) {
userBalance -= +payment.payment_route.total_fees + +payment.payment_route.total_amt;
u.saveBalance(userBalance);
payment.pay_req = req.body.invoice;
payment.decoded = info;
u.savePaidLndInvoice(payment);
res.send(payment);
} else {
// payment failed
return errorLnd(res);
}
});
if (!info.num_satoshis && !info.num_satoshis) {
// tip invoice, but someone forgot to specify amount
return errorBadArguments(res);
}
let inv = { payment_request: req.body.invoice, amt: info.num_satoshis }; // amt is used only for 'tip' invoices
try {
logger.log('/payinvoice', [req.id, 'before write', JSON.stringify(inv)]);
call.write(inv);
} catch (Err) {
logger.log('/payinvoice', [req.id, 'exception', JSON.stringify(Err)]);
return errorLnd(res); return errorLnd(res);
} }
} else { });
return errorNotEnougBalance(res); if (!info.num_satoshis && !info.num_satoshis) {
// tip invoice, but someone forgot to specify amount
return errorBadArguments(res);
} }
}); let inv = { payment_request: req.body.invoice, amt: info.num_satoshis }; // amt is used only for 'tip' invoices
} catch (Err) { try {
return errorLnd(res); logger.log('/payinvoice', [req.id, 'before write', JSON.stringify(inv)]);
} call.write(inv);
} catch (Err) {
logger.log('/payinvoice', [req.id, 'exception', JSON.stringify(Err)]);
return errorLnd(res);
}
} else {
return errorNotEnougBalance(res);
}
});
}); });
router.get('/getbtc', async function(req, res) { router.get('/getbtc', async function(req, res) {