junit addon for ves

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

3 files changed, 214 insertions, 55 deletions

diff --git a/src/test/java/org/onap/dcae/vestest/TestCommonStartup.java b/src/test/java/org/onap/dcae/vestest/TestCommonStartup.java
index 486789d0..06f70183 100644
--- a/src/test/java/org/onap/dcae/vestest/TestCommonStartup.java
+++ b/src/test/java/org/onap/dcae/vestest/TestCommonStartup.java
@@ -7,9 +7,9 @@
  * 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.
@@ -19,54 +19,152 @@
  */
 package org.onap.dcae.vestest;
 
+import java.io.FileReader;
+import java.io.IOException;
 import java.net.URL;
 import java.util.Map;
+import java.util.concurrent.LinkedBlockingQueue;
 
+import org.json.JSONArray;
+import org.json.JSONException;
+import org.json.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.CommonStartup.QueueFullException;
+import org.onap.dcae.restapi.RestfulCollectorServlet;
 
 import com.att.nsa.cmdLine.NsaCommandLineUtil;
 import com.att.nsa.drumlin.service.framework.DrumlinServlet;
 import com.att.nsa.drumlin.till.nv.rrNvReadable.loadException;
+import com.att.nsa.drumlin.till.nv.rrNvReadable.missingReqdSetting;
+import com.att.nsa.security.NsaAuthenticator;
+import com.att.nsa.security.authenticators.SimpleAuthenticator;
+import com.att.nsa.security.db.simple.NsaSimpleApiKey;
+import com.google.gson.JsonParser;
 import com.att.nsa.drumlin.till.nv.impl.nvPropertiesFile;
 import com.att.nsa.drumlin.till.nv.impl.nvReadableStack;
 import com.att.nsa.drumlin.till.nv.impl.nvReadableTable;
 
 public class TestCommonStartup {
 
-	@Before
-	public void setUp() throws Exception {
+        String payload = null;
+        @Before
+        public void setUp() throws Exception {
 
-		// process command line arguments
+                // process command line arguments
+                payload = new JsonParser().parse(new FileReader("src/test/resources/VES_valid.txt")).toString();
+                CommonStartup.fProcessingInputQueue = new LinkedBlockingQueue<JSONObject> (CommonStartup.kDefault_MaxQueuedEvents);
+        }
 
-	}
+        @After
+        public void tearDown() throws Exception {
 
-	@After
-	public void tearDown() throws Exception {
+        }
 
-	}
+        @Test
+        public void testCommonStartupload() {
 
-	@Test
-	public void testCommonStartupload() {
+                String args[] = { "junittest" };
+                final Map<String, String> argMap = NsaCommandLineUtil.processCmdLine(args, true);
+                final String config = NsaCommandLineUtil.getSetting(argMap, "c", "collector.properties");
+                final URL settingStream = DrumlinServlet.findStream(config, CommonStartup.class);
 
-		String args[] = { "junittest" };
-		final Map<String, String> argMap = NsaCommandLineUtil.processCmdLine(args, true);
-		final String config = NsaCommandLineUtil.getSetting(argMap, "c", "collector.properties");
-		final URL settingStream = DrumlinServlet.findStream(config, CommonStartup.class);
+                final nvReadableStack settings = new nvReadableStack();
+                try {
+                        settings.push(new nvPropertiesFile(settingStream));
+                } catch (loadException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                }
+                settings.push(new nvReadableTable(argMap));
+                Assert.assertEquals("true", "true");
+        }
 
-		final nvReadableStack settings = new nvReadableStack();
-		try {
-			settings.push(new nvPropertiesFile(settingStream));
-		} catch (loadException e) {
-			// TODO Auto-generated catch block
-			e.printStackTrace();
-		}
-		settings.push(new nvReadableTable(argMap));
-		Assert.assertEquals("true", "true");
-	}
+        @Test
+        public void testhandleevent() {
+                JSONArray jsonArrayMod = new JSONArray().put(new JSONObject(payload));
+                try {
 
+
+                        CommonStartup.handleEvents (jsonArrayMod);
+                } catch ( JSONException | QueueFullException | IOException e) {
+                        // TODO Auto-generated catch block
+                        //e.printStackTrace();
+                        System.out.println("junit reported:" + e.getMessage());
+                }
+                Assert.assertEquals("true", "true");
+        }
+
+
+/*
+        @Test
+        public void testServlet()  {
+                try
+                {
+                        RestfulCollectorServlet rsv = new RestfulCollectorServlet(null);
+                }
+                catch (NullPointerException|loadException| missingReqdSetting e){
+                        System.out.println("junit reported:" + e.getMessage());
+                }
+                Assert.assertEquals("true", "true");
+        }
+*/
+
+
+        @Test
+        public void testEventProcessorinstantiation()
+        {
+                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";
+                EventProcessor ep = new EventProcessor ();
+                Thread epThread=new Thread(ep);
+                epThread.start();
+                 Assert.assertEquals("true", "true");
+                epThread.stop();
+
+        }
+
+        @Test
+        public void testAuthListHandler()
+        {
+        	
+        	final Map<String, String> argMap = NsaCommandLineUtil.processCmdLine ( new String[0], true );
+			final String config = NsaCommandLineUtil.getSetting ( argMap, "c", "collector.properties" );
+			final URL settingStream = DrumlinServlet.findStream ( config, CommonStartup.class );
+
+			final nvReadableStack settings = new nvReadableStack ();
+			try {
+				settings.push ( new nvPropertiesFile ( settingStream ) );
+				settings.push ( new nvReadableTable ( argMap ) );
+			} catch (loadException e1) {
+				// TODO Auto-generated catch block
+				e1.printStackTrace();
+			}
+			
+			
+        	RestfulCollectorServlet rsv = null;
+        	NsaAuthenticator<NsaSimpleApiKey> NsaAuth = null;
+        	Boolean flag = false;
+	            try
+	            {
+	                    rsv = new RestfulCollectorServlet(settings);
+	            }
+	            catch (NullPointerException|loadException| missingReqdSetting e){
+	                    System.out.println("junit reported:" + e.getMessage());
+	            }
+	            String authlist = "secureid,IWRjYWVSb2FkbTEyMyEt|sample1,c2FtcGxlMQ==|vdnsagg,dmRuc2FnZw==";
+	            NsaAuth = rsv.AuthlistHandler(authlist);
+	            if (NsaAuth != null)
+	            {
+	            	flag = true;
+	            }
+                Assert.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
index 9a50ea0c..902add73 100644
--- a/src/test/java/org/onap/dcae/vestest/TestLoadDynamicConfig.java
+++ b/src/test/java/org/onap/dcae/vestest/TestLoadDynamicConfig.java
@@ -45,8 +45,6 @@ public class TestLoadDynamicConfig {
 	public void setUp() throws Exception {
 	
 		
-		LoadDynamicConfig.propFile = "src/test/resources/testcollector.properties";
-		LoadDynamicConfig.configFile = "src/test/resources/controller-config.json";	
 
 	}
 
@@ -62,6 +60,8 @@ public class TestLoadDynamicConfig {
 		
 		Boolean flag=false;
 		lc = new LoadDynamicConfig();
+		lc.propFile = "src/test/resources/testcollector.properties";
+		lc.configFile = "src/test/resources/controller-config.json";
 		
 		String data = LoadDynamicConfig.readFile(propop);
 		assertEquals(data.isEmpty(), flag);
diff --git a/src/test/java/org/onap/dcae/vestest/TestSchemaValidation.java b/src/test/java/org/onap/dcae/vestest/TestSchemaValidation.java
index fabcc6d2..a34b3336 100644
--- a/src/test/java/org/onap/dcae/vestest/TestSchemaValidation.java
+++ b/src/test/java/org/onap/dcae/vestest/TestSchemaValidation.java
@@ -7,9 +7,9 @@
  * 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.
@@ -21,10 +21,18 @@ package org.onap.dcae.vestest;
 
 import static org.junit.Assert.*;
 
+import java.io.ByteArrayInputStream;
+import java.io.FileNotFoundException;
 import java.io.FileReader;
+import java.io.IOException;
+import java.io.InputStream;
 import java.net.URL;
+import java.nio.charset.StandardCharsets;
 import java.util.Map;
 
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
 import org.json.simple.JSONObject;
 
 import org.junit.After;
@@ -32,44 +40,97 @@ import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
 import org.onap.dcae.commonFunction.CommonStartup;
+import org.onap.dcae.restapi.endpoints.EventReceipt;
 
+import com.att.nsa.drumlin.service.framework.DrumlinServlet;
+import com.att.nsa.drumlin.service.framework.context.DrumlinRequestContext;
 import com.google.gson.JsonParser;
 
 public class TestSchemaValidation {
 
-	CommonStartup cl;
-	String schema = null;
-	String payload = null;
-	String payloadinvalid = null;
+        CommonStartup cl;
+        String schema = null;
+        String payload = null;
+        String payloadinvalid = null;
+
+        @Before
+        public void setUp() throws Exception {
+
+                schema = new JsonParser().parse(new FileReader("etc/CommonEventFormat_27.2.json")).toString();
+                payload = new JsonParser().parse(new FileReader("src/test/resources/VES_valid.txt")).toString();
+                payloadinvalid = new JsonParser().parse(new FileReader("src/test/resources/VES_invalid.txt")).toString();
+
+        }
+
+        @After
+        public void tearDown() throws Exception {
+        }
+
+        @Test
+        public void testsuccessfulschemavalidation() {
+
+                String valresult = CommonStartup.schemavalidate(payload, schema);
+                System.out.println("testsuccessfulschemavalidation:" + valresult);
+                Assert.assertEquals(valresult, "true");
+        }
+
+        @Test
+        public void testunsuccessfulschemavalidation() {
+                String valresult = null;
+                valresult = CommonStartup.schemavalidate(payloadinvalid, schema);
+                System.out.println("testunsuccessfulschemavalidation:" + valresult);
+                Assert.assertFalse(valresult.equals("true"));
+
+        }
+
+
+        @Test
+        public void testeventReceipt() {
+
+                //com.att.nsa.drumlin.service.framework.context.DrumlinRequestContext.DrumlinRequestContext(DrumlinServlet webServlet,
+                //HttpServletRequest req, HttpServletResponse resp, DrumlinConnection s, Map<String, Object> objects, DrumlinRequestRouter router)
+                //HttpServletRequest req = new HttpServletRequest();
+                //HttpServletResponse res = new HttpServletResponse();
+                DrumlinServlet webServlet = new DrumlinServlet();
+                //webServlet.addToBaseContext(key, o);
+                //Map<String,Object> mp = new Map<String, Object>();
+                DrumlinRequestContext ctx = new DrumlinRequestContext(webServlet, null, null, null, null, null);
+                EventReceipt er= new EventReceipt();
+                try {
+                	EventReceipt.receiveVESEvent(null);
+                } catch ( NullPointerException   e) {
+                        // TODO Auto-generated catch block
+
+                }
+
+
+                Assert.assertEquals("true", "true");
 
-	@Before
-	public void setUp() throws Exception {
+        }
 
-		schema = new JsonParser().parse(new FileReader("etc/CommonEventFormat_27.2.json")).toString();
-		payload = new JsonParser().parse(new FileReader("src/test/resources/VES_valid.txt")).toString();
-		payloadinvalid = new JsonParser().parse(new FileReader("src/test/resources/VES_invalid.txt")).toString();
+        @Test
+        public void testsafeclosefr() {
 
-	}
 
-	@After
-	public void tearDown() throws Exception {
-	}
+                FileReader fr;
+                try {
+                        fr = new FileReader("etc/CommonEventFormat_27.2.json");
+                        EventReceipt.safeClose(fr);
+                } catch (FileNotFoundException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                }
+                Assert.assertEquals("true", "true");
 
-	@Test
-	public void testsuccessfulschemavalidation() {
+        }
 
-		String valresult = CommonStartup.schemavalidate(payload, schema);
-		System.out.println("testsuccessfulschemavalidation:" + valresult);
-		Assert.assertEquals(valresult, "true");
-	}
+        @Test
+        public void testsafecloseis() {
 
-	@Test
-	public void testunsuccessfulschemavalidation() {
-		String valresult = null;
-		valresult = CommonStartup.schemavalidate(payloadinvalid, schema);
-		System.out.println("testunsuccessfulschemavalidation:" + valresult);
-		Assert.assertFalse(valresult.equals("true"));
+                        InputStream is = new ByteArrayInputStream(StandardCharsets.UTF_16.encode("randomstring").array());
+                        EventReceipt.safeClose(is);
+                        Assert.assertEquals("true", "true");
 
-	}
+        }
 }