From c0888fab024cc9f7c99812bfabf9d7774312dbf7 Mon Sep 17 00:00:00 2001
From: Adam Soltys <asoltys@gmail.com>
Date: Wed, 11 Mar 2020 15:10:40 -0700
Subject: refactor

---
 index.js | 91 ++++++++++++++++++++++++----------------------------------------
 1 file changed, 34 insertions(+), 57 deletions(-)

(limited to 'index.js')

diff --git a/index.js b/index.js
index e2116a39..b84aa10f 100644
--- a/index.js
+++ b/index.js
@@ -1,63 +1,40 @@
 const bodyParser = require("body-parser");
 const compression = require("compression");
 const cookieParser = require("cookie-parser");
-const BitcoinCore = require("bitcoin-core");
 const cors = require("cors");
 const express = require("express");
 
-const config = require("./config");
-const bolt11 = require("bolt11");
-
-const l = require("pino")();
-
-(async () => {
-  const bc = new BitcoinCore(config.bitcoin);
-  const app = express();
-  app.enable("trust proxy");
-  app.use(bodyParser.urlencoded({ extended: true }));
-  app.use(bodyParser.json());
-  app.use(cookieParser());
-  app.use(cors({ credentials: true, origin: "http://*:*" }));
-  app.use(compression());
-
-  const server = require("http").Server(app);
-  const db = require("./db");
-  const [socket, emit] = require("./sockets")(app, db, server);
-  const passport = require("./passport")(db);
-  const auth = passport.authenticate("jwt", { session: false });
-
-  app.use(passport.initialize());
-
-  require("./rates")(app, socket);
-
-  const seen = [];
-  const addresses = {};
-  await db.User.findAll({
-    attributes: ["username", "address", "liquid"]
-  }).map(u => {
-    addresses[u.address] = u.username;
-    if (u.liquid) addresses[u.liquid] = u.username;
-  });
-
-  const payments = (await db.Payment.findAll({
-    attributes: ["hash"]
-  })).map(p => p.hash);
-
-  app.get("/rates", (req, res) => {
-    res.send(app.get("rates"));
-  });
-
-  require("./payments")(app, auth, addresses, bc, db, emit, seen, payments);
-  require("./users")(addresses, auth, app, bc, db, emit);
-
-  app.use(function(err, req, res, next) {
-    res.status(500);
-    res.send("An error occurred");
-    l.error(err.stack);
-    return res.end();
-  });
-
-  server.listen(config.port, () =>
-    console.log(`CoinOS Server listening on port ${config.port}`)
-  );
-})();
+l = require("pino")();
+config = require("./config");
+
+SATS = 100000000;
+toSats = n => parseInt((n * SATS).toFixed())
+
+app = express();
+app.enable("trust proxy");
+app.use(bodyParser.urlencoded({ extended: true }));
+app.use(bodyParser.json());
+app.use(cookieParser());
+app.use(cors({ credentials: true, origin: "http://*:*" }));
+app.use(compression());
+
+server = require("http").Server(app);
+require("./db");
+require("./lib/sockets");
+require("./lib/passport");
+require("./lib/rates");
+
+require("./routes/payments");
+require("./routes/users");
+
+app.use((err, req, res, next) => {
+  l.info("res", res);
+  res.status(500);
+  res.send("An error occurred");
+  l.error("uncaught error", err.stack);
+  return res.end();
+});
+
+server.listen(config.port, () =>
+  console.log(`CoinOS Server listening on port ${config.port}`)
+);
-- 
cgit v1.2.3