vivo-explorer/routes/baseActionsRouter.js

var express = require('express');
var router = express.Router();
var util = require('util');
var moment = require('moment');
var utils = require('./../app/utils');
var env = require("./../app/env");
var bitcoin = require("bitcoin");
var rpcApi = require("./../app/rpcApi");

var fs = require('fs');
var stream = fs.createWriteStream("proglog.txt");


router.get("/", function(req, res) {
    if (!req.session.host) {
        if (req.cookies['rpc-host']) {
            res.locals.host = req.cookies['rpc-host'];
        }

        if (req.cookies['rpc-port']) {
            res.locals.port = req.cookies['rpc-port'];
        }

        if (req.cookies['rpc-username']) {
            res.locals.username = req.cookies['rpc-username'];
        }

        res.render("connect");
        res.end();

        return;
    }

    var client = global.client;

    rpcApi.getInfo().then(function(getinfo) {
        res.locals.getinfo = getinfo;

        var blockHeights = [];
        if (getinfo.blocks) {
            for (var i = 0; i < 10; i++) {
                blockHeights.push(getinfo.blocks - i);
            }
        }

        rpcApi.getBlocksByHeight(blockHeights).then(function(latestBlocks) {
            res.locals.latestBlocks = latestBlocks;

            res.render("index");
        });
    }).catch(function(err) {
        console.log(err);
        res.locals.userMessage = "Unable to connect to Vivocoin Node at " + req.session.host + ":" + req.session.port;
        res.render("index");
    });
});

router.get("/node-info", function(req, res) {
    var client = global.client;

    stream.write("yyyyyyyyyyyyyyyyyyyyyyy\n");

    rpcApi.getInfo().then(function(getinfo) {
        res.locals.getinfo = getinfo;

        rpcApi.getMiningInfo().then(function(getmininginfo) {
            res.locals.getmininginfo = getmininginfo;

            console.log(getmininginfo);
            stream.write('mininghash:' + getmininginfo.networkhashps + "\n");


            res.render("node-info");

        });
    }).catch(function(err) {
        res.locals.userMessage = "Unable to connect to Vivocoin Node at " + req.session.host + ":" + req.session.port;
        console.log(err);
        res.render("node-info");
    });
});

router.get("/mempool", function(req, res) {
    var client = global.client;

    rpcApi.getMempoolInfo().then(function(getmempoolinfo) {
        res.locals.getmempoolinfo = getmempoolinfo;

        rpcApi.getMempoolStats().then(function(mempoolstats) {
            res.locals.mempoolstats = mempoolstats;

            res.render("mempool");
        });
    }).catch(function(err) {
        res.locals.userMessage = "Unable to connect to Vivocoin Node at " + req.session.host + ":" + req.session.port;
        console.log(err);
        res.render("mempool");
    });
});

router.post("/connect", function(req, res) {
    var host = req.body.host;
    var port = req.body.port;
    var username = req.body.username;
    var password = req.body.password;

    res.cookie('rpc-host', host);
    res.cookie('rpc-port', port);
    res.cookie('rpc-username', username);

    req.session.host = host;
    req.session.port = port;
    req.session.username = username;

    var client = new bitcoin.Client({
        host: host,
        port: port,
        user: username,
        pass: password,
        timeout: 30000
    });

    console.log("created client: " + client);

    global.client = client;

    req.session.userMessage = "<strong>Connected via RPC</strong>: " + username + " @ " + host + ":" + port;
    req.session.userMessageType = "success";

    res.redirect("/");
});

router.get("/blocks", function(req, res) {
    var limit = 20;
    var offset = 0;
    var sort = "desc";

    if (req.query.limit) {
        limit = parseInt(req.query.limit);
    }

    if (req.query.offset) {
        offset = parseInt(req.query.offset);
    }

    if (req.query.sort) {
        sort = req.query.sort;
    }

    res.locals.limit = limit;
    res.locals.offset = offset;
    res.locals.sort = sort;
    res.locals.paginationBaseUrl = "/blocks";

    rpcApi.getInfo().then(function(getinfo) {
        res.locals.blockCount = getinfo.blocks;
        res.locals.blockOffset = offset;

        var blockHeights = [];
        if (sort == "desc") {
            for (var i = (getinfo.blocks - offset); i > (getinfo.blocks - offset - limit); i--) {
                blockHeights.push(i);
            }
        } else {
            for (var i = offset; i < (offset + limit); i++) {
                blockHeights.push(i);
            }
        }

        rpcApi.getBlocksByHeight(blockHeights).then(function(blocks) {
            res.locals.blocks = blocks;

            res.render("blocks");
        });
    }).catch(function(err) {
        res.locals.userMessage = "Unable to connect to Vivocoin Node at " + req.session.host + ":" + req.session.port;
        console.log(err);
        res.render("blocks");
    });
});

router.post("/search", function(req, res) {
    if (!req.body.query) {
        req.session.userMessage = "Enter a block height, block hash, or transaction id.";

        res.redirect("/");

        return;
    }

    var query = req.body.query.toLowerCase();

    if (query === null || query === "null" || query.length < 1) {
        res.redirect("/");
        return;
    }

    query = query.replace(/,/g, "");

    if (query.stringLength < 9) {
        if (typeof query == "number") {
            res.redirect("/block-height/" + query);
            console.log('This is a block');
            return;
        }
    }

    if (query.stringLength < 36) {
        if (typeof query != "number") {
            res.redirect("/address/" + query);
            console.log('This is not number');
            return;
        }
    }


    rpcApi.getRawTransaction(query).then(function(tx) {
        if (tx) {
            res.redirect("/tx/" + query);

            return;
        }
    }).catch(function(err) {
        rpcApi.getBlockByHash(query).then(function(blockByHash) {
            if (blockByHash) {
                res.redirect("/block/" + query);

                return;
            }
        }).catch(function(err) {
            if (isNaN(query)) {
                req.session.userMessage = "No results found for query: " + query;

                res.redirect("/");

                return;
            }

            rpcApi.getBlockByHeight(parseInt(query)).then(function(blockByHeight) {
                if (blockByHeight) {
                    res.redirect("/block-height/" + query);

                    return;
                }
            }).catch(function(err) {
                req.session.userMessage = "No results found for query: " + query;

                res.redirect("/");
            });
        });
    });
});

router.get("/block-height/:blockHeight", function(req, res) {
    var client = global.client;

    var blockHeight = parseInt(req.params.blockHeight);

    res.locals.blockHeight = blockHeight;

    res.locals.result = {};

    var limit = 20;
    var offset = 0;

    if (req.query.limit) {
        limit = parseInt(req.query.limit);
    }

    if (req.query.offset) {
        offset = parseInt(req.query.offset);
    }

    res.locals.limit = limit;
    res.locals.offset = offset;
    res.locals.paginationBaseUrl = "/block-height/" + blockHeight;

    client.cmd('getblockhash', blockHeight, function(err, result, resHeaders) {
        if (err) {
            // TODO handle RPC error
            return console.log(err);
        }

        res.locals.result.getblockhash = result;

        rpcApi.getBlockData(client, result, limit, offset).then(function(result) {
            res.locals.result.getblock = result.getblock;
            res.locals.result.transactions = result.transactions;
            res.locals.result.txInputsByTransaction = result.txInputsByTransaction;

            res.render("block-height");
        });
    });
});

router.get("/block/:blockHash", function(req, res) {
    var blockHash = req.params.blockHash;

    res.locals.blockHash = blockHash;

    res.locals.result = {};

    var limit = 20;
    var offset = 0;

    if (req.query.limit) {
        limit = parseInt(req.query.limit);
    }

    if (req.query.offset) {
        offset = parseInt(req.query.offset);
    }

    res.locals.limit = limit;
    res.locals.offset = offset;
    res.locals.paginationBaseUrl = "/block/" + blockHash;

    // TODO handle RPC error
    rpcApi.getBlockData(client, blockHash, limit, offset).then(function(result) {
        res.locals.result.getblock = result.getblock;
        res.locals.result.transactions = result.transactions;
        res.locals.result.txInputsByTransaction = result.txInputsByTransaction;

        res.render("block");
    });
});


router.get("/address/:address", function(req, res) {


    var address = req.params.address;


    res.locals.address = address;

    console.log("address is:" + address);

    console.log("/usr/local/bin/vivo-cli -conf=/etc/masternodes/vivo_n1.conf getaddressbalance \'{\"addresses\": [\"" + address + "\"]}\'");

    res.locals.result = {};

    const { exec } = require('child_process');

    var balance = "Not Found";
    var received = "Not Found";


    var yourscript = exec('/usr/local/bin/vivo-cli -conf=/etc/masternodes/vivo_n1.conf getaddressbalance \'{\"addresses\": [\"' + address + '"]}\'',
        //var yourscript = exec('whoami',
        (error, stdout, stderr) => {
            console.log(stdout);

            const json = stdout;
            const obj = JSON.parse(json);

            console.log(obj.balance);
            console.log(obj.received);


            res.locals.balance = parseInt(obj.balance) / 100000000;
            res.locals.received = parseInt(obj.received) / 100000000;

            console.log(stderr);

            if (error !== null) {
                console.log(`exec error: ${error}`);
            }

            res.render("address");

        });

    /*
                const { spawn } = require("child_process");

                //const ls = spawn("/usr/local/bin/vivo-cli", [" -conf=/etc/masternodes/vivo_n1.conf \'{\"addresses\": [\"" + address + "\"]}\'"]);



    
                const ls = spawn("ls", "-lah");

                ls.stdout.on("data", data => {
                    console.log(`stdout: ${data}`);
                });

                ls.stderr.on("data", data => {
                    console.log(`stderr: ${data}`);
                });

                ls.on('error', (error) => {
                    console.log(`error: ${error.message}`);
                });

                ls.on("close", code => {
                    console.log(`child process exited with code ${code}`);
                });
                */



});

router.get("/tx/:transactionId", function(req, res) {
    var txid = req.params.transactionId;

    var output = -1;
    if (req.query.output) {
        output = parseInt(req.query.output);
    }

    res.locals.txid = txid;
    res.locals.output = output;

    res.locals.result = {};

    // TODO handle RPC error
    rpcApi.getRawTransaction(txid).then(function(rawTxResult) {
        res.locals.result.getrawtransaction = rawTxResult;

        client.cmd('getblock', rawTxResult.blockhash, function(err3, result3, resHeaders3) {
            res.locals.result.getblock = result3;

            var txids = [];
            for (var i = 0; i < rawTxResult.vin.length; i++) {
                if (!rawTxResult.vin[i].coinbase) {
                    txids.push(rawTxResult.vin[i].txid);
                }
            }

            rpcApi.getRawTransactions(txids).then(function(txInputs) {
                res.locals.result.txInputs = txInputs;

                res.render("transaction");
            });
        });
    });
});

router.get("/terminal", function(req, res) {
    if (!env.debug) {
        res.send("Debug mode is off.");

        return;
    }

    res.render("terminal");
});

router.post("/terminal", function(req, res) {
    if (!env.debug) {
        res.send("Debug mode is off.");

        return;
    }

    client.cmd(req.body.cmd, function(err, result, resHeaders) {
        console.log(result);
        console.log(err);
        console.log(resHeaders);

        res.send(JSON.stringify(result, null, 4));
    });
});


module.exports = router;