feat(hapi): created eosrate stats api endpoint (#993)

* fix(enviroment): change env value

* fix(hasura): add permissions tables

* fix(comments): fix comments section

* fix(hyperion): fix codefactor issues

* fix(hyperion): fix codefactor issues

* fix(hasura): delete migration restriction

* fix(hyperion): fix updater flows

* feat(hapi): created eosrate stats api endpoint

* fix(hapi): fix codefactor error

Author: AngeloCG97

.env.example

@@ -19,6 +19,7 @@ HAPI_POSTGRES_SCHEMA=public
 HAPI_SERVER_PORT=9090
 HAPI_SERVER_ADDRESS=0.0.0.0
 HAPI_EOS_API_ENDPOINT=https://jungle.edenia.cloud
+HAPI_VALID_USERS=[{"username": "username", "password": "password"}]
 HAPI_EOS_CHAIN_ID=aca376f206b8fc25a6ed44dbdc66547c36c6c33e3a119ffbeaef943642f0e906
 HAPI_PROXY_CONTRACT=proxyaccount
 HAPI_RATING_CONTRACT=rateproducer

.github/workflows/push-master-environment.yaml

@@ -76,6 +76,7 @@ jobs:
           # hapi
           HAPI_SERVER_ADDRESS: 0.0.0.0
           HAPI_SERVER_PORT: 9090
+          HAPI_VALID_USERS: ${{secrets.HAPI_VALID_USERS}}
           HAPI_POSTGRES_USER: ${{ secrets.HAPI_POSTGRES_USER }}
           HAPI_POSTGRES_PASSWORD: ${{ secrets.HAPI_POSTGRES_PASSWORD }}
           HAPI_HASURA_URL: ${{ secrets.HAPI_HASURA_URL }}

.github/workflows/push-staging-environment.yaml

@@ -77,6 +77,7 @@ jobs:
           # hapi
           HAPI_SERVER_ADDRESS: 0.0.0.0
           HAPI_SERVER_PORT: 9090
+          HAPI_VALID_USERS: ${{secrets.HAPI_VALID_USERS}}
           HAPI_POSTGRES_USER: ${{ secrets.HAPI_POSTGRES_USER }}
           HAPI_POSTGRES_PASSWORD: ${{ secrets.HAPI_POSTGRES_PASSWORD }}
           HAPI_HASURA_URL: ${{ secrets.HAPI_HASURA_URL }}

docker-compose.yml

@@ -38,6 +38,7 @@ services:
     environment:
       HAPI_SERVER_ADDRESS: "${HAPI_SERVER_ADDRESS}"
       HAPI_SERVER_PORT: "${HAPI_SERVER_PORT}"
+      HAPI_VALID_USERS: "${HAPI_VALID_USERS}"
       HAPI_POSTGRES_USER: "${HAPI_POSTGRES_USER}"
       HAPI_POSTGRES_PASSWORD: "${HAPI_POSTGRES_PASSWORD}"
       HAPI_POSTGRES_PORT: "${HAPI_POSTGRES_PORT}"

hapi/package.json

@@ -17,9 +17,11 @@
   "author": "EOS Costa Rica",
   "license": "MIT",
   "dependencies": {
+    "@hapi/basic": "^7.0.0",
     "@hapi/boom": "^10.0.0",
     "@hapi/hapi": "^20.1.5",
     "axios": "^0.26.1",
+    "bcrypt": "^5.1.0",
     "eosjs": "^22.1.0",
     "eosjs-api": "^7.0.4",
     "graphql": "^16.3.0",

hapi/src/index.js

@@ -1,11 +1,30 @@
 'use strict'
-const { HAPI_SERVER_PORT, HAPI_SERVER_ADDRESS } = process.env
+const { HAPI_SERVER_PORT, HAPI_SERVER_ADDRESS, HAPI_VALID_USERS } = process.env
 
 const Hapi = require('@hapi/hapi')
+const Bcrypt = require('bcrypt')
 
 const routes = require('./routes')
 const { workerService } = require('./services')
 
+const validate = async (request, username, password) => {
+  if (!HAPI_VALID_USERS) return { credentials: null, isValid: false }
+
+  const users = JSON.parse(HAPI_VALID_USERS || '[]')
+  const user = users.find(user => user.username === username)
+
+  if (!user) {
+    return { credentials: null, isValid: false }
+  }
+
+  const saltRounds = 10
+  const hashPassword = await Bcrypt.hash(user.password, saltRounds)
+  const isValid = await Bcrypt.compare(password, hashPassword)
+  const credentials = { id: users.indexOf(user), name: user.username }
+
+  return { isValid, credentials }
+}
+
 const init = async () => {
   const server = Hapi.server({
     port: HAPI_SERVER_PORT,
@@ -16,6 +35,10 @@ const init = async () => {
     debug: { request: ['handler'] }
   })
 
+  await server.register(require('@hapi/basic'))
+
+  server.auth.strategy('simple', 'basic', { validate })
+
   server.route(routes)
 
   await server.start()

hapi/src/routes/get-rates-stats.route.js

@@ -0,0 +1,39 @@
+const Boom = require('@hapi/boom')
+const Joi = require('joi')
+
+const { ratesStatsService } = require('../services')
+
+module.exports = {
+  method: 'POST',
+  path: '/get-rates-stats',
+  handler: async ({ payload: { input } }) => {
+    try {
+      if (!input) throw new Error('Invalid get-rates-stats Input')
+
+      const whereCondition = input?.ratesStatsInput?.bps
+        ? { _in: input?.ratesStatsInput?.bps }
+        : { _nin: [] }
+      const bpsStats = await ratesStatsService.getRatesStats({
+        where: { bp: whereCondition }
+      })
+
+      return { bpsStats }
+    } catch (error) {
+      console.error('get-rates-stats', error)
+
+      return Boom.badRequest(error.message)
+    }
+  },
+  options: {
+    validate: {
+      payload: Joi.object({
+        input: Joi.object({
+          ratesStatsInput: Joi.object({
+            bps: Joi.array().items(Joi.string().required()).optional()
+          }).required()
+        }).required()
+      }).options({ stripUnknown: true })
+    },
+    auth: 'simple'
+  }
+}

hapi/src/routes/index.js

@@ -1,4 +1,5 @@
 const healthzRoute = require('./healthz.route')
 const ratebpRoute = require('./ratebp.route')
+const getRatesStats = require('./get-rates-stats.route')
 
-module.exports = [healthzRoute, ratebpRoute]
+module.exports = [healthzRoute, ratebpRoute, getRatesStats]

hapi/src/routes/ratebp.route.js

@@ -52,6 +52,7 @@ module.exports = {
           }).required()
         }).required()
       }).options({ stripUnknown: true })
-    }
+    },
+    auth: false
   }
 }

hapi/src/services/get-rates-stats.service.js

@@ -0,0 +1,25 @@
+const { hasuraUtil } = require('../utils')
+
+const getRatesStats = async ({ where }) => {
+  const query = `
+    query ($where: total_ratings_stats_bool_exp!) {
+        total_ratings_stats(where: $where) {
+            average
+            bp
+            community
+            development
+            infrastructure
+            ratings_cntr
+            transparency
+            trustiness
+          }
+    }
+  `
+  const data = await hasuraUtil.instance.request(query, { where })
+
+  return data?.total_ratings_stats || [{}]
+}
+
+module.exports = {
+  getRatesStats
+}

hapi/src/services/hyperion/updaters/rateproducer-logcomment.updater.js

@@ -38,7 +38,7 @@ module.exports = {
       })
 
       const [blockProducer] = userRatings.rows.filter(
-        ({ id }) => id == ratingId
+        ({ id }) => id === ratingId
       )
 
       await save({

hapi/src/services/index.js

@@ -1,5 +1,7 @@
 const workerService = require('./worker.service')
+const ratesStatsService = require('./get-rates-stats.service')
 
 module.exports = {
-  workerService
+  workerService,
+  ratesStatsService
 }