1 files changed, 142 insertions, 0 deletions
diff --git a/src/main/java/org/onap/aai/sparky/search/filters/FilterProcessor.java b/src/main/java/org/onap/aai/sparky/search/filters/FilterProcessor.java
new file mode 100644
index 0000000..100257b
--- /dev/null
+++ b/src/main/java/org/onap/aai/sparky/search/filters/FilterProcessor.java
@@ -0,0 +1,142 @@
+/**
+ * ============LICENSE_START=======================================================
+ * org.onap.aai
+ * ================================================================================
+ * Copyright © 2017 AT&T Intellectual Property. All rights reserved.
+ * Copyright © 2017 Amdocs
+ * ================================================================================
+ * 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.
+ * ============LICENSE_END=========================================================
+ *
+ * ECOMP is a trademark and service mark of AT&T Intellectual Property.
+ */
+package org.onap.aai.sparky.search.filters;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import javax.json.JsonObject;
+
+import org.apache.camel.Exchange;
+import org.apache.camel.component.restlet.RestletConstants;
+import org.onap.aai.cl.api.Logger;
+import org.onap.aai.cl.eelf.LoggerFactory;
+import org.onap.aai.sparky.logging.AaiUiMsgs;
+import org.onap.aai.sparky.search.filters.FilteredSearchHelper;
+import org.onap.aai.sparky.search.filters.entity.UiFilterEntity;
+import org.onap.aai.sparky.search.filters.entity.UiFiltersEntity;
+import org.onap.aai.sparky.viewandinspect.config.TierSupportUiConstants;
+import org.restlet.Request;
+import org.restlet.Response;
+import org.restlet.data.MediaType;
+import org.restlet.data.Status;
+
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
+
+public class FilterProcessor {
+  
+  private static final Logger LOG = LoggerFactory.getInstance().getLogger(FilterProcessor.class);
+  
+  private ObjectMapper mapper;
+  private FilteredSearchHelper filteredSearchHelper;
+  
+  public FilterProcessor() {
+    this.mapper = new ObjectMapper();
+  }
+  
+  public FilterProcessor(FilteredSearchHelper filteredSearchHelper) {
+    this.mapper = new ObjectMapper();
+    this.filteredSearchHelper = filteredSearchHelper;
+  }
+  
+  public ObjectMapper getMapper() {
+    return mapper;
+  }
+
+  public FilteredSearchHelper getFilteredSearchHelper() {
+    return filteredSearchHelper;
+  }
+  
+  public void setFilteredSearchHelper(FilteredSearchHelper filteredSearchHelper) {
+    this.filteredSearchHelper = filteredSearchHelper;
+  }
+
+  public void getFiltersWithValues(Exchange exchange) {
+    Response response = exchange.getIn().getHeader(RestletConstants.RESTLET_RESPONSE, Response.class);
+
+    Request request = exchange.getIn().getHeader(RestletConstants.RESTLET_REQUEST, Request.class);
+
+    /* Disables automatic Apache Camel Restlet component logging which prints out an undesirable log entry
+       which includes client (e.g. browser) information */
+    request.setLoggable(false);
+    
+    UiFiltersEntity viewFiltersList = null;
+    boolean wasErrorDuringFilterDiscovery = false;
+    
+    try {
+      String payload = exchange.getIn().getBody(String.class);
+
+      if (payload == null || payload.isEmpty()) {
+        /* Don't throw back an error, just return an empty set */
+        LOG.error(AaiUiMsgs.SEARCH_SERVLET_ERROR, "Request Payload is empty");
+        wasErrorDuringFilterDiscovery = true;
+      } else {
+        String viewName = mapper.readValue(payload, JsonNode.class).get(TierSupportUiConstants.UI_FILTER_VIEW_NAME_PARAMETER).asText();
+
+        if (viewName == null || viewName.isEmpty()) {
+          wasErrorDuringFilterDiscovery = true;
+        } else {
+          viewFiltersList = filteredSearchHelper.doFilterDiscovery(viewName);
+        }
+      }
+    } catch(Exception exc) {
+      LOG.error(AaiUiMsgs.ERROR_GENERIC, "FilterProcessor failed to get filter list due to error = " + exc.getMessage());
+      wasErrorDuringFilterDiscovery = true;
+    }
+    
+    boolean wasErrorDuringValueSearch = false;
+    if(!wasErrorDuringFilterDiscovery) {
+      try {
+        if(!viewFiltersList.getFilters().isEmpty()) {
+          List<String> filterIds = new ArrayList<String>();
+          
+          for(UiFilterEntity filterEntity : viewFiltersList.getFilters()) {
+            filterIds.add(filterEntity.getFilterId());
+          }
+          
+          UiFiltersEntity responseFiltersList = filteredSearchHelper.doFilterEnumeration(filterIds);
+          
+          JsonObject finalResponse = UiFiltersEntityConverter.convertUiFiltersEntityToUnifiedFilterResponse(responseFiltersList);
+          
+          response.setStatus(Status.SUCCESS_OK);
+          response.setEntity(finalResponse.toString(), MediaType.APPLICATION_JSON);
+          exchange.getOut().setBody(response);
+        } else {
+          wasErrorDuringValueSearch = true;
+        }
+      } catch(Exception exc) {
+        LOG.error(AaiUiMsgs.ERROR_GENERIC, "FilterProcessor failed to generate valid unifiedFilterRequest response due to error, " + exc.getMessage());
+        response.setStatus(Status.SERVER_ERROR_INTERNAL);
+      }
+    } 
+    
+    // In the case of an error we want to respond with a valid empty response
+    if(wasErrorDuringFilterDiscovery || wasErrorDuringValueSearch) {
+      response.setStatus(Status.SUCCESS_OK);
+      response.setEntity(UiFiltersEntityConverter.generateEmptyResponse().toString(), MediaType.APPLICATION_JSON);
+      exchange.getOut().setBody(response);
+    }
+  }
+  
+}