From a3cc882cee6afcfa4b278e653b3927b0cf79df9a Mon Sep 17 00:00:00 2001
From: Adam Soltys <asoltys@gmail.com>
Date: Sat, 22 Oct 2016 16:43:51 -0700
Subject: wip

---
 src/app.coffee   | 26 +++-----------------------
 src/bcoin.coffee | 38 ++++++++++++++++++++++++++++++++++++++
 2 files changed, 41 insertions(+), 23 deletions(-)
 create mode 100644 src/bcoin.coffee

(limited to 'src')

diff --git a/src/app.coffee b/src/app.coffee
index 1c11fa05..d51eaa99 100644
--- a/src/app.coffee
+++ b/src/app.coffee
@@ -6,9 +6,7 @@ path = require('path')
 passport = require('./passport')
 config = require('./config')
 fs = require('fs')
-bcoin = require('bcoin').set('testnet')
 proxyMiddleware = require('http-proxy-middleware')
-
 sessions = require("./routes/sessions")(passport)
 transactions = require("./routes/transactions")
 users = require("./routes/users")(sessions)
@@ -17,6 +15,7 @@ session = require('express-session')
 RedisStore = require('connect-redis')(session)
 sessionStore = new RedisStore(require('./redis').host, ttl: 172800)
 
+
 proxyContext = '/blockcypher'
 proxyOptions = 
   target: 'https://api.blockcypher.com'
@@ -76,27 +75,8 @@ 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))
-  )
+do startBcoin = -> 
+  require('./bcoin').init()
 
 app.get('/', cache, sessions.new)
 
diff --git a/src/bcoin.coffee b/src/bcoin.coffee
new file mode 100644
index 00000000..31bd7ca1
--- /dev/null
+++ b/src/bcoin.coffee
@@ -0,0 +1,38 @@
+bcoin = require('bcoin')
+db = require('./redis')
+
+module.exports =
+  init: ->
+    addresses = {}
+
+    chain = new bcoin.chain(
+      db: 'leveldb'
+      location: __dirname + 'mainchain/mainchain.db'
+      spv: true
+    )
+
+    pool = new bcoin.pool(
+      chain: chain
+      spv: true
+    )
+
+    pool.open((err) -> 
+      db.keys("user:*", (err, users) ->
+        users.map((key) ->
+          db.hgetall(key, (err, user) ->
+            addresses[user.address] = user.username
+            pool.watchAddress(user.address)
+            console.log(user.address)
+          )
+        )
+      )
+
+      pool.connect()
+      pool.startSync()
+
+      pool.on('error', (err) -> 
+        debugger
+        console.log(err)
+      )
+      pool.on('tx', (tx) -> console.log(tx))
+    )
-- 
cgit v1.2.3