104 lines
4.7 KiB
JavaScript
104 lines
4.7 KiB
JavaScript
/**
|
|
* This script gets all locked payments from our database and cross-checks them with actual
|
|
* sentout payments from LND. If locked payment is in there we moe locked payment to array of real payments for the user
|
|
* (it is effectively spent coins by user), if not - we attempt to pay it again (if it is not too old).
|
|
*/
|
|
import { User, Paym } from '../class/';
|
|
const config = require('../config');
|
|
|
|
/****** START SET FEES FROM CONFIG AT STARTUP ******/
|
|
/** GLOBALS */
|
|
global.forwardFee = config.forwardReserveFee || 0.01;
|
|
global.internalFee = config.intraHubFee || 0.003;
|
|
/****** END SET FEES FROM CONFIG AT STARTUP ******/
|
|
|
|
var Redis = require('ioredis');
|
|
var redis = new Redis(config.redis);
|
|
|
|
let bitcoinclient = require('../bitcoin');
|
|
let lightning = require('../lightning');
|
|
|
|
(async () => {
|
|
let keys = await redis.keys('locked_payments_for_*');
|
|
keys = User._shuffle(keys);
|
|
|
|
console.log('fetching listPayments...');
|
|
let tempPaym = new Paym(redis, bitcoinclient, lightning);
|
|
let listPayments = await tempPaym.listPayments();
|
|
// DEBUG let listPayments = JSON.parse(fs.readFileSync('listpayments.txt').toString('ascii'));
|
|
console.log('done', 'got', listPayments['payments'].length, 'payments');
|
|
|
|
for (let key of keys) {
|
|
const userid = key.replace('locked_payments_for_', '');
|
|
console.log('===================================================================================');
|
|
console.log('userid=', userid);
|
|
let user = new User(redis, bitcoinclient, lightning);
|
|
user._userid = userid;
|
|
let lockedPayments = await user.getLockedPayments();
|
|
// DEBUG let lockedPayments = [{ pay_req : 'lnbc108130n1pshdaeupp58kw9djt9vcdx26wkdxl07tgncdmxz2w7s9hzul45tf8gfplme94sdqqcqzzgxqrrssrzjqw8c7yfutqqy3kz8662fxutjvef7q2ujsxtt45csu0k688lkzu3ld93gutl3k6wauyqqqqryqqqqthqqpysp5jcmk82hypuud0lhpf66dg3w5ta6aumc4w9g9sxljazglq9wkwstq9qypqsqnw8hwwauvzrala3g4yrkgazk2l2fh582j9ytz7le46gmsgglvmrknx842ej9z4c63en5866l8tpevm8cwul8g94kf2nepppn256unucp43jnsw', amount: 10813, timestamp: 1635186606 }];
|
|
|
|
for (let lockedPayment of lockedPayments) {
|
|
let daysPassed = (+new Date() / 1000 - lockedPayment.timestamp) / 3600 / 24;
|
|
console.log('processing lockedPayment=', lockedPayment, daysPassed, 'days passed');
|
|
|
|
let payment = new Paym(redis, bitcoinclient, lightning);
|
|
payment.setInvoice(lockedPayment.pay_req);
|
|
|
|
// first things first:
|
|
// trying to lookup this stuck payment in an array of delivered payments
|
|
let isPaid = false;
|
|
for (let sentPayment of listPayments['payments']) {
|
|
if ((await payment.getPaymentHash()) == sentPayment.payment_hash) {
|
|
console.log('found this payment in listPayments array, so it is paid successfully');
|
|
let sendResult = payment.processSendPaymentResponse({ payment_error: 'already paid' } /* hacky */); // adds fees
|
|
console.log('saving paid invoice:', sendResult);
|
|
await user.savePaidLndInvoice(sendResult);
|
|
await user.unlockFunds(lockedPayment.pay_req);
|
|
isPaid = true;
|
|
console.log('!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!', await payment.getPaymentHash(), sentPayment.payment_hash);
|
|
break;
|
|
}
|
|
}
|
|
// could not find...
|
|
|
|
if (daysPassed > 1 / 24 && daysPassed <= 1) {
|
|
let sendResult;
|
|
console.log('attempting to pay to route');
|
|
try {
|
|
sendResult = await payment.attemptPayToRoute();
|
|
} catch (_) {
|
|
console.log(_);
|
|
console.log('evict lock');
|
|
await user.unlockFunds(lockedPayment.pay_req);
|
|
continue;
|
|
}
|
|
console.log('sendResult=', sendResult);
|
|
console.log('payment.getIsPaid() = ', payment.getIsPaid());
|
|
if (payment.getIsPaid() === true) {
|
|
console.log('paid successfully');
|
|
sendResult = payment.processSendPaymentResponse(sendResult); // adds fees
|
|
console.log('saving paid invoice:', sendResult);
|
|
await user.savePaidLndInvoice(sendResult);
|
|
await user.unlockFunds(lockedPayment.pay_req);
|
|
} else if (payment.getIsPaid() === false) {
|
|
console.log('not paid, just evict the lock');
|
|
await user.unlockFunds(lockedPayment.pay_req);
|
|
} else {
|
|
console.log('payment is in unknown state');
|
|
}
|
|
console.log('sleeping 5 sec...');
|
|
console.log('-----------------------------------------------------------------------------------');
|
|
await User._sleep(0);
|
|
} else if (daysPassed > 1) {
|
|
// could not find in listpayments array; too late to retry
|
|
if (!isPaid) {
|
|
console.log('very old payment, evict the lock');
|
|
await user.unlockFunds(lockedPayment.pay_req);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
console.log('done');
|
|
process.exit();
|
|
})();
|