insightapi.js

var request = require('request');
var config = require(__dirname + '/config');
var insightUrl = config.insight.protocol + '://' + config.insight.host + ':' + config.insight.port;

var getLastBlockHash = function(cb) {
  var requestUrl = insightUrl + '/api/status?q=getLastBlockHash';
  request(requestUrl, function(error, response, body) {
    if (error) {
      return cb(error, null);
    }
    body = JSON.parse(body);
    if (!body.lastblockhash) {
      var err = new Error('Error retrieving last block from insight.');
      return cb(err, null);
    }
    var lastBlockHash = {
      hash: body.lastblockhash,
      type: 'blockhash'
    };
    return cb(null, lastBlockHash);
  });
};

var getBlock = function(blockHash, cb){
  if (!blockHash) {
    var err = new Error('No blockhash provided.');
    return cb(err, null);
  }
  var requestUrl = insightUrl + '/api/block/' + blockHash;
  request(requestUrl, function(error, response, body) {
    if (error) {
      return cb(error, null);
    }
    try {
      var block = JSON.parse(body);
      return cb(null, block);
    }
    catch (err) {
      console.log(err);
      return cb(err, null);
    }
  });
};

module.exports = {
  getLastBlockHash: getLastBlockHash,
  getBlock: getBlock
};