refactor(sync): get eden scope data from cronjob query (#697)

* refactor(sync): get eden scope data from cronjob query * refactor(hapi): change default reference to general * refactor(hapi): change default reference to general Co-authored-by: Leister Alvarez Campos <[email protected]>
eoscostarica · Aug 26, 2021 · 4c0854a · 4c0854a
1 parent edd719f
commit 4c0854a
Show file tree

Hide file tree

Showing 3 changed files with 27 additions and 14 deletions.
diff --git a/hapi/src/config/index.js b/hapi/src/config/index.js
@@ -6,6 +6,6 @@ const massiveDB = (async () => await massive(massiveConfig))()
 module.exports = {
     massiveConfig,
     massiveDB,
-    defaultContractScope: process.env.HAPI_RATING_CONTRACT || 'rateproducer',
+    generalContractScope: process.env.HAPI_RATING_CONTRACT || 'rateproducer',
     edenContractScope: 'eden'
 }
diff --git a/hapi/src/libs/sync-bp-stats.js b/hapi/src/libs/sync-bp-stats.js
@@ -1,6 +1,6 @@
 const {
   massiveDB,
-  defaultContractScope,
+  generalContractScope,
   edenContractScope
 } = require('../config')
 const eosjs = require('eosjs')
@@ -33,7 +33,7 @@ const getBpStats = async (bp, scope) => {
 const updateBpStats = async (bpName) => {
   try {
     const edenResult = await getEdenBpStats(bpName)
-    await getDefaultBpStats(bpName)
+    await getGeneralBpStats(bpName)
 
     return edenResult
   } catch (err) {
@@ -57,29 +57,29 @@ const getEdenBpStats = async (bpName) => {
   }
 }
 
-const getDefaultBpStats = async (bpName) => {
+const getGeneralBpStats = async (bpName) => {
   try {
-    const bpStat = await getBpStats(bpName, defaultContractScope)
+    const bpStat = await getBpStats(bpName, generalContractScope)
 
     if (!bpStat.rows.length || !bpStat.rows[0].bp === bpName)
       return 'Did not find ratings for BP: ' + bpName
 
     const stat = bpStat.rows[0]
 
-    return await updateBpStatsDefault(bpName, stat)
+    return await updateBpStatsGeneral(bpName, stat)
   } catch (err) {
     console.error(`sync-bp-stats: ${err}`)
   }
 }
 
-const updateBpStatsDefault = async (bpName, stat) => {
+const updateBpStatsGeneral = async (bpName, stat) => {
   const db = await massiveDB
   const resultRatingsSave = await db.ratings_stats.save(stat)
   const dbResult = resultRatingsSave
     ? resultRatingsSave
     : await db.ratings_stats.insert(stat)
   console.log(
-    `Default save or insert of ${bpName} was ${
+    `General save or insert of ${bpName} was ${
       dbResult ? 'SUCCESSFULL' : 'UNSUCCESSFULL'
     }`
   )

diff --git a/hapi/src/libs/sync-stats.js b/hapi/src/libs/sync-stats.js
@@ -1,19 +1,23 @@
 #!/usr/bin/env node
 const { JsonRpc } = require('eosjs')
 const fetch = require('node-fetch')
-const { massiveDB } = require('../config')
+const {
+  generalContractScope,
+  edenContractScope,
+  massiveDB
+} = require('../config')
 
 const HAPI_EOS_API_ENDPOINT = process.env.HAPI_EOS_API_ENDPOINT || 'https://jungle.eosio.cr'
 const HAPI_RATING_CONTRACT = process.env.HAPI_RATING_CONTRACT || 'rateproducer'
 
-const getRatingsStats = async () => {
+const getRatingsStats = async (scope) => {
   const eos = new JsonRpc(HAPI_EOS_API_ENDPOINT, { fetch })
 
   try {
     const ratings = await eos.get_table_rows({
       json: true,
       code: HAPI_RATING_CONTRACT,
-      scope: HAPI_RATING_CONTRACT,
+      scope: scope,
       table: 'stats',
       limit: 1000,
       reverse: false,
@@ -29,13 +33,22 @@ const getRatingsStats = async () => {
 
 const updateRatingsStats = async () => {
   console.log('==== Updating ratings stats ====')
-  const ratingsStats = await getRatingsStats()
+  const generalRatingsStats = await getRatingsStats(generalContractScope)
+  const edenRatingsStats = await getRatingsStats(edenContractScope)
 
-  ratingsStats.rows.forEach(async (rating) => {
+  generalRatingsStats.rows.forEach(async (rating) => {
     try {
       const resultRatingStatsSave = await (await massiveDB).ratings_stats.save(rating)
       const dbResult = resultRatingStatsSave ? resultRatingStatsSave : await (await massiveDB).ratings_stats.insert(rating)
-      console.log(`Save or insert of ${rating.bp} was ${dbResult ? 'SUCCESSFULL' : 'UNSUCCESSFULL'}`)
+      console.log(`General save or insert of ${rating.bp} was ${dbResult ? 'SUCCESSFULL' : 'UNSUCCESSFULL'}`)
+    } catch (err) { console.log(`Error: ${err}`) }
+  })
+
+  edenRatingsStats.rows.forEach(async (rating) => {
+    try {
+      const resultRatingStatsSave = await (await massiveDB).eden_ratings_stats.save(rating)
+      const dbResult = resultRatingStatsSave ? resultRatingStatsSave : await (await massiveDB).eden_ratings_stats.insert(rating)
+      console.log(`Eden save or insert of ${rating.bp} was ${dbResult ? 'SUCCESSFULL' : 'UNSUCCESSFULL'}`)
     } catch (err) { console.log(`Error: ${err}`) }
   })
 }