From 667302c91ceb1c1477782a6262d8d618ccd133e6 Mon Sep 17 00:00:00 2001 From: Adam Soltys Date: Thu, 16 Dec 2021 22:05:36 -0500 Subject: check for payment existence --- routes/liquid/receive.js | 20 +++++++++++++++++--- 1 file changed, 17 insertions(+), 3 deletions(-) (limited to 'routes/liquid') diff --git a/routes/liquid/receive.js b/routes/liquid/receive.js index 626cb21a..92942ce4 100644 --- a/routes/liquid/receive.js +++ b/routes/liquid/receive.js @@ -104,15 +104,29 @@ zmqRawTx.on("message", async (topic, message, sequence) => { let invoice = await db.Invoice.findOne({ where: { - unconfidential: address, + [Op.or]: { + unconfidential: address, + address + }, user_id: user.id, network: "liquid" }, - order: [["id", "DESC"]] + order: [["id", "DESC"]], + transaction }); if (!invoice) return; + let payment = await db.Payment.findOne({ + where: { + invoice_id: invoice.id, + }, + order: [["id", "DESC"]], + transaction + }); + + if (payment) return; + let confirmed = 0; let account = await db.Account.findOne({ @@ -156,7 +170,7 @@ zmqRawTx.on("message", async (topic, message, sequence) => { const tip = invoice ? invoice.tip : 0; const memo = invoice ? invoice.memo : ""; - let payment = await db.Payment.create( + payment = await db.Payment.create( { account_id: account.id, user_id: user.id, -- cgit v1.2.3