RanchiMall/flosight-api
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

top n txs setup

Browse Source
This commit is contained in:
tenthirtyone 2017-08-17 17:49:54 -04:00
parent 9b7336b066
commit 805e5ec0c3
3 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
server/lib/api/transaction.js
View File

@ -204,17 +204,15 @@ module.exports = function transactionAPI(router) {
}); });
} }
// Get last n txs // Get last n txs
console.log('GETTING N TXS');
db.txs.getTopTransactions((err, txs) => { db.txs.getTopTransactions((err, txs) => {
if (err) { if (err) {
logger.log('err', logger.log('err',
`/txs getTopTransactions ${err}`); `/txs getTopTransactions ${err}`);
return res.status(404).send(err); return res.status(404).send(err);
} }
console.log(txs.length);
return res.json(txs); return res.json(txs);
}); });
// return res.status(404).send({ error: 'Block hash or address expected' });
}); });
router.get('/rawtx/:txid', (req, res) => { router.get('/rawtx/:txid', (req, res) => {

2
server/lib/db/transactions.js
View File

@ -6,7 +6,7 @@ const config = require('../../config');
// These will be replaced with more advanced mongo // These will be replaced with more advanced mongo
// No optimization yet. // No optimization yet.
const MAX_TXS = config.api.max_page_txs; const MAX_TXS = config.api.max_txs;
const MAX_PAGE_TXS = config.api.max_page_txs; const MAX_PAGE_TXS = config.api.max_page_txs;
// For Paging // For Paging

2
server/lib/node/index.js
View File

@ -1,6 +1,7 @@
const FullNode = require('bcoin/lib/node/fullnode'); const FullNode = require('bcoin/lib/node/fullnode');
const logger = require('../../lib/logger'); const logger = require('../../lib/logger');
const BlockParser = require('../parser').Block; const BlockParser = require('../parser').Block;
const TxParser = require('../parser').Transaction;
const config = require('../../config'); const config = require('../../config');
const socket = require('../../lib/api/socket'); const socket = require('../../lib/api/socket');
const db = require('../../lib/db'); const db = require('../../lib/db');
@ -18,6 +19,7 @@ function start() {
node.chain.on('connect', (entry, block) => { node.chain.on('connect', (entry, block) => {
BlockParser.parse(entry, block); BlockParser.parse(entry, block);
TxParser.parse(entry, block.txs);
socket.processBlock(entry, block); socket.processBlock(entry, block);
db.blocks.bestHeight(entry.height); db.blocks.bestHeight(entry.height);
}); });