feat(hapi): use an array of endpoints to query producers

edenia · Oct 31, 2022 · f53977c · f53977c
1 parent fbae50e
commit f53977c
Show file tree

Hide file tree

Showing 3 changed files with 33 additions and 9 deletions.
diff --git a/docker-compose.yaml b/docker-compose.yaml
@@ -32,6 +32,7 @@ services:
     environment:
       HAPI_EOS_API_NETWORK_NAME: '${HAPI_EOS_API_NETWORK_NAME}'
       HAPI_EOS_API_ENDPOINT: '${HAPI_EOS_API_ENDPOINT}'
+      HAPI_EOS_API_ENDPOINTS: '${HAPI_EOS_API_ENDPOINTS}'
       HAPI_EOS_STATE_HISTORY_PLUGIN_ENDPOINT: '${HAPI_EOS_STATE_HISTORY_PLUGIN_ENDPOINT}'
       HAPI_EOS_API_CHAIN_ID: '${HAPI_EOS_API_CHAIN_ID}'
       HAPI_EOS_BASE_ACCOUNT: '${HAPI_EOS_BASE_ACCOUNT}'

diff --git a/hapi/src/config/eos.config.js b/hapi/src/config/eos.config.js
@@ -1,6 +1,9 @@
 module.exports = {
   networkName: process.env.HAPI_EOS_API_NETWORK_NAME,
   apiEndpoint: process.env.HAPI_EOS_API_ENDPOINT,
+  apiEndpoints: process.env.HAPI_EOS_API_ENDPOINTS
+  ? JSON.parse(process.env.HAPI_EOS_API_ENDPOINTS)
+  : [],
   stateHistoryPluginEndpoint:
     process.env.HAPI_EOS_STATE_HISTORY_PLUGIN_ENDPOINT,
   chainId: process.env.HAPI_EOS_API_CHAIN_ID,

diff --git a/hapi/src/utils/eos.util.js b/hapi/src/utils/eos.util.js
@@ -16,8 +16,26 @@ const eosApi = EosApi({
   verbose: false,
   fetchConfiguration: {}
 })
+const eosApis = eosConfig.apiEndpoints.map((endpoint) => {
+  return EosApi({
+    httpEndpoint: endpoint,
+    verbose: false,
+    fetchConfiguration: {}
+  })
+})
+
+const callEosApi = async (method) => {
+  for (let i = 0; i < eosApis.length; i++) {
+    try {
+      const response = await method(eosApis[i])
 
-const newAccount = async accountName => {
+      return response
+    } catch (error) {
+      console.log(error)
+    }
+  }
+}
+const newAccount = async (accountName) => {
   const password = await walletUtil.create(accountName)
   const key = await walletUtil.createKey(accountName)
 
@@ -140,9 +158,9 @@ const generateRandomAccountName = async (prefix = '') => {
   }
 }
 
-const getAbi = account => eosApi.getAbi(account)
+const getAbi = (account) => eosApi.getAbi(account)
 
-const getAccount = async account => {
+const getAccount = async (account) => {
   try {
     const accountInfo = await eosApi.getAccount(account)
 
@@ -152,18 +170,19 @@ const getAccount = async account => {
   }
 }
 
-const getBlock = async blockNumber => {
+const getBlock = async (blockNumber) => {
   const block = await eosApi.getBlock(blockNumber)
 
   return block
 }
 
-const getCodeHash = account => eosApi.getCodeHash(account)
+const getCodeHash = (account) => eosApi.getCodeHash(account)
 
 const getCurrencyBalance = (code, account, symbol) =>
   eosApi.getCurrencyBalance(code, account, symbol)
 
-const getTableRows = options => eosApi.getTableRows({ json: true, ...options })
+const getTableRows = (options) =>
+  eosApi.getTableRows({ json: true, ...options })
 
 const getProducerSchedule = () => eosApi.getProducerSchedule({})
 
@@ -196,11 +215,12 @@ const transact = async (actions, account, password) => {
   return transaction
 }
 
-const getCurrencyStats = options => eosApi.getCurrencyStats(options)
+const getCurrencyStats = (options) => eosApi.getCurrencyStats(options)
 
-const getProducers = options => eosApi.getProducers(options)
+const getProducers = async (options) =>
+  callEosApi(async (eosApi) => eosApi.getProducers(options))
 
-const getInfo = options => eosApi.getInfo(options || {})
+const getInfo = (options) => eosApi.getInfo(options || {})
 
 module.exports = {
   newAccount,