ddp
/
vivo-explorer
1
0
Fork 0
Code Issues 0 Pull Requests 0 Releases 0 Wiki Activity
Browse Source

05/25/2021 11:18:10 AM MST

master
coldstar 3 years ago
parent
b737a4045c
commit
1ef31cdf75
3 changed files with 363 additions and 340 deletions
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. +357
    -339
      app/rpcApi.js
  2. +4
    -1
      installnodejs.txt
  3. +2
    -0
      views/index.pug

+ 357
- 339
app/rpcApi.js View File

@@ -1,446 +1,464 @@

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



var genesisCoinbaseTransactionTxid = "4a5e1e4baab89f3a32518a88c31bc87f618f76673e2cc77ab2127b7afdeda33b";
var genesisCoinbaseTransaction = {
"hex": "01000000010000000000000000000000000000000000000000000000000000000000000000ffffffff0804ffff001d02fd04ffffffff0100f2052a01000000434104f5eeb2b10c944c6b9fbcfff94c35bdeecd93df977882babc7f3a2cf7f5c81d3b09a68db7f0e04f21de5d4230e75e6dbe7ad16eefe0d4325a62067dc6f369446aac00000000",
"txid": "4a5e1e4baab89f3a32518a88c31bc87f618f76673e2cc77ab2127b7afdeda33b",
"hash": "4a5e1e4baab89f3a32518a88c31bc87f618f76673e2cc77ab2127b7afdeda33b",
"size": 204,
"vsize": 204,
"version": 1,
"confirmations":475000,
"vin": [
{
"coinbase": "04ffff001d0104455468652054696d65732030332f4a616e2f32303039204368616e63656c6c6f72206f6e206272696e6b206f66207365636f6e64206261696c6f757420666f722062616e6b73",
"sequence": 4294967295
}
],
"vout": [
{
"value": 50,
"n": 0,
"scriptPubKey": {
"asm": "04f5eeb2b10c944c6b9fbcfff94c35bdeecd93df977882babc7f3a2cf7f5c81d3b09a68db7f0e04f21de5d4230e75e6dbe7ad16eefe0d4325a62067dc6f369446a OP_CHECKSIG",
"hex": "4104f5eeb2b10c944c6b9fbcfff94c35bdeecd93df977882babc7f3a2cf7f5c81d3b09a68db7f0e04f21de5d4230e75e6dbe7ad16eefe0d4325a62067dc6f369446aac",
"reqSigs": 1,
"type": "pubkey",
"addresses": [
"1A1zP1eP5QGefi2DMPTfTL5SLmv7DivfNa"
]
}
}
],
"blockhash": "000000000019d6689c085ae165831e934ff763ae46a2a6c172b3f1b60a8ce26f",
"time": 1230988505,
"blocktime": 1230988505
"hex": "01000000010000000000000000000000000000000000000000000000000000000000000000ffffffff0804ffff001d02fd04ffffffff0100f2052a01000000434104f5eeb2b10c944c6b9fbcfff94c35bdeecd93df977882babc7f3a2cf7f5c81d3b09a68db7f0e04f21de5d4230e75e6dbe7ad16eefe0d4325a62067dc6f369446aac00000000",
"txid": "4a5e1e4baab89f3a32518a88c31bc87f618f76673e2cc77ab2127b7afdeda33b",
"hash": "4a5e1e4baab89f3a32518a88c31bc87f618f76673e2cc77ab2127b7afdeda33b",
"size": 204,
"vsize": 204,
"version": 1,
"confirmations": 475000,
"vin": [{
"coinbase": "04ffff001d0104455468652054696d65732030332f4a616e2f32303039204368616e63656c6c6f72206f6e206272696e6b206f66207365636f6e64206261696c6f757420666f722062616e6b73",
"sequence": 4294967295
}],
"vout": [{
"value": 50,
"n": 0,
"scriptPubKey": {
"asm": "04f5eeb2b10c944c6b9fbcfff94c35bdeecd93df977882babc7f3a2cf7f5c81d3b09a68db7f0e04f21de5d4230e75e6dbe7ad16eefe0d4325a62067dc6f369446a OP_CHECKSIG",
"hex": "4104f5eeb2b10c944c6b9fbcfff94c35bdeecd93df977882babc7f3a2cf7f5c81d3b09a68db7f0e04f21de5d4230e75e6dbe7ad16eefe0d4325a62067dc6f369446aac",
"reqSigs": 1,
"type": "pubkey",
"addresses": [
"1A1zP1eP5QGefi2DMPTfTL5SLmv7DivfNa"
]
}
}],
"blockhash": "000000000019d6689c085ae165831e934ff763ae46a2a6c172b3f1b60a8ce26f",
"time": 1230988505,
"blocktime": 1230988505
};

function getInfo() {
return new Promise(function(resolve, reject) {
client.cmd('getinfo', function(err, result, resHeaders) {
if (err) {
console.log("Error 3207fh0f: " + err);
return new Promise(function(resolve, reject) {
client.cmd('getinfo', function(err, result, resHeaders) {
if (err) {
console.log("Error 3207fh0f: " + err);

reject(err);
reject(err);

return;
}
return;
}

resolve(result);
});
});
resolve(result);
});
});
}

function getMiningInfo() {
return new Promise(function(resolve, reject) {
client.cmd('getmininginfo', function(err, result, resHeaders) {
if (err) {
console.log("Error 3207fh0f: " + err);
return new Promise(function(resolve, reject) {
client.cmd('getmininginfo', function(err, result, resHeaders) {
if (err) {
console.log("Error 3207fh0f: " + err);

reject(err);
reject(err);

return;
}
return;
}

resolve(result);
});
});
resolve(result);
});
});
}

function getMempoolInfo() {
return new Promise(function(resolve, reject) {
client.cmd('getmempoolinfo', function(err, result, resHeaders) {
if (err) {
console.log("Error 23407rhwe07fg: " + err);
return new Promise(function(resolve, reject) {
client.cmd('getmempoolinfo', function(err, result, resHeaders) {
if (err) {
console.log("Error 23407rhwe07fg: " + err);

reject(err);
reject(err);

return;
}
return;
}

resolve(result);
});
});
resolve(result);
});
});
}

function getMempoolStats() {
return new Promise(function(resolve, reject) {
client.cmd('getrawmempool', true, function(err, result, resHeaders) {
if (err) {
console.log("Error 428thwre0ufg: " + err);
return new Promise(function(resolve, reject) {
client.cmd('getrawmempool', true, function(err, result, resHeaders) {
if (err) {
console.log("Error 428thwre0ufg: " + err);

reject(err);
reject(err);

return;
}
return;
}

var compiledResult = {};
compiledResult.count = 0;
compiledResult.fee_0_5 = 0;
compiledResult.fee_6_10 = 0;
compiledResult.fee_11_25 = 0;
compiledResult.fee_26_50 = 0;
compiledResult.fee_51_75 = 0;
compiledResult.fee_76_100 = 0;
compiledResult.fee_101_150 = 0;
compiledResult.fee_151_max = 0;
var compiledResult = {};
compiledResult.count = 0;
compiledResult.fee_0_5 = 0;
compiledResult.fee_6_10 = 0;
compiledResult.fee_11_25 = 0;
compiledResult.fee_26_50 = 0;
compiledResult.fee_51_75 = 0;
compiledResult.fee_76_100 = 0;
compiledResult.fee_101_150 = 0;
compiledResult.fee_151_max = 0;

var totalFee = 0;
for (var txid in result) {
var txMempoolInfo = result[txid];
totalFee += txMempoolInfo.modifiedfee;
var feeRate = Math.round(txMempoolInfo.modifiedfee * 100000000 / txMempoolInfo.size);
var totalFee = 0;
for (var txid in result) {
var txMempoolInfo = result[txid];
totalFee += txMempoolInfo.modifiedfee;
var feeRate = Math.round(txMempoolInfo.modifiedfee * 100000000 / txMempoolInfo.size);

if (feeRate <= 5) {
compiledResult.fee_0_5++;
if (feeRate <= 5) {
compiledResult.fee_0_5++;

} else if (feeRate <= 10) {
compiledResult.fee_6_10++;
} else if (feeRate <= 10) {
compiledResult.fee_6_10++;

} else if (feeRate <= 25) {
compiledResult.fee_11_25++;
} else if (feeRate <= 25) {
compiledResult.fee_11_25++;

} else if (feeRate <= 50) {
compiledResult.fee_26_50++;
} else if (feeRate <= 50) {
compiledResult.fee_26_50++;

} else if (feeRate <= 75) {
compiledResult.fee_51_75++;
} else if (feeRate <= 75) {
compiledResult.fee_51_75++;

} else if (feeRate <= 100) {
compiledResult.fee_76_100++;
} else if (feeRate <= 100) {
compiledResult.fee_76_100++;

} else if (feeRate <= 150) {
compiledResult.fee_101_150++;
} else if (feeRate <= 150) {
compiledResult.fee_101_150++;

} else {
compiledResult.fee_151_max++;
}
} else {
compiledResult.fee_151_max++;
}

compiledResult.count++;
}
compiledResult.count++;
}

compiledResult.totalFee = totalFee;
compiledResult.totalFee = totalFee;

resolve(compiledResult);
});
});
resolve(compiledResult);
});
});
}

function getBlockByHeight(blockHeight) {
console.log("getBlockByHeightzz: " + blockHeight);
console.log("xxxxxxxxxxxxxxxxxxxxxxxxxxxxx \n");
//*************************************************************************************
stream.write('block:'+blockHeight);
console.log("getBlockByHeightzz: " + blockHeight);
console.log("xxxxxxxxxxxxxxxxxxxxxxxxxxxxx \n");
//*************************************************************************************

stream.write('block:' + blockHeight);


return new Promise(function(resolve, reject) {
var client = global.client;

return new Promise(function(resolve, reject) {
var client = global.client;
client.cmd('getblockhash', blockHeight, function(err, result, resHeaders) {
if (err) {
console.log("Error 0928317yr3w: " + err);
client.cmd('getblockhash', blockHeight, function(err, result, resHeaders) {
if (err) {
console.log("Error 0928317yr3w: " + err);

reject(err);
reject(err);

return;
}
return;
}

client.cmd('getblock', result, function(err2, result2, resHeaders2) {
if (err2) {
console.log("Error 320fh7e0hg: " + err2);
client.cmd('getblock', result, function(err2, result2, resHeaders2) {
if (err2) {
console.log("Error 320fh7e0hg: " + err2);

reject(err2);
reject(err2);

return;
}
return;
}

resolve({ success:true, getblockhash:result, getblock:result2 });
});
});
});
resolve({ success: true, getblockhash: result, getblock: result2 });
});
});
});
}



function getBlocksByHeight(blockHeights) {
console.log("getBlocksByHeight: " + blockHeights);
console.log("getBlockByHeightzz: " + blockHeights);
console.log("xxxxxxxxxxxxxxxxxxxxxxxxxxxxx \n");
//*************************************************************************************
stream.write('block:'+blockHeights+"\n");
return new Promise(function(resolve, reject) {
var batch = [];
for (var i = 0; i < blockHeights.length; i++) {
batch.push({
method: 'getblockhash',
params: [ blockHeights[i] ]
});
}
var blockHashes = [];
client.cmd(batch, function(err, result, resHeaders) {
blockHashes.push(result);
if (blockHashes.length == batch.length) {
var batch2 = [];
for (var i = 0; i < blockHashes.length; i++) {
batch2.push({
method: 'getblock',
params: [ blockHashes[i] ]
});
}
var blocks = [];
client.cmd(batch2, function(err2, result2, resHeaders2) {
if (err2) {
console.log("Error 138ryweufdf: " + err2);
}
blocks.push(result2);
if (blocks.length == batch2.length) {
resolve(blocks);
}
});
}
});
});
console.log("getBlocksByHeight: " + blockHeights);
console.log("getBlockByHeightzz: " + blockHeights);
console.log("xxxxxxxxxxxxxxxxxxxxxxxxxxxxx \n");
//*************************************************************************************
stream.write('block:' + blockHeights + "\n");
return new Promise(function(resolve, reject) {
var batch = [];
for (var i = 0; i < blockHeights.length; i++) {
batch.push({
method: 'getblockhash',
params: [blockHeights[i]]
});
}
var blockHashes = [];
client.cmd(batch, function(err, result, resHeaders) {
blockHashes.push(result);
if (blockHashes.length == batch.length) {
var batch2 = [];
for (var i = 0; i < blockHashes.length; i++) {
batch2.push({
method: 'getblock',
params: [blockHashes[i]]
});
}
var blocks = [];
client.cmd(batch2, function(err2, result2, resHeaders2) {
if (err2) {
console.log("Error 138ryweufdf: " + err2);
}
blocks.push(result2);
if (blocks.length == batch2.length) {
resolve(blocks);
}
});
}
});
});
}

function getBlockByHash(blockHash) {
console.log("getBlockByHash: " + blockHash);
console.log("getBlockByHash: " + blockHash);

return new Promise(function(resolve, reject) {
var client = global.client;
client.cmd('getblock', blockHash, function(err, result, resHeaders) {
if (err) {
console.log("Error 0u2fgewue: " + err);
return new Promise(function(resolve, reject) {
var client = global.client;

reject(err);
client.cmd('getblock', blockHash, function(err, result, resHeaders) {
if (err) {
console.log("Error 0u2fgewue: " + err);

return;
}
reject(err);

resolve(result);
});
});
return;
}

resolve(result);
});
});
}

function getTransactionInputs(rpcClient, transaction, inputLimit=0) {
console.log("getTransactionInputs: " + transaction.txid);
return new Promise(function(resolve, reject) {
var txids = [];
for (var i = 0; i < transaction.vin.length; i++) {
if (i < inputLimit || inputLimit == 0) {
txids.push(transaction.vin[i].txid);
}
}
getRawTransactions(txids).then(function(inputTransactions) {
resolve({ txid:transaction.txid, inputTransactions:inputTransactions });
});
});
function getTransactionInputs(rpcClient, transaction, inputLimit = 0) {
console.log("getTransactionInputs: " + transaction.txid);
return new Promise(function(resolve, reject) {
var txids = [];
for (var i = 0; i < transaction.vin.length; i++) {
if (i < inputLimit || inputLimit == 0) {
txids.push(transaction.vin[i].txid);
}
}
getRawTransactions(txids).then(function(inputTransactions) {
resolve({ txid: transaction.txid, inputTransactions: inputTransactions });
});
});
}

function getRawTransaction(txid) {
return new Promise(function(resolve, reject) {
if (txid == genesisCoinbaseTransactionTxid) {
getBlockByHeight(0).then(function(blockZeroResult) {
var result = genesisCoinbaseTransaction;
result.confirmations = blockZeroResult.getblock.confirmations;
resolve(result);
});
return;
}
client.cmd('getrawtransaction', txid, 1, function(err, result, resHeaders) {
if (err) {
console.log("Error 329813yre823: " + err);
reject(err);
return;
}
resolve(result);
});
});
return new Promise(function(resolve, reject) {
if (txid == genesisCoinbaseTransactionTxid) {
getBlockByHeight(0).then(function(blockZeroResult) {
var result = genesisCoinbaseTransaction;
result.confirmations = blockZeroResult.getblock.confirmations;
resolve(result);
});
return;
}
client.cmd('getrawtransaction', txid, 1, function(err, result, resHeaders) {
if (err) {
console.log("Error 329813yre823: " + err);
reject(err);
return;
}
resolve(result);
});
});
}

function getRawTransactions(txids) {
console.log("getRawTransactions: " + txids);
return new Promise(function(resolve, reject) {
if (!txids || txids.length == 0) {
resolve([]);
return;
}
if (txids.length == 1 && txids[0] == "4a5e1e4baab89f3a32518a88c31bc87f618f76673e2cc77ab2127b7afdeda33b") {
// copy the "confirmations" field from genesis block to the genesis-coinbase tx
getBlockByHeight(0).then(function(blockZeroResult) {
var result = genesisCoinbaseTransaction;
result.confirmations = blockZeroResult.getblock.confirmations;
resolve([result]);
}).catch(function(err) {
reject(err);
return;
});
return;
}
var requests = [];
for (var i = 0; i < txids.length; i++) {
var txid = txids[i];
if (txid) {
requests.push({
method: 'getrawtransaction',
params: [ txid, 1 ]
});
}
}
var requestBatches = utils.splitArrayIntoChunks(requests, 20);
executeBatchesSequentially(requestBatches, function(results) {
resolve(results);
});
});
console.log("getRawTransactions: " + txids);
return new Promise(function(resolve, reject) {
if (!txids || txids.length == 0) {
resolve([]);
return;
}
if (txids.length == 1 && txids[0] == "4a5e1e4baab89f3a32518a88c31bc87f618f76673e2cc77ab2127b7afdeda33b") {
// copy the "confirmations" field from genesis block to the genesis-coinbase tx
getBlockByHeight(0).then(function(blockZeroResult) {
var result = genesisCoinbaseTransaction;
result.confirmations = blockZeroResult.getblock.confirmations;
resolve([result]);
}).catch(function(err) {
reject(err);
return;
});
return;
}
var requests = [];
for (var i = 0; i < txids.length; i++) {
var txid = txids[i];
if (txid) {
requests.push({
method: 'getrawtransaction',
params: [txid, 1]
});
}
}
var requestBatches = utils.splitArrayIntoChunks(requests, 20);
executeBatchesSequentially(requestBatches, function(results) {
resolve(results);
});
});
}

function executeBatchesSequentially(batches, resultFunc) {
var batchId = utils.getRandomString(20, 'aA#');
var batchId = utils.getRandomString(20, 'aA#');

console.log("Starting " + batches.length + "-item batch " + batchId + "...");
console.log("Starting " + batches.length + "-item batch " + batchId + "...");

executeBatchesSequentiallyInternal(batchId, batches, 0, [], resultFunc);
executeBatchesSequentiallyInternal(batchId, batches, 0, [], resultFunc);
}

function executeBatchesSequentiallyInternal(batchId, batches, currentIndex, accumulatedResults, resultFunc) {
if (currentIndex == batches.length) {
console.log("Finishing batch " + batchId + "...");
if (currentIndex == batches.length) {
console.log("Finishing batch " + batchId + "...");

resultFunc(accumulatedResults);
resultFunc(accumulatedResults);

return;
}
return;
}

console.log("Executing item #" + (currentIndex + 1) + " (of " + batches.length + ") for batch " + batchId);
console.log("Executing item #" + (currentIndex + 1) + " (of " + batches.length + ") for batch " + batchId);

var count = batches[currentIndex].length;
var count = batches[currentIndex].length;

client.cmd(batches[currentIndex], function(err, result, resHeaders) {
if (err) {
console.log("Error f83024hf4: " + err);
}
client.cmd(batches[currentIndex], function(err, result, resHeaders) {
if (err) {
console.log("Error f83024hf4: " + err);
}

accumulatedResults.push(result);
accumulatedResults.push(result);

count--;
count--;

if (count == 0) {
executeBatchesSequentiallyInternal(batchId, batches, currentIndex + 1, accumulatedResults, resultFunc);
}
});
if (count == 0) {
executeBatchesSequentiallyInternal(batchId, batches, currentIndex + 1, accumulatedResults, resultFunc);
}
});
}

function getBlockData(rpcClient, blockHash, txLimit, txOffset) {
console.log("getBlockData: " + blockHash);
console.log("getBlockData: " + blockHash);

return new Promise(function(resolve, reject) {
client.cmd('getblock', blockHash, function(err2, result2, resHeaders2) {
if (err2) {
console.log("Error 3017hfwe0f: " + err2);

reject(err2);

return new Promise(function(resolve, reject) {
client.cmd('getblock', blockHash, function(err2, result2, resHeaders2) {
if (err2) {
console.log("Error 3017hfwe0f: " + err2);
return;
}

reject(err2);
var txids = [];
for (var i = txOffset; i < Math.min(txOffset + txLimit, result2.tx.length); i++) {
txids.push(result2.tx[i]);
}

return;
}
getRawTransactions(txids).then(function(transactions) {
var txInputsByTransaction = {};

var txids = [];
for (var i = txOffset; i < Math.min(txOffset + txLimit, result2.tx.length); i++) {
txids.push(result2.tx[i]);
}
var promises = [];
for (var i = 0; i < transactions.length; i++) {
var transaction = transactions[i];

getRawTransactions(txids).then(function(transactions) {
var txInputsByTransaction = {};
if (transaction) {
promises.push(getTransactionInputs(client, transaction, 10));
}
}

var promises = [];
for (var i = 0; i < transactions.length; i++) {
var transaction = transactions[i];
Promise.all(promises).then(function() {
var results = arguments[0];
for (var i = 0; i < results.length; i++) {
var resultX = results[i];

if (transaction) {
promises.push(getTransactionInputs(client, transaction, 10));
}
}
txInputsByTransaction[resultX.txid] = resultX.inputTransactions;
}

Promise.all(promises).then(function() {
var results = arguments[0];
for (var i = 0; i < results.length; i++) {
var resultX = results[i];
resolve({ getblock: result2, transactions: transactions, txInputsByTransaction: txInputsByTransaction });
});
});
});
});
}

function getBalanceFromAddress(rpcClient, address) {
console.log("getBalanceFromAddress: " + address);

return new Promise(function(resolve, reject) {
client.cmd("getaddressbalance", "\'{\"addresses\": [\"" + address + "\"]}\'", function(err2, result2, resHeaders2) {
if (err2) {
console.log("Error 3017hfwe0f: " + err2);

reject(err2);

txInputsByTransaction[resultX.txid] = resultX.inputTransactions;
}
return;
}

resolve({ getblock:result2, transactions:transactions, txInputsByTransaction:txInputsByTransaction });
});
});
});
});
resolve(result);
});
});
}



module.exports = {
getInfo: getInfo,
getMiningInfo: getMiningInfo,
getMempoolInfo: getMempoolInfo,
getBlockByHeight: getBlockByHeight,
getBlocksByHeight: getBlocksByHeight,
getBlockByHash: getBlockByHash,
getTransactionInputs: getTransactionInputs,
getBlockData: getBlockData,
getRawTransaction: getRawTransaction,
getRawTransactions: getRawTransactions,
getMempoolStats: getMempoolStats
getInfo: getInfo,
getMiningInfo: getMiningInfo,
getMempoolInfo: getMempoolInfo,
getBlockByHeight: getBlockByHeight,
getBlocksByHeight: getBlocksByHeight,
getBlockByHash: getBlockByHash,
getBalanceFromAddress: getBalanceFromAddress,
getTransactionInputs: getTransactionInputs,
getBlockData: getBlockData,
getRawTransaction: getRawTransaction,
getRawTransactions: getRawTransactions,
getMempoolStats: getMempoolStats
};

+ 4
- 1
installnodejs.txt View File

@@ -13,4 +13,7 @@ nano /etc/lighttpd/lighttpd.conf

/etc/init.d/lighttpd restart

ufw allow 3002
ufw allow 3002

change port in
/home/ddp/vivo-explorer/docs/btc-explorer.com.conf

+ 2
- 0
views/index.pug View File

@@ -28,4 +28,6 @@ block content
:markdown-it
More information available on Website: [http://vivocoin.net](http://vivocoin.net)
Other Explorers are at [http://explorer2.vivocoin.net](http://explorer2.vivocoin.net) and [http://explorer3.vivocoin.net](http://explorer3.vivocoin.net)

[&copy; 2021 Vivocoin](http://vivocoin.net/)

Write Preview
Loading…
Cancel
Save