-/*-
- * ============LICENSE_START=======================================================
- * PROJECT
- * ================================================================================
- * 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=========================================================
- */
-package org.onap.dcae.vestest;
-
-import static org.junit.Assert.assertEquals;
-
-import java.io.FileReader;
-import java.io.IOException;
-import org.json.JSONObject;
-import com.google.gson.JsonParser;
-import com.google.gson.JsonObject;
-import org.junit.Test;
-
-import org.onap.dcae.commonFunction.ConfigProcessors;
-
-
-
-public class TestConfigProcessor {
- public JSONObject getFileAsJsonObject()
- {
- JSONObject jsonObject = null;
- FileReader fr = null;
- final JsonParser parser = new JsonParser();
- String jsonfilepath="src/test/resources/event4xjson.txt";
- try{
- fr = new FileReader ( jsonfilepath );
- final JsonObject jo = (JsonObject) parser.parse (fr);
- final String jsonText = jo.toString ();
- jsonObject = new JSONObject ( jsonText );
- }
- catch(Exception e){
- System.out.println("Exception while opening the file");
- e.printStackTrace();
- }
- finally {
- //close the file
- if (fr != null) {
- try {
- fr.close();
- } catch (IOException e) {
- System.out.println("Error closing file reader stream : " +e.toString());
- }
- }
- }
- return jsonObject;
- }
- @Test
- public void testAttrMap(){
-
- final JSONObject jsonObject = getFileAsJsonObject();
- final String functionRole = (jsonObject.getJSONObject("event")).getJSONObject("commonEventHeader").get("functionalRole").toString();
- System.out.println("event==" + jsonObject.toString());
- System.out.println("functionRole==" + functionRole);
- final JSONObject jsonArgs = new JSONObject ( "{\"field\": \"event.commonEventHeader.nfNamingCode\",\"oldField\": \"event.commonEventHeader.functionalRole\"}" );
- ConfigProcessors cpEvent = new ConfigProcessors(jsonObject);
- cpEvent.map(jsonArgs);
- final String responseData = cpEvent.getEventObjectVal("event.commonEventHeader.nfNamingCode").toString();
- System.out.println("modified event==" + jsonObject.toString());
- System.out.println("responseData==" + responseData);
- assertEquals (functionRole, responseData);
- }
-
- @Test
- public void testArrayMap(){
-
- final JSONObject jsonObject = getFileAsJsonObject();
- final String alarmAdditionalInformation = (jsonObject.getJSONObject("event")).getJSONObject("faultFields").get("alarmAdditionalInformation").toString();
- System.out.println("event==" + jsonObject.toString());
- System.out.println("alarmAdditionalInformation==" + alarmAdditionalInformation);
- final JSONObject jsonArgs = new JSONObject ( "{\"field\": \"event.faultFields.eventAdditionalInformation\",\"oldField\": \"event.faultFields.alarmAdditionalInformation\"}" );
- ConfigProcessors cpEvent = new ConfigProcessors(jsonObject);
- cpEvent.map(jsonArgs);
- final String responseData = cpEvent.getEventObjectVal("event.faultFields.eventAdditionalInformation").toString();
- System.out.println("modified event==" + jsonObject.toString());
- System.out.println("responseData==" + responseData);
- assertEquals (alarmAdditionalInformation, responseData);
- }
- @Test
- public void testJobjMaptoArray(){
-
- final JSONObject jsonObject = getFileAsJsonObject();
- //final String receiveDiscards = (((jsonObject.getJSONObject("event")).getJSONObject("faultFields")).get("errors")).get("receiveDiscards").toString();
- System.out.println("event==" + jsonObject.toString());
- //System.out.println("alarmAdditionalInformation==" + alarmAdditionalInformation);
- final JSONObject jsonArgs = new JSONObject ( "{\"field\": \"event.faultFields.vNicPerformanceArray[]\",\"oldField\": \"event.faultFields.errors\",\"attrMap\":{\"receiveDiscards\":\"receivedDiscardedPacketsAccumulated\"}}" );
- ConfigProcessors cpEvent = new ConfigProcessors(jsonObject);
- final String receiveDiscards = cpEvent.getEventObjectVal("event.faultFields.errors.receiveDiscards").toString();
- System.out.println("receiveDiscards==" + receiveDiscards);
- cpEvent.map(jsonArgs);
- final String responseData = cpEvent.getEventObjectVal("event.faultFields.vNicPerformanceArray[0].receivedDiscardedPacketsAccumulated").toString();
- System.out.println("modified event==" + jsonObject.toString());
- System.out.println("responseData==" + responseData);
- assertEquals (receiveDiscards, responseData);
- }
- @Test
- public void testAttrAdd(){
-
- final JSONObject jsonObject = getFileAsJsonObject();
- //final String functionRole = (jsonObject.getJSONObject("event")).getJSONObject("commonEventHeader").get("functionalRole").toString();
- System.out.println("event==" + jsonObject.toString());
- //System.out.println("functionRole==" + functionRole);
- final JSONObject jsonArgs = new JSONObject ( "{\"field\": \"event.faultFields.version\",\"value\": \"2.0\",\"fieldType\": \"number\"}" );
- ConfigProcessors cpEvent = new ConfigProcessors(jsonObject);
- cpEvent.addAttribute(jsonArgs);
- final String responseData = cpEvent.getEventObjectVal("event.faultFields.version").toString();
- System.out.println("modified event==" + jsonObject.toString());
- System.out.println("responseData==" + responseData);
- assertEquals ("2.0", responseData);
- }
-
- @Test
- public void testAttrUpdate(){
-
- final JSONObject jsonObject = getFileAsJsonObject();
- //final String functionRole = (jsonObject.getJSONObject("event")).getJSONObject("commonEventHeader").get("functionalRole").toString();
- System.out.println("event==" + jsonObject.toString());
- //System.out.println("functionRole==" + functionRole);
- final JSONObject jsonArgs = new JSONObject ( "{\"field\": \"event.faultFields.version\",\"value\": \"2.0\",\"fieldType\": \"number\"}" );
- ConfigProcessors cpEvent = new ConfigProcessors(jsonObject);
- cpEvent.updateAttribute(jsonArgs);
- final String responseData = cpEvent.getEventObjectVal("event.faultFields.version").toString();
- System.out.println("modified event==" + jsonObject.toString());
- System.out.println("responseData==" + responseData);
- assertEquals ("2.0", responseData);
- }
-
- @Test
- public void testAttrConcatenate(){
-
- final JSONObject jsonObject = getFileAsJsonObject();
- final String eventType = (jsonObject.getJSONObject("event")).getJSONObject("commonEventHeader").get("eventType").toString();
- final String domain = (jsonObject.getJSONObject("event")).getJSONObject("commonEventHeader").get("domain").toString();
- final String alarmCondition = (jsonObject.getJSONObject("event")).getJSONObject("faultFields").get("alarmCondition").toString();
- System.out.println("event==" + jsonObject.toString());
- final String eventName = domain + "_" + eventType + "_" + alarmCondition;
- System.out.println("eventName==" + eventName);
- final JSONObject jsonArgs = new JSONObject ( "{\"field\":\"event.commonEventHeader.eventName\",\"concatenate\": [\"$event.commonEventHeader.domain\",\"$event.commonEventHeader.eventType\",\"$event.faultFields.alarmCondition\"],\"delimiter\":\"_\"}");
- ConfigProcessors cpEvent = new ConfigProcessors(jsonObject);
- cpEvent.concatenateValue(jsonArgs);
- final String responseData = cpEvent.getEventObjectVal("event.commonEventHeader.eventName").toString();
- System.out.println("modified event==" + jsonObject.toString());
- System.out.println("responseData==" + responseData);
- assertEquals (eventName, responseData);
- }
-
- @Test
- public void testAttrSubtract(){
-
- final JSONObject jsonObject = getFileAsJsonObject();
- final String memoryConfigured = (jsonObject.getJSONObject("event")).getJSONObject("faultFields").get("memoryConfigured").toString();
- final String memoryUsed = (jsonObject.getJSONObject("event")).getJSONObject("faultFields").get("memoryUsed").toString();
- System.out.println("event==" + jsonObject.toString());
- System.out.println("memoryConfigured==" + memoryConfigured);
- System.out.println("memoryUsed==" + memoryUsed);
- final JSONObject jsonArgs = new JSONObject ( "{\"field\": \"event.faultFields.memoryFree\",\"subtract\": [\"$event.faultFields.memoryConfigured\",\"$event.faultFields.memoryUsed\"]}" );
- ConfigProcessors cpEvent = new ConfigProcessors(jsonObject);
- cpEvent.subtractValue(jsonArgs);
- final String responseData = cpEvent.getEventObjectVal("event.faultFields.memoryFree").toString();
- System.out.println("modified event==" + jsonObject.toString());
- System.out.println("responseData==" + responseData);
- assertEquals ("1980.0", responseData);
- }
-
- @Test
- public void testAttrGet(){
-
- Boolean Flag= true;
- final JSONObject jsonObject = getFileAsJsonObject();
- System.out.println("event==" + jsonObject.toString());
- final JSONObject jsonArgs = new JSONObject ( "{\"field\": \"event.faultFields.version\",\"value\": \"2.0\",\"fieldType\": \"number\"}" );
- ConfigProcessors cpEvent = new ConfigProcessors(jsonObject);
- cpEvent.getValue(jsonArgs);
- assertEquals (true, Flag);
- }
-
- @Test
- public void testAttrSet(){
- Boolean Flag= true;
- final JSONObject jsonObject = getFileAsJsonObject();
- System.out.println("event==" + jsonObject.toString());
- final JSONObject jsonArgs = new JSONObject ( "{\"field\": \"event.faultFields.version\",\"value\": \"2.0\",\"fieldType\": \"number\"}" );
- ConfigProcessors cpEvent = new ConfigProcessors(jsonObject);
- cpEvent.setValue(jsonArgs);
-
- assertEquals (true, Flag);
- }
-
-
-}
-
+/*-\r
+ * ============LICENSE_START=======================================================\r
+ * PROJECT\r
+ * ================================================================================\r
+ * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.\r
+ * ================================================================================\r
+ * Licensed under the Apache License, Version 2.0 (the "License");\r
+ * you may not use this file except in compliance with the License.\r
+ * You may obtain a copy of the License at\r
+ * \r
+ * http://www.apache.org/licenses/LICENSE-2.0\r
+ * \r
+ * Unless required by applicable law or agreed to in writing, software\r
+ * distributed under the License is distributed on an "AS IS" BASIS,\r
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
+ * See the License for the specific language governing permissions and\r
+ * limitations under the License.\r
+ * ============LICENSE_END=========================================================\r
+ */\r
+package org.onap.dcae.vestest;\r
+\r
+import static org.junit.Assert.assertEquals;\r
+\r
+import java.io.FileReader;\r
+import java.io.IOException;\r
+import org.json.JSONObject;\r
+import com.google.gson.JsonParser;\r
+import com.google.gson.JsonObject;\r
+import org.junit.Test;\r
+\r
+import org.onap.dcae.commonFunction.ConfigProcessors;\r
+\r
+\r
+\r
+public class TestConfigProcessor {\r
+ public JSONObject getFileAsJsonObject()\r
+ {\r
+ JSONObject jsonObject = null;\r
+ FileReader fr = null;\r
+ final JsonParser parser = new JsonParser();\r
+ String jsonfilepath="src/test/resources/event4xjson.txt";\r
+ try{\r
+ fr = new FileReader ( jsonfilepath );\r
+ final JsonObject jo = (JsonObject) parser.parse (fr);\r
+ final String jsonText = jo.toString ();\r
+ jsonObject = new JSONObject ( jsonText );\r
+ }\r
+ catch(Exception e){\r
+ System.out.println("Exception while opening the file");\r
+ e.printStackTrace();\r
+ }\r
+ finally {\r
+ //close the file\r
+ if (fr != null) {\r
+ try {\r
+ fr.close();\r
+ } catch (IOException e) {\r
+ System.out.println("Error closing file reader stream : " +e.toString());\r
+ }\r
+ }\r
+ }\r
+ return jsonObject;\r
+ }\r
+ @Test\r
+ public void testAttrMap(){\r
+ \r
+ final JSONObject jsonObject = getFileAsJsonObject();\r
+ final String functionRole = (jsonObject.getJSONObject("event")).getJSONObject("commonEventHeader").get("functionalRole").toString();\r
+ System.out.println("event==" + jsonObject.toString());\r
+ System.out.println("functionRole==" + functionRole);\r
+ final JSONObject jsonArgs = new JSONObject ( "{\"field\": \"event.commonEventHeader.nfNamingCode\",\"oldField\": \"event.commonEventHeader.functionalRole\"}" );\r
+ ConfigProcessors cpEvent = new ConfigProcessors(jsonObject);\r
+ cpEvent.map(jsonArgs);\r
+ final String responseData = cpEvent.getEventObjectVal("event.commonEventHeader.nfNamingCode").toString();\r
+ System.out.println("modified event==" + jsonObject.toString());\r
+ System.out.println("responseData==" + responseData); \r
+ assertEquals (functionRole, responseData); \r
+ }\r
+ \r
+ @Test\r
+ public void testArrayMap(){\r
+ \r
+ final JSONObject jsonObject = getFileAsJsonObject();\r
+ final String alarmAdditionalInformation = (jsonObject.getJSONObject("event")).getJSONObject("faultFields").get("alarmAdditionalInformation").toString();\r
+ System.out.println("event==" + jsonObject.toString());\r
+ System.out.println("alarmAdditionalInformation==" + alarmAdditionalInformation);\r
+ final JSONObject jsonArgs = new JSONObject ( "{\"field\": \"event.faultFields.eventAdditionalInformation\",\"oldField\": \"event.faultFields.alarmAdditionalInformation\"}" );\r
+ ConfigProcessors cpEvent = new ConfigProcessors(jsonObject);\r
+ cpEvent.map(jsonArgs);\r
+ final String responseData = cpEvent.getEventObjectVal("event.faultFields.eventAdditionalInformation").toString();\r
+ System.out.println("modified event==" + jsonObject.toString());\r
+ System.out.println("responseData==" + responseData); \r
+ assertEquals (alarmAdditionalInformation, responseData); \r
+ }\r
+ @Test\r
+ public void testJobjMaptoArray(){\r
+ \r
+ final JSONObject jsonObject = getFileAsJsonObject();\r
+ //final String receiveDiscards = (((jsonObject.getJSONObject("event")).getJSONObject("faultFields")).get("errors")).get("receiveDiscards").toString();\r
+ System.out.println("event==" + jsonObject.toString());\r
+ //System.out.println("alarmAdditionalInformation==" + alarmAdditionalInformation);\r
+ final JSONObject jsonArgs = new JSONObject ( "{\"field\": \"event.faultFields.vNicPerformanceArray[]\",\"oldField\": \"event.faultFields.errors\",\"attrMap\":{\"receiveDiscards\":\"receivedDiscardedPacketsAccumulated\"}}" );\r
+ ConfigProcessors cpEvent = new ConfigProcessors(jsonObject);\r
+ final String receiveDiscards = cpEvent.getEventObjectVal("event.faultFields.errors.receiveDiscards").toString();\r
+ System.out.println("receiveDiscards==" + receiveDiscards);\r
+ cpEvent.map(jsonArgs);\r
+ final String responseData = cpEvent.getEventObjectVal("event.faultFields.vNicPerformanceArray[0].receivedDiscardedPacketsAccumulated").toString();\r
+ System.out.println("modified event==" + jsonObject.toString());\r
+ System.out.println("responseData==" + responseData); \r
+ assertEquals (receiveDiscards, responseData); \r
+ }\r
+ @Test\r
+ public void testAttrAdd(){\r
+ \r
+ final JSONObject jsonObject = getFileAsJsonObject();\r
+ //final String functionRole = (jsonObject.getJSONObject("event")).getJSONObject("commonEventHeader").get("functionalRole").toString();\r
+ System.out.println("event==" + jsonObject.toString());\r
+ //System.out.println("functionRole==" + functionRole);\r
+ final JSONObject jsonArgs = new JSONObject ( "{\"field\": \"event.faultFields.version\",\"value\": \"2.0\",\"fieldType\": \"number\"}" );\r
+ ConfigProcessors cpEvent = new ConfigProcessors(jsonObject);\r
+ cpEvent.addAttribute(jsonArgs);\r
+ final String responseData = cpEvent.getEventObjectVal("event.faultFields.version").toString();\r
+ System.out.println("modified event==" + jsonObject.toString());\r
+ System.out.println("responseData==" + responseData); \r
+ assertEquals ("2.0", responseData); \r
+ }\r
+ \r
+ @Test\r
+ public void testAttrUpdate(){\r
+ \r
+ final JSONObject jsonObject = getFileAsJsonObject();\r
+ //final String functionRole = (jsonObject.getJSONObject("event")).getJSONObject("commonEventHeader").get("functionalRole").toString();\r
+ System.out.println("event==" + jsonObject.toString());\r
+ //System.out.println("functionRole==" + functionRole);\r
+ final JSONObject jsonArgs = new JSONObject ( "{\"field\": \"event.faultFields.version\",\"value\": \"2.0\",\"fieldType\": \"number\"}" );\r
+ ConfigProcessors cpEvent = new ConfigProcessors(jsonObject);\r
+ cpEvent.updateAttribute(jsonArgs);\r
+ final String responseData = cpEvent.getEventObjectVal("event.faultFields.version").toString();\r
+ System.out.println("modified event==" + jsonObject.toString());\r
+ System.out.println("responseData==" + responseData); \r
+ assertEquals ("2.0", responseData); \r
+ }\r
+ \r
+ @Test\r
+ public void testAttrConcatenate(){\r
+ \r
+ final JSONObject jsonObject = getFileAsJsonObject();\r
+ final String eventType = (jsonObject.getJSONObject("event")).getJSONObject("commonEventHeader").get("eventType").toString();\r
+ final String domain = (jsonObject.getJSONObject("event")).getJSONObject("commonEventHeader").get("domain").toString();\r
+ final String alarmCondition = (jsonObject.getJSONObject("event")).getJSONObject("faultFields").get("alarmCondition").toString();\r
+ System.out.println("event==" + jsonObject.toString());\r
+ final String eventName = domain + "_" + eventType + "_" + alarmCondition;\r
+ System.out.println("eventName==" + eventName);\r
+ final JSONObject jsonArgs = new JSONObject ( "{\"field\":\"event.commonEventHeader.eventName\",\"concatenate\": [\"$event.commonEventHeader.domain\",\"$event.commonEventHeader.eventType\",\"$event.faultFields.alarmCondition\"],\"delimiter\":\"_\"}");\r
+ ConfigProcessors cpEvent = new ConfigProcessors(jsonObject);\r
+ cpEvent.concatenateValue(jsonArgs);\r
+ final String responseData = cpEvent.getEventObjectVal("event.commonEventHeader.eventName").toString();\r
+ System.out.println("modified event==" + jsonObject.toString());\r
+ System.out.println("responseData==" + responseData); \r
+ assertEquals (eventName, responseData); \r
+ }\r
+ \r
+ @Test\r
+ public void testAttrSubtract(){\r
+ \r
+ final JSONObject jsonObject = getFileAsJsonObject();\r
+ final String memoryConfigured = (jsonObject.getJSONObject("event")).getJSONObject("faultFields").get("memoryConfigured").toString();\r
+ final String memoryUsed = (jsonObject.getJSONObject("event")).getJSONObject("faultFields").get("memoryUsed").toString();\r
+ System.out.println("event==" + jsonObject.toString());\r
+ System.out.println("memoryConfigured==" + memoryConfigured);\r
+ System.out.println("memoryUsed==" + memoryUsed);\r
+ final JSONObject jsonArgs = new JSONObject ( "{\"field\": \"event.faultFields.memoryFree\",\"subtract\": [\"$event.faultFields.memoryConfigured\",\"$event.faultFields.memoryUsed\"]}" );\r
+ ConfigProcessors cpEvent = new ConfigProcessors(jsonObject);\r
+ cpEvent.subtractValue(jsonArgs);\r
+ final String responseData = cpEvent.getEventObjectVal("event.faultFields.memoryFree").toString();\r
+ System.out.println("modified event==" + jsonObject.toString());\r
+ System.out.println("responseData==" + responseData); \r
+ assertEquals ("1980.0", responseData); \r
+ }\r
+ \r
+ @Test\r
+ public void testSetValue(){\r
+ \r
+ final JSONObject jsonObject = getFileAsJsonObject();\r
+ System.out.println("event==" + jsonObject.toString());\r
+ System.out.println("Testing SetValue");\r
+ final JSONObject jsonArgs = new JSONObject ( "{\"field\": \"event.faultFields.version\",\"value\": \"2.0\",\"fieldType\": \"number\"}" );\r
+ ConfigProcessors cpEvent = new ConfigProcessors(jsonObject);\r
+ cpEvent.setValue(jsonArgs);\r
+ final String responseData = cpEvent.getEventObjectVal("event.faultFields.version").toString();\r
+ System.out.println("modified event==" + jsonObject.toString());\r
+ System.out.println("responseData==" + responseData); \r
+ assertEquals ("2.0", responseData); \r
+ }\r
+ \r
+ @Test\r
+ public void testSetEventObjectVal(){\r
+ \r
+ final JSONObject jsonObject = getFileAsJsonObject();\r
+ System.out.println("event==" + jsonObject.toString());\r
+ System.out.println("Testing SetEventObjectVal");\r
+ //final JSONObject jsonArgs = new JSONObject ( "{\"field\": \"event.faultFields.version\",\"value\": \"2.0\",\"fieldType\": \"number\"}" );\r
+ ConfigProcessors cpEvent = new ConfigProcessors(jsonObject);\r
+ cpEvent.setEventObjectVal("event.faultFields.version", "2.0", "number");\r
+ final String responseData = cpEvent.getEventObjectVal("event.faultFields.version").toString();\r
+ System.out.println("modified event==" + jsonObject.toString());\r
+ System.out.println("responseData==" + responseData); \r
+ assertEquals ("2.0", responseData); \r
+ }\r
+ \r
+ @Test\r
+ public void testGetValue(){\r
+ \r
+ final JSONObject jsonObject = getFileAsJsonObject();\r
+ System.out.println("event==" + jsonObject.toString());\r
+ System.out.println("Testing GetValue");\r
+ final JSONObject jsonArgs = new JSONObject ( "{\"field\": \"event.faultFields.eventSeverity\"}" );\r
+ ConfigProcessors cpEvent = new ConfigProcessors(jsonObject);\r
+ cpEvent.getValue(jsonArgs);\r
+ final String responseData = cpEvent.getEventObjectVal("event.faultFields.eventSeverity").toString();\r
+ System.out.println("modified event==" + jsonObject.toString());\r
+ System.out.println("responseData==" + responseData); \r
+ assertEquals ("CRITICAL", responseData); \r
+ }\r
+ \r
+ @Test\r
+ public void testGetEventObjectVal(){\r
+ \r
+ final JSONObject jsonObject = getFileAsJsonObject();\r
+ System.out.println("event==" + jsonObject.toString());\r
+ System.out.println("Testing GetEventObjectVal");\r
+ //final JSONObject jsonArgs = new JSONObject ( "{\"field\": \"event.faultFields.eventSeverity\"}" );\r
+ ConfigProcessors cpEvent = new ConfigProcessors(jsonObject);\r
+ cpEvent.getEventObjectVal("event.faultFields.eventSeverity");\r
+ final String responseData = cpEvent.getEventObjectVal("event.faultFields.eventSeverity").toString();\r
+ System.out.println("modified event==" + jsonObject.toString());\r
+ System.out.println("responseData==" + responseData); \r
+ assertEquals ("CRITICAL", responseData); \r
+ }\r
+ \r
+ @Test\r
+ public void testRemoveAttribute(){\r
+ \r
+ final JSONObject jsonObject = getFileAsJsonObject();\r
+ System.out.println("event==" + jsonObject.toString());\r
+ System.out.println("Testing removeAttribute");\r
+ final JSONObject jsonArgs = new JSONObject ( "{\"field\": \"event.faultFields.memoryUsed\"}" );\r
+ ConfigProcessors cpEvent = new ConfigProcessors(jsonObject);\r
+ cpEvent.removeAttribute(jsonArgs);\r
+ final String responseData = cpEvent.getEventObjectVal("event.faultFields.memoryUsed").toString();\r
+ System.out.println("modified event==" + jsonObject.toString());\r
+ System.out.println("responseData==" + responseData); \r
+ assertEquals ("ObjectNotFound", responseData); \r
+ }\r
+ \r
+ @Test\r
+ public void testIsFilterMet(){\r
+ \r
+ final JSONObject jsonObject = getFileAsJsonObject();\r
+ System.out.println("event==" + jsonObject.toString());\r
+ System.out.println("Testing isFilterMet");\r
+ final JSONObject jsonArgs = new JSONObject ( "{\"event.faultFields.eventSeverity\":\"CRITICAL\"}" );\r
+ ConfigProcessors cpEvent = new ConfigProcessors(jsonObject);\r
+ \r
+ final boolean response = cpEvent.isFilterMet(jsonArgs);\r
+ String responseData = "CRITICAL";\r
+ if (response == false)\r
+ responseData = "notCRITICAL";\r
+ \r
+ System.out.println("responseData==" + responseData); \r
+ assertEquals ("CRITICAL", responseData); \r
+ }\r
+ \r
+ @Test\r
+ public void testSuppressEvent(){\r
+ \r
+ final JSONObject jsonObject = getFileAsJsonObject();\r
+ System.out.println("event==" + jsonObject.toString());\r
+ System.out.println("Testing SuppressEvent");\r
+ final JSONObject jsonArgs = new JSONObject ( "{\"event.faultFields.eventSeverity\":\"CRITICAL\"}" );\r
+ ConfigProcessors cpEvent = new ConfigProcessors(jsonObject);\r
+ \r
+ cpEvent.suppressEvent(jsonArgs);\r
+ String responseData = cpEvent.getEventObjectVal("suppressEvent").toString();\r
+ \r
+ System.out.println("responseData==" + responseData); \r
+ assertEquals ("true", responseData); \r
+ }\r
+} \r
+\r
Code Review / dcaegen2 / collectors / ves.git / commitdiff