Add unit test cases.
Issue-ID: AAI-429
Change-Id: I3efdaf3b5f477442c691b6095681f34c4e35b53c
Signed-off-by: Aditya Gajulapalli <ag282f@att.com>
--- /dev/null
+package org.onap.aai.sparky.analytics;\r
+\r
+import org.junit.Assert;\r
+import org.junit.Test;\r
+\r
+public class AbstractStatisticsTest {\r
+\r
+ @Test\r
+ public void testAllMethods() {\r
+ AbstractStatistics abs = new AbstractStatistics();\r
+ \r
+ int counterValue1 = abs.getCounterValue("key");\r
+ Assert.assertEquals(-1, counterValue1);\r
+ \r
+ abs.addCounter("key");\r
+ int counterValue2 = abs.getCounterValue("key");\r
+ Assert.assertEquals(0, counterValue2);\r
+ \r
+ abs.pegCounter("key");\r
+ int counterValue3 = abs.getCounterValue("key");\r
+ Assert.assertEquals(1, counterValue3);\r
+ \r
+ abs.incrementCounter("key", 2);\r
+ int counterValue4 = abs.getCounterValue("key");\r
+ Assert.assertEquals(3, counterValue4);\r
+ \r
+ String histStat1 = abs.getHistogramStats("key", false, " ");\r
+ Assert.assertNull(histStat1);\r
+ \r
+ abs.addHistogram("key", "hist1", 10, 1, 2);\r
+ String histStat2 = abs.getHistogramStats("key", false, " ");\r
+ Assert.assertEquals(" hist1,-1,0,0,0,1,10.00,0",histStat2);\r
+ \r
+ abs.updateHistogram("key", 3);\r
+ String histStat3 = abs.getHistogramStats("key", false, " ");\r
+ Assert.assertEquals(" hist1,3,3,3,1,1,10.00,1",histStat3);\r
+ \r
+ abs.reset();\r
+ int counterValue5 = abs.getCounterValue("key");\r
+ String histStat4 = abs.getHistogramStats("key", false, " ");\r
+ Assert.assertEquals(0, counterValue5);\r
+ Assert.assertEquals(" hist1,-1,0,0,0,1,10.00,0",histStat4);\r
+ \r
+ \r
+ }\r
+}\r
--- /dev/null
+package org.onap.aai.sparky.analytics;\r
+\r
+import org.junit.Assert;\r
+import org.junit.Test;\r
+\r
+public class HistoricalCounterTest {\r
+\r
+ \r
+ @Test\r
+ public void testAllMethods() {\r
+ HistoricalCounter hc = new HistoricalCounter(true);\r
+ \r
+ boolean maintainSingleValue = hc.isSingleValue();\r
+ Assert.assertTrue(maintainSingleValue);\r
+ \r
+ hc.update(1.0);\r
+ double value = hc.getValue();\r
+ Assert.assertEquals(1.0, value, 0.1);\r
+ \r
+ double min = hc.getMin();\r
+ Assert.assertEquals(-1, min, 0.1);\r
+ \r
+ double max = hc.getMax();\r
+ Assert.assertEquals(0, max, 0.1);\r
+ \r
+ long numOfSamples = hc.getNumSamples();\r
+ Assert.assertEquals(0, numOfSamples, 0.1);\r
+ \r
+ double avg = hc.getAvg();\r
+ Assert.assertEquals(0, avg, 0.1);\r
+ \r
+ String stringValue = hc.toString();\r
+ Assert.assertNotNull(stringValue);\r
+ \r
+ hc.reset();\r
+ \r
+ double valueReset = hc.getValue();\r
+ Assert.assertEquals(0.0, valueReset, 0.1);\r
+ \r
+ double minReset = hc.getMin();\r
+ Assert.assertEquals(-1, minReset, 0.1);\r
+ \r
+ double maxReset = hc.getMax();\r
+ Assert.assertEquals(0, maxReset, 0.1);\r
+ \r
+ long numOfSamplesReset = hc.getNumSamples();\r
+ Assert.assertEquals(0, numOfSamplesReset, 0.1);\r
+ \r
+ double avgReset = hc.getAvg();\r
+ Assert.assertEquals(0, avgReset, 0.1);\r
+ }\r
+}\r
--- /dev/null
+package org.onap.aai.sparky.config.oxm;\r
+\r
+import org.junit.Assert;\r
+import org.junit.Test;\r
+import org.onap.aai.sparky.config.oxm.CrossEntityReference;\r
+\r
+public class CrossEntityReferenceTest {\r
+\r
+ \r
+ @Test\r
+ public void testCrossEntityReferenceAllMethods() {\r
+ CrossEntityReference cer = new CrossEntityReference();\r
+ \r
+ Assert.assertNull(cer.getTargetEntityType());\r
+ \r
+ cer.setTargetEntityType("TET");\r
+ Assert.assertEquals(cer.getTargetEntityType(), "TET");\r
+ \r
+ Assert.assertEquals(cer.getReferenceAttributes().size(), 0);\r
+ \r
+ cer.addReferenceAttribute("AT");\r
+ \r
+ Assert.assertEquals(cer.getReferenceAttributes().size(), 1);\r
+ \r
+ Assert.assertNotNull(cer.toString());\r
+ }\r
+}\r
--- /dev/null
+package org.onap.aai.sparky.config.oxm;\r
+\r
+import java.io.IOException;\r
+\r
+import javax.servlet.FilterChain;\r
+import javax.servlet.FilterConfig;\r
+import javax.servlet.ServletException;\r
+import javax.servlet.ServletRequest;\r
+import javax.servlet.ServletResponse;\r
+\r
+import org.junit.Before;\r
+import org.junit.Test;\r
+import org.mockito.InjectMocks;\r
+import org.mockito.Mock;\r
+import org.mockito.Mockito;\r
+import org.mockito.MockitoAnnotations;\r
+import org.onap.aai.sparky.config.oxm.OxmModelLoaderFilter;\r
+\r
+public class OxmModelLoaderFilterTest {\r
+\r
+ @Mock\r
+ ServletRequest servletRequest;\r
+ \r
+ @Mock\r
+ ServletResponse servletResponse;\r
+ \r
+ @Mock\r
+ FilterChain filterChain;\r
+ \r
+ @Mock\r
+ FilterConfig filterConfig;\r
+ \r
+ @InjectMocks\r
+ OxmModelLoaderFilter oxmModelLoaderFilter;\r
+ \r
+ @Before\r
+ public void init() {\r
+ MockitoAnnotations.initMocks(this);\r
+ }\r
+ \r
+ @Test\r
+ public void testDoFilter() throws IOException, ServletException{\r
+ Mockito.doNothing().when(filterChain).doFilter(Mockito.any(ServletRequest.class), Mockito.any(ServletResponse.class));\r
+ oxmModelLoaderFilter.doFilter(servletRequest, servletResponse, filterChain);\r
+ Mockito.verify(filterChain, Mockito.times(1)).doFilter(Mockito.any(ServletRequest.class), Mockito.any(ServletResponse.class));\r
+ }\r
+ \r
+ /*This test is taking more than 5 secs. Commented out\r
+ @Test\r
+ public void testInit() throws ServletException {\r
+ OxmModelLoaderFilter oxmFilter = new OxmModelLoaderFilter();\r
+ oxmFilter.init(filterConfig);\r
+ }*/\r
+ \r
+}\r
--- /dev/null
+package org.onap.aai.sparky.dal;\r
+\r
+import org.junit.Assert;\r
+import org.junit.Test;\r
+import org.onap.aai.sparky.config.oxm.OxmEntityDescriptor;\r
+import org.onap.aai.sparky.dal.rest.HttpMethod;\r
+import org.onap.aai.sparky.dal.rest.OperationResult;\r
+\r
+public class NetworkTransactionTest {\r
+\r
+ @Test\r
+ public void testAllMethods() {\r
+ NetworkTransaction ntt = new NetworkTransaction();\r
+ ntt.setOperationType(HttpMethod.GET);\r
+ Assert.assertEquals(HttpMethod.GET, ntt.getOperationType());\r
+ \r
+ ntt.setTaskAgeInMs();\r
+ Assert.assertNotNull(ntt.getTaskAgeInMs());\r
+ \r
+ ntt.setOperationResult(new OperationResult());\r
+ Assert.assertNotNull(ntt.getOperationResult());\r
+ \r
+ ntt.setEntityType("entity");\r
+ Assert.assertEquals(ntt.getEntityType(), "entity");\r
+ \r
+ ntt.setLink("link");\r
+ Assert.assertEquals(ntt.getLink(), "link");\r
+ \r
+ ntt.setDescriptor(new OxmEntityDescriptor());\r
+ Assert.assertNotNull(ntt.getDescriptor());\r
+ \r
+ Assert.assertNotNull(ntt.toString());\r
+ }\r
+ \r
+ \r
+}\r
--- /dev/null
+package org.onap.aai.sparky.dal.aai;\r
+\r
+import java.util.HashMap;\r
+import java.util.Map;\r
+\r
+import org.junit.Assert;\r
+import org.junit.Before;\r
+import org.junit.Test;\r
+import org.onap.aai.sparky.config.oxm.OxmEntityDescriptor;\r
+import org.onap.aai.sparky.config.oxm.OxmModelLoader;\r
+import org.onap.aai.sparky.dal.NetworkTransaction;\r
+import org.onap.aai.sparky.dal.rest.HttpMethod;\r
+import org.onap.aai.sparky.dal.rest.OperationResult;\r
+\r
+public class ActiveInventoryEntityStatisticsTest {\r
+\r
+ OxmModelLoader oxmModelLoader;\r
+ \r
+ @Before\r
+ public void init() {\r
+ oxmModelLoader = OxmModelLoader.getInstance();\r
+ }\r
+ \r
+ @Test\r
+ public void testInitializeCountersFromOxmEntityDescriptors_NotNullDescriptors() {\r
+ ActiveInventoryEntityStatistics aies = new ActiveInventoryEntityStatistics(oxmModelLoader);\r
+ \r
+ Map<String, OxmEntityDescriptor> descriptors = new HashMap<>();\r
+ \r
+ OxmEntityDescriptor oxmEd = new OxmEntityDescriptor();\r
+ oxmEd.setEntityName("entity-1");\r
+ oxmEd.setGeoLatName("geoLatName-1");\r
+ \r
+ descriptors.put("entity-1", oxmEd);\r
+ \r
+ aies.initializeCountersFromOxmEntityDescriptors(descriptors);\r
+ \r
+ aies.reset();\r
+ \r
+ }\r
+ \r
+ @Test\r
+ public void testInitializeCountersFromOxmEntityDescriptors_NullDescriptors() {\r
+ ActiveInventoryEntityStatistics aies = new ActiveInventoryEntityStatistics(oxmModelLoader);\r
+ \r
+ Map<String, OxmEntityDescriptor> descriptors = null;\r
+ \r
+ aies.initializeCountersFromOxmEntityDescriptors(descriptors);\r
+ \r
+ }\r
+ \r
+ @Test\r
+ public void testUpdateCounters() {\r
+ \r
+ ActiveInventoryEntityStatistics aies = new ActiveInventoryEntityStatistics(oxmModelLoader);\r
+ Map<String, OxmEntityDescriptor> descriptors = new HashMap<>();\r
+ OxmEntityDescriptor oxmEd = new OxmEntityDescriptor();\r
+ oxmEd.setEntityName("entity-1");\r
+ oxmEd.setGeoLatName("geoLatName-1");\r
+ descriptors.put("entity-1", oxmEd);\r
+ aies.initializeCountersFromOxmEntityDescriptors(descriptors);\r
+ \r
+ OperationResult result = new OperationResult();\r
+ result.setResultCode(200);\r
+ result.setResult("result-1");\r
+ result.setNumRequestRetries(1);\r
+ NetworkTransaction ntwTxn = new NetworkTransaction(HttpMethod.GET, "entity-1", result);\r
+ \r
+ aies.updateCounters(ntwTxn);\r
+ \r
+ String statistics = aies.getStatisticsReport();\r
+ Assert.assertNotNull(statistics);\r
+ \r
+ }\r
+}\r
--- /dev/null
+package org.onap.aai.sparky.dal.aai;\r
+\r
+import org.junit.Assert;\r
+import org.junit.Test;\r
+import org.onap.aai.sparky.dal.NetworkTransaction;\r
+import org.onap.aai.sparky.dal.rest.HttpMethod;\r
+import org.onap.aai.sparky.dal.rest.OperationResult;\r
+\r
+public class ActiveInventoryProcessingExceptionStatisticsTest {\r
+\r
+ \r
+ @Test\r
+ public void testUpdateCounters() {\r
+ ActiveInventoryProcessingExceptionStatistics aipes = new ActiveInventoryProcessingExceptionStatistics();\r
+ \r
+ aipes.incrementCounter("NativeSocketConnectException", 1);\r
+ aipes.incrementCounter("NativeSocketConnectionReset", 1);\r
+ aipes.incrementCounter("NativeSocketConnectionRefused", 1);\r
+ aipes.incrementCounter("JerseyClientTimoutException", 1);\r
+ aipes.incrementCounter("UnknownException", 1);\r
+ \r
+ OperationResult result = new OperationResult();\r
+ result.setResultCode(310);\r
+ result.setResult("java.net.SocketTimeoutException: connect timed out");\r
+ result.setNumRequestRetries(1);\r
+ NetworkTransaction ntwTxn1 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);\r
+ aipes.updateCounters(ntwTxn1);\r
+ \r
+ result.setResult("result-1");\r
+ NetworkTransaction ntwTxn2 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);\r
+ aipes.updateCounters(ntwTxn2);\r
+ \r
+ result.setResult("java.net.ConnectException: Connection timed out: connect"); \r
+ NetworkTransaction ntwTxn3 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);\r
+ aipes.updateCounters(ntwTxn3);\r
+ \r
+ result.setResult("java.net.ConnectException: Connection refused: connect"); \r
+ NetworkTransaction ntwTxn4 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);\r
+ aipes.updateCounters(ntwTxn4);\r
+ \r
+ result.setResult("java.net.SocketException: Connection reset"); \r
+ NetworkTransaction ntwTxn5 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);\r
+ aipes.updateCounters(ntwTxn5);\r
+ \r
+ }\r
+ \r
+ @Test\r
+ public void testGetStatisticsReport() {\r
+ ActiveInventoryProcessingExceptionStatistics aipes = new ActiveInventoryProcessingExceptionStatistics();\r
+ \r
+ aipes.incrementCounter("NativeSocketConnectException", 1);\r
+ aipes.incrementCounter("NativeSocketConnectionReset", 1);\r
+ aipes.incrementCounter("NativeSocketConnectionRefused", 1);\r
+ aipes.incrementCounter("JerseyClientTimoutException", 1);\r
+ aipes.incrementCounter("UnknownException", 1);\r
+ \r
+ String statReport = aipes.getStatisticsReport();\r
+ Assert.assertNotNull(statReport);\r
+ }\r
+}\r
--- /dev/null
+package org.onap.aai.sparky.dal.cache;\r
+\r
+import org.junit.Assert;\r
+import org.junit.Test;\r
+import org.onap.aai.sparky.dal.rest.OperationResult;\r
+\r
+public class InMemoryEntityCacheTest {\r
+\r
+ @Test\r
+ public void testInMemoryEntityCache_AllMethods() {\r
+ \r
+ InMemoryEntityCache imec = new InMemoryEntityCache();\r
+ \r
+ imec.put("key-1", null);\r
+ Assert.assertNull(imec.get("entity-1", "key-1"));\r
+ Assert.assertNull(imec.get("entity-1", null));\r
+ \r
+ OperationResult result = new OperationResult();\r
+ result.setResultCode(200);\r
+ result.setResult("result-1");\r
+ result.setNumRequestRetries(1);\r
+ \r
+ imec.put("key-1", result);\r
+ Assert.assertNotNull(imec.get("entity-1", "key-1"));\r
+ }\r
+}\r