catalog-fe/src/main/java/org/openecomp/sdc/fe/impl/PluginStatusBL.java

   1 package org.openecomp.sdc.fe.impl;
   2
   3 import java.io.IOException;
   4 import java.util.ArrayList;
   5 import java.util.List;
   6
   7 import org.apache.http.client.methods.CloseableHttpResponse;
   8 import org.apache.http.client.methods.HttpHead;
   9 import org.apache.http.impl.client.CloseableHttpClient;
  10 import org.apache.http.impl.client.HttpClients;
  11 import org.openecomp.sdc.fe.config.ConfigurationManager;
  12 import org.openecomp.sdc.fe.config.PluginsConfiguration;
  13 import org.openecomp.sdc.fe.config.PluginsConfiguration.Plugin;
  14 import org.slf4j.Logger;
  15 import org.slf4j.LoggerFactory;
  16
  17 import com.google.gson.Gson;
  18 import com.google.gson.GsonBuilder;
  19
  20 public class PluginStatusBL {
  21
  22         private static Logger log = LoggerFactory.getLogger(PluginStatusBL.class.getName());
  23         private static  Gson gson = new GsonBuilder().setPrettyPrinting().create();
  24         private CloseableHttpClient client = null;
  25
  26         public PluginStatusBL() {
  27                 this.client = HttpClients.createDefault();
  28         }
  29
  30         public PluginStatusBL(CloseableHttpClient client) {
  31                 this.client = client;
  32
  33         }
  34
  35         public String checkPluginsListAvailability() {
  36                 String result = null;
  37
  38                 PluginsConfiguration pluginsConfiguration = ConfigurationManager.getConfigurationManager()
  39                                 .getPluginsConfiguration();
  40
  41                 if (pluginsConfiguration == null || pluginsConfiguration.getPluginsList() == null) {
  42                         log.warn("Configuration of type {} was not found", PluginsConfiguration.class);
  43                 } else {
  44                         log.debug("The value returned from getConfig is {}", pluginsConfiguration);
  45
  46                         List<Plugin> availablePluginsList = new ArrayList<>();
  47
  48                         pluginsConfiguration.getPluginsList().forEach(value -> {
  49                                 if (checkPluginAvailability(value)) {
  50                                         availablePluginsList.add(value);
  51                                 }
  52
  53                         });
  54                         result = gson.toJson(availablePluginsList);
  55                 }
  56                 return result;
  57         }
  58
  59         private boolean checkPluginAvailability(Plugin plugin) {
  60                 boolean result = false;
  61
  62                 HttpHead head = new HttpHead(plugin.getPluginDiscoveryUrl());
  63
  64                 try (CloseableHttpResponse response = this.client.execute(head)) {
  65                         result = response != null && response.getStatusLine().getStatusCode() == 200;
  66                 } catch (IOException e) {
  67                         log.debug("The plugin {} is offline", plugin.getPluginId());
  68                 }
  69
  70                 return result;
  71         }
  72
  73 }