address sweep wip

3 files changed, 22 insertions, 1 deletions

diff --git a/lib/sockets.js b/lib/sockets.js
index cc6da34c..e297703b 100644
--- a/lib/sockets.js
+++ b/lib/sockets.js
@@ -48,7 +48,7 @@ wss.on("connection", function (ws, req) {
       names[id] = username;
 
       ws.ok = true;
-      ws.send(JSON.stringify({ type: "networks", data: networks }));
+      ws.send(JSON.stringify({ type: "nodes", data: networks }));
       ws.send(JSON.stringify({ type: "rates", data: app.get("rates") }));
       ws.send(JSON.stringify({ type: "login", data: await getUser(username) }));
       l.info("socket open", username, id);
diff --git a/routes/bitcoin/address.js b/routes/bitcoin/address.js
new file mode 100644
index 00000000..3434f107
--- /dev/null
+++ b/routes/bitcoin/address.js
@@ -0,0 +1,20 @@
+const axios = require("axios");
+const api = "https://blockstream.info/api";
+
+module.exports = async (req, res) => {
+  try {
+    let { address } = req.body;
+    let {
+      data: {
+        chain_stats: { funded_txo_sum: balance },
+      },
+    } = await axios.get(`${api}/address/${address}`);
+
+    let utxos = [];
+    // let { data: utxos } = await axios.get(`${api}/address/${address}/utxo`);
+    res.send({ balance, utxos });
+  } catch (e) {
+    l.error("error retrieving address info", e.message);
+    return res.status(500).send(e.message);
+  }
+};
diff --git a/routes/payments.js b/routes/payments.js
index ab35c9a0..cfeb8450 100644
--- a/routes/payments.js
+++ b/routes/payments.js
@@ -40,6 +40,7 @@ const { join } = require("path");
 
   if (config.bitcoin) {
     bc = new BitcoinCore(config.bitcoin);
+    app.get("/bitcoin/address", auth, require("./bitcoin/address"));
     app.post("/bitcoin/fee", auth, require("./bitcoin/fee"));
     app.post("/bitcoin/send", auth, require("./bitcoin/send"));
     require("./bitcoin/receive");