You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
114 lines
3.1 KiB
114 lines
3.1 KiB
'use strict';
|
|
|
|
var Networks = require('../networks');
|
|
var JSUtil = require('../util/js');
|
|
var $ = require('../util/preconditions');
|
|
var _ = require('lodash');
|
|
var Address = require('../address');
|
|
var Transaction = require('../transaction');
|
|
var UnspentOutput = Transaction.UnspentOutput;
|
|
|
|
var request = require('request');
|
|
|
|
/**
|
|
* Allows the retrieval of information regarding the state of the blockchain
|
|
* (and broadcasting of transactions) from/to a trusted Insight server.
|
|
* @param {string=} url the url of the Insight server
|
|
* @param {Network=} network whether to use livenet or testnet
|
|
* @constructor
|
|
*/
|
|
function Insight(url, network) {
|
|
if (!url && !network) {
|
|
return new Insight(Networks.defaultNetwork);
|
|
}
|
|
if (Networks.get(url)) {
|
|
network = Networks.get(url);
|
|
if (network === Networks.livenet) {
|
|
url = 'https://insight.bitpay.com';
|
|
} else {
|
|
url = 'https://test-insight.bitpay.com';
|
|
}
|
|
}
|
|
JSUtil.defineImmutable(this, {
|
|
url: url,
|
|
network: Networks.get(network) || Networks.defaultNetwork
|
|
});
|
|
return this;
|
|
}
|
|
|
|
/**
|
|
* @callback Insight.GetUnspentUtxosCallback
|
|
* @param {Error} err
|
|
* @param {Array.UnspentOutput} utxos
|
|
*/
|
|
|
|
/**
|
|
* Retrieve a list of unspent outputs associated with an address or set of addresses
|
|
* @param {Address|string|Array.Address|Array.string} addresses
|
|
* @param {GetUnspentUtxosCallback} callback
|
|
*/
|
|
Insight.prototype.getUnspentUtxos = function(addresses, callback) {
|
|
$.checkArgument(_.isFunction(callback));
|
|
if (!_.isArray(addresses)) {
|
|
addresses = [addresses];
|
|
}
|
|
addresses = _.map(addresses, function(address) { return new Address(address); });
|
|
|
|
this.requestPost('/api/addrs/utxo', {
|
|
addrs: _.map(addresses, function(address) { return address.toString(); }).join(',')
|
|
}, function(err, res, unspent) {
|
|
if (err || res.statusCode !== 200) {
|
|
return callback(err || res);
|
|
}
|
|
unspent = _.map(unspent, UnspentOutput);
|
|
|
|
return callback(null, unspent);
|
|
});
|
|
};
|
|
|
|
/**
|
|
* @callback Insight.BroadcastCallback
|
|
* @param {Error} err
|
|
* @param {string} txid
|
|
*/
|
|
|
|
/**
|
|
* Broadcast a transaction to the bitcoin network
|
|
* @param {transaction|string} transaction
|
|
* @param {BroadcastCallback} callback
|
|
*/
|
|
Insight.prototype.broadcast = function(transaction, callback) {
|
|
$.checkArgument(JSUtil.isHexa(transaction) || transaction instanceof Transaction);
|
|
$.checkArgument(_.isFunction(callback));
|
|
if (transaction instanceof Transaction) {
|
|
transaction = transaction.serialize();
|
|
}
|
|
|
|
this.requestPost('/api/tx/send', {
|
|
rawtx: transaction
|
|
}, function(err, res, body) {
|
|
if (err || res.statusCode !== 200) {
|
|
return callback(err || body);
|
|
}
|
|
return callback(null, body ? body.txid : null);
|
|
});
|
|
};
|
|
|
|
/**
|
|
* Internal function to make a post request to the server
|
|
* @param {string} path
|
|
* @param {?} data
|
|
* @param {function} callback
|
|
* @private
|
|
*/
|
|
Insight.prototype.requestPost = function(path, data, callback) {
|
|
$.checkArgument(_.isString(path));
|
|
$.checkArgument(_.isFunction(callback));
|
|
request({
|
|
method: 'POST',
|
|
url: this.url + path,
|
|
json: data
|
|
}, callback);
|
|
};
|
|
|
|
module.exports = Insight;
|
|
|