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  *Service for combined health (BlueprintProcessor and CDSListener)
  27  *
  28  * @author Shaaban Ebrahim
  29  * @version 1.0
  30  */
  31 @Service
  32 open class CombinedHealthService(
  33     private val endPointExecution: EndPointExecution,
  34     private val healthCheckProperties: HealthCheckProperties
  35 ) {
  36
  37     private fun setupServiceEndpoint(): List<ServiceEndpoint> {
  38         return listOf(
  39             ServiceEndpoint("BlueprintProcessor Health Check ", healthCheckProperties.getBlueprintBaseURL() + "actuator/health"),
  40             ServiceEndpoint("CDSListener Health Check", healthCheckProperties.getCDSListenerBaseURL() + "actuator/health")
  41         )
  42     }
  43
  44     open fun getCombinedHealthCheck(): List<ApplicationHealth?> {
  45         val listOfResponse = ArrayList<ApplicationHealth?>()
  46         for (serviceEndpoint in setupServiceEndpoint().parallelStream()) {
  47             val result: WebClientEnpointResponse? = endPointExecution?.retrieveWebClientResponse(serviceEndpoint)
  48             if (result?.response != null &&
  49                 result.response!!.status?.equals(200)!!
  50             ) {
  51                 listOfResponse.add(endPointExecution?.getHealthFromWebClientEnpointResponse(result))
  52             } else {
  53                 listOfResponse.add(
  54                     ApplicationHealth(
  55                         Status.DOWN,
  56                         hashMapOf(serviceEndpoint.serviceLink to serviceEndpoint.serviceLink)
  57                     )
  58                 )
  59             }
  60         }
  61         return listOfResponse
  62     }
  63 }