getClaims.js

'use strict'

const Promise = require('bluebird')
const bitcoin = require('bitcoin-promise');
const rp = require('request-promise');
const request = require('request');

let client;

async function getClaims (height, gclient) {
  return new Promise(async (resolve, reject) => {
    try {
        client = gclient;
        let blockHash = await client.getBlockHash(height).then(blockHash => {return blockHash}).catch( err => reject(err));
        let block = await client.getBlock(blockHash).then(block => {return block}).catch( err => reject(err));
        let claims = await getClaimsForTxes(block.tx,height); // should return an array of claims, decoded if possible.
        resolve(claims);
    } catch (err) {
      return reject(err)
    }
  })
}
async function getClaimsForTxes(txes,height) {
  return new Promise(async (resolve, reject) => {
    try {
    let claimsArr = [];
    let i=0;
    for (let tx of txes) {
      let claims_tx = await client.getClaimsForTx(tx).then(claims => {return claims}).catch( err => reject(err));
      if(claims_tx != null){for (let claim of claims_tx) {
        claim['height'] = height;
        let d_claim = await getValue(tx,claim['nOut']);
        if(d_claim !== 'error when decoding claims' && claim['value']){
            claim['value'] = JSON.parse(d_claim);
            claimsArr.push(claim);
        }else{
          claim['value'] = { error: 'non_decodable' }
          claimsArr.push(claim);
        }
      }}
    }  
    resolve(claimsArr);
    } catch (err) {
      return reject(err)
    }
  })
}

async function getValue(tx, i){
  return new Promise(async (resolve, reject) => {
rp(`http://localhost:5000/claim_decode/${tx}/${i}`)
    .then(function (htmlString) {
        resolve(htmlString);
    })
    .catch(function (err) {
        reject(err);
    });
  })
}

module.exports = exports = getClaims