summaryrefslogtreecommitdiffstats
path: root/lib/service-health.js
diff options
context:
space:
mode:
Diffstat (limited to 'lib/service-health.js')
-rw-r--r--lib/service-health.js120
1 files changed, 120 insertions, 0 deletions
diff --git a/lib/service-health.js b/lib/service-health.js
new file mode 100644
index 0000000..0b36b88
--- /dev/null
+++ b/lib/service-health.js
@@ -0,0 +1,120 @@
+/*
+Copyright(c) 2019 AT&T Intellectual Property. All rights reserved.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+
+You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing,
+software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
+CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and limitations under the License.
+*/
+
+/* Handle the /servicehealth API which checks if inventory and cloudify are healthy*/
+
+"use strict";
+
+const app = require('express')();
+app.set('x-powered-by', false);
+app.set('etag', false);
+
+const bodyParser = require('body-parser');
+const inv = require('./inventory');
+const log = require('./logging').getLogger();
+
+/* Pick up config and cloudify exported by main */
+const config = process.mainModule.exports.config;
+const cfy = process.mainModule.exports.cfy;
+const inventory = inv({url: config.inventory.url});
+
+app.use(bodyParser.json({strict: true})); // Parse body as JSON
+app.use(function (req, res, next) {
+ log.info(req.dcaeReqId,
+ "new req: " + req.method + " " + req.originalUrl +
+ " from: " + req.ip + " body: " + JSON.stringify(req.body)
+ );
+ next();
+});
+
+
+/* Accept an incoming service health check request */
+app.get('/', function (req, res, next) {
+
+ /* Verify inventory service health*/
+ inventory.isServiceHealthy(req)
+
+ .then(function (isInvHealthy) {
+ log.info(req.dcaeReqId,"Checking isInventoryHealthy: " + isInvHealthy);
+ if ( isInvHealthy === true) {
+ log.info(req.dcaeReqId,"Inventory is healthy: ");
+ return cfy.getCfyStatus(req)
+
+ .then(function (cfyStatusResp) {
+ log.info(req.dcaeReqId,"getCfyStatus Response -> " + JSON.stringify(cfyStatusResp, 2));
+ if (cfyStatusResp.status === 200) {
+ var isCfyHealthy = true;
+ if ( cfyStatusResp.json && cfyStatusResp.json.status === "running" ) {
+ log.info(req.dcaeReqId,"getCfyStatus Response status is running: ");
+ const services = Object.keys(cfyStatusResp.json.services);
+ log.info(req.dcaeReqId,"getCfyStatus services.length -> " + services.length);
+ // run through all the cfy services to see which ones are running
+ // don't stop looping when a cfy service is down, it's better to see a list of all serivces' status
+ // so that we an idea about overall health of cfy
+ services.forEach( service => {
+ const service_display_name = cfyStatusResp.json.services[service].display_name;
+ const instances = Object.keys(cfyStatusResp.json.services[service].instances);
+ instances.forEach( instance => {
+ var description = cfyStatusResp.json.services[service].instances[instance].Description;
+ var subState = cfyStatusResp.json.services[service].instances[instance].SubState;
+ log.info(req.dcaeReqId,"cfy status for service display_name: " + service_display_name
+ + " and Description: " + description + " has a SubState of: " + subState);
+ if ( subState !== "running" ) {
+ log.info(req.dcaeReqId,"getCfyStatus Description-> " + description + " NOT running ok");
+ isCfyHealthy = false;
+ res.status(503).json({requestId: req.dcaeReqId, status: 'NOT OK'});
+ }
+ });
+ });
+ }
+ if ( isCfyHealthy === true ) {
+ log.info(req.dcaeReqId,"Cloudify is healthy");
+ res.status(200).json({requestId: req.dcaeReqId, status: 'OK'});
+ }
+ else {
+ log.info(req.dcaeReqId,"Cloudify is not healthy");
+ res.status(503).json({requestId: req.dcaeReqId, status: 'NOT OK'});
+ }
+ } else {
+ log.info(req.dcaeReqId,"Cloudify is not healthy; responded with status " + cfyStatusResp.status);
+ res.status(503).json({requestId: req.dcaeReqId, status: 'NOT OK'});
+ }
+ })
+ }
+ else {
+ res.status(503).json({requestId: req.dcaeReqId, status: 'NOT OK'});
+ log.info(req.dcaeReqId,"Inventory is not healthy");
+ }
+ })
+
+ /* All errors show up here */
+
+ .catch(function (error) {
+ /* If we haven't already sent a response, let the error handler send response and log the error */
+ if (!res.headersSent) {
+ next(error);
+ }
+ else {
+ /* Already sent the response, so just log error */
+ error.message = "Error checking service health :" + error.message
+ + " " + (error.stack || "").replace(/\n/g, " ");
+ log.error(error, req);
+ log.audit(req, 500, error.message);
+ }
+ });
+});
+
+module.exports = app;