update-transactions.js

let request = require('request');

let DataBase = require('./lib/DataBase');

let BitcoinParser = require("./lib/parsers/BitcoinParser.js");
let BitcoinCashParser = require("./lib/parsers/BitcoinCashParser.js");
let LitecoinParser = require("./lib/parsers/LitecoinParser.js");
let DashParser = require("./lib/parsers/DashParser.js");
let BancorParser = require("./lib/parsers/BancorParser.js");
let AragonParser = require("./lib/parsers/AragonParser.js");

function getSpecificParser(coin){
    var parser;
    if (coin === "BTC") {
        parser = new BitcoinParser();
    } else if (coin === "BCH") {
        parser = new BitcoinCashParser();
    } else if (coin === "LTC") {
        parser = new LitecoinParser();
    } else if (coin === "DASH") {
        parser = new DashParser();
    } else if (coin === "BNT") {
        parser = new BancorParser();
    } else if (coin === "ANT") {
        parser = new AragonParser();
    }
    return parser;
}

function getTransactions(coin){
    var parser = getSpecificParser(coin);

    request(parser.getAdrApiUrl(), function (error, response, body, callback) {
        if (body === "Not found" || body === "{}") {
            console.log("Error");
        } else if (!error && response.statusCode === 200) {
            var parsed = JSON.parse(body);

            var txs = parser.getTransactions(parsed);

            var database = new DataBase({});

            txs.forEach(function (tx) {
                database.insertTransaction(tx, coin);
            });

            // Close database
            database.close();

        } else {
            console.log("Error");
        }
    });
}

getTransactions("BTC");
getTransactions("BCH");
getTransactions("LTC");
getTransactions("DASH");
getTransactions("BNT");
getTransactions("ANT");