Fire up SPV node

3 files changed, 46 insertions, 1 deletions

diff --git a/app.js b/app.js
index 76f070eb..acbc9cb4 100644
--- a/app.js
+++ b/app.js
@@ -1,5 +1,5 @@
 (function() {
-  var RedisStore, app, authorize, bcoin, bodyParser, cache, config, cookieParser, express, fetchRates, fs, passport, path, proxy, proxyContext, proxyMiddleware, proxyOptions, request, session, sessionStore, sessions, transactions, users,
+  var RedisStore, app, authorize, bcoin, bodyParser, cache, config, cookieParser, express, fetchRates, fs, passport, path, proxy, proxyContext, proxyMiddleware, proxyOptions, request, session, sessionStore, sessions, startBcoin, transactions, users,
     indexOf = [].indexOf || function(item) { for (var i = 0, l = this.length; i < l; i++) { if (i in this && this[i] === item) return i; } return -1; };
 
   request = require('request');
@@ -125,6 +125,28 @@
     return setTimeout(fetchRates, 120000);
   })();
 
+  (startBcoin = function() {
+    var chain, pool;
+    chain = new bcoin.chain({
+      db: 'leveldb',
+      location: process.env.HOME + '/chain.db',
+      spv: true
+    });
+    pool = new bcoin.pool({
+      chain: chain,
+      spv: true
+    });
+    return pool.open(function(err) {
+      pool.watchAddress('mhwWUZAmP4ycvwj4DdfGRy2JNRwDXeuwtj');
+      pool.connect();
+      pool.startSync();
+      pool.on('error', function(err) {});
+      return pool.on('tx', function(tx) {
+        return console.log(tx);
+      });
+    });
+  })();
+
   app.get('/', cache, sessions["new"]);
 
   app.get('/address', cache, function(req, res) {
diff --git a/package.json b/package.json
index e908316b..9f907a10 100644
--- a/package.json
+++ b/package.json
@@ -8,6 +8,7 @@
   },
   "dependencies": {
     "async": "2.1.1",
+    "bcoin": "git+https://github.com/bcoin-org/bcoin.git#0ca843e3cabd4920546a9947f15954e2b7ede195",
     "bcryptjs": "^2.3.0",
     "bip39": "^2.2.0",
     "bluebird": "^3.4.6",
diff --git a/src/app.coffee b/src/app.coffee
index dfc1e295..1c11fa05 100644
--- a/src/app.coffee
+++ b/src/app.coffee
@@ -76,6 +76,28 @@ do fetchRates = ->
   )
   setTimeout(fetchRates, 120000)
 
+do startBcoin = ->
+  chain = new bcoin.chain(
+    db: 'leveldb'
+    location: process.env.HOME + '/chain.db'
+    spv: true
+  )
+
+  pool = new bcoin.pool(
+    chain: chain
+    spv: true
+  )
+
+  pool.open((err) -> 
+    pool.watchAddress('mhwWUZAmP4ycvwj4DdfGRy2JNRwDXeuwtj')
+
+    pool.connect()
+    pool.startSync()
+
+    pool.on('error', (err) -> return)
+    pool.on('tx', (tx) -> console.log(tx))
+  )
+
 app.get('/', cache, sessions.new)
 
 app.get('/address', cache, (req, res) ->