You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
117 lines
5.2 KiB
JavaScript
117 lines
5.2 KiB
JavaScript
4 years ago
|
var request = require('request-promise');
|
||
|
var common = require('../../common');
|
||
|
var logger = require('../logger');
|
||
|
var options = {};
|
||
|
var pendingInvoices = [];
|
||
|
|
||
|
getReceivedPaymentInfo = (invoice) => {
|
||
|
let idx = -1;
|
||
|
return new Promise(function(resolve, reject) {
|
||
|
invoice.timestampStr = (!invoice.timestamp) ? '' : common.convertTimestampToDate(invoice.timestamp);
|
||
|
invoice.expiresAt = (!invoice.expiry) ? null : (+invoice.timestamp + +invoice.expiry);
|
||
|
invoice.expiresAtStr = (!invoice.expiresAt) ? '' : common.convertTimestampToDate(invoice.expiresAt);
|
||
|
if (invoice.amount) { invoice.amount = Math.round(invoice.amount/1000); }
|
||
|
idx = pendingInvoices.findIndex(pendingInvoice => invoice.serialized === pendingInvoice.serialized);
|
||
|
if (idx < 0) {
|
||
|
options.url = common.getSelLNServerUrl() + '/getreceivedinfo';
|
||
|
options.form = { paymentHash: invoice.paymentHash };
|
||
|
request(options).then(response => {
|
||
|
invoice.status = response.status.type;
|
||
|
invoice.amount = Math.round(response.status.amount/1000);
|
||
|
if (response.status.receivedAt) {
|
||
|
invoice.receivedAt = Math.round(response.status.receivedAt / 1000);
|
||
|
invoice.receivedAtStr = common.convertTimestampToDate(invoice.receivedAt);
|
||
|
}
|
||
|
resolve(invoice);
|
||
|
}).catch(err => {
|
||
|
invoice.status = 'unknown';
|
||
|
resolve(invoice);
|
||
|
});
|
||
|
} else {
|
||
|
pendingInvoices.splice(idx, 1);
|
||
|
invoice.status = 'unpaid';
|
||
|
resolve(invoice);
|
||
|
}
|
||
|
});
|
||
|
}
|
||
|
|
||
|
exports.listInvoices = (req, res, next) => {
|
||
|
options = common.getOptions();
|
||
|
options.form = {};
|
||
|
options1 = JSON.parse(JSON.stringify(options));
|
||
|
options1.url = common.getSelLNServerUrl() + '/listinvoices';
|
||
|
options1.form = {};
|
||
|
options2 = JSON.parse(JSON.stringify(options));
|
||
|
options2.url = common.getSelLNServerUrl() + '/listpendinginvoices';
|
||
|
options2.form = {};
|
||
|
Promise.all([request(options1), request(options2)])
|
||
|
.then(body => {
|
||
|
logger.info({fileName: 'Invoice', msg: 'Invoices List Received: ' + JSON.stringify(body)});
|
||
|
let invoices = (!body[0] || body[0].length <= 0) ? [] : body[0];
|
||
|
pendingInvoices = (!body[1] || body[1].length <= 0) ? [] : body[1];
|
||
|
if (invoices && invoices.length > 0) {
|
||
|
Promise.all(invoices.map(invoice => getReceivedPaymentInfo(invoice)))
|
||
|
.then(values => {
|
||
|
body = common.sortDescByKey(invoices, 'expiresAt');
|
||
|
logger.info({fileName: 'Invoice', msg: 'Final Invoices List: ' + JSON.stringify(invoices)});
|
||
|
res.status(200).json(invoices);
|
||
|
})
|
||
|
.catch(errRes => {
|
||
|
let err = JSON.parse(JSON.stringify(errRes));
|
||
|
if (err.options && err.options.headers && err.options.headers.authorization) {
|
||
|
delete err.options.headers.authorization;
|
||
|
}
|
||
|
if (err.response && err.response.request && err.response.request.headers && err.response.request.headers.authorization) {
|
||
|
delete err.response.request.headers.authorization;
|
||
|
}
|
||
|
logger.error({fileName: 'Invoice', lineNum: 66, msg: 'List Invoices Error: ' + JSON.stringify(err)});
|
||
|
return res.status(err.statusCode ? err.statusCode : 500).json({
|
||
|
message: "Fetching Invoices failed!",
|
||
|
error: err.error && err.error.error ? err.error.error : err.error ? err.error : "Unknown Server Error"
|
||
|
});
|
||
|
});
|
||
|
} else {
|
||
|
res.status(200).json([]);
|
||
|
}
|
||
|
})
|
||
|
.catch(errRes => {
|
||
|
let err = JSON.parse(JSON.stringify(errRes));
|
||
|
if (err.options && err.options.headers && err.options.headers.authorization) {
|
||
|
delete err.options.headers.authorization;
|
||
|
}
|
||
|
if (err.response && err.response.request && err.response.request.headers && err.response.request.headers.authorization) {
|
||
|
delete err.response.request.headers.authorization;
|
||
|
}
|
||
|
logger.error({fileName: 'Invoice', lineNum: 84, msg: 'List Invoices Error: ' + JSON.stringify(err)});
|
||
|
return res.status(err.statusCode ? err.statusCode : 500).json({
|
||
|
message: "Fetching Invoices failed!",
|
||
|
error: err.error && err.error.error ? err.error.error : err.error ? err.error : "Unknown Server Error"
|
||
|
});
|
||
|
});
|
||
|
};
|
||
|
|
||
|
exports.createInvoice = (req, res, next) => {
|
||
|
options = common.getOptions();
|
||
|
options.url = common.getSelLNServerUrl() + '/createinvoice';
|
||
|
options.form = req.body;
|
||
|
request.post(options).then((body) => {
|
||
|
logger.info({fileName: 'Invoice', msg: 'Create Invoice Response: ' + JSON.stringify(body)});
|
||
|
if (body.amount) { body.amount = Math.round(body.amount/1000); }
|
||
|
res.status(201).json(body);
|
||
|
})
|
||
|
.catch(errRes => {
|
||
|
let err = JSON.parse(JSON.stringify(errRes));
|
||
|
if (err.options && err.options.headers && err.options.headers.authorization) {
|
||
|
delete err.options.headers.authorization;
|
||
|
}
|
||
|
if (err.response && err.response.request && err.response.request.headers && err.response.request.headers.authorization) {
|
||
|
delete err.response.request.headers.authorization;
|
||
|
}
|
||
|
logger.error({fileName: 'Invoice', lineNum: 108, msg: 'Create Invoice Error: ' + JSON.stringify(err)});
|
||
|
return res.status(err.statusCode ? err.statusCode : 500).json({
|
||
|
message: "Create Invoice Failed!",
|
||
|
error: err.error && err.error.error ? err.error.error : err.error ? err.error : "Unknown Server Error"
|
||
|
});
|
||
|
});
|
||
|
};
|