Merge pull request #69 from maraoz/polish/addresses

polish API: /v1/addresses

api/controllers/addresses.js

@@ -63,7 +63,7 @@ Addresses.addressesParam = function(req, res, next, addresses) {
  */
 Addresses.get = function(req, res) {
   $.checkState(req.address instanceof Address);
-  node.getAddressInfo(req.address)
+  node.addressService.getSummary(req.address)
     .then(function(info) {
       res.send(info);
     });

api/test/data/addresses.js

@@ -1,6 +1,67 @@
 'use strict';
 
 var mockAddresses = {
+  '13fas9TWPMRBakZ822mvddS6PM92udNB2g': {
+    summary: {
+      address: '13fas9TWPMRBakZ822mvddS6PM92udNB2g',
+      transactions: [
+        '4469092947a437f9b4276e0a7e3c899a2b74b2fe325e49202c3005911adaab85',
+        'afa55c2ce0e1038d87921d4de7b13a456edfa5ca6f44cddaf4cda9f1db441481'
+      ],
+      confirmed: {
+        balance: 0,
+        sent: 675000000,
+        received: 675000000
+      },
+      unconfirmed: {
+        balance: 0,
+        sent: 675000000,
+        received: 675000000
+      }
+    },
+    utxos: []
+  },
+  '17afxUJouat3fkaaQ9tZrDThxdkXGL4WrM': {
+    summary: {
+      address: '17afxUJouat3fkaaQ9tZrDThxdkXGL4WrM',
+      transactions: [
+        '2ccc3f59d28c709770a8bc478b112e10feda4bf55197c2e48deaa0eb6bca0311',
+        '92f55c2c0b8317eafad83c73487fbeceb8279d0eb57e398763298e6cc983b356'
+      ],
+      confirmed: {
+        balance: 0,
+        sent: 100000000000,
+        received: 100000000000
+      },
+      unconfirmed: {
+        balance: 0,
+        sent: 100000000000,
+        received: 100000000000
+      }
+    },
+    utxos: []
+  },
+  '17DC6Fxidja2DN7oHTVgfx3uQ4KGArYEwg': {
+    summary: {
+      'address': '17DC6Fxidja2DN7oHTVgfx3uQ4KGArYEwg',
+      'transactions': [
+        '33d1ad0d24e2cb466054e47060c8ae527af7a3c46445335bebf9d24a6f5b1e9e',
+        '6884733345b952b244a44cf770be62afbcf41549d8a89d2a4bea9f479e09dd47',
+        '2847ae66175042438532c2eccc5b39935fd1216453e62e2c3cb9c8e5020cc771'
+      ],
+      'confirmed': {
+        'balance': 0,
+        'sent': 65000000000,
+        'received': 65000000000
+      },
+      'unconfirmed': {
+        'balance': 0,
+        'sent': 65000000000,
+        'received': 65000000000
+      }
+    },
+    utxos: []
+  },
   '1CT9huFgxMFveRvzZ7zPPJNoaMm2Fo64VH': {
     summary: {
       address: '1CT9huFgxMFveRvzZ7zPPJNoaMm2Fo64VH',

api/test/v1/addresses.js

@@ -2,7 +2,6 @@
 
 var chai = require('chai');
 var should = chai.should();
-var request = require('supertest');
 
 var EventEmitter = require('eventemitter2').EventEmitter2;
 var Promise = require('bluebird');
@@ -10,7 +9,6 @@ Promise.longStackTraces();
 var bitcore = require('bitcore');
 var _ = bitcore.deps._;
 
-var BitcoreHTTP = require('../../lib/http');
 
 var mockAddresses = require('../data/addresses');
 var mockTransactions = require('../data/transactions');
@@ -19,7 +17,7 @@ describe('BitcoreHTTP v1 addresses routes', function() {
 
   // mocks
   var transactionList = _.values(mockTransactions);
-  var nodeMock, app, agent;
+  var nodeMock, agent;
   var txs_for_addr = function(addr) {
     var amount = mockAddresses[addr].summary.transactions.length;
     return transactionList.slice(0, amount);
@@ -51,8 +49,9 @@ describe('BitcoreHTTP v1 addresses routes', function() {
 
   beforeEach(function() {
     nodeMock = new EventEmitter();
-    nodeMock.getAddressInfo = function(address) {
-      return Promise.resolve(mockAddresses[address.toString()]);
+    nodeMock.addressService = {};
+    nodeMock.addressService.getSummary = function(address) {
+      return Promise.resolve(mockAddresses[address.toString()].summary);
     };
     nodeMock.listTransactions = function(opts) {
       return Promise.resolve(txs_for_addr(opts.address));
@@ -60,8 +59,7 @@ describe('BitcoreHTTP v1 addresses routes', function() {
     nodeMock.getUTXOs = function(addresses) {
       return Promise.resolve(utxos_for_addrs(addresses));
     };
-    app = new BitcoreHTTP(nodeMock).app;
-    agent = request(app);
+    agent = require('../app')(nodeMock);
   });
 
   var failsWithInvalidAddress = function(agent, url, cb) {
@@ -79,7 +77,7 @@ describe('BitcoreHTTP v1 addresses routes', function() {
       it('works with valid address ' + addr, function(cb) {
         agent.get('/v1/addresses/' + addr)
           .expect(200)
-          .expect(JSON.stringify(info), cb);
+          .expect(JSON.stringify(info.summary), cb);
       });
     });
   });

api/test/v1/node.js

@@ -18,7 +18,7 @@ describe('BitcoreHTTP v1 node routes', function() {
       peerCount: 8,
       version: 'test',
       network: 'regtest',
-      height: 1234,
+      height: 60000,
     };
     nodeMock.getStatus = function() {
       return Promise.resolve(nodeMock.status);

lib/node.js

@@ -188,10 +188,17 @@ BitcoreNode.prototype.getStatus = function() {
     peerCount: this.networkMonitor.getConnectedPeers(),
     version: pjson.version,
     network: bitcore.Networks.defaultNetwork.name,
-    height: this.blockchain.getCurrentHeight(),
+    height: this.getCurrentHeight(),
   });
 };
 
+BitcoreNode.prototype.getCurrentHeight = function() {
+  if (!this.blockchain) {
+    return 0;
+  }
+  return this.blockchain.getCurrentHeight();
+};
+
 BitcoreNode.prototype.getSyncProgress = function() {
   return !_.isUndefined(this.reportedMaxHeight) ?
     (this.blockchain.getCurrentHeight() / this.reportedMaxHeight) : 0;

lib/services/transaction.js

@@ -120,27 +120,26 @@ TransactionService.prototype._confirmOutput = function(ops, block, transaction)
       key: Index.getOutput(txid, index),
       value: output.toJSON()
     });
-    var address;
-    if (output.script.isPublicKeyHashOut() || output.script.isScriptHashOut()) {
-      address = output.script.toAddress();
-    }
-    if (address) {
-      var out4addr = output.toObject();
-      out4addr.heightConfirmed = block.height;
-      ops.push({
-        type: 'put',
-        key: Index.getOutputsForAddress(address, txid, index),
-        value: JSON.stringify(out4addr)
-      });
+    var script = output.script;
+    if (!script.isPublicKeyHashOut() && !script.isScriptHashOut()) {
+      return;
     }
+    var address = output.script.toAddress();
+    //console.log('o', address.type, address.toString());
+    var obj = output.toObject();
+    obj.heightConfirmed = block.height;
+    ops.push({
+      type: 'put',
+      key: Index.getOutputsForAddress(address, txid, index),
+      value: JSON.stringify(obj)
+    });
   };
 };
 
 TransactionService.prototype._confirmInput = function(ops, block, transaction) {
-  var self = this;
   var txid = transaction.id;
   return function(input, index) {
-    if (input.prevTxId.toString('hex') === NULLTXHASH) {
+    if (input.isNull()) {
       return Promise.resolve();
     }
     ops.push({
@@ -151,34 +150,27 @@ TransactionService.prototype._confirmInput = function(ops, block, transaction) {
       }))
     });
     var script = input.script;
-    if (!(script.isPublicKeyHashIn() || script.isPublicKeyIn() || script.isScriptHashIn())) {
-      return;
+    if (!(script.isPublicKeyHashIn() || script.isScriptHashIn())) {
+      return Promise.resolve();
     }
 
     return Promise.try(function() {
-      var address = self._getAddressForInput(input);
-      if (address) {
-        ops.push({
-          type: 'put',
-          key: Index.getSpentOutputsForAddress(address, txid, index),
-          value: JSON.stringify({
-            heightSpent: block.height,
-            spentTx: txid,
-            spentTxInputIndex: index,
-            spendInput: input.toObject()
-          })
-        });
-      }
+      var address = input.script.toAddress();
+      //console.log('i', address.type, address.toString());
+      ops.push({
+        type: 'put',
+        key: Index.getSpentOutputsForAddress(address, txid, index),
+        value: JSON.stringify({
+          heightSpent: block.height,
+          spentTx: txid,
+          spentTxInputIndex: index,
+          spendInput: input.toObject()
+        })
+      });
     });
   };
 };
 
-TransactionService.prototype._getAddressForInput = function(input) {
-  var script = input.script;
-  // TODO: move this to bitcore
-  return new bitcore.Script(script.chunks[script.chunks.length - 1]).toAddress();
-};
-
 TransactionService.prototype._confirmTransaction = function(ops, block, transaction) {
   var self = this;
   ops.push({

package.json

@@ -39,7 +39,6 @@
     "bluebird": "^2.9.12",
     "body-parser": "^1.12.0",
     "bufferput": "bitpay/node-bufferput",
-    "buffertools": "*",
     "compression": "^1.4.1",
     "config": "^1.12.0",
     "cors": "^2.5.3",