* 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.
* limitations under the License.
* ============LICENSE_END=========================================================
*/
+
package org.onap.policyengine;
import java.io.IOException;
/**
* Class contains static functions which make call to policy engine using API.
* This class is used by generalTestClient.java
- *
- *
+ *
+ *
* @version 1.0
*
*/
public class PolicyEngineTestClient {
- /**
- * This fuction make API call to policy engine to get config. And returns
- * policy name, policy version and policy configStatus
- *
- * @param org.onap.policyEngine
- * @param onapComponentName
- * @param configName
- * @param configAttributes
- * @return
- */
+ /**
+ * This function make API call to policy engine to get config. And returns
+ * policy name, policy version and policy configStatus
+ *
+ * @param policyEngine Policy Engine object
+ * @param onapComponentName String
+ * @param configName String
+ * @param configAttributes Map of String to String
+ * @return ArrayList of String
+ */
+
+ @SuppressWarnings("deprecation")
+ public static ArrayList<String> getConfig(PolicyEngine policyEngine, String onapComponentName, String configName,
+ Map<String, String> configAttributes) {
+ ArrayList<String> resultReceived = new ArrayList<>();
+ try {
+ UUID requestID = UUID.randomUUID();
+ Collection<PolicyConfig> policyConfigs;
+ if (configName == null) {
+ policyConfigs = policyEngine.getConfig(onapComponentName, requestID);
+ } else {
+ if (configAttributes == null) {
+ policyConfigs = policyEngine.getConfig(onapComponentName, configName, requestID);
+ } else {
- @SuppressWarnings("deprecation")
- public static ArrayList<String> getConfig(PolicyEngine policyEngine,
- String onapComponentName, String configName,
- Map<String, String> configAttributes) {
- ArrayList<String> resultReceived = new ArrayList<>();
- try {
- UUID requestID = UUID.randomUUID();
- Collection<PolicyConfig> policyConfigs;
- if (configName == null) {
- policyConfigs = policyEngine.getConfig(onapComponentName, requestID);
- } else {
- if (configAttributes == null) {
- policyConfigs = policyEngine.getConfig(onapComponentName,
- configName, requestID);
- } else {
-
- policyConfigs = policyEngine.getConfig(onapComponentName,
- configName, configAttributes, requestID);
- }
- }
- if (policyConfigs != null && !policyConfigs.isEmpty()) {
- for (PolicyConfig policyConfig : policyConfigs) {
- resultReceived.add("Policy Name: "
- + policyConfig.getPolicyName()
- + " Policy version: "
- + policyConfig.getPolicyVersion() + " - "
- + policyConfig.getPolicyConfigStatus());
- }
- }
- } catch (PolicyConfigException e) {
-// logger.error("Exception Occured"+e);
- resultReceived.add(""+e);
- }
- return resultReceived;
- }
+ policyConfigs = policyEngine.getConfig(onapComponentName, configName, configAttributes, requestID);
+ }
+ }
+ if (policyConfigs != null && !policyConfigs.isEmpty()) {
+ for (PolicyConfig policyConfig : policyConfigs) {
+ resultReceived.add("Policy Name: " + policyConfig.getPolicyName() + " Policy version: "
+ + policyConfig.getPolicyVersion() + " - " + policyConfig.getPolicyConfigStatus());
+ }
+ }
+ } catch (PolicyConfigException e) {
+ // logger.error("Exception Occured"+e);
+ resultReceived.add("" + e);
+ }
+ return resultReceived;
+ }
- /**
- * This functions make API call to policy engine to get decision. And
- * returns policy Decision
- *
- * @param org.onap.policyEngine
- * @param onapComponentName
- * @param decisionAttributes
- * @return
- */
- public static ArrayList<String> getDecision(PolicyEngine policyEngine,
- String onapComponentName, Map<String, String> decisionAttributes) {
- ArrayList<String> resultReceived = new ArrayList<>();
- // Decision example
- try {
- UUID requestID = UUID.randomUUID();
- @SuppressWarnings("deprecation")
- DecisionResponse policyDecision = policyEngine.getDecision(
- onapComponentName, decisionAttributes, requestID);
- resultReceived.add(policyDecision.getDecision().toString());
- } catch (PolicyDecisionException e) {
-// logger.error("Exception Occured"+e);
- resultReceived.add(""+e);
- }
- return resultReceived;
- }
+ /**
+ * This functions make API call to policy engine to get decision. And
+ * returns policy Decision
+ *
+ * @param policyEngine Policy Engine
+ * @param onapComponentName String
+ * @param decisionAttributes Map of String
+ * @return List of String
+ */
+ public static ArrayList<String> getDecision(PolicyEngine policyEngine, String onapComponentName,
+ Map<String, String> decisionAttributes) {
+ ArrayList<String> resultReceived = new ArrayList<>();
+ // Decision example
+ try {
+ UUID requestID = UUID.randomUUID();
+ @SuppressWarnings("deprecation")
+ DecisionResponse policyDecision =
+ policyEngine.getDecision(onapComponentName, decisionAttributes, requestID);
+ resultReceived.add(policyDecision.getDecision().toString());
+ } catch (PolicyDecisionException e) {
+ // logger.error("Exception Occured"+e);
+ resultReceived.add("" + e);
+ }
+ return resultReceived;
+ }
- /**
- * This function makes API call to policy engine to get action. And returns
- * responseMessage and responseStatus
- *
- * @param org.onap.policyEngine
- * @param eventAttributes
- * @return
- */
- public static ArrayList<String> getAction(PolicyEngine policyEngine,
- Map<String, String> eventAttributes) {
- ArrayList<String> resultReceived = new ArrayList<>();
- try {
- UUID requestID = UUID.randomUUID();
- @SuppressWarnings("deprecation")
- Collection<PolicyResponse> policyResponses = policyEngine
- .sendEvent(eventAttributes, requestID);
- if (policyResponses != null && !policyResponses.isEmpty()) {
- for (PolicyResponse policyResponse : policyResponses) {
- resultReceived.add(policyResponse
- .getPolicyResponseMessage()
- + " : "
- + policyResponse.getPolicyResponseStatus());
- }
- }
- } catch (PolicyEventException e) {
-// logger.error("Exception Occured"+e);
- resultReceived.add(""+e);
- }
- return resultReceived;
- }
+ /**
+ * This function makes API call to policy engine to get action. And returns
+ * responseMessage and responseStatus
+ *
+ * @param policyEngine Policy Engine object
+ * @param eventAttributes Map of String
+ * @return List of String
+ */
+ public static ArrayList<String> getAction(PolicyEngine policyEngine, Map<String, String> eventAttributes) {
+ ArrayList<String> resultReceived = new ArrayList<>();
+ try {
+ UUID requestID = UUID.randomUUID();
+ @SuppressWarnings("deprecation")
+ Collection<PolicyResponse> policyResponses = policyEngine.sendEvent(eventAttributes, requestID);
+ if (policyResponses != null && !policyResponses.isEmpty()) {
+ for (PolicyResponse policyResponse : policyResponses) {
+ resultReceived.add(policyResponse.getPolicyResponseMessage() + " : "
+ + policyResponse.getPolicyResponseStatus());
+ }
+ }
+ } catch (PolicyEventException e) {
+ // logger.error("Exception Occured"+e);
+ resultReceived.add("" + e);
+ }
+ return resultReceived;
+ }
- /**
- * This function makes API call to policy engine to get manual
- * notifications.
- *
- * @param org.onap.policyEngine
- */
+ /**
+ * This function makes API call to policy engine to get manual
+ * notifications.
+ *
+ * @param policyEngine Policy Engine object
+ */
- public static void getManualNotifications(PolicyEngine policyEngine) {
- policyEngine.setScheme(NotificationScheme.MANUAL_ALL_NOTIFICATIONS);
- System.out.println(policyEngine.getNotification().getNotificationType());
- for (LoadedPolicy updated : policyEngine.getNotification().getLoadedPolicies()) {
- System.out.println(updated.getPolicyName());
- System.out.println(updated.getVersionNo());
- System.out.println(updated.getMatches());
- }
- for (RemovedPolicy removed : policyEngine.getNotification()
- .getRemovedPolicies()) {
- System.out.println(removed.getPolicyName());
- System.out.println(removed.getVersionNo());
- }
- }
+ public static void getManualNotifications(PolicyEngine policyEngine) {
+ policyEngine.setScheme(NotificationScheme.MANUAL_ALL_NOTIFICATIONS);
+ System.out.println(policyEngine.getNotification().getNotificationType());
+ for (LoadedPolicy updated : policyEngine.getNotification().getLoadedPolicies()) {
+ System.out.println(updated.getPolicyName());
+ System.out.println(updated.getVersionNo());
+ System.out.println(updated.getMatches());
+ }
+ for (RemovedPolicy removed : policyEngine.getNotification().getRemovedPolicies()) {
+ System.out.println(removed.getPolicyName());
+ System.out.println(removed.getVersionNo());
+ }
+ }
- /**
- * This function makes API call to policy engine to get automatic
- * notifications.
- *
- * @param org.onap.policyEngine
- */
- public static void getAutoNotifications(PolicyEngine policyEngine) {
- Handler handler = new Handler();
- policyEngine.setNotification(NotificationScheme.AUTO_ALL_NOTIFICATIONS,
- handler);
- //
- System.out.println("Enter a any key to exit");
- try {
- System.in.read();
- } catch (IOException e) {
- //
- }
- }
+ /**
+ * This function makes API call to policy engine to get automatic
+ * notifications.
+ *
+ * @param policyEngine Policy Engine object
+ */
+ public static void getAutoNotifications(PolicyEngine policyEngine) {
+ Handler handler = new Handler();
+ policyEngine.setNotification(NotificationScheme.AUTO_ALL_NOTIFICATIONS, handler);
+ //
+ System.out.println("Enter a any key to exit");
+ try {
+ System.in.read();
+ } catch (IOException e) {
+ //
+ }
+ }
}
Code Review / policy / engine.git / blobdiff