aboutsummaryrefslogtreecommitdiffstats
path: root/lib/sync.js
diff options
context:
space:
mode:
authorAdrien Hopkins <[email protected]>2022-06-06 07:14:45 -0500
committerAdrien Hopkins <[email protected]>2022-06-06 07:14:45 -0500
commita2d2caf5eb29c6c804301e1faedd96856d57fcdc (patch)
tree930257d4ab30f89d3929e969739624758c815af5 /lib/sync.js
parentc3a28b2d1b1c902f7b691d5fefe70cda573d954f (diff)
parent47aeb5f041db40ef964116bbb4fe22ee8e8f64dd (diff)
downloadcoinos-server-a2d2caf5eb29c6c804301e1faedd96856d57fcdc.tar.gz
coinos-server-a2d2caf5eb29c6c804301e1faedd96856d57fcdc.zip
Merge branch 'master' into feature-withdrawal-fee
Diffstat (limited to 'lib/sync.js')
-rw-r--r--lib/sync.js12
1 files changed, 4 insertions, 8 deletions
diff --git a/lib/sync.js b/lib/sync.js
index fedb6798..e217dcd0 100644
--- a/lib/sync.js
+++ b/lib/sync.js
@@ -116,7 +116,7 @@ const sync = async () => {
preimage,
rate: invoice.rate,
received: true,
- confirmed: false,
+ confirmed: true,
network: "lightning",
tip: invoice.tip,
invoice_id: invoice.id,
@@ -124,7 +124,7 @@ const sync = async () => {
updatedAt: createdAt
});
- // await account.increment({ balance: amount });
+ await account.increment({ balance: amount });
l.info("lightning missing from account", account.id, amount);
}
@@ -152,7 +152,7 @@ const sync = async () => {
const transactions = [
...(await bc.listTransactions("*", 500)),
...(await lq.listTransactions("*", 500))
- ].filter(tx => ["send", "receive"].includes(tx.category));
+ ].filter(tx => ["send", "receive"].includes(tx.category) && new Date(tx.time * 1000) > twoWeeksAgo);
missed = transactions.filter(
tx =>
@@ -163,7 +163,6 @@ const sync = async () => {
for (let i = 0; i < missed.length; i++) {
let p = unconfirmed.find(p => p.hash === missed[i].txid);
- /*
p.confirmed = 1;
await db.transaction(async transaction => {
@@ -175,7 +174,6 @@ const sync = async () => {
emit(p.user.username, "account", p.account);
emit(p.user.username, "payment", p);
- */
l.info("unconfirmed tx", p.user_id, p.hash, p.address);
}
@@ -253,8 +251,7 @@ const sync = async () => {
amount = toSats(amount);
await db.transaction(async transaction => {
- l.info("found pending balance", user.username, amount);
- /*
+ l.info("found pending transaction", user.username, amount, hash);
payments.push(hash);
let p = await db.Payment.create(
{
@@ -278,7 +275,6 @@ const sync = async () => {
emit(user.username, "account", account);
emit(user.username, "payment", p);
- */
});
}
}