InfoController.java

package org.phoebus.channelfinder.rest.controller;

import co.elastic.clients.elasticsearch.ElasticsearchClient;
import co.elastic.clients.elasticsearch._types.ElasticsearchVersionInfo;
import co.elastic.clients.elasticsearch.core.InfoResponse;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.SerializationFeature;
import java.io.IOException;
import java.util.LinkedHashMap;
import java.util.Map;
import java.util.logging.Level;
import java.util.logging.Logger;
import org.phoebus.channelfinder.rest.api.IInfo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.web.bind.annotation.CrossOrigin;
import org.springframework.web.bind.annotation.RestController;

@CrossOrigin
@RestController
@EnableAutoConfiguration
public class InfoController implements IInfo {

  private static final Logger logger = Logger.getLogger(InfoController.class.getName());

  @Value("${channelfinder.version:4.7.0}")
  private String version;

  @Autowired private ElasticsearchClient elasticsearchClient;

  private static final ObjectMapper objectMapper =
      new ObjectMapper().enable(SerializationFeature.INDENT_OUTPUT);

  @Override
  public String info() {

    Map<String, Object> cfServiceInfo = new LinkedHashMap<>();
    cfServiceInfo.put("name", "ChannelFinder Service");
    cfServiceInfo.put("version", version);

    Map<String, String> elasticInfo = new LinkedHashMap<>();
    try {

      InfoResponse response = elasticsearchClient.info();

      elasticInfo.put("status", "Connected");
      elasticInfo.put("clusterName", response.clusterName());
      elasticInfo.put("clusterUuid", response.clusterUuid());
      ElasticsearchVersionInfo elasticVersion = response.version();
      elasticInfo.put("version", elasticVersion.number());
    } catch (IOException e) {
      logger.log(Level.WARNING, "Failed to create ChannelFinder service info resource.", e);
      elasticInfo.put("status", "Failed to connect to elastic " + e.getLocalizedMessage());
    }
    cfServiceInfo.put("elastic", elasticInfo);
    try {
      return objectMapper.writeValueAsString(cfServiceInfo);
    } catch (JsonProcessingException e) {
      logger.log(Level.WARNING, "Failed to create ChannelFinder service info resource.", e);
      return "Failed to gather ChannelFinder service info";
    }
  }
}