server.js

"use strict";

require('dotenv').config({silent: true});
const bodyParser = require("body-parser");
const path = require("path");
const pug = require("pug");
const express = require("express");
const session = require("express-session");
const async = require("async");
const Client = require("coinbase").Client;
const ExpressOIDC = require("@okta/oidc-middleware").ExpressOIDC;
const passport = require("passport");
const CoinbaseStrategy = require("passport-coinbase").Strategy;
const router = express.Router();

// Globals
const OKTA_ISSUER_URI = process.env.OKTA_ISSUER_URI;
const OKTA_CLIENT_ID = process.env.OKTA_CLIENT_ID;
const OKTA_CLIENT_SECRET = process.env.OKTA_CLIENT_SECRET;
const REDIRECT_URI = process.env.REDIRECT_URI;
const PORT = process.env.PORT || "3000";
const SECRET = process.env.SECRET;
const client = new Client({
    apiKey: process.env.COINBASE_APIKEY_ID,
    apiSecret: process.env.COINBASE_APIKEY_SECRET,
    "version": "2018-05-28"
});

let account;
var transactions;
var addresses;

let app = express();
let db = require("./models");

// App settings
app.use(bodyParser.urlencoded({extended: true}));
app.use(bodyParser.json());
app.set("view engine", "pug");
app.set("views", path.join(__dirname, "views"));

//App middleware
app.use("/public", express.static("public"));
app.use(express.static(path.join(__dirname, "public")));

app.use(session({
    cookie: {httpOnly: true},
    secret: SECRET
}));

//Authentication
let oidc = new ExpressOIDC({
    issuer: OKTA_ISSUER_URI,
    client_id: OKTA_CLIENT_ID,
    client_secret: OKTA_CLIENT_SECRET,
    redirect_uri: REDIRECT_URI,
    routes: {
        callback: {
            defaultRedirect: "/dashboard"
        }
    },
    scope: "openid profile"
});

app.use(oidc.router);

// App routes
// require("./routes/api-accounts-routes.js")(app);
// require("./routes/api-transactions-routes.js")(app, client, oidc);
// require("./controllers/oauth2")(app, passport, CoinbaseStrategy);
// require("./routes/api-oauth2-routes")(app, passport);

app.get("/", (req, res) => {
    res.render("index");
});

app.get('/dashboard', (req, res, next) => {
    res.render("index", {
        addresses: addresses,
        transactions: transactions
    });
    next();
});

app.get('/address', oidc.ensureAuthenticated(), (req, res) => {
    res.render("index", {
        transactions: transactions,
        addresses: addresses
    });
});

app.get("/invoice", oidc.ensureAuthenticated(), (req, res) => {
    res.render("invoice");
});

app.post("/dashboard", oidc.ensureAuthenticated(), (req, res) => {
    account.requestMoney({
        to: req.body.email,
        amount: req.body.amount,
        currency: "USD",
        description: req.body.description
    }, (err, txn) => {
        if (err) {
            console.error(err);
            return res.render("index", {
                error: err
            });
        }

        updateTransactions((err, transactions) => {
            if (err) {
                console.error(err);
                return res.render("index", {
                    error: err.message
                });
            }

            return res.render("index", {
                transactions: transactions
            });
        });
    });
});

app.get("/logout", (req, res) => {
    req.logout();
    res.redirect("/");
});

// Helpers
function updateTransactions(cb) {
    transactions = [];
    let pagination = null;

    async.doWhilst(
        function (callback) {
            account.getTransactions(pagination, (err, txns, page) => {
                if (err) {
                    return callback(err);
                }

                pagination = page.next_uri ? page : false;

                txns.forEach(txn => {
                    if (txn.type === "request") {
                        transactions.push(txn);
                    }
                });

                callback();
            });
        },
        function () {
            return pagination ? true : false;
        },
        function (err) {
            if (err) {
                return cb(err);
            }

            cb(null, transactions);
        }
    );
};

function updateAddress(cb) {
    addresses = [];
    let pagination = null;

    async.doWhilst(
        function (callback) {
            account.getAddresses(pagination, (err, arr, page) => {
                if (err) {
                    return callback(err);
                }
                pagination = page.next_uri ? page : false;
                arr.forEach( add => {
                    addresses.push(add);
                });
                callback();
            });
        },
        function() {
            return pagination ? true : false;
        },
        function(err) {
            if (err) {
                return cb(err);
            }

            cb(null, addresses);
        }
    );
};

// Startup jobs
client.getAccounts({}, (err, accounts) => {
    if (err) {
        console.error(err);
    }

    accounts.forEach(acct => {
        if (acct.primary) {
            account = acct;
            console.log("Found primary account: " + account.name + ". Current balance: " + account.balance.amount + " " + account.currency + ".");

            console.log("Downloading initial list of transactions.");
            updateTransactions(err => {
                if (err) {
                    console.error(err);
                }
            });
            console.log("Downloading inital list of addresses.");
            updateAddress(err => {
                if (err) {
                    console.error(err);
                }
            });
        }
    });
});

// Cron jobs
setInterval(() => {
    updateTransactions(err => {
        if (err) {
            console.error(err);
        }
    });
    updateAddress( err => {
        if (err) {
            console.error(err);
        }
    });
}, 1000 * 60 * 60);

//Server management
oidc.on("ready", () => {
    // db.sequelize.sync({
    //     force: true
    // }).then(function() {
        app.listen(PORT, () => {
            console.log(`Listening web service on port ` + PORT);
        });
    // });
});

oidc.on("error", err => {
    console.error(err);
});