+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