/api/unspent-outpoints.js

Author: andrewschaaf

app.coffee

@@ -1,12 +1,15 @@
 
 url = require 'url'
 async = require 'async'
-{get_address_info} = require './scrape-blockexplorer'
+{get_unspent_outpoints} = require './scrape-blockexplorer'
 {BitcoinNode} = require './bitcoin-node'
 
 
+CONNECT_TO_BITCOIND = true
 
-bitcoin_node = new BitcoinNode
+
+if CONNECT_TO_BITCOIND
+  bitcoin_node = new BitcoinNode
 
 
 
@@ -20,14 +23,20 @@ api = (req, res, next) ->
 
 module.exports = (app) ->
 
-  app.get '/api/check-addresses.js', api, (req, res, next) ->
+  app.get '/api/unspent-outpoints.js', api, (req, res, next) ->
     addrs = req.x.addresses.split ','
-    async.map addrs, get_address_info, (err, results) ->
+    async.map addrs, get_unspent_outpoints, (err, results) ->
+      unspent_outpoints = []
+      for arr in results
+        for x in arr
+          unspent_outpoints.push x
       res.api {
-        addresses: results
+        unspent_outpoints: unspent_outpoints
       }
 
-  app.post '/api/publish-tx.js', api, (req, res, next) ->
-    tx = new Buffer req.body.tx64, 'base64'
-    bitcoin_node.publishTX_via_tx tx, () ->
-      res.api {}
+  if CONNECT_TO_BITCOIND
+    app.post '/api/publish-tx.js', api, (req, res, next) ->
+      tx = new Buffer req.body.tx64, 'base64'
+      console.log require('hexy').hexy tx
+      bitcoin_node.publishTX_via_tx tx, () ->
+        res.api {}

bitcoin-node.coffee

@@ -4,10 +4,12 @@ net = require 'net'
 {readData} = require './util'
 
 
+
 exports.BitcoinNode = class BitcoinNode
 
   publishTX_via_tx: (data, callback) ->
-    @conn.write msg pack_message 'tx', data
+    @conn.write pack_message 'tx', data
+    callback()
 
   publishTX_via_inv: (data, callback) ->
     k = inv_for_tx(data).toString('base64')
@@ -24,7 +26,7 @@ exports.BitcoinNode = class BitcoinNode
       console.log "Bitcoin message: #{name}"
 
     p.on 'version', (m) =>
-      if m >= 209
+      if m.version >= 209
         @conn.write pack_message 'verack', {}
 
     p.on 'getdata', (m) =>

scrape-blockexplorer.coffee

@@ -1,45 +1,88 @@
 
 http = require 'http'
 assert = require 'assert'
+async = require 'async'
 {readData} = require './util'
 
 
-exports.get_address_info = (address, callback) ->
+exports.get_unspent_outpoints = (address, callback) ->
+  
   http.get {host:"blockexplorer.com", port:80, path:"/address/#{address}"}, (res) ->
     readData res, (data) ->
-      html = data.toString('utf-8')
-      callback null, {
-        address: address
-        outpoints: scrape_address_outpoints(html)
-      }
+      [received, sent_transactions] = scrape_address_ledger data.toString 'utf-8'
+      
+      async.map sent_transactions, tx_input_outpoints, (err, results) ->
+        
+        # Set of received outpoints
+        set = {}
+        for row in received
+          set[row.outpoint] = row
+        
+        # Setminus the spent ones
+        for outpoints in results
+          for outpoint in outpoints
+            delete set[outpoint]
+        
+        unspent_outpoints = []
+        for own k, v of set
+          unspent_outpoints.push v
+        
+        callback null, unspent_outpoints
+
+
+tx_input_outpoints = (tx_hash, cb) ->
+  http.get {host:"blockexplorer.com", port:80, path:"/tx/#{tx_hash}"}, (res) ->
+    readData res, (data) ->
+      html = data.toString 'utf-8'
+      
+      rg = /<td><a name="i[0-9]+" href="\/tx\/([0-9a-fA-F]+)#o([0-9]+)"/g
+      r  = /<td><a name="i[0-9]+" href="\/tx\/([0-9a-fA-F]+)#o([0-9]+)"/
+      
+      outpoints = []
+      for text in html.match rg
+        m = text.match r
+        outpoints.push "#{m[1]}:#{m[2]}"
+      
+      cb null, outpoints
 
 
-scrape_address_outpoints = (html) ->
-  outpoints = []
+scrape_address_ledger = (html) ->
 
-  trs = html.match(/<tr>(.|\n)*?Received: Address(.|\n)*?<\/tr>/g)
+  received = []
+  sent_transactions_set = {}
+  
+  trs = html.match /<tr>(.|[\r\n])*?<\/tr>/g
   assert.ok trs
 
   for tr in trs
-    
-    m = tr.match /href="\/tx\/([a-zA-Z0-9]+)#o([0-9]+)"/
-    assert.ok m
-    hash = m[1]
-    n = parseInt m[2], 10
-    
-    m = tr.match(/Block ([0-9]+)<\/a>/)
-    assert.ok m
-    block_number = parseInt m[1], 10
-    
-    m = tr.match /<td>([0-9.]+)<\/td>\n<td>Received/
-    assert.ok m
-    value_str = m[1]
-    
-    outpoints.push {
-      hash: hash
-      n: n
-      block_number: block_number
-      value_str: value_str
-    }
-  outpoints
+    amount_match = tr.match /<td>([0-9.]+)<\/td>[ \t\r\n]*<td>(Received|Sent)/
+    if amount_match
+      
+      m = tr.match /href="\/tx\/([a-zA-Z0-9]+)#.([0-9]+)"/
+      assert.ok m, 'hash, n'
+      hash = m[1]
+      n = parseInt m[2], 10
+      
+      m = tr.match /Block ([0-9]+)<\/a>/
+      assert.ok m, 'block_number'
+      block_number = parseInt m[1], 10
+      
+      value_str = amount_match[1]
+      
+      if tr.match /Received/
+        received.push {
+          hash: hash
+          n: n
+          outpoint: "#{hash}:#{n}"
+          block_number: block_number
+          value_str: value_str
+        }
+      else
+        sent_transactions_set[hash] = true
+  
+  sent_transactions = []
+  for own k of sent_transactions_set
+    sent_transactions.push k
+  
+  return [received, sent_transactions]