copay/js/models/blockchain/Insight.js

'use strict';

var imports = require('soop').imports();
var bitcore = require('bitcore');
var coinUtil = bitcore.util;
var preconditions = require('preconditions').singleton();

var http;
if (process.version) {
  http = require('http');
};

function Insight(opts) {
  opts = opts || {};
  this.host = opts.host || 'localhost';
  this.port = opts.port || '3001';
  this.schema = opts.schema || 'http';
  this.retryDelay = opts.retryDelay || 5000;
}

function _asyncForEach(array, fn, callback) {
  array = array.slice(0);

  function processOne() {
    var item = array.pop();
    fn(item, function(result) {
      if (array.length > 0) {
        setTimeout(processOne, 0); // schedule immediately
      } else {
        callback(); // Done!
      }
    });
  }
  if (array.length > 0) {
    setTimeout(processOne, 0); // schedule immediately
  } else {
    callback(); // Done!
  }
};

Insight.prototype._getOptions = function(method, path, data) {
  return {
    host: this.host,
    port: this.port,
    schema: this.schema,
    method: method,
    path: path,
    data: data,
    headers: {
      'Access-Control-Request-Headers': ''
    }
  };
};


// This is vulneable to txid maneability
// TODO: if ret = false,
// check output address from similar transactions.
//
Insight.prototype.checkSentTx = function(tx, cb) {
  var hash = coinUtil.formatHashFull(tx.getHash());
  var options = this._getOptions('GET', '/api/tx/' + hash);

  this._request(options, function(err, res) {
    if (err) return cb(err);
    var ret = false;
    if (res && res.txid === hash) {
      ret = hash;
    }
    return cb(err, ret);
  });
};

Insight.prototype.getTransactions = function(addresses, cb) {
  preconditions.shouldBeArray(addresses);
  preconditions.shouldBeFunction(cb);

  var self = this;
  if (!addresses || !addresses.length) return cb([]);

  var txids = [];
  var txs = [];

  _asyncForEach(addresses, function(addr, callback) {
    var options = self._getOptions('GET', '/api/addr/' + addr);

    self._request(options, function(err, res) {
      if (res && res.transactions) {
        var txids_tmp = res.transactions;
        for (var i = 0; i < txids_tmp.length; i++) {
          txids.push(txids_tmp[i]);
        }
      }
      callback();
    });
  }, function() {
    var uniqueTxids = {};
    for (var k in txids) {
      uniqueTxids[txids[k]] = 1;
    }
    _asyncForEach(Object.keys(uniqueTxids), function(txid, callback2) {
      var options = self._getOptions('GET', '/api/tx/' + txid);
      self._request(options, function(err, res) {
        txs.push(res);
        callback2();
      });
    }, function() {
      return cb(txs);
    });
  });
};

Insight.prototype.getUnspent = function(addresses, cb) {
  if (!addresses || !addresses.length) return cb(null, []);

  var all = [];

  var options = this._getOptions('POST', '/api/addrs/utxo', 'addrs=' + addresses.join(','));

  var self = this;
  this._request(options, function(err, res) {
    if (err) {
      return cb(err);
    }

    if (res && res.length > 0) {
      all = all.concat(res);
    }

    return cb(null, all);
  });
};

Insight.prototype.sendRawTransaction = function(rawtx, cb) {
  if (!rawtx) throw new Error('rawtx must be set');

  var options = this._getOptions('POST', '/api/tx/send', 'rawtx=' + rawtx);
  this._request(options, function(err, res) {
    if (err) return cb();

    return cb(res.txid);
  });
};


Insight.prototype.checkActivity = function(addresses, cb) {
  if (!addresses) throw new Error('address must be set');

  this.getTransactions(addresses, function onResult(txs) {
    var flatArray = function(xss) {
      return xss.reduce(function(r, xs) {
        return r.concat(xs);
      }, []);
    };
    var getInputs = function(t) {
      return t.vin.map(function(vin) {
        return vin.addr
      });
    };
    var getOutputs = function(t) {
      return flatArray(
        t.vout.map(function(vout) {
        return vout.scriptPubKey.addresses;
      })
      );
    };

    var activityMap = new Array(addresses.length);
    var activeAddress = flatArray(txs.map(function(t) {
      return getInputs(t).concat(getOutputs(t));
    }));
    activeAddress.forEach(function(addr) {
      var index = addresses.indexOf(addr);
      if (index != -1) activityMap[index] = true;
    });

    cb(null, activityMap);
  });
};

Insight.prototype._requestNode = function(options, callback) {
  if (options.method === 'POST') {
    options.headers = {
      'Content-Type': 'application/x-www-form-urlencoded',
      'Content-Length': options.data.length,

    };
  }

  var req = http.request(options, function(response) {
    var ret, errTxt, e;
    if (response.statusCode == 200 || response.statusCode === 304) {
      response.on('data', function(chunk) {
        try {
          ret = JSON.parse(chunk);
        } catch (e2) {
          errTxt = 'CRITICAL:  Wrong response from insight' + e2;
        }
      });
    } else {
      errTxt = "INSIGHT ERROR:" + response.statusCode;
      console.log(errTxt);
      e = new Error(errTxt);
      return callback(e);
    }
    response.on('end', function() {
      if (errTxt) {
        console.log("INSIGHT ERROR:" + errTxt);
        e = new Error(errTxt);
      }
      return callback(e, ret);
    });
    response.on('error', function(e) {
      return callback(e, ret);
    });
  });

  if (options.data) {
    req.write(options.data);
  }
  req.end();
};

Insight.prototype._requestBrowser = function(options, callback) {
  var self = this;
  var request = new XMLHttpRequest();
  var url = (options.schema || 'http') + '://' + options.host;

  if (options.port !== 80) {
    url = url + ':' + options.port;
  }

  url = url + options.path;

  if (options.data && options.method === 'GET') {
    url = url + '?' + options.data;
  }

  request.open(options.method, url, true);
  request.timeout = 5000;
  request.ontimeout = function() {
    setTimeout(function() {
      return self._request(options, callback);
    }, self.retryDelay);
    return callback(new Error('Insight request timeout'));
  };


  request.onreadystatechange = function() {
    if (request.readyState !== 4) return;
    var ret, errTxt, e;

    if (request.status === 200 || request.status === 304) {
      try {
        ret = JSON.parse(request.responseText);
      } catch (e2) {
        errTxt = 'CRITICAL:  Wrong response from insight' + e2;
      }
    } else if (request.status >= 400 && request.status < 499) {
      errTxt = 'CRITICAL: Bad request to insight. Probably wrong transaction to broadcast?.';
    } else {
      errTxt = 'Error code: ' + request.status + ' - Status: ' + request.statusText + ' - Description: ' + request.responseText;
      setTimeout(function() {
        return self._request(options, callback);
      }, self.retryDelay);
    }
    if (errTxt) {
      console.log("INSIGHT ERROR:", e);
      e = new Error(errTxt);
    }
    return callback(e, ret);
  };

  if (options.method === 'POST') {
    request.setRequestHeader('Content-Type', 'application/x-www-form-urlencoded');
  }

  request.send(options.data || null);
};

Insight.prototype._request = function(options, callback) {
  if (typeof process === 'undefined' || !process.version) {
    this._requestBrowser(options, callback);
  } else {
    this._requestNode(options, callback);
  }
};

module.exports = require('soop')(Insight);