diff --git a/app.js b/app.js deleted file mode 100644 index e69de29..0000000 diff --git a/config/index.js b/config/index.js index 66878ce..d3bc4dc 100644 --- a/config/index.js +++ b/config/index.js @@ -1,5 +1,5 @@ const config = { - start_node: false, + start_node: true, logging: 'debug', bcoin: { network: 'main', diff --git a/index.js b/index.js index eb4c8af..23d3125 100644 --- a/index.js +++ b/index.js @@ -18,6 +18,3 @@ db.connection.once('open', () => { 'listening on port 3000'); }); }); - - - diff --git a/lib/api/index.js b/lib/api/index.js index 10e2791..44a1e8f 100644 --- a/lib/api/index.js +++ b/lib/api/index.js @@ -34,7 +34,8 @@ app.use((req, res) => { }); const server = require('http').Server(app); +const io = require('socket.io')(server); -const SocketAPI = require('./socket')(server); +const SocketAPI = require('./socket')(io); module.exports = server; diff --git a/lib/api/socket.js b/lib/api/socket.js index 6a7e534..dfc4557 100644 --- a/lib/api/socket.js +++ b/lib/api/socket.js @@ -1,9 +1,4 @@ - -module.exports = function addressrouter(express) { - const io = require('socket.io')(express); - - console.log('starting sockets') - +module.exports = function addressrouter(io) { io.on('connection', (socket) => { socket.on('subscribe', (data) => { console.log('subscribe message'); @@ -25,5 +20,4 @@ module.exports = function addressrouter(express) { console.log(data); }); }); - }; diff --git a/lib/node/index.js b/lib/node/index.js index 7e4b8d2..42e400a 100644 --- a/lib/node/index.js +++ b/lib/node/index.js @@ -6,6 +6,8 @@ const addrParser = require('../parser').Address; const config = require('../../config'); const node = new FullNode(config.bcoin); +let socket; + function start() { node.open() @@ -22,6 +24,8 @@ function start() { BlockParser.parse(entry, block); TxParser.parse(entry, block.txs); addrParser.parse(entry, block.txs); + + }); node.pool.on('peer', (peer) => { @@ -36,6 +40,14 @@ function start() { // node.mempool.on('tx' ...) } +// Super Hack +function setSocket(client) { + console.log('setting socket for node'); + //socket = client; + +} + module.exports = { start, + setSocket, };