aboutsummaryrefslogtreecommitdiffstats
path: root/PolicyEngineClient/src/test/java/org/onap/policyengine/MainClient.java
diff options
context:
space:
mode:
authorPamela Dragosh <pdragosh@research.att.com>2019-10-18 09:25:01 -0400
committerPamela Dragosh <pdragosh@research.att.com>2019-10-22 07:40:20 -0400
commit18998fee10abecb2ff1b2cdc3b99a3115d7de77c (patch)
tree0a0d24f34913cd66616a48799c87c4dc4827ed57 /PolicyEngineClient/src/test/java/org/onap/policyengine/MainClient.java
parent3c4b4fcb076e90f2d2a2582d27f316e60dba6ac3 (diff)
Format source code PolicyEngineClient
Formatting and sonar issues. Looks like this is all code used for demonstrating how to call the API's. Uses all main so actually no JUnit is being called. Unfortunately there are no associated test files for it. Would be interesting to see if adding a JUnit to call it with some test code would help to improve overall coverage. Future work. Issue-ID: POLICY-2145 Change-Id: I0d0f6d8898076a92d342553f45f70a56fd9d49f6 Signed-off-by: Pamela Dragosh <pdragosh@research.att.com>
Diffstat (limited to 'PolicyEngineClient/src/test/java/org/onap/policyengine/MainClient.java')
-rw-r--r--PolicyEngineClient/src/test/java/org/onap/policyengine/MainClient.java169
1 files changed, 91 insertions, 78 deletions
diff --git a/PolicyEngineClient/src/test/java/org/onap/policyengine/MainClient.java b/PolicyEngineClient/src/test/java/org/onap/policyengine/MainClient.java
index 210499ca1..dfd06e51e 100644
--- a/PolicyEngineClient/src/test/java/org/onap/policyengine/MainClient.java
+++ b/PolicyEngineClient/src/test/java/org/onap/policyengine/MainClient.java
@@ -2,14 +2,14 @@
* ============LICENSE_START=======================================================
* PolicyEngineClient
* ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
+ * Copyright (C) 2017, 2019 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* 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.
@@ -46,80 +46,93 @@ import org.onap.policy.common.logging.flexlogger.Logger;
import org.w3c.dom.Document;
public class MainClient {
-
- private static final Logger LOGGER = FlexLogger.getLogger(MainClient.class);
-
- public static void main(String[] args) {
- PolicyEngine policyEngine;
- try {
- policyEngine = new PolicyEngine("config.properties");
- Map<String, String> configAttributes = new HashMap<>();
- configAttributes.put("java", "java");
- configAttributes.put("peach", "Tar");
- configAttributes.put("true", "false");
- configAttributes.put("small", "testPass");
- Map<String, String> eventAttributes = new HashMap<>();
- eventAttributes.put("true", "true");
- eventAttributes.put("cpu", "91");
- Map<String, String> decisionAttributes = new HashMap<>();
- decisionAttributes.put("Key", "Value");
-
- // Config Example
- try {
- @SuppressWarnings("deprecation")
- Collection<PolicyConfig> policyConfigs = policyEngine.getConfigByPolicyName(".*");//(onapComponentName, configName, configAttributes);
- if(policyConfigs!=null && !policyConfigs.isEmpty()){
- for(PolicyConfig policyConfig: policyConfigs){
- System.out.println("\nConfig Message: "+ policyConfig.getPolicyConfigMessage());
- System.out.println("Config Status: " + policyConfig.getPolicyConfigStatus());
- System.out.println("Policy Name: "+ policyConfig.getPolicyName());
- System.out.println("policy Version: " + policyConfig.getPolicyVersion());
- }
- }
- } catch (PolicyConfigException e) {
- LOGGER.error("Exception Occured"+e);
- }
-
- // Manual Notifications..
- policyEngine.setScheme(NotificationScheme.MANUAL_ALL_NOTIFICATIONS);
- if(policyEngine.getNotification()!=null){
- 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());
- }
- }
- // Auto Notifications..
- 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) {
- System.err.println("Exception Occured"+e);
- }
-
- } catch (PolicyEngineException e1) {
- System.err.println("Exception Occured"+e1);
- }
- }
-
- public static void printDocument(Document doc, OutputStream out) throws IOException, TransformerException {
- TransformerFactory tf = TransformerFactory.newInstance();
- Transformer transformer = tf.newTransformer();
- transformer.setOutputProperty(OutputKeys.OMIT_XML_DECLARATION, "no");
- transformer.setOutputProperty(OutputKeys.METHOD, "xml");
- transformer.setOutputProperty(OutputKeys.INDENT, "yes");
- transformer.setOutputProperty(OutputKeys.ENCODING, "UTF-8");
- transformer.setOutputProperty("{http://xml.apache.org/xslt}indent-amount", "4");
- transformer.transform(new DOMSource(doc),
- new StreamResult(new OutputStreamWriter(out, "UTF-8")));
- }
+ private static final Logger LOGGER = FlexLogger.getLogger(MainClient.class);
+
+ /**
+ * main.
+ *
+ * @param args String[] args
+ */
+ public static void main(String[] args) {
+ PolicyEngine policyEngine;
+ try {
+ policyEngine = new PolicyEngine("config.properties");
+ Map<String, String> configAttributes = new HashMap<>();
+ configAttributes.put("java", "java");
+ configAttributes.put("peach", "Tar");
+ configAttributes.put("true", "false");
+ configAttributes.put("small", "testPass");
+ Map<String, String> eventAttributes = new HashMap<>();
+ eventAttributes.put("true", "true");
+ eventAttributes.put("cpu", "91");
+ Map<String, String> decisionAttributes = new HashMap<>();
+ decisionAttributes.put("Key", "Value");
+
+ // Config Example
+ try {
+ @SuppressWarnings("deprecation")
+ Collection<PolicyConfig> policyConfigs = policyEngine.getConfigByPolicyName(".*");
+ if (policyConfigs != null && !policyConfigs.isEmpty()) {
+ for (PolicyConfig policyConfig : policyConfigs) {
+ System.out.println("\nConfig Message: " + policyConfig.getPolicyConfigMessage());
+ System.out.println("Config Status: " + policyConfig.getPolicyConfigStatus());
+ System.out.println("Policy Name: " + policyConfig.getPolicyName());
+ System.out.println("policy Version: " + policyConfig.getPolicyVersion());
+ }
+ }
+ } catch (PolicyConfigException e) {
+ LOGGER.error("Exception Occured" + e);
+ }
+
+ // Manual Notifications..
+ policyEngine.setScheme(NotificationScheme.MANUAL_ALL_NOTIFICATIONS);
+ if (policyEngine.getNotification() != null) {
+ 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());
+ }
+ }
+ // Auto Notifications..
+ 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) {
+ System.err.println("Exception Occured" + e);
+ }
+
+ } catch (PolicyEngineException e1) {
+ System.err.println("Exception Occured" + e1);
+ }
+ }
+
+ /**
+ * printDocument.
+ *
+ * @param doc Document
+ * @param out OutputStream
+ * @throws IOException IOException
+ * @throws TransformerException TransformerException
+ */
+ public static void printDocument(Document doc, OutputStream out)
+ throws IOException, TransformerException {
+ TransformerFactory tf = TransformerFactory.newInstance();
+ Transformer transformer = tf.newTransformer();
+ transformer.setOutputProperty(OutputKeys.OMIT_XML_DECLARATION, "no");
+ transformer.setOutputProperty(OutputKeys.METHOD, "xml");
+ transformer.setOutputProperty(OutputKeys.INDENT, "yes");
+ transformer.setOutputProperty(OutputKeys.ENCODING, "UTF-8");
+ transformer.setOutputProperty("{http://xml.apache.org/xslt}indent-amount", "4");
+
+ transformer.transform(new DOMSource(doc), new StreamResult(new OutputStreamWriter(out, "UTF-8")));
+ }
}