ms/blueprintsprocessor/modules/inbounds/health-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/healthapi/service/CombinedHealthService.kt

   1 /*
   2  * Copyright © 2019-2020 Orange.
   3  *
   4  * Licensed under the Apache License, Version 2.0 (the "License");
   5  * you may not use this file except in compliance with the License.
   6  * You may obtain a copy of the License at
   7  *
   8  *     http://www.apache.org/licenses/LICENSE-2.0
   9  *
  10  * Unless required by applicable law or agreed to in writing, software
  11  * distributed under the License is distributed on an "AS IS" BASIS,
  12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13  * See the License for the specific language governing permissions and
  14  * limitations under the License.
  15  */
  16 package org.onap.ccsdk.cds.blueprintsprocessor.healthapi.service
  17
  18 import org.onap.ccsdk.cds.blueprintsprocessor.healthapi.configuration.HealthCheckProperties
  19 import org.onap.ccsdk.cds.blueprintsprocessor.healthapi.domain.ApplicationHealth
  20 import org.onap.ccsdk.cds.blueprintsprocessor.healthapi.domain.ServiceEndpoint
  21 import org.onap.ccsdk.cds.blueprintsprocessor.healthapi.domain.WebClientEnpointResponse
  22 import org.springframework.boot.actuate.health.Status
  23 import org.springframework.stereotype.Service
  24
  25
  26 /**
  27  *Service for combined health (BluePrintProcessor and CDSListener)
  28  *
  29  * @author Shaaban Ebrahim
  30  * @version 1.0
  31  */
  32 @Service
  33 open class CombinedHealthService(private val endPointExecution: EndPointExecution
  34                                  , private val healthCheckProperties: HealthCheckProperties) {
  35
  36     private fun setupServiceEndpoint(): List<ServiceEndpoint> {
  37         return listOf(
  38                 ServiceEndpoint("BluePrintProcessor Health Check ", healthCheckProperties.getBluePrintBaseURL() + "actuator/health")
  39                 , ServiceEndpoint("CDSListener Health Check", healthCheckProperties.getCDSListenerBaseURL() + "actuator/health")
  40         )
  41     }
  42
  43     open fun getCombinedHealthCheck(): List<ApplicationHealth?> {
  44         val listOfResponse = ArrayList<ApplicationHealth?>()
  45         for (serviceEndpoint in setupServiceEndpoint().parallelStream()) {
  46             val result: WebClientEnpointResponse? = endPointExecution?.retrieveWebClientResponse(serviceEndpoint)
  47             if (result?.response != null &&
  48                     result.response!!.status?.equals(200)!!) {
  49                 listOfResponse.add(endPointExecution?.getHealthFromWebClientEnpointResponse(result))
  50             } else {
  51                 listOfResponse.add(ApplicationHealth(Status.DOWN,
  52                         hashMapOf(serviceEndpoint.serviceLink to serviceEndpoint.serviceLink)))
  53             }
  54         }
  55         return listOfResponse
  56     }
  57
  58 }