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);
  require("./stripe")(auth, app, db, emit);

  app.get("/balance/:address", require("./addressBalance"));

  app.use(function(err, req, res, next) {
    res.status(500);
    res.send("An error occurred");
   l.info(err.stack);
    return res.end();
  });

  server.listen(config.port, () =>
    console.log(`CoinOS Server listening on port ${config.port}`)
  );
})();