vescollector junit addon

Issue-ID:DCAEGEN2-82
Change-Id: I109a01ec7d4927e3fbce723355012d80290f2b48
Signed-off-by: Vijay <vv770d@att.com>

6 files changed, 469 insertions, 0 deletions

diff --git a/src/test/java/org/onap/dcae/vestest/EventTransformTest.java b/src/test/java/org/onap/dcae/vestest/EventTransformTest.java
new file mode 100644
index 00000000..8a85117b
--- /dev/null
+++ b/src/test/java/org/onap/dcae/vestest/EventTransformTest.java
@@ -0,0 +1,152 @@
+/*-
+ * ============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 EventTransformTest {
+	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 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 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); 
+	}
+}  
+
diff --git a/src/test/java/org/onap/dcae/vestest/TestEventProcessor.java b/src/test/java/org/onap/dcae/vestest/TestEventProcessor.java
new file mode 100644
index 00000000..31807dba
--- /dev/null
+++ b/src/test/java/org/onap/dcae/vestest/TestEventProcessor.java
@@ -0,0 +1,104 @@
+/*-
+ * ============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.*;
+
+
+import java.io.File;
+import java.io.FileReader;
+import java.net.URL;
+import java.util.Map;
+
+import org.json.simple.JSONObject;
+
+import org.junit.After;
+import org.junit.Assert;
+import org.junit.Before;
+import org.junit.Test;
+import org.onap.dcae.commonFunction.CommonStartup;
+import org.onap.dcae.commonFunction.EventProcessor;
+import org.onap.dcae.commonFunction.EventPublisher;
+import org.onap.dcae.controller.LoadDynamicConfig;
+import org.onap.dcae.commonFunction.DmaapPropertyReader;
+
+
+import com.google.gson.JsonParser;
+
+public class TestEventProcessor {
+
+	EventProcessor ec;
+	String ev= "{\"event\": {\"commonEventHeader\": {	\"reportingEntityName\": \"VM name will be provided by ECOMP\",	\"startEpochMicrosec\": 1477012779802988,\"lastEpochMicrosec\": 1477012789802988,\"eventId\": \"83\",\"sourceName\": \"Dummy VM name - No Metadata available\",\"sequence\": 83,\"priority\": \"Normal\",\"functionalRole\": \"vFirewall\",\"domain\": \"measurementsForVfScaling\",\"reportingEntityId\": \"VM UUID will be provided by ECOMP\",\"sourceId\": \"Dummy VM UUID - No Metadata available\",\"version\": 1.1},\"measurementsForVfScalingFields\": {\"measurementInterval\": 10,\"measurementsForVfScalingVersion\": 1.1,\"vNicUsageArray\": [{\"multicastPacketsIn\": 0,\"bytesIn\": 3896,\"unicastPacketsIn\": 0,	\"multicastPacketsOut\": 0,\"broadcastPacketsOut\": 0,		\"packetsOut\": 28,\"bytesOut\": 12178,\"broadcastPacketsIn\": 0,\"packetsIn\": 58,\"unicastPacketsOut\": 0,\"vNicIdentifier\": \"eth0\"}]}}}";
+			
+	
+	@Before
+	public void setUp() throws Exception {
+		CommonStartup.streamid="fault=sec_fault|syslog=sec_syslog|heartbeat=sec_heartbeat|measurementsForVfScaling=sec_measurement|mobileFlow=sec_mobileflow|other=sec_other|stateChange=sec_statechange|thresholdCrossingAlert=sec_thresholdCrossingAlert|voiceQuality=ves_voicequality|sipSignaling=ves_sipsignaling";
+		CommonStartup.eventTransformFlag = 1;
+		
+	
+	}
+
+	@After
+	public void tearDown() throws Exception {
+	}
+
+	@Test
+	public void testLoad() {
+
+	
+		EventProcessor ec = new EventProcessor();
+		
+		ec.event=new org.json.JSONObject(ev);
+		
+		ec.overrideEvent();
+		//event.commonEventHeader.sourceName
+		Boolean flag = ec.event.getJSONObject("event").getJSONObject("commonEventHeader").has("sourceName");
+		assertEquals(true, flag);
+	}
+
+
+	@Test
+	public void testpublisher() {
+
+	    DmaapPropertyReader dr;
+		EventPublisher ep = null;
+	    String testinput = "src/test/resources/testDmaapConfig.json";
+	    Boolean flag = false;
+	    dr = new DmaapPropertyReader(testinput);
+
+				//new EventPublisher("sec_fault_ueb");
+		ep = EventPublisher.getInstance("sec_fault_ueb");
+		//event.commonEventHeader.sourceName
+		
+		if (ep.equals(null))
+		{
+			flag = false;
+		}
+		else
+		{
+			flag = true;
+		}
+		assertEquals(true, flag);
+	}
+	
+
+}
+
diff --git a/src/test/java/org/onap/dcae/vestest/TestLoadDynamicConfig.java b/src/test/java/org/onap/dcae/vestest/TestLoadDynamicConfig.java
new file mode 100644
index 00000000..9a50ea0c
--- /dev/null
+++ b/src/test/java/org/onap/dcae/vestest/TestLoadDynamicConfig.java
@@ -0,0 +1,72 @@
+/*-
+ * ============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.*;
+
+import java.io.File;
+import java.io.FileReader;
+import java.net.URL;
+import java.util.Map;
+
+import org.json.simple.JSONObject;
+
+import org.junit.After;
+import org.junit.Assert;
+import org.junit.Before;
+import org.junit.Test;
+import org.onap.dcae.controller.LoadDynamicConfig;
+
+import com.google.gson.JsonParser;
+
+public class TestLoadDynamicConfig {
+
+	LoadDynamicConfig lc;
+	String propop = "src/test/resources/testcollector.properties";
+	
+	@Before
+	public void setUp() throws Exception {
+	
+		
+		LoadDynamicConfig.propFile = "src/test/resources/testcollector.properties";
+		LoadDynamicConfig.configFile = "src/test/resources/controller-config.json";	
+
+	}
+
+	@After
+	public void tearDown() throws Exception {
+	}
+
+	@Test
+	public void testLoad() {
+
+	//	File file = new File(".");
+	//	for(String fileNames : file.list()) System.out.println(fileNames);
+		
+		Boolean flag=false;
+		lc = new LoadDynamicConfig();
+		
+		String data = LoadDynamicConfig.readFile(propop);
+		assertEquals(data.isEmpty(), flag);
+	}
+
+
+}
+
diff --git a/src/test/resources/controller-config.json b/src/test/resources/controller-config.json
new file mode 100644
index 00000000..c71f434d
--- /dev/null
+++ b/src/test/resources/controller-config.json
@@ -0,0 +1,17 @@
+{
+	"services_calls": {},
+	"collector.schema.checkflag": 1,
+	"collector.inputQueue.maxPending": 8096,
+	"collector.keystore.alias": "dynamically generated",
+	"collector.schema.file": "{\"v1\":\"./etc/CommonEventFormat_27.2.json\",\"v2\":\"./etc/CommonEventFormat_27.2.json\",\"v3\":\"./etc/CommonEventFormat_27.2.json\",\"v4\":\"./etc/CommonEventFormat_27.2.json\",\"v5\":\"./etc/CommonEventFormat_28.4.json\"}",
+	"header.authlist": "userid1,base64encodepwd1|userid2,base64encodepwd2",
+	"streams_subscribes": {},
+	"tomcat.maxthreads": "200",
+	"collector.service.secure.port": 8443,
+	"collector.dmaap.streamid": "fault=ves_fault|syslog=ves_syslog|heartbeat=ves_heartbeat|measurementsForVfScaling=ves_measurement|mobileFlow=ves_mobileflow|other=ves_other|stateChange=ves_statechange|thresholdCrossingAlert=ves_thresholdCrossingAlert|voiceQuality=ves_voicequality|sipSignaling=ves_sipsignaling",
+	"event.transform.flag": 0,
+	"collector.keystore.file.location": "/opt/app/dcae-certificate/keystore.jks",
+	"collector.keystore.passwordfile": "/opt/app/dcae-certificate/.password",
+	"header.authflag": 0,
+	"collector.service.port": 8080
+}
diff --git a/src/test/resources/event4xjson.txt b/src/test/resources/event4xjson.txt
new file mode 100644
index 00000000..46c5fb51
--- /dev/null
+++ b/src/test/resources/event4xjson.txt
@@ -0,0 +1,49 @@
+{
+"event": {
+"commonEventHeader": {
+"sourceId": "owb-rdm-003",
+"startEpochMicrosec": 1469528413000,
+"eventId": "owb-rdm-003 1",
+"reportingEntityId": "127.0.1.1",
+"eventType": "fault_owb-rdm-003_lossOfSignal",
+"priority": "High",
+"version": 1.0,
+"reportingEntityName": "agilevm",
+"sequence": 0,
+"domain": "fault",
+"functionalRole": "rdm",
+"lastEpochMicrosec": 1469528413000,
+"sourceName": "owb-rdm-003"
+},
+"faultFields": {
+"eventSeverity": "CRITICAL",
+"alarmCondition": "lossOfSignal",
+"faultFieldsVersion": 1.0,
+"specificProblem": "lossOfSignal",
+"alarmInterfaceA": "1/0/0 E1",
+"memoryConfigured": "2000",
+"memoryUsed":"20",
+"alarmAdditionalInformation": [
+{
+"name": "DIR",
+"value": "tx"
+},
+{
+"name": "LOC",
+"value": "NEND"
+},
+{
+"name": "TYPE",
+"value": "communication"
+},
+{
+"name": "CKTID",
+"value": "circuit-1"
+}
+],
+"eventSourceType": "port",
+"vfStatus": "Active"
+}
+}
+}
+
diff --git a/src/test/resources/testcollector.properties b/src/test/resources/testcollector.properties
new file mode 100644
index 00000000..6b166b04
--- /dev/null
+++ b/src/test/resources/testcollector.properties
@@ -0,0 +1,75 @@
+###############################################################################
+##
+## Collector Server config
+##
+##	- Default values are shown as commented settings.
+##
+###############################################################################
+##
+## HTTP(S) service
+##
+##	Normally:
+##
+##		- 8080 is http service
+##		- https is disabled by default (-1)
+##
+##		- At this time, the server always binds to 0.0.0.0
+##
+## The default port when header.authflag is disabled (0)
+collector.service.port=9999
+
+## The secure port is required if header.authflag is set to 1 (true)
+## Authentication is only supported via secure port
+## When enabled - require valid keystore defined
+collector.service.secure.port=8443
+
+## The keystore must be setup per installation when secure port is configured
+collector.keystore.file.location=../etc/keystore
+collector.keystore.passwordfile=./etc/passwordfile
+collector.keystore.alias=tomcat
+
+
+###############################################################################
+## Processing
+##
+## If there's a problem that prevents the collector from processing alarms,
+## it's normally better to apply back pressure to the caller than to try to
+## buffer beyond a reasonable size limit. With a limit, the server won't crash
+## due to being out of memory, and the caller will get a 5xx reply saying the
+## server is in trouble.
+collector.inputQueue.maxPending=8096
+
+## Schema Validation checkflag
+## default no validation checkflag (-1)
+## If enabled (1) - schemafile location must be specified
+collector.schema.checkflag=1
+collector.schema.file={\"v1\":\"./etc/CommonEventFormat_27.2.json\",\"v2\":\"./etc/CommonEventFormat_27.2.json\",\"v3\":\"./etc/CommonEventFormat_27.2.json\",\"v4\":\"./etc/CommonEventFormat_27.2.json\",\"v5\":\"./etc/CommonEventFormat_28.4.json\"}
+
+## List all streamid per domain to be supported. The streamid should match to channel name on dmaapfile  
+collector.dmaap.streamid=fault=sec_fault|syslog=sec_syslog|heartbeat=sec_heartbeat|measurementsForVfScaling=sec_measurement|mobileFlow=sec_mobileflow|other=sec_other|stateChange=sec_statechange|thresholdCrossingAlert=sec_thresholdCrossingAlert|voiceQuality=ves_voicequality|sipSignaling=ves_sipsignaling
+collector.dmaapfile=./etc/DmaapConfig.json
+
+## Custom ExceptionConfiguration
+exceptionConfig=./etc/ExceptionConfig.json
+
+## authflag control authentication by the collector
+## If enabled (1) - then authlist has to be defined
+## When authflag is enabled, only secure port will be supported
+## To disable enter 0
+header.authflag=1
+## Combination of userid,base64 encoded pwd list to be supported
+## userid and pwd comma separated; pipe delimitation between each pair
+header.authlist=secureid,IWRjYWVSb2FkbTEyMyEt|sample1,c2FtcGxlMQ==|vdnsagg,dmRuc2FnZw==
+
+## Event transformation Flag - when set expects configurable transformation
+## defined under ./etc/eventTransform.json
+## Enabled by default; to disable set to 0
+event.transform.flag=1
+
+###############################################################################
+##
+## Tomcat control
+##
+#tomcat.maxthreads=(tomcat default, which is usually 200)
+
+