Expose resource usage

.gitignore

@@ -65,3 +65,8 @@ typings/
 ecosystem.config.js
 package-lock.json
 connections.json
+api_access.log
+api_error.log
+explorer
+api/explorer
+.ecosystem.config.js.swp

api/handlers/health.js

@@ -8,10 +8,23 @@ const system_domain = process.env.SYSTEM_DOMAIN;
 const ecosystem = require('../../ecosystem.config');
 
 function checkFeat(name) {
-    return currentENV[name] === 'true';
+    if (currentENV) {
+        return currentENV[name] === 'true';
+    } else {
+        return null;
+    }
 }
 
-const currentENV = ecosystem.apps.find(app => app.env.CHAIN === process.env.CHAIN)['env'];
+let currentENV;
+if (ecosystem.apps.length > 1) {
+    const indexerApp = ecosystem.apps.find(app => {
+        return app.env.CHAIN === process.env.CHAIN && app.script === "./launcher.js";
+    });
+
+    if (indexerApp) {
+        currentENV = indexerApp['env'];
+    }
+}
 
 // get current github version
 let last_commit_hash;
@@ -108,49 +121,58 @@ async function checkElastic(elastic) {
 }
 
 module.exports = function (fastify, opts, next) {
-    fastify.get('/health', {}, async (request, reply) => {
-        const t0 = Date.now();
-        const {redis, elastic} = fastify;
+    fastify.route({
+        url: '/health',
+        method: 'GET',
+        schema: {
+            tags: ['status'],
+            summary: "API Service Health Report"
+        },
+        handler: async (request, reply) => {
+            const t0 = Date.now();
+            const {redis, elastic} = fastify;
 
-        let cachedResponse, hash;
-        [cachedResponse, hash] = await getCacheByHash(redis, 'health');
-        if (cachedResponse) {
-            cachedResponse = JSON.parse(cachedResponse);
-            cachedResponse['query_time'] = Date.now() - t0;
-            cachedResponse['cached'] = true;
-            reply.send(cachedResponse);
-            return;
-        }
+            let cachedResponse, hash;
+            [cachedResponse, hash] = await getCacheByHash(redis, 'health');
+            if (cachedResponse) {
+                cachedResponse = JSON.parse(cachedResponse);
+                cachedResponse['query_time'] = Date.now() - t0;
+                cachedResponse['cached'] = true;
+                reply.send(cachedResponse);
+                return;
+            }
 
-        let response = {
-            version_hash: last_commit_hash,
-            features: {
-                indices: {
-                    all_deltas: checkFeat('INDEX_ALL_DELTAS'),
-                    transfer_memo: checkFeat('INDEX_TRANSFER_MEMO'),
-                },
-                tables: {
-                    proposals: checkFeat('PROPOSAL_STATE'),
-                    accounts: checkFeat('ACCOUNT_STATE'),
-                    voters: checkFeat('VOTERS_STATE')
+            let response = {
+                version_hash: last_commit_hash,
+                host: process.env.SERVER_NAME,
+                features: {
+                    indices: {
+                        all_deltas: checkFeat('INDEX_ALL_DELTAS'),
+                        transfer_memo: checkFeat('INDEX_TRANSFER_MEMO'),
+                    },
+                    tables: {
+                        proposals: checkFeat('PROPOSAL_STATE'),
+                        accounts: checkFeat('ACCOUNT_STATE'),
+                        voters: checkFeat('VOTERS_STATE')
+                    },
+                    stream: {
+                        traces: checkFeat('STREAM_TRACES'),
+                        deltas: checkFeat('STREAM_DELTAS')
+                    }
                 },
-                stream: {
-                    traces: checkFeat('STREAM_TRACES'),
-                    deltas: checkFeat('STREAM_DELTAS')
-                }
-            },
-            health: []
-        };
+                health: []
+            };
 
-        response.health.push(await checkRabbit());
-        response.health.push(await checkNodeos());
-        response.health.push(await checkRedis(redis));
-        response.health.push(await checkElastic(elastic));
-        response['query_time'] = Date.now() - t0;
+            response.health.push(await checkRabbit());
+            response.health.push(await checkNodeos());
+            response.health.push(await checkRedis(redis));
+            response.health.push(await checkElastic(elastic));
+            response['query_time'] = Date.now() - t0;
 
-        // prevent abuse of the health endpoint
-        redis.set(hash, JSON.stringify(response), 'EX', 10);
-        reply.send(response);
+            // prevent abuse of the health endpoint
+            redis.set(hash, JSON.stringify(response), 'EX', 10);
+            reply.send(response);
+        }
     });
     next();
 };