Socket architecture change. More maleable/easier to wire up events with the node

config/index.js

@@ -1,5 +1,5 @@
 const config = {
-  start_node: false,
+  start_node: true,
   logging: 'debug',
   bcoin: {
     network: 'main',

index.js

@@ -18,6 +18,3 @@ db.connection.once('open', () => {
       'listening on port 3000');
   });
 });
-
-
-

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;

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);
     });
   });
-
 };

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,
 };