liquid receiving support

1 files changed, 134 insertions, 0 deletions

diff --git a/liquidPayments.js b/liquidPayments.js
new file mode 100644
index 00000000..62be1243
--- /dev/null
+++ b/liquidPayments.js
@@ -0,0 +1,134 @@
+const reverse = require("buffer-reverse");
+const zmq = require("zeromq");
+const config = require("./config");
+const Sequelize = require("sequelize");
+const BitcoinCore = require("bitcoin-core");
+const bitcoin = require("bitcoinjs-lib");
+const l = console.log;
+
+const zmqRawBlock = zmq.socket("sub");
+zmqRawBlock.connect(config.liquid.zmqrawblock);
+zmqRawBlock.subscribe("rawblock");
+
+const zmqRawTx = zmq.socket("sub");
+zmqRawTx.connect("tcp://127.0.0.1:18603");
+zmqRawTx.subscribe("rawtx");
+
+let NETWORK = bitcoin.networks[config.bitcoin.network === "mainnet" ? "bitcoin" : config.bitcoin.network];
+const bc = new BitcoinCore(config.liquid);
+
+module.exports = (app, db, addresses, payments, emit) => {
+  zmqRawTx.on("message", async (topic, message, sequence) => {
+    const tx = await bc.decodeRawTransaction(message.toString("hex"));
+
+    Promise.all(
+      tx.vout.map(async o => {
+        if (!(o.scriptPubKey && o.scriptPubKey.addresses)) return;
+        const address = o.scriptPubKey.addresses[0];
+
+        if (Object.keys(addresses).includes(address)) {
+          payments.push(hash);
+
+          let user = await db.User.findOne({
+            where: {
+              username: addresses[address]
+            }
+          });
+
+          let invoices = await db.Payment.findAll({
+            limit: 1,
+            where: {
+              address,
+              received: null,
+              amount: {
+                [Sequelize.Op.gt]: 0
+              }
+            },
+            order: [["id", "DESC"]]
+          });
+
+          let tip = null;
+          if (invoices.length) tip = invoices[0].tip;
+
+          let confirmed = false;
+
+          if (user.friend) {
+            user.balance += o.value;
+            confirmed = true;
+          } else {
+            user.pending += o.value;
+          }
+
+          await user.save();
+          emit(user.username, "user", user);
+
+          const payment = await db.Payment.create({
+            user_id: user.id,
+            hash,
+            amount: o.value,
+            currency: "CAD",
+            rate: app.get("ask"),
+            received: true,
+            tip,
+            confirmed,
+            address
+          });
+
+          emit(user.username, "payment", payment);
+          emit(user.username, "tx", message);
+        }
+      })
+    );
+  });
+
+  let queue = {};
+
+  zmqRawBlock.on("message", async (topic, message, sequence) => {
+    /*
+    const payments = await db.Payment.findAll({
+      where: { confirmed: false }
+    });
+
+    const hashes = payments.map(p => p.hash);
+
+    let block = bitcoin.Block.fromHex(message.toString("hex"));
+    block.transactions.map(tx => {
+      let hash = reverse(tx.getHash()).toString("hex");
+      if (hashes.includes(hash)) queue[hash] = 1;
+    }); 
+  */
+  });
+
+  /*
+  setInterval(async () => {
+    let arr = Object.keys(queue);
+    for (let i = 0; i < arr.length; i++) {
+      let hash = arr[i];
+
+      let p = await db.Payment.findOne({
+        include: [{ model: db.User, as: "user" }],
+        where: { hash, confirmed: 0 }
+      })
+
+      p.confirmed = 1;
+
+      let user = await p.getUser();
+      user.balance += p.amount;
+      user.pending -= p.amount;
+      emit(user.username, "user", user);
+
+      await user.save();
+      await p.save();
+
+      let payments = await db.Payment.findAll({
+        where: { user_id: user.id },
+        order: [['id', 'DESC']],
+        limit: 20
+      });
+
+      emit(user.username, "payments", payments);
+      delete queue[hash];
+    }
+  }, 1000);
+  */
+};