diff --git a/index.js b/index.js index 93c851e..005f5be 100644 --- a/index.js +++ b/index.js @@ -10,3 +10,4 @@ Api.listen(3000, () => { 'listening on port 3000'); }); +node.start(); diff --git a/lib/node/index.js b/lib/node/index.js index 5df301b..40edae7 100644 --- a/lib/node/index.js +++ b/lib/node/index.js @@ -6,44 +6,51 @@ const logger = require('../../lib/logger'); const db = require('../../lib/db'); const util = require('../../lib/util'); -node.open() -.then(() => { - node.connect().then(() => { - node.startSync(); - }); -}); -node.chain.on('connect', (entry, block) => { - processBlock(entry, block); -}); - -function processBlock(entry, block, cb) { - block.hash = util.revHex(block.hash().toString('hex')) - const b = new BlockSchema({ - hash: block.hash, - size: block.size, - height: block.height, - version: block.version, - merkleRoot: block.merkleRoot, - tx: block.txs.map(tx => util.revHex(tx.hash().toString('hex'))), - time: block.ts, - nonce: block.nonce, - bits: block.bits, - difficulty: block.bits, - chainwork: entry.chainwork, - confirmations: 0, - previousBlockHash: block.previousBlockHash, - nextBlockHash: 0, - reward: 0, - timeNormalized: block.ts, - isMainChain: true, - poolInfo: Object, - transactionCount: block.txs.length, +function start() { + node.open() + .then(() => { + node.connect().then(() => { + node.startSync(); + }); }); - b.save((err) => { - if (err) { - console.log(err.message); - } + node.chain.on('connect', (entry, block) => { + processBlock(entry, block); }); + + function processBlock(entry, block, cb) { + block.hash = util.revHex(block.hash().toString('hex')) + const b = new BlockSchema({ + hash: block.hash, + size: block.size, + height: block.height, + version: block.version, + merkleRoot: block.merkleRoot, + tx: block.txs.map(tx => util.revHex(tx.hash().toString('hex'))), + time: block.ts, + nonce: block.nonce, + bits: block.bits, + difficulty: block.bits, + chainwork: entry.chainwork, + confirmations: 0, + previousBlockHash: block.previousBlockHash, + nextBlockHash: 0, + reward: 0, + timeNormalized: block.ts, + isMainChain: true, + poolInfo: Object, + transactionCount: block.txs.length, + }); + + b.save((err) => { + if (err) { + console.log(err.message); + } + }); + } } + +module.exports = { + start, +} \ No newline at end of file