--- /dev/null
+/*-
+ * ============LICENSE_START=======================================================
+ * PolicyEngineClient
+ * ================================================================================
+ * Copyright (C) 2017 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.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+/*
+ * AT&T - PROPRIETARY
+ * THIS FILE CONTAINS PROPRIETARY INFORMATION OF
+ * AT&T AND IS NOT TO BE DISCLOSED OR USED EXCEPT IN
+ * ACCORDANCE WITH APPLICABLE AGREEMENTS.
+ *
+ * Copyright (c) 2014 AT&T Knowledge Ventures
+ * Unpublished and Not for Publication
+ * All Rights Reserved
+ */
+package org.onap.policyEngine;
+
+import java.io.FileNotFoundException;
+import java.io.FileReader;
+import java.io.IOException;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.nio.file.Paths;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.Map;
+
+import org.json.simple.JSONArray;
+import org.json.simple.JSONObject;
+import org.json.simple.parser.JSONParser;
+import org.onap.policy.api.PolicyEngine;
+import org.onap.policy.api.PolicyEngineException;
+import org.onap.policy.common.logging.flexlogger.FlexLogger;
+import org.onap.policy.common.logging.flexlogger.Logger;
+
+/**
+ * Class reads from .testCases file and run the test cases available in the file
+ * and generates output for each test cases specifing whether is passed or fail
+ * and reason why it fails.
+ *
+ *
+ * @version 1.0
+ *
+ */
+public class GeneralTestClient {
+
+ private static final Logger LOGGER = FlexLogger.getLogger(GeneralTestClient.class);
+
+ static int totalTC = 0, passTC = 0, failTC = 0;
+
+ public static void main(String[] args) {
+ Path file;
+ /* command line arguments */
+ if (args.length != 0) {
+ for (int index = 0; index < args.length; index++) {
+ // System.out.println(args[index]);
+ file = Paths.get(args[index]);
+ runTestClientOnConfigFile(file);
+ }
+ } else {
+ /* default file */
+ file = Paths.get("input.testCases");
+ runTestClientOnConfigFile(file);
+ }
+ System.out
+ .println("###############################################################################################");
+ System.out.println("\n\t SUMMARY: TOTAL: " + totalTC + ",\tPASS: "
+ + passTC + ",\tFAIL: " + failTC + "\n");
+ System.out
+ .println("###############################################################################################");
+
+ System.out.println("Enter a any key to exit");
+ try {
+ System.in.read();
+ } catch (IOException e) {
+ //
+ }
+
+ }
+
+ /**
+ * This function reads the files passed as arguments and runs the test cases
+ * in the file
+ *
+ * @param file
+ */
+ private static void runTestClientOnConfigFile(Path file) {
+ String resultReturned, onapComponentName;
+ int totalTCforFile = 0, passTCforFile = 0, failTCforFile = 0;
+ System.out
+ .println("\n###############################################################################################");
+ System.out.println("\tRuning test Client on Config file: " + file);
+ System.out
+ .println("###############################################################################################\n");
+
+ if (Files.notExists(file)) {
+ System.out.println("file doesnot exist");
+ // throw new
+ // PolicyEngineException("File doesn't exist in the specified Path "
+ // + file.toString());
+ } else if (file.toString().endsWith(".testCases")) {
+ try {
+ // read the json file
+ FileReader reader = new FileReader(file.toString());
+
+ JSONParser jsonParser = new JSONParser();
+ JSONArray jsonObjectArray = (JSONArray) jsonParser
+ .parse(reader);
+ for (Object jsonObject : jsonObjectArray) {
+ totalTC++;
+ totalTCforFile++;
+ ArrayList<String> expectedResult = new ArrayList<>();
+ ArrayList<String> resultReceived = new ArrayList<>();
+ JSONObject testCase = (JSONObject) jsonObject;
+ // get a String from the JSON object
+ long id = (long) testCase.get("id");
+ String testFor = (String) testCase.get("testFor");
+ String testCaseDescription = (String) testCase
+ .get("testCaseDescription");
+ JSONArray expectedResultJson = (JSONArray) testCase
+ .get("expectedResult");
+ @SuppressWarnings("rawtypes")
+ Iterator i = expectedResultJson.iterator();
+ while (i.hasNext()) {
+ expectedResult.add((String) i.next());
+ }
+ String pdp_urlConfigFile = (String) testCase
+ .get("PDP_URLConfigFile");
+ // System.out.println(pdp_urlConfigFile);
+ PolicyEngine policyEngine;
+ try {
+ policyEngine = new PolicyEngine(pdp_urlConfigFile);
+
+ switch (testFor) {
+
+ case "getConfig":
+ onapComponentName = (String) testCase
+ .get("ONAPName");
+ String configName = (String) testCase
+ .get("ConfigName");
+ Map<String, String> configAttributes = new HashMap<>();
+ configAttributes.put("key", "value");
+ JSONArray configAttributesJSON = (JSONArray) testCase
+ .get("configAttributes");
+ if(configAttributesJSON!=null){
+ i = configAttributesJSON.iterator();
+ while (i.hasNext()) {
+ JSONObject innerObj = (JSONObject) i.next();
+ configAttributes.put(
+ (String) innerObj.get("key"),
+ (String) innerObj.get("value"));
+
+ }
+ }else{
+ configAttributes = null;
+ }
+ resultReceived = PolicyEngineTestClient.getConfig(
+ policyEngine, onapComponentName,
+ configName, configAttributes);
+ Collections.sort(expectedResult);
+ Collections.sort(resultReceived);
+ resultReturned = compareResults(expectedResult,resultReceived);
+ if (resultReturned.equals("PASSED")) {
+ printResult(id, testFor, testCaseDescription,
+ "PASSED");
+ passTCforFile++;
+ passTC++;
+ } else {
+ printResult(id, testFor, testCaseDescription,
+ "FAILED", resultReturned);
+ failTCforFile++;
+ failTC++;
+ }
+ break;
+
+ case "getAction":
+ Map<String, String> eventAttributes = new HashMap<>();
+ eventAttributes.put("Key", "Value");
+ JSONArray eventAttributesJSON = (JSONArray) testCase
+ .get("eventAttributes");
+ if(eventAttributesJSON != null){
+ i = eventAttributesJSON.iterator();
+ while (i.hasNext()) {
+ JSONObject innerObj = (JSONObject) i.next();
+ eventAttributes.put(
+ (String) innerObj.get("key"),
+ (String) innerObj.get("value"));
+ }
+ }else{
+ eventAttributes=null;
+ }
+ resultReceived = PolicyEngineTestClient.getAction(
+ policyEngine, eventAttributes);
+ Collections.sort(expectedResult);
+ Collections.sort(resultReceived);
+ resultReturned = compareResults(expectedResult,
+ resultReceived);
+ if (resultReturned.equals("PASSED")) {
+ printResult(id, testFor, testCaseDescription,
+ "PASSED");
+ passTCforFile++;
+ passTC++;
+ } else {
+ printResult(id, testFor, testCaseDescription,
+ "FAILED", resultReturned);
+ failTCforFile++;
+ failTC++;
+ }
+ break;
+
+ case "getDecision":
+ onapComponentName = (String) testCase
+ .get("ONAPName");
+ Map<String, String> decisionAttributes = new HashMap<>();
+ decisionAttributes.put("Key", "Value");
+ JSONArray decisionAttributesJSON = (JSONArray) testCase
+ .get("decisionAttributes");
+ i = decisionAttributesJSON.iterator();
+ while (i.hasNext()) {
+ JSONObject innerObj = (JSONObject) i.next();
+ decisionAttributes.put(
+ (String) innerObj.get("key"),
+ (String) innerObj.get("value"));
+
+ }
+
+ resultReceived = PolicyEngineTestClient
+ .getDecision(policyEngine,
+ onapComponentName,
+ decisionAttributes);
+ Collections.sort(expectedResult);
+ Collections.sort(resultReceived);
+ resultReturned = compareResults(expectedResult,
+ resultReceived);
+ if (resultReturned.equals("PASSED")) {
+ printResult(id, testFor, testCaseDescription,
+ "PASSED");
+ passTCforFile++;
+ passTC++;
+ } else {
+ printResult(id, testFor, testCaseDescription,
+ "FAILED", resultReturned);
+ failTCforFile++;
+ failTC++;
+ }
+ break;
+
+ // case "getManualNotification":
+ // PolicyEngineTestClient
+ // .getManualNotifications(org.onap.policyEngine);
+ // break;
+ // case "getAutoNotification":
+ // PolicyEngineTestClient
+ // .getAutoNotifications(org.onap.policyEngine);
+ // break;
+
+ default:
+ printResult(id, testFor, testCaseDescription,
+ "FAILED", "\tINVAILD TEST CASE.");
+ failTCforFile++;
+ failTC++;
+ break;
+
+ }
+ } catch (PolicyEngineException e) {
+ printResult(id, testFor, testCaseDescription, "FAILED");
+ failTCforFile++;
+ failTC++;
+ LOGGER.error("Exception Occured"+e);
+ } catch (Exception e) {
+ printResult(id, testFor, testCaseDescription, "FAILED");
+ failTCforFile++;
+ failTC++;
+ LOGGER.error("Exception Occured"+e);
+ }
+ }
+
+ } catch (FileNotFoundException ex) {
+ LOGGER.error("Exception Occured due to File not found"+ex);
+ } catch (IOException ex) {
+ LOGGER.error("Exception Occured"+ex);
+ } catch (NullPointerException ex) {
+ LOGGER.error("Exception Occured due to Null Pointer"+ex);
+ } catch (org.json.simple.parser.ParseException e) {
+ LOGGER.error("Exception Occured while Parsing"+e);
+ }
+ }
+ System.out.println("\n\n\t Summary for the file: TOTAL: "
+ + totalTCforFile + ",\tPASS: " + passTCforFile + ",\tFAIL: "
+ + failTCforFile + "\n");
+ }
+
+ /**
+ * This function prints the reason if test fails.
+ *
+ * @param id
+ * @param testFor
+ * @param testCaseDescription
+ * @param passFail
+ * @param resultReturned
+ */
+ private static void printResult(long id, String testFor,
+ String testCaseDescription, String passFail, String resultReturned) {
+ // TODO Auto-generated method stub
+ printResult(id, testFor, testCaseDescription, passFail);
+ System.out.println(resultReturned);
+
+ }
+
+ /**
+ * This function prints in output in required format.
+ *
+ * @param id
+ * @param testFor
+ * @param testCaseDescription
+ * @param result
+ */
+ private static void printResult(long id, String testFor,
+ String testCaseDescription, String result) {
+ System.out.println(result + " - Test Case " + id + " - Test type: "
+ + testFor + " - " + testCaseDescription);
+ }
+
+ /**
+ * This function compares the required expected output and received output
+ * and returns PASS if expected output and received output matches
+ *
+ * @param expectedResult
+ * @param resultReceived
+ * @return
+ */
+ private static String compareResults(ArrayList<String> expectedResult,
+ ArrayList<String> resultReceived) {
+ // TODO Auto-generated method stub
+ String returnString = "";
+ int index;
+// System.out.println(expectedResult.size());
+// System.out.println(resultReceived.size());
+ for (index = 0; index < expectedResult.size()
+ || index < resultReceived.size(); index++) {
+ if (index < expectedResult.size() && index < resultReceived.size()) {
+ if (!expectedResult.get(index)
+ .equals(resultReceived.get(index))) {
+ //returnString = "FAILED";
+ returnString += "\tExpected Output: "
+ + expectedResult.get(index)
+ + ",\n\tOutput Received: "
+ + resultReceived.get(index)+"\n";
+//
+ //System.out.println(resultReceived.get(index));
+ }
+
+ } else {
+ if (index >= expectedResult.size()) {
+ returnString += "\tExpected Size of output: "
+ + expectedResult.size()
+ + ", Size of output received: "
+ + resultReceived.size()
+ + "\n\tExpected Output: none,\n\tOutput Received: "
+ + resultReceived.get(index)+"\n";
+
+ } else {
+ if (index >= resultReceived.size()) {
+ returnString += "\tExpected Size of output: "
+ + expectedResult.size()
+ + ", Size of output received: "
+ + resultReceived.size()
+ + "\n\tExpected Output: "
+ + expectedResult.get(index)
+ + ",\n\tOutput Received: none\n";
+
+ }
+ }
+ }
+
+ }
+ if(index==expectedResult.size() && index==resultReceived.size() && returnString.equals("")){
+ returnString="PASSED";
+ }
+ return returnString;
+
+ }
+}
Code Review / policy / engine.git / blobdiff