2014-04-14 13:17:56 -07:00
|
|
|
'use strict';
|
|
|
|
|
2014-05-12 13:41:15 -07:00
|
|
|
var imports = require('soop').imports();
|
|
|
|
var bitcore = require('bitcore');
|
2014-04-14 13:17:56 -07:00
|
|
|
|
|
|
|
function Insight(opts) {
|
|
|
|
opts = opts || {};
|
2014-04-15 14:23:35 -07:00
|
|
|
this.host = opts.host || 'localhost';
|
|
|
|
this.port = opts.port || '3001';
|
|
|
|
this.scheme = opts.scheme || 'http';
|
2014-04-14 13:17:56 -07:00
|
|
|
}
|
|
|
|
|
|
|
|
function _asyncForEach(array, fn, callback) {
|
|
|
|
array = array.slice(0);
|
2014-05-12 13:41:15 -07:00
|
|
|
|
2014-04-14 13:17:56 -07:00
|
|
|
function processOne() {
|
|
|
|
var item = array.pop();
|
|
|
|
fn(item, function(result) {
|
2014-05-12 13:41:15 -07:00
|
|
|
if (array.length > 0) {
|
|
|
|
setTimeout(processOne, 0); // schedule immediately
|
|
|
|
} else {
|
|
|
|
callback(); // Done!
|
|
|
|
}
|
|
|
|
});
|
2014-04-14 13:17:56 -07:00
|
|
|
}
|
2014-05-12 13:41:15 -07:00
|
|
|
if (array.length > 0) {
|
2014-04-14 13:17:56 -07:00
|
|
|
setTimeout(processOne, 0); // schedule immediately
|
|
|
|
} else {
|
|
|
|
callback(); // Done!
|
|
|
|
}
|
2014-04-22 23:37:17 -07:00
|
|
|
};
|
|
|
|
|
2014-05-12 13:41:15 -07:00
|
|
|
function removeRepeatedElements(ar) {
|
|
|
|
var ya = false,
|
|
|
|
v = "",
|
|
|
|
aux = [].concat(ar),
|
|
|
|
r = Array();
|
|
|
|
for (var i in aux) { //
|
|
|
|
v = aux[i];
|
|
|
|
ya = false;
|
|
|
|
for (var a in aux) {
|
|
|
|
if (v == aux[a]) {
|
|
|
|
if (ya == false) {
|
|
|
|
ya = true;
|
|
|
|
} else {
|
|
|
|
aux[a] = "";
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
for (var a in aux) {
|
|
|
|
if (aux[a] != "") {
|
|
|
|
r.push(aux[a]);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return r;
|
2014-04-22 23:37:17 -07:00
|
|
|
}
|
2014-04-14 13:17:56 -07:00
|
|
|
|
2014-04-22 21:55:00 -07:00
|
|
|
Insight.prototype.getTransactions = function(addresses, cb) {
|
|
|
|
var self = this;
|
2014-05-12 13:41:15 -07:00
|
|
|
|
2014-04-22 21:55:00 -07:00
|
|
|
if (!addresses || !addresses.length) return cb([]);
|
|
|
|
|
|
|
|
var txids = [];
|
|
|
|
var txs = [];
|
2014-05-12 13:41:15 -07:00
|
|
|
|
2014-04-22 21:55:00 -07:00
|
|
|
_asyncForEach(addresses, function(addr, callback) {
|
|
|
|
var options = {
|
|
|
|
host: self.host,
|
|
|
|
port: self.port,
|
|
|
|
scheme: self.scheme,
|
|
|
|
method: 'GET',
|
|
|
|
path: '/api/addr/' + addr,
|
|
|
|
|
2014-05-12 13:41:15 -07:00
|
|
|
headers: {
|
|
|
|
'Access-Control-Request-Headers': ''
|
|
|
|
}
|
2014-04-22 21:55:00 -07:00
|
|
|
};
|
2014-05-12 13:41:15 -07:00
|
|
|
|
2014-04-22 21:55:00 -07:00
|
|
|
self._request(options, function(err, res) {
|
|
|
|
var txids_tmp = res.transactions;
|
2014-05-12 13:41:15 -07:00
|
|
|
for (var i = 0; i < txids_tmp.length; i++) {
|
2014-04-22 21:55:00 -07:00
|
|
|
txids.push(txids_tmp[i]);
|
|
|
|
}
|
|
|
|
callback();
|
|
|
|
});
|
|
|
|
}, function() {
|
2014-04-22 23:37:17 -07:00
|
|
|
var clean_txids = removeRepeatedElements(txids);
|
|
|
|
_asyncForEach(clean_txids, function(txid, callback2) {
|
2014-04-22 21:55:00 -07:00
|
|
|
var options = {
|
|
|
|
host: self.host,
|
|
|
|
port: self.port,
|
|
|
|
scheme: self.scheme,
|
|
|
|
method: 'GET',
|
|
|
|
path: '/api/tx/' + txid,
|
2014-05-12 13:41:15 -07:00
|
|
|
headers: {
|
|
|
|
'Access-Control-Request-Headers': ''
|
|
|
|
}
|
2014-04-22 21:55:00 -07:00
|
|
|
};
|
|
|
|
self._request(options, function(err, res) {
|
|
|
|
txs.push(res);
|
|
|
|
callback2();
|
|
|
|
});
|
|
|
|
}, function() {
|
|
|
|
return cb(txs);
|
|
|
|
});
|
|
|
|
});
|
|
|
|
};
|
|
|
|
|
2014-04-18 09:20:35 -07:00
|
|
|
Insight.prototype.getUnspent = function(addresses, cb) {
|
2014-04-14 13:17:56 -07:00
|
|
|
var self = this;
|
2014-05-12 13:41:15 -07:00
|
|
|
|
2014-04-15 14:23:35 -07:00
|
|
|
if (!addresses || !addresses.length) return cb([]);
|
2014-04-14 13:17:56 -07:00
|
|
|
|
|
|
|
var all = [];
|
|
|
|
|
|
|
|
_asyncForEach(addresses, function(addr, callback) {
|
|
|
|
var options = {
|
|
|
|
host: self.host,
|
|
|
|
port: self.port,
|
2014-04-15 14:23:35 -07:00
|
|
|
scheme: self.scheme,
|
2014-04-14 13:17:56 -07:00
|
|
|
method: 'GET',
|
2014-04-15 14:23:35 -07:00
|
|
|
path: '/api/addr/' + addr + '/utxo',
|
|
|
|
|
2014-05-12 13:41:15 -07:00
|
|
|
headers: {
|
|
|
|
'Access-Control-Request-Headers': ''
|
|
|
|
}
|
2014-04-14 13:17:56 -07:00
|
|
|
};
|
2014-05-12 13:41:15 -07:00
|
|
|
|
2014-04-14 13:17:56 -07:00
|
|
|
self._request(options, function(err, res) {
|
2014-05-12 13:41:15 -07:00
|
|
|
if (res && res.length > 0) {
|
2014-04-14 13:17:56 -07:00
|
|
|
all = all.concat(res);
|
2014-05-12 13:41:15 -07:00
|
|
|
}
|
2014-04-14 13:17:56 -07:00
|
|
|
callback();
|
|
|
|
});
|
|
|
|
}, function() {
|
|
|
|
return cb(all);
|
|
|
|
});
|
|
|
|
};
|
|
|
|
|
|
|
|
Insight.prototype.sendRawTransaction = function(rawtx, cb) {
|
|
|
|
if (!rawtx) return callback();
|
|
|
|
|
|
|
|
var options = {
|
|
|
|
host: this.host,
|
|
|
|
port: this.port,
|
|
|
|
method: 'POST',
|
|
|
|
path: '/api/tx/send',
|
2014-05-12 13:41:15 -07:00
|
|
|
data: 'rawtx=' + rawtx,
|
|
|
|
headers: {
|
|
|
|
'content-type': 'application/x-www-form-urlencoded'
|
|
|
|
}
|
2014-04-14 13:17:56 -07:00
|
|
|
};
|
2014-05-12 13:41:15 -07:00
|
|
|
this._request(options, function(err, res) {
|
|
|
|
console.log('[Insight.js.73:err:]', err); //TODO
|
2014-04-14 13:17:56 -07:00
|
|
|
if (err) return cb();
|
2014-04-20 16:24:24 -07:00
|
|
|
|
2014-05-12 13:41:15 -07:00
|
|
|
console.log('[Insight.js.74]', res); //TODO
|
2014-04-14 13:17:56 -07:00
|
|
|
return cb(res.txid);
|
|
|
|
});
|
|
|
|
};
|
|
|
|
|
|
|
|
Insight.prototype._request = function(options, callback) {
|
2014-04-15 14:44:10 -07:00
|
|
|
if (typeof process === 'undefined' || !process.version) {
|
|
|
|
var request = new XMLHttpRequest();
|
|
|
|
|
|
|
|
// TODO: Normalize URL
|
|
|
|
var url = '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.onreadystatechange = function() {
|
|
|
|
if (request.readyState === 4) {
|
|
|
|
if (request.status === 200) {
|
2014-04-21 07:28:25 -07:00
|
|
|
return callback(null, JSON.parse(request.responseText));
|
2014-05-12 13:41:15 -07:00
|
|
|
} else {
|
2014-04-21 07:49:19 -07:00
|
|
|
return callback({
|
|
|
|
message: 'Error code: ' + request.status + ' - Status: ' + request.statusText + ' - Description: ' + request.responseText
|
|
|
|
});
|
2014-04-14 13:17:56 -07:00
|
|
|
}
|
2014-04-15 14:44:10 -07:00
|
|
|
}
|
|
|
|
};
|
|
|
|
|
|
|
|
if (options.method === 'POST') {
|
|
|
|
request.setRequestHeader('Content-Type', 'application/x-www-form-urlencoded');
|
|
|
|
request.send(options.data);
|
|
|
|
} else {
|
|
|
|
request.send(null);
|
2014-04-14 13:17:56 -07:00
|
|
|
}
|
2014-04-15 14:44:10 -07:00
|
|
|
} else {
|
|
|
|
var http = require('http');
|
|
|
|
var req = http.request(options, function(response) {
|
|
|
|
var ret;
|
|
|
|
if (response.statusCode == 200) {
|
|
|
|
response.on('data', function(chunk) {
|
|
|
|
try {
|
|
|
|
ret = JSON.parse(chunk);
|
|
|
|
} catch (e) {
|
2014-05-12 13:41:15 -07:00
|
|
|
callback({
|
|
|
|
message: "Wrong response from insight"
|
|
|
|
});
|
2014-04-15 14:44:10 -07:00
|
|
|
return;
|
|
|
|
}
|
|
|
|
});
|
2014-05-12 13:41:15 -07:00
|
|
|
response.on('end', function() {
|
|
|
|
callback(undefined, ret);
|
2014-04-15 14:44:10 -07:00
|
|
|
return;
|
|
|
|
});
|
2014-05-12 13:41:15 -07:00
|
|
|
} else {
|
|
|
|
callback({
|
|
|
|
message: 'Error ' + response.statusCode
|
|
|
|
});
|
2014-04-15 14:44:10 -07:00
|
|
|
return;
|
|
|
|
}
|
|
|
|
});
|
|
|
|
if (options.data) {
|
|
|
|
req.write(options.data);
|
2014-04-14 13:17:56 -07:00
|
|
|
}
|
2014-04-15 14:44:10 -07:00
|
|
|
req.end();
|
2014-04-14 13:17:56 -07:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
module.exports = require('soop')(Insight);
|