diff options
| -rw-r--r-- | app.js | 24 | ||||
| -rw-r--r-- | package.json | 1 | ||||
| -rw-r--r-- | src/app.coffee | 22 |
3 files changed, 46 insertions, 1 deletions
@@ -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) -> |