getblockproducer.js

  
const EosApi = require('eosjs-api')
const get = require('lodash.get')
const fetch = require('node-fetch')

// gets data from mainnet
const getBlockProducersData = async () => {
  const eos = EosApi({
    httpEndpoint: process.env.EOS_API_ENDPOINT,
    verbose: false
  })
  const { rows: producers } = await eos.getProducers({ json: true, limit: 1000 })
  const { rows: bpJsons } = await eos.getTableRows({
    json: true,
    code: 'producerjson',
    scope: 'producerjson',
    table: 'producerjson',
    limit: 1000
  })

  const allProducers = producers.reduce(
    (result, producer) => [
      ...result,
      {
        owner: producer.owner,
        system: { ...producer },
        bpJson: get(bpJsons.find(bpJson => bpJson.owner === producer.owner), 'json', {})
      }
    ],
    []
  )

  const requests = allProducers
    .filter(({ bpJson, system }) => !Object.keys(bpJson) && system.url)
    .map(({ system: { url } }) => {
      let result = url
      if (!url.startsWith('http')) {
        result = `http://${url}`
      }
      if (!url.endsWith('.json')) {
        result = `${result}/bp.json`
      }
      return result
    })
    .map(url =>
      fetch(url)
        .then(res => res.json())
        .catch(e => {
          console.error(e)
        })
    )

  const allJsons = await Promise.all(requests)
  const result = allProducers.map(producer => ({
    ...producer,
    bpJson: Object.keys(producer.bpJson).length
      ? producer.bpJson
      : allJsons.find(bpJson => bpJson && bpJson.producer_account_name === producer.owner) || {}
  }))

  return result
}