Add support for ABATED alerts within CDAP TCA

[dcaegen2/analytics/tca.git] / dcae-analytics-tca / src / main / java / org / openecomp / dcae / apod / analytics / tca / processor / TCACEFPolicyEventNameFilter.java

diff --git a/dcae-analytics-tca/src/main/java/org/openecomp/dcae/apod/analytics/tca/processor/TCACEFPolicyFunctionalRoleFilter.java b/dcae-analytics-tca/src/main/java/org/openecomp/dcae/apod/analytics/tca/processor/TCACEFPolicyEventNameFilter.java
similarity index 83%
rename from dcae-analytics-tca/src/main/java/org/openecomp/dcae/apod/analytics/tca/processor/TCACEFPolicyFunctionalRoleFilter.java
rename to dcae-analytics-tca/src/main/java/org/openecomp/dcae/apod/analytics/tca/processor/TCACEFPolicyEventNameFilter.java
index 8a97299..689b06c 100644 (file)
--- a/dcae-analytics-tca/src/main/java/org/openecomp/dcae/apod/analytics/tca/processor/TCACEFPolicyFunctionalRoleFilter.java
+++ b/dcae-analytics-tca/src/main/java/org/openecomp/dcae/apod/analytics/tca/processor/TCACEFPolicyEventNameFilter.java
@@ -26,18 +26,18 @@ import org.openecomp.dcae.apod.analytics.model.domain.policy.tca.TCAPolicy;
 
 import java.util.List;
 
-import static org.openecomp.dcae.apod.analytics.tca.utils.TCAUtils.getPolicyFunctionalRoleSupplier;
+import static org.openecomp.dcae.apod.analytics.tca.utils.TCAUtils.getPolicyEventNamesSupplier;
 
 /**
  * <p>
- *     TCA Processor that acts like a filter to filter out messages which does not belong to TCA Policy Functional Roles
+ *     TCA Processor that acts like a filter to filter out messages which does not belong to TCA Policy Event Name
  *     <br>
  *     Pre Conditions: CEF Event Listener must be present
  * </p>
  *
  * @author Rajiv Singla . Creation Date: 11/9/2016.
  */
-public class TCACEFPolicyFunctionalRoleFilter extends AbstractTCAECEFPolicyProcessor {
+public class TCACEFPolicyEventNameFilter extends AbstractTCAECEFPolicyProcessor {
 
     private static final long serialVersionUID = 1L;
 
@@ -53,36 +53,36 @@ public class TCACEFPolicyFunctionalRoleFilter extends AbstractTCAECEFPolicyProce
         // event listener is indeed present
         final EventListener eventListener = processorContext.getCEFEventListener();
 
-        String cefMessageFunctionalRole;
+        String cefMessageEventName;
 
         if (eventListener.getEvent() != null &&
                 eventListener.getEvent().getCommonEventHeader() != null &&
-                eventListener.getEvent().getCommonEventHeader().getFunctionalRole() != null) {
-            cefMessageFunctionalRole = eventListener.getEvent().getCommonEventHeader().getFunctionalRole();
+                eventListener.getEvent().getCommonEventHeader().getEventName() != null) {
+            cefMessageEventName = eventListener.getEvent().getCommonEventHeader().getEventName();
         } else {
-            String terminationMessage = "Invalid CEF Message.Common Event Header Functional Role not present.";
+            String terminationMessage = "Invalid CEF Message.Common Event Header Event Name not present.";
             setTerminatingProcessingMessage(terminationMessage, processorContext);
             return processorContext;
         }
 
         // Determine Policy Functional Roles
         final TCAPolicy tcaPolicy = processorContext.getTCAPolicy();
-        final List<String> policyFunctionalRoles = getPolicyFunctionalRoleSupplier(tcaPolicy).get();
+        final List<String> policyFunctionalRoles = getPolicyEventNamesSupplier(tcaPolicy).get();
         final String policyFunctionalRolesString = Joiner.on(",").join(policyFunctionalRoles);
 
         // If Policy functional Roles contains CEF message Functional Role then continue processing
-        if (policyFunctionalRoles.contains(cefMessageFunctionalRole)) {
+        if (policyFunctionalRoles.contains(cefMessageEventName)) {
             final String finishMessage = String.format(
                     "Policy Functional Roles and CEF Message Functional match successful." +
                             "Message Functional Role: %s, Policy Functional Roles: %s",
-                    cefMessageFunctionalRole, policyFunctionalRolesString);
+                    cefMessageEventName, policyFunctionalRolesString);
             setFinishedProcessingMessage(finishMessage, processorContext);
         } else {
             // If Policy functional Roles does not contain CEF message Functiona Role then terminate processing
             final String terminatingMessage = String.format(
                     "Policy Domain and CEF Message Domain match unsuccessful." +
                             "Message Functional Role: %s, Policy Functional Roles: %s",
-                    cefMessageFunctionalRole, policyFunctionalRolesString);
+                    cefMessageEventName, policyFunctionalRolesString);
             setTerminatingProcessingMessage(terminatingMessage, processorContext);
         }