mirror of https://github.com/BTCPrivate/copay.git
289 lines
7.1 KiB
JavaScript
289 lines
7.1 KiB
JavaScript
'use strict';
|
|
|
|
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 = Insight;
|