aboutsummaryrefslogtreecommitdiffstats
path: root/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter
diff options
context:
space:
mode:
authorPooja03 <pm00501616@techmahindra.com>2019-03-20 19:39:58 +0530
committerPooja Malik <PM00501616@techmahindra.com>2019-03-22 10:09:32 +0000
commit5e76fbd802ca4dcf48dac5c9a8f262470a326ef7 (patch)
tree0ce8b9549c76ac909c52d503dc0e16820fc09658 /UniversalVesAdapter/src/test/java/org/onap/universalvesadapter
parent52f8f061b460c84d03e570958950a2e63a4f6461 (diff)
Resolving warning reported in build - VES Mapper
Changes made to resolve warnings in the build. Change-Id: I03dee6780941881afc65c4b907ade078febb5e39 Issue-ID: DCAEGEN2-604 Signed-off-by: Pooja03 <pm00501616@techmahindra.com>
Diffstat (limited to 'UniversalVesAdapter/src/test/java/org/onap/universalvesadapter')
-rw-r--r--UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/adapter/UniversalEventAdapterTest.java236
-rw-r--r--UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/configs/DmaapMrBaseConfigTest.java (renamed from UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/configs/DMaaPMRBaseConfigTest.java)153
-rw-r--r--UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/controller/VesControllerTest.java134
-rw-r--r--UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/exception/ConfigFileSmooksConversionExceptionTest.java72
-rw-r--r--UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/exception/DMaapExceptionTest.java84
-rw-r--r--UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/exception/MapperConfigExceptionTest.java65
-rw-r--r--UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/mappingconfig/EntryTest.java119
-rw-r--r--UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/mappingconfig/EvaluationTest.java140
-rw-r--r--UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/mappingconfig/MapperConfigTest.java109
-rw-r--r--UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/service/VesServiceTest.java244
-rw-r--r--UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/utils/SmooksUtilsTest.java217
11 files changed, 781 insertions, 792 deletions
diff --git a/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/adapter/UniversalEventAdapterTest.java b/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/adapter/UniversalEventAdapterTest.java
index c866235..b016cc7 100644
--- a/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/adapter/UniversalEventAdapterTest.java
+++ b/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/adapter/UniversalEventAdapterTest.java
@@ -1,22 +1,22 @@
-/*
-* ============LICENSE_START=======================================================
-* ONAP : DCAE
-* ================================================================================
-* Copyright 2018 TechMahindra
-*=================================================================================
-* 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=========================================================
-*/
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP : DCAE
+ * ================================================================================
+ * Copyright 2018-2019 TechMahindra
+ * ================================================================================
+ * 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.universalvesadapter.adapter;
@@ -25,6 +25,7 @@ import static org.junit.Assert.assertNotNull;
import java.util.HashMap;
import java.util.Map;
+
import org.junit.Before;
import org.junit.Test;
import org.junit.runner.RunWith;
@@ -45,97 +46,108 @@ import org.springframework.boot.test.context.SpringBootTest;
@RunWith(PowerMockRunner.class)
@SpringBootTest(classes = Application.class)
public class UniversalEventAdapterTest {
-
- private static final Logger errorLogger = LoggerFactory.getLogger("errorLogger");
-
- @Mock
- private VESAdapterInitializer vesAdapterInitializer;
-
- @InjectMocks
- private UniversalEventAdapter universalVesAdapter;
-
- @Before
- public void init() {
- MockitoAnnotations.initMocks(this);
- }
-
- @PrepareForTest({ CollectorConfigPropertyRetrival.class })
- @Test
- public void testtransform() {
-
- StringBuffer incomingJsonString = new StringBuffer("{\n" + " \"rule-id\": \"12121\",\n"
- + " \"notification\": {\n" + " \"event-time\": \"2018-03-15T08:15:32.000Z\",\n"
- + " \"notification-id\": \"2541256\",\n" + " \"message\": {\n"
- + " \"topic\":\"resource\",\n" + " \"object-type\":\"onu\", \n"
- + " \"version\": \"v1\", \n" + " \"operation\": \"create\", \n"
- + " \"target\": \"ont/ont=23hk1231231232\", \n" + " \"content\": {\n"
- + " \"onu\": {\n" + " \"sn\": \"48575443FA637D1A\",\n"
- + " \"refParentNE\": \"550e8400-e29b-41d4-a716-446655440000\",\n"
- + " \"refParentNeNativeId\": \"FDN\",\n"
- + " \"refParentLTP\": \"8c0db89e-218c-4e18-b0de-7a6788b3dda4\",\n"
- + " \"refParentLTPNativeId\": \"FDN\",\n"
- + " \"onuId\": \"213\",\n" + " \"accessID\": \"HG65875420001\"\n"
- + " }\n" + " }\n" + " }\n" + " }\n" + "}");
- Map<String, String> testMap = new HashMap<String, String>();
- testMap.put("defaultMappingFile-" + Thread.currentThread().getName(),
- "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n"
- + "<smooks-resource-list xmlns=\"http://www.milyn.org/xsd/smooks-1.1.xsd\" xmlns:jb=\"http://www.milyn.org/xsd/smooks/javabean-1.4.xsd\" xmlns:json=\"http://www.milyn.org/xsd/smooks/json-1.1.xsd\">\n"
- + " <json:reader rootName=\"vesevent\" keyWhitspaceReplacement=\"-\">\n"
- + " <json:keyMap>\n"
- + " <json:key from=\"date&amp;time\" to=\"date-and-time\" />\n"
- + " </json:keyMap>\n" + " </json:reader>\n"
- + " <jb:bean class=\"org.onap.dcaegen2.ves.domain.ves7_0.VesEvent\""
- + " beanId=\"vesEvent\" createOnElement=\"vesevent\">\n"
- + " <jb:wiring property=\"event\" beanIdRef=\"event\" />\n" + " </jb:bean>\n"
- + " <jb:bean class=\"org.onap.dcaegen2.ves.domain.ves7_0.Event\" "
- + "beanId=\"event\" createOnElement=\"vesevent\">\n"
- + " <jb:wiring property=\"commonEventHeader\" beanIdRef=\"commonEventHeader\" />\n"
- + " <jb:wiring property=\"pnfRegistrationFields\" beanIdRef=\"pnfRegistrationFields\" />\n"
- + " </jb:bean>\n"
- + " <jb:bean class=\"org.onap.dcaegen2.ves.domain.ves7_0.CommonEventHeader\""
- + " beanId=\"commonEventHeader\" createOnElement=\"vesevent\">\n"
- + "<jb:expression property=\"version\">"
- + "org.onap.dcaegen2.ves.domain.ves7_0.CommonEventHeader.Version._4_0_1</jb:expression> \n"
- + "<jb:expression property=\"eventType\">\"pnfRegistration\"</jb:expression>\n"
- + "<jb:expression property=\"vesEventListenerVersion\">"
- + "org.onap.dcaegen2.ves.domain.ves7_0.CommonEventHeader.VesEventListenerVersion._7_0_1</jb:expression>\n"
- + " <jb:expression property=\"eventId\" execOnElement=\"vesevent\">"
- + "\"registration_\"+commonEventHeader.ts1</jb:expression>\n"
- + "<jb:expression property=\"reportingEntityName\">\"VESMapper\"</jb:expression>\n"
- + " <jb:expression property=\"domain\">"
- + "org.onap.dcaegen2.ves.domain.ves7_0.CommonEventHeader.Domain.PNF_REGISTRATION</jb:expression>\n"
- + " <jb:expression property=\"eventName\" execOnElement=\"vesevent\">"
- + "commonEventHeader.domain</jb:expression>\n"
- + "<jb:value property=\"sequence\" data=\"0\" default=\"0\" decoder=\"Long\" />\n"
- + "<jb:expression property=\"lastEpochMicrosec\" execOnElement=\"vesevent\">"
- + "commonEventHeader.ts1</jb:expression>\n"
- + " <jb:expression property=\"startEpochMicrosec\" execOnElement=\"vesevent\">"
- + "commonEventHeader.ts1</jb:expression>\n" + " <jb:expression property=\"priority\">"
- + "org.onap.dcaegen2.ves.domain.ves7_0.CommonEventHeader.Priority.NORMAL</jb:expression>\n"
- + " <jb:value property=\"sourceName\" data=\"notification/message/target\" />\n"
- + " </jb:bean>\n"
- + " <jb:bean class=\"org.onap.dcaegen2.ves.domain.ves7_0.PnfRegistrationFields\""
- + " beanId=\"pnfRegistrationFields\" createOnElement=\"vesevent\">\n" + " \n"
- + " <jb:expression property=\"pnfRegistrationFieldsVersion\">"
- + "org.onap.dcaegen2.ves.domain.ves7_0.PnfRegistrationFields.PnfRegistrationFieldsVersion._2_0"
- + "</jb:expression>\n"
- + " <jb:value property=\"serialNumber\" data=\"notification/message/content/onu/sn\" />\n"
- + " \n" + " </jb:bean>\n" + "</smooks-resource-list>");
-
- try {
- vesAdapterInitializer.setMappingFiles(testMap);
-
- String identifiertest[] = CollectorConfigPropertyRetrival.getProperyArray("identifier", "kvTest.json");
- PowerMockito.mockStatic(CollectorConfigPropertyRetrival.class);
- PowerMockito.when(CollectorConfigPropertyRetrival.getProperyArray("identifier", null))
- .thenReturn(identifiertest);
-
- String actualResult = universalVesAdapter.transform(incomingJsonString.toString());
- assertNotNull(actualResult);
- assertNotEquals("", actualResult);
- } catch (VesException exception) {
- errorLogger.error("Error occurred : {}", exception);
- }
- }
-
+
+ private static final Logger errorLogger = LoggerFactory.getLogger("errorLogger");
+
+ @Mock
+ private VESAdapterInitializer vesAdapterInitializer;
+
+ @InjectMocks
+ private UniversalEventAdapter universalVesAdapter;
+
+ @Before
+ public void init() {
+ MockitoAnnotations.initMocks(this);
+ }
+
+ @PrepareForTest({CollectorConfigPropertyRetrival.class})
+ @Test
+ public void testtransform() {
+
+ StringBuffer incomingJsonString = new StringBuffer("{\n" + " \"rule-id\": \"12121\",\n"
+ + " \"notification\": {\n"
+ + " \"event-time\": \"2018-03-15T08:15:32.000Z\",\n"
+ + " \"notification-id\": \"2541256\",\n" + " \"message\": {\n"
+ + " \"topic\":\"resource\",\n"
+ + " \"object-type\":\"onu\", \n"
+ + " \"version\": \"v1\", \n"
+ + " \"operation\": \"create\", \n"
+ + " \"target\": \"ont/ont=23hk1231231232\", \n"
+ + " \"content\": {\n" + " \"onu\": {\n"
+ + " \"sn\": \"48575443FA637D1A\",\n"
+ + " \"refParentNE\": \"550e8400-e29b-41d4-a716-446655440000\",\n"
+ + " \"refParentNeNativeId\": \"FDN\",\n"
+ + " \"refParentLTP\": \"8c0db89e-218c-4e18-b0de-7a6788b3dda4\",\n"
+ + " \"refParentLTPNativeId\": \"FDN\",\n"
+ + " \"onuId\": \"213\",\n"
+ + " \"accessID\": \"HG65875420001\"\n" + " }\n"
+ + " }\n" + " }\n" + " }\n" + "}");
+ Map<String, String> testMap = new HashMap<String, String>();
+ testMap.put("defaultMappingFile-" + Thread.currentThread().getName(),
+ "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n"
+ + "<smooks-resource-list xmlns=\"http://www.milyn.org/xsd/smooks-1.1.xsd\" xmlns:jb=\"http://www.milyn.org/xsd/smooks/javabean-1.4.xsd\" xmlns:json=\"http://www.milyn.org/xsd/smooks/json-1.1.xsd\">\n"
+ + " <json:reader rootName=\"vesevent\" keyWhitspaceReplacement=\"-\">\n"
+ + " <json:keyMap>\n"
+ + " <json:key from=\"date&amp;time\" to=\"date-and-time\" />\n"
+ + " </json:keyMap>\n" + " </json:reader>\n"
+ + " <jb:bean class=\"org.onap.dcaegen2.ves.domain.ves70.VesEvent\""
+ + " beanId=\"vesEvent\" createOnElement=\"vesevent\">\n"
+ + " <jb:wiring property=\"event\" beanIdRef=\"event\" />\n"
+ + " </jb:bean>\n"
+ + " <jb:bean class=\"org.onap.dcaegen2.ves.domain.ves70.Event\" "
+ + "beanId=\"event\" createOnElement=\"vesevent\">\n"
+ + " <jb:wiring property=\"commonEventHeader\" beanIdRef=\"commonEventHeader\" />\n"
+ + " <jb:wiring property=\"pnfRegistrationFields\" beanIdRef=\"pnfRegistrationFields\" />\n"
+ + " </jb:bean>\n"
+ + " <jb:bean class=\"org.onap.dcaegen2.ves.domain.ves70.CommonEventHeader\""
+ + " beanId=\"commonEventHeader\" createOnElement=\"vesevent\">\n"
+ + "<jb:expression property=\"version\">"
+ + "org.onap.dcaegen2.ves.domain.ves70.CommonEventHeader.Version._4_0_1</jb:expression> \n"
+ + "<jb:expression property=\"eventType\">\"pnfRegistration\"</jb:expression>\n"
+ + "<jb:expression property=\"vesEventListenerVersion\">"
+ + "org.onap.dcaegen2.ves.domain.ves70.CommonEventHeader.VesEventListenerVersion._7_0_1"
+ + "</jb:expression>\n"
+ + " <jb:expression property=\"eventId\" execOnElement=\"vesevent\">"
+ + "\"registration_\"+commonEventHeader.ts1</jb:expression>\n"
+ + "<jb:expression property=\"reportingEntityName\">\"VESMapper\"</jb:expression>\n"
+ + " <jb:expression property=\"domain\">"
+ + "org.onap.dcaegen2.ves.domain.ves70.CommonEventHeader.Domain.PNF_REGISTRATION"
+ + "</jb:expression>\n"
+ + " <jb:expression property=\"eventName\" execOnElement=\"vesevent\">"
+ + "commonEventHeader.domain</jb:expression>\n"
+ + "<jb:value property=\"sequence\" data=\"0\" default=\"0\" decoder=\"Long\" />\n"
+ + "<jb:expression property=\"lastEpochMicrosec\" execOnElement=\"vesevent\">"
+ + "commonEventHeader.ts1</jb:expression>\n"
+ + " <jb:expression property=\"startEpochMicrosec\" execOnElement=\"vesevent\">"
+ + "commonEventHeader.ts1</jb:expression>\n"
+ + " <jb:expression property=\"priority\">"
+ + "org.onap.dcaegen2.ves.domain.ves70.CommonEventHeader.Priority.NORMAL</jb:expression>\n"
+ + " <jb:value property=\"sourceName\" data=\"notification/message/target\" />\n"
+ + " </jb:bean>\n"
+ + " <jb:bean class=\"org.onap.dcaegen2.ves.domain.ves70.PnfRegistrationFields\""
+ + " beanId=\"pnfRegistrationFields\" createOnElement=\"vesevent\">\n"
+ + " \n"
+ + " <jb:expression property=\"pnfRegistrationFieldsVersion\">"
+ + "org.onap.dcaegen2.ves.domain.ves70.PnfRegistrationFields.PnfRegistrationFieldsVersion._2_0"
+ + "</jb:expression>\n"
+ + " <jb:value property=\"serialNumber\" data=\"notification/message/content/onu/sn\" />\n"
+ + " \n" + " </jb:bean>\n" + "</smooks-resource-list>");
+
+ try {
+ vesAdapterInitializer.setMappingFiles(testMap);
+
+ String [] identifiertest =
+ CollectorConfigPropertyRetrival.getProperyArray("identifier", "kvTest.json");
+ PowerMockito.mockStatic(CollectorConfigPropertyRetrival.class);
+ PowerMockito.when(CollectorConfigPropertyRetrival.getProperyArray("identifier", null))
+ .thenReturn(identifiertest);
+
+ String actualResult = universalVesAdapter.transform(incomingJsonString.toString());
+ assertNotNull(actualResult);
+ assertNotEquals("", actualResult);
+ } catch (VesException exception) {
+ errorLogger.error("Error occurred : {}", exception);
+ }
+ }
+
}
diff --git a/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/configs/DMaaPMRBaseConfigTest.java b/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/configs/DmaapMrBaseConfigTest.java
index 0ec9557..495722f 100644
--- a/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/configs/DMaaPMRBaseConfigTest.java
+++ b/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/configs/DmaapMrBaseConfigTest.java
@@ -1,75 +1,78 @@
-/*-
- * ============LICENSE_START=======================================================
- * Copyright (C) 2019 Samsung. 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.universalvesadapter.configs;
-
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertNotNull;
-import static org.junit.Assert.assertNull;
-import org.junit.Before;
-import org.junit.Test;
-import org.mockito.Mockito;
-import org.onap.universalvesadapter.exception.DMaapException;
-
-public class DMaaPMRBaseConfigTest {
- DMaaPMRBaseConfig dmaapMRBaseConfig = null;
- public static final String JSON_APPLICATION_TYPE = "application/json";
-
- @Before
- public void setUp() throws Exception {
- dmaapMRBaseConfig = Mockito.mock(DMaaPMRBaseConfig.class, Mockito.CALLS_REAL_METHODS);
- }
-
- @Test
- public void testDMaaPMRBaseConfigGetMethods() {
- assertNotNull(dmaapMRBaseConfig);
- assertNull(dmaapMRBaseConfig.getHostName());
- assertNull(dmaapMRBaseConfig.getPortNumber());
- assertNull(dmaapMRBaseConfig.getTopicName());
- assertNull(dmaapMRBaseConfig.getProtocol());
- assertNull(dmaapMRBaseConfig.getContentType());
- assertNull(dmaapMRBaseConfig.getUserName());
- assertNull(dmaapMRBaseConfig.getUserPassword());
- }
-
- @Test(expected = DMaapException.class)
- public void testNormalizeValidateProtocol() {
- DMaaPMRBaseConfig.normalizeValidateProtocol("");
- }
-
- @Test(expected = DMaapException.class)
- public void testNormalizeValidateProtocolWithDifferentProtocol() {
- DMaaPMRBaseConfig.normalizeValidateProtocol("FTP");
- }
-
- @Test
- public void testNormalizeValidateProtocolWithProperValue() {
- assertEquals("https", DMaaPMRBaseConfig.normalizeValidateProtocol("HTTPS"));
- assertEquals("http", DMaaPMRBaseConfig.normalizeValidateProtocol("HTTP"));
- }
-
- @Test(expected = DMaapException.class)
- public void testNormalizeValidateContentType() {
- DMaaPMRBaseConfig.normalizeValidateContentType("");
- }
-
- @Test
- public void testNormalizeValidateContentTypeWithProperValue() {
- assertEquals(JSON_APPLICATION_TYPE, DMaaPMRBaseConfig.normalizeValidateContentType("application/json"));
- }
-}
+/*-
+ * ============LICENSE_START=======================================================
+ * Copyright (C) 2019 Samsung. 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.universalvesadapter.configs;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertNull;
+
+import org.junit.Before;
+import org.junit.Test;
+import org.mockito.Mockito;
+import org.onap.universalvesadapter.exception.DMaapException;
+
+public class DmaapMrBaseConfigTest {
+ DMaaPMRBaseConfig dmaapMrBaseConfig = null;
+ public static final String JSON_APPLICATION_TYPE = "application/json";
+
+ @Before
+ public void setUp() throws Exception {
+ dmaapMrBaseConfig = Mockito.mock(DMaaPMRBaseConfig.class, Mockito.CALLS_REAL_METHODS);
+ }
+
+ @Test
+ public void testDmaapMrBaseConfigGetMethods() {
+ assertNotNull(dmaapMrBaseConfig);
+ assertNull(dmaapMrBaseConfig.getHostName());
+ assertNull(dmaapMrBaseConfig.getPortNumber());
+ assertNull(dmaapMrBaseConfig.getTopicName());
+ assertNull(dmaapMrBaseConfig.getProtocol());
+ assertNull(dmaapMrBaseConfig.getContentType());
+ assertNull(dmaapMrBaseConfig.getUserName());
+ assertNull(dmaapMrBaseConfig.getUserPassword());
+ }
+
+ @Test(expected = DMaapException.class)
+ public void testNormalizeValidateProtocol() {
+ DMaaPMRBaseConfig.normalizeValidateProtocol("");
+ }
+
+ @Test(expected = DMaapException.class)
+ public void testNormalizeValidateProtocolWithDifferentProtocol() {
+ DMaaPMRBaseConfig.normalizeValidateProtocol("FTP");
+ }
+
+ @Test
+ public void testNormalizeValidateProtocolWithProperValue() {
+ assertEquals("https", DMaaPMRBaseConfig.normalizeValidateProtocol("HTTPS"));
+ assertEquals("http", DMaaPMRBaseConfig.normalizeValidateProtocol("HTTP"));
+ }
+
+ @Test(expected = DMaapException.class)
+ public void testNormalizeValidateContentType() {
+ DMaaPMRBaseConfig.normalizeValidateContentType("");
+ }
+
+ @Test
+ public void testNormalizeValidateContentTypeWithProperValue() {
+ assertEquals(JSON_APPLICATION_TYPE,
+ DMaaPMRBaseConfig.normalizeValidateContentType("application/json"));
+ }
+}
diff --git a/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/controller/VesControllerTest.java b/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/controller/VesControllerTest.java
index cbacc61..829ae0d 100644
--- a/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/controller/VesControllerTest.java
+++ b/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/controller/VesControllerTest.java
@@ -1,65 +1,69 @@
-/*
-* ============LICENSE_START=======================================================
-* ONAP : DCAE
-* ================================================================================
-* Copyright 2018 TechMahindra
-*=================================================================================
-* 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.universalvesadapter.controller;
-
-import static org.junit.Assert.assertEquals;
-import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.get;
-import static org.springframework.test.web.servlet.result.MockMvcResultHandlers.print;
-import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.status;
-
-import org.junit.Ignore;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.onap.universalvesadapter.Application;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.test.autoconfigure.web.servlet.AutoConfigureMockMvc;
-import org.springframework.boot.test.context.SpringBootTest;
-import org.springframework.test.context.junit4.SpringRunner;
-import org.springframework.test.web.servlet.MockMvc;
-import org.springframework.test.web.servlet.MvcResult;
-
-@RunWith(SpringRunner.class)
-@SpringBootTest(classes=Application.class)
-@AutoConfigureMockMvc
-@Ignore
-public class VesControllerTest {
-
- @Autowired
- private MockMvc mockMvc;
-
- @Test
- public void startShouldReturnApplicationStartedMessage() throws Exception {
-
- MvcResult mvcResult = this.mockMvc.perform(get("/start")).andDo(print()).andExpect(status().isOk())
- .andReturn();//Expect(jsonPath("$.content").value("Application started"));
- assertEquals("Application started", mvcResult.getResponse().getContentAsString());
- }
-
- @Test
- public void stopShouldReturnApplicationStoppingMessage() throws Exception {
-
- MvcResult mvcResult = this.mockMvc.perform(get("/stop")).andDo(print()).andExpect(status().isOk())
- .andReturn();//.andExpect(jsonPath("$.content").value("Application will be stopped soon"));
- assertEquals("Application will be stopped soon", mvcResult.getResponse().getContentAsString());
- }
-
-
-
-}
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP : DCAE
+ * ================================================================================
+ * Copyright 2018-2019 TechMahindra
+ * ================================================================================
+ * 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.universalvesadapter.controller;
+
+import static org.junit.Assert.assertEquals;
+import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.get;
+import static org.springframework.test.web.servlet.result.MockMvcResultHandlers.print;
+import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.status;
+
+import org.junit.Ignore;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.onap.universalvesadapter.Application;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.autoconfigure.web.servlet.AutoConfigureMockMvc;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringRunner;
+import org.springframework.test.web.servlet.MockMvc;
+import org.springframework.test.web.servlet.MvcResult;
+
+@RunWith(SpringRunner.class)
+@SpringBootTest(classes = Application.class)
+@AutoConfigureMockMvc
+@Ignore
+public class VesControllerTest {
+
+ @Autowired
+ private MockMvc mockMvc;
+
+ @Test
+ public void startShouldReturnApplicationStartedMessage() throws Exception {
+
+ MvcResult mvcResult = this.mockMvc.perform(get("/start")).andDo(print())
+ .andExpect(status().isOk()).andReturn();
+ // Expect(jsonPath("$.content").value("Application started"));
+ assertEquals("Application started", mvcResult.getResponse().getContentAsString());
+ }
+
+ @Test
+ public void stopShouldReturnApplicationStoppingMessage() throws Exception {
+
+ MvcResult mvcResult = this.mockMvc.perform(get("/stop")).andDo(print())
+ .andExpect(status().isOk()).andReturn();
+ // .andExpect(jsonPath("$.content").value("Application will be stopped soon"));
+ assertEquals("Application will be stopped soon",
+ mvcResult.getResponse().getContentAsString());
+ }
+
+
+
+}
diff --git a/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/exception/ConfigFileSmooksConversionExceptionTest.java b/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/exception/ConfigFileSmooksConversionExceptionTest.java
index ac60be1..ff30305 100644
--- a/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/exception/ConfigFileSmooksConversionExceptionTest.java
+++ b/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/exception/ConfigFileSmooksConversionExceptionTest.java
@@ -1,35 +1,37 @@
-/*
-* ============LICENSE_START=======================================================
-* ONAP : DCAE
-* ================================================================================
-* Copyright 2018 TechMahindra
-*=================================================================================
-* 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.universalvesadapter.exception;
-
-import org.junit.Test;
-
-public class ConfigFileSmooksConversionExceptionTest {
-
-
- @Test
- public void test() {
- ConfigFileSmooksConversionException se = new ConfigFileSmooksConversionException("message");
- ConfigFileSmooksConversionException se1 = new ConfigFileSmooksConversionException("message", se);
-
-
- }
-
-}
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP : DCAE
+ * ================================================================================
+ * Copyright 2018-2019 TechMahindra
+ * ================================================================================
+ * 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.universalvesadapter.exception;
+
+import org.junit.Test;
+
+public class ConfigFileSmooksConversionExceptionTest {
+
+
+ @Test
+ public void test() {
+ ConfigFileSmooksConversionException se = new ConfigFileSmooksConversionException("message");
+ ConfigFileSmooksConversionException se1 =
+ new ConfigFileSmooksConversionException("message", se);
+
+
+ }
+
+}
diff --git a/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/exception/DMaapExceptionTest.java b/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/exception/DMaapExceptionTest.java
index 4da29de..0f24229 100644
--- a/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/exception/DMaapExceptionTest.java
+++ b/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/exception/DMaapExceptionTest.java
@@ -1,41 +1,43 @@
-/*
-* ============LICENSE_START=======================================================
-* ONAP : DCAE
-* ================================================================================
-* Copyright 2018 TechMahindra
-*=================================================================================
-* 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.universalvesadapter.exception;
-
-import static org.junit.Assert.assertNotNull;
-import org.junit.Test;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class DMaapExceptionTest {
- private static final Logger debugLogger = LoggerFactory.getLogger("debugLogger");
-
- @Test
- public void test() {
- DMaapException se = new DMaapException("message");
- assertNotNull(se);
- DMaapException se1 = new DMaapException("message", se);
- assertNotNull(se1);
- DMaapException se2 = new DMaapException("message", se.getCause());
- assertNotNull(se2);
- DMaapException se3 = new DMaapException("message", debugLogger, se);
- assertNotNull(se3);
- }
-}
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP : DCAE
+ * ================================================================================
+ * Copyright 2018-2019 TechMahindra
+ * ================================================================================
+ * 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.universalvesadapter.exception;
+
+import static org.junit.Assert.assertNotNull;
+
+import org.junit.Test;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class DMaapExceptionTest {
+ private static final Logger debugLogger = LoggerFactory.getLogger("debugLogger");
+
+ @Test
+ public void test() {
+ DMaapException se = new DMaapException("message");
+ assertNotNull(se);
+ DMaapException se1 = new DMaapException("message", se);
+ assertNotNull(se1);
+ DMaapException se2 = new DMaapException("message", se.getCause());
+ assertNotNull(se2);
+ DMaapException se3 = new DMaapException("message", debugLogger, se);
+ assertNotNull(se3);
+ }
+}
diff --git a/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/exception/MapperConfigExceptionTest.java b/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/exception/MapperConfigExceptionTest.java
index 19dfd87..966bf4a 100644
--- a/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/exception/MapperConfigExceptionTest.java
+++ b/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/exception/MapperConfigExceptionTest.java
@@ -1,32 +1,33 @@
-/*
-* ============LICENSE_START=======================================================
-* ONAP : DCAE
-* ================================================================================
-* Copyright 2018 TechMahindra
-*=================================================================================
-* 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.universalvesadapter.exception;
-
-import org.junit.Test;
-
-public class MapperConfigExceptionTest {
-
- @Test
- public void test() {
- MapperConfigException se = new MapperConfigException("message");
- MapperConfigException se1 = new MapperConfigException("message", se);
- }
-
-}
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP : DCAE
+ * ================================================================================
+ * Copyright 2018-2019 TechMahindra
+ * ================================================================================
+ * 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.universalvesadapter.exception;
+
+import org.junit.Test;
+
+public class MapperConfigExceptionTest {
+
+ @Test
+ public void test() {
+ MapperConfigException se = new MapperConfigException("message");
+ MapperConfigException se1 = new MapperConfigException("message", se);
+ }
+
+}
diff --git a/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/mappingconfig/EntryTest.java b/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/mappingconfig/EntryTest.java
index d72892b..0097658 100644
--- a/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/mappingconfig/EntryTest.java
+++ b/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/mappingconfig/EntryTest.java
@@ -1,59 +1,60 @@
-/*
-* ============LICENSE_START=======================================================
-* ONAP : DCAE
-* ================================================================================
-* Copyright 2018 TechMahindra
-*=================================================================================
-* 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.universalvesadapter.mappingconfig;
-
-import static org.junit.Assert.*;
-
-import java.util.HashMap;
-import java.util.Map;
-
-import org.junit.Test;
-import org.mockito.Mock;
-import org.springframework.beans.factory.annotation.Autowired;
-
-public class EntryTest {
-
- @Autowired
- Entry entry = new Entry();
- @Mock
- Evaluation evaluation = new Evaluation();
- Object value = new Object();
- Map<String, Object> additionalProperties = new HashMap<String, Object>();
-
- @Test
- public void test() {
- entry.setPriority(1);
- entry.setEvaluation(evaluation);
- entry.setResult("result");
- entry.setAdditionalProperty("name", value);
-
- additionalProperties.put("name", value);
- assertEquals(entry.getEvaluation(), evaluation);
- assertEquals(entry.getPriority(), new Integer(1));
- assertEquals(entry.getResult(),"result");
- assertEquals(entry.getAdditionalProperties(), additionalProperties);
- assert (entry.toString() != null);
- assert (entry.hashCode() != 0);
-
- assert (entry.equals(entry));
-
- }
-
-}
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP : DCAE
+ * ================================================================================
+ * Copyright 2018-2019 TechMahindra
+ * ================================================================================
+ * 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.universalvesadapter.mappingconfig;
+
+import static org.junit.Assert.assertEquals;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import org.junit.Test;
+import org.mockito.Mock;
+import org.springframework.beans.factory.annotation.Autowired;
+
+public class EntryTest {
+
+ @Autowired
+ Entry entry = new Entry();
+ @Mock
+ Evaluation evaluation = new Evaluation();
+ Object value = new Object();
+ Map<String, Object> additionalProperties = new HashMap<String, Object>();
+
+ @Test
+ public void test() {
+ entry.setPriority(1);
+ entry.setEvaluation(evaluation);
+ entry.setResult("result");
+ entry.setAdditionalProperty("name", value);
+
+ additionalProperties.put("name", value);
+ assertEquals(entry.getEvaluation(), evaluation);
+ assertEquals(entry.getPriority(), new Integer(1));
+ assertEquals(entry.getResult(), "result");
+ assertEquals(entry.getAdditionalProperties(), additionalProperties);
+ assert (entry.toString() != null);
+ assert (entry.hashCode() != 0);
+
+ assert (entry.equals(entry));
+
+ }
+
+}
diff --git a/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/mappingconfig/EvaluationTest.java b/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/mappingconfig/EvaluationTest.java
index a3b9db6..5799d01 100644
--- a/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/mappingconfig/EvaluationTest.java
+++ b/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/mappingconfig/EvaluationTest.java
@@ -1,70 +1,70 @@
-/*
-* ============LICENSE_START=======================================================
-* ONAP : DCAE
-* ================================================================================
-* Copyright 2018 TechMahindra
-*=================================================================================
-* 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.universalvesadapter.mappingconfig;
-
-import static org.junit.Assert.*;
-
-import java.util.HashMap;
-import java.util.Map;
-
-import org.junit.Test;
-import org.springframework.beans.factory.annotation.Autowired;
-
-public class EvaluationTest {
-
- @Autowired
- Evaluation evaluation =new Evaluation();
- Evaluation lhs =new Evaluation();
- Evaluation rhs =new Evaluation();
- Object value = new Object();
- Map<String, Object> additionalProperties = new HashMap<String, Object>();
-
- @Test
- public void test() {
- evaluation.setAdditionalProperty("name", value);
- evaluation.setDatatype("datatype");
- evaluation.setField("field");
- evaluation.setLhs(lhs);
- evaluation.setOperand("operand");
- evaluation.setRhs(rhs);
- evaluation.setValue("value");
- additionalProperties.put("name", value);
-
- assertEquals(evaluation.getAdditionalProperties(), additionalProperties);
- assertEquals(evaluation.getDatatype(),"datatype");
- assertEquals(evaluation.getField(),"field");
- assertEquals(evaluation.getLhs(),lhs);
- assertEquals(evaluation.getOperand(),"operand");
- assertEquals(evaluation.getRhs(),rhs);
- assertEquals(evaluation.getValue(),"value");
-
- assert (evaluation.toString() != null);
- assert (evaluation.hashCode() != 0);
-
- assert (evaluation.equals(evaluation));
- assertEquals(evaluation.equals(value),false);
- assertEquals(evaluation.equals(null),false);
-
-
-
-
- }
-
-}
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP : DCAE
+ * ================================================================================
+ * Copyright 2018-2019 TechMahindra
+ * ================================================================================
+ * 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.universalvesadapter.mappingconfig;
+
+import static org.junit.Assert.assertEquals;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import org.junit.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+
+public class EvaluationTest {
+
+ @Autowired
+ Evaluation evaluation = new Evaluation();
+ Evaluation lhs = new Evaluation();
+ Evaluation rhs = new Evaluation();
+ Object value = new Object();
+ Map<String, Object> additionalProperties = new HashMap<String, Object>();
+
+ @Test
+ public void test() {
+ evaluation.setAdditionalProperty("name", value);
+ evaluation.setDatatype("datatype");
+ evaluation.setField("field");
+ evaluation.setLhs(lhs);
+ evaluation.setOperand("operand");
+ evaluation.setRhs(rhs);
+ evaluation.setValue("value");
+ additionalProperties.put("name", value);
+
+ assertEquals(evaluation.getAdditionalProperties(), additionalProperties);
+ assertEquals(evaluation.getDatatype(), "datatype");
+ assertEquals(evaluation.getField(), "field");
+ assertEquals(evaluation.getLhs(), lhs);
+ assertEquals(evaluation.getOperand(), "operand");
+ assertEquals(evaluation.getRhs(), rhs);
+ assertEquals(evaluation.getValue(), "value");
+
+ assert (evaluation.toString() != null);
+ assert (evaluation.hashCode() != 0);
+
+ assert (evaluation.equals(evaluation));
+ assertEquals(evaluation.equals(value), false);
+ assertEquals(evaluation.equals(null), false);
+
+
+
+ }
+
+}
diff --git a/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/mappingconfig/MapperConfigTest.java b/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/mappingconfig/MapperConfigTest.java
index 474ba05..a9cf2b0 100644
--- a/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/mappingconfig/MapperConfigTest.java
+++ b/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/mappingconfig/MapperConfigTest.java
@@ -1,54 +1,55 @@
-/*
-* ============LICENSE_START=======================================================
-* ONAP : DCAE
-* ================================================================================
-* Copyright 2018 TechMahindra
-*=================================================================================
-* 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.universalvesadapter.mappingconfig;
-
-import static org.junit.Assert.*;
-
-import java.util.HashMap;
-import java.util.Map;
-import java.util.Set;
-
-import org.junit.Test;
-import org.springframework.beans.factory.annotation.Autowired;
-
-public class MapperConfigTest {
-
- @Autowired
- MapperConfig mapperConfig = new MapperConfig();
- Map<String, Object> additionalProperties = new HashMap<String, Object>();
- Object value = new Object();
- Set<Entry> entries = null;
-
- @Test
- public void test() {
- mapperConfig.setAdditionalProperty("name", value);
- mapperConfig.setEntries(entries);
- additionalProperties.put("name", value);
-
- assertEquals(mapperConfig.getAdditionalProperties(),additionalProperties);
- assertEquals(mapperConfig.getEntries(),entries);
- assert (mapperConfig.toString() != null);
- assert (mapperConfig.hashCode() != 0);
-
- assert (mapperConfig.equals(mapperConfig));
-
- }
-
-}
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP : DCAE
+ * ================================================================================
+ * Copyright 2018-2019 TechMahindra
+ * ================================================================================
+ * 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.universalvesadapter.mappingconfig;
+
+import static org.junit.Assert.assertEquals;
+
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Set;
+
+import org.junit.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+
+public class MapperConfigTest {
+
+ @Autowired
+ MapperConfig mapperConfig = new MapperConfig();
+ Map<String, Object> additionalProperties = new HashMap<String, Object>();
+ Object value = new Object();
+ Set<Entry> entries = null;
+
+ @Test
+ public void test() {
+ mapperConfig.setAdditionalProperty("name", value);
+ mapperConfig.setEntries(entries);
+ additionalProperties.put("name", value);
+
+ assertEquals(mapperConfig.getAdditionalProperties(), additionalProperties);
+ assertEquals(mapperConfig.getEntries(), entries);
+ assert (mapperConfig.toString() != null);
+ assert (mapperConfig.hashCode() != 0);
+
+ assert (mapperConfig.equals(mapperConfig));
+
+ }
+
+}
diff --git a/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/service/VesServiceTest.java b/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/service/VesServiceTest.java
index 3ad47f0..2e6ed56 100644
--- a/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/service/VesServiceTest.java
+++ b/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/service/VesServiceTest.java
@@ -1,144 +1,100 @@
-/*
-* ============LICENSE_START=======================================================
-* ONAP : DCAE
-* ================================================================================
-* Copyright 2018 TechMahindra
-*=================================================================================
-* 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.universalvesadapter.service;
-
-import static org.junit.Assert.*;
-import static org.mockito.Mockito.doNothing;
-import static org.mockito.Mockito.doReturn;
-
-import java.io.IOException;
-import java.util.Arrays;
-import java.util.Collections;
-
-import org.junit.Before;
-import org.junit.Ignore;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.mockito.ArgumentCaptor;
-import org.mockito.InjectMocks;
-import org.mockito.Mock;
-import org.mockito.Mockito;
-import org.mockito.MockitoAnnotations;
-import org.onap.universalvesadapter.Application;
-import org.onap.universalvesadapter.exception.DMaapException;
-import org.onap.universalvesadapter.service.DMaapService;
-import org.onap.universalvesadapter.service.VesService;
-import org.onap.universalvesadapter.utils.ParallelTasks;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.test.context.SpringBootTest;
-import org.springframework.test.context.junit4.SpringRunner;
-
-import com.att.nsa.mr.client.MRConsumer;
-@Ignore
-@RunWith(SpringRunner.class)
-@SpringBootTest(classes = Application.class)
-public class VesServiceTest {
-
- @InjectMocks
- @Autowired
- private VesService vesService;
-
- @Mock
- private DMaapService dmaapService;
-
- private final Logger eLOGGER = LoggerFactory.getLogger(this.getClass());
-
- @Before
- public void init() {
- MockitoAnnotations.initMocks(this);
- }
-
-
- @Test
- public void testStart() throws IOException {
-
- String[] incomingMessages = {"{ "
- + " \"protocol version \": \"v2c \", "
- + " \"notify OID \": \".1.3.6.1.4.1.74.2.46.12.1.1AAA \", "
- + " \"cambria.partition \": \"dcae-snmp.client.research.att.com \", "
- + " \"trap category \": \"UCSNMP-HEARTBEAT \", "
- + " \"epoch_serno \": 15161177410000, "
- + " \"community \": \"public \", "
- + " \"time received \": 1516117741, "
- + " \"agent name \": \"localhost \", "
- + " \"agent address \": \"127.0.0.1 \", "
- + " \"community len \": 6, "
- + " \"notify OID len \": 12, "
- + " \"varbinds \": [{ "
- + " \"varbind_type \": \"octet \", "
- + " \"varbind_oid \": \".1.3.6.1.4.1.74.2.46.12.1.1.1 \", "
- + " \"varbind_value \": \"ucsnmp heartbeat - ignore \" "
- + " }, { "
- + " \"varbind_type \": \"octet \", "
- + " \"varbind_oid \": \".1.3.6.1.4.1.74.2.46.12.1.1.2 \", "
- + " \"varbind_value \": \"Tue Jan 16 10:49:01 EST 2018 \" "
- + " }] "
- + "}"};
- try {
- // Mockito.when(dmaapService.fetchAndPublishInDMaaP(null,null)).thenReturn(Arrays.asList(incomingMessages)).thenReturn(() -> Collections.emptyIterator());
- } catch (Exception e) {
- eLOGGER.error("Error occurred : " + e.getMessage());
- }
-
- ArgumentCaptor<?> valueCapture = ArgumentCaptor.forClass(String.class);
- try {
- //doNothing().when(dmaapService).fetchAndPublishInDMaaP((String) valueCapture.capture());
- } catch (DMaapException e) {
- eLOGGER.error("Error occurred : " + e.getMessage());
- }
-
-
- new Thread(new Runnable() {
-
- @Override
- public void run() {
- // TODO Auto-generated method stub
- vesService.start();
-
- }
- }).start();
- try {
- Thread.sleep(5000);
- } catch (InterruptedException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
- new Thread(new Runnable() {
-
- @Override
- public void run() {
- // TODO Auto-generated method stub
- vesService.stop();
-
- }
- }).start();
- String result = "{\"event\":{\"commonEventHeader\":{},\"faultFields\":{},\"measurementsForVfScalingFields\":{\"additionalMeasurements\":[]}}}";
- assertEquals(result, valueCapture.getValue());
- }
-
- @Test
- public void testStop() {
- fail("Not yet implemented");
- }
-
-}
-*/ \ No newline at end of file
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP : DCAE
+ * ================================================================================
+ * Copyright 2018-2019 TechMahindra
+ * ================================================================================
+ * 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.universalvesadapter.service;
+ *
+ * import static org.junit.Assert.*; import static org.mockito.Mockito.doNothing; import static
+ * org.mockito.Mockito.doReturn;
+ *
+ * import java.io.IOException; import java.util.Arrays; import java.util.Collections;
+ *
+ * import org.junit.Before; import org.junit.Ignore; import org.junit.Test; import
+ * org.junit.runner.RunWith; import org.mockito.ArgumentCaptor; import org.mockito.InjectMocks;
+ * import org.mockito.Mock; import org.mockito.Mockito; import org.mockito.MockitoAnnotations;
+ * import org.onap.universalvesadapter.Application; import
+ * org.onap.universalvesadapter.exception.DMaapException; import
+ * org.onap.universalvesadapter.service.DMaapService; import
+ * org.onap.universalvesadapter.service.VesService; import
+ * org.onap.universalvesadapter.utils.ParallelTasks; import org.slf4j.Logger; import
+ * org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import
+ * org.springframework.boot.test.context.SpringBootTest; import
+ * org.springframework.test.context.junit4.SpringRunner;
+ *
+ * import com.att.nsa.mr.client.MRConsumer;
+ *
+ * @Ignore
+ *
+ * @RunWith(SpringRunner.class)
+ *
+ * @SpringBootTest(classes = Application.class) public class VesServiceTest {
+ *
+ * @InjectMocks
+ *
+ * @Autowired private VesService vesService;
+ *
+ * @Mock private DMaapService dmaapService;
+ *
+ * private final Logger eLOGGER = LoggerFactory.getLogger(this.getClass());
+ *
+ * @Before public void init() { MockitoAnnotations.initMocks(this); }
+ *
+ *
+ * @Test public void testStart() throws IOException {
+ *
+ * String[] incomingMessages = {"{ " + " \"protocol version \": \"v2c \", " +
+ * " \"notify OID \": \".1.3.6.1.4.1.74.2.46.12.1.1AAA \", " +
+ * " \"cambria.partition \": \"dcae-snmp.client.research.att.com \", " +
+ * " \"trap category \": \"UCSNMP-HEARTBEAT \", " + " \"epoch_serno \": 15161177410000, " +
+ * " \"community \": \"public \", " + " \"time received \": 1516117741, " +
+ * " \"agent name \": \"localhost \", " + " \"agent address \": \"127.0.0.1 \", " +
+ * " \"community len \": 6, " + " \"notify OID len \": 12, " + " \"varbinds \": [{ " +
+ * " \"varbind_type \": \"octet \", " +
+ * " \"varbind_oid \": \".1.3.6.1.4.1.74.2.46.12.1.1.1 \", " +
+ * " \"varbind_value \": \"ucsnmp heartbeat - ignore \" " + " }, { " +
+ * " \"varbind_type \": \"octet \", " +
+ * " \"varbind_oid \": \".1.3.6.1.4.1.74.2.46.12.1.1.2 \", " +
+ * " \"varbind_value \": \"Tue Jan 16 10:49:01 EST 2018 \" " + " }] " + "}"}; try { //
+ * Mockito.when(dmaapService.fetchAndPublishInDMaaP(null,null)).
+ * thenReturn(Arrays.asList(incomingMessages)).thenReturn(() -> Collections.emptyIterator());
+ *
+ * } catch (Exception e) { eLOGGER.error("Error occurred : " + e.getMessage()); }
+ *
+ * ArgumentCaptor<?> valueCapture = ArgumentCaptor.forClass(String.class); try {
+ * //doNothing().when(dmaapService).fetchAndPublishInDMaaP((String) valueCapture.capture()); } catch
+ * (DMaapException e) { eLOGGER.error("Error occurred : " + e.getMessage()); }
+ *
+ *
+ * new Thread(new Runnable() {
+ *
+ * @Override public void run() { // TODO Auto-generated method stub vesService.start();
+ *
+ * } }).start(); try { Thread.sleep(5000); } catch (InterruptedException e) { // TODO Auto-generated
+ * catch block e.printStackTrace(); } new Thread(new Runnable() {
+ *
+ * @Override public void run() { // TODO Auto-generated method stub vesService.stop();
+ *
+ * } }).start(); String result = "{\"event\":{\"commonEventHeader\":{},\"faultFields\":{},
+ * \"measurementsForVfScalingFields\":{\"additionalMeasurements\":[]}}}"; assertEquals(result,
+ * valueCapture.getValue()); }
+ *
+ * @Test public void testStop() { fail("Not yet implemented"); }
+ *
+ * }
+ */
diff --git a/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/utils/SmooksUtilsTest.java b/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/utils/SmooksUtilsTest.java
index 13a5e78..19fcaa2 100644
--- a/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/utils/SmooksUtilsTest.java
+++ b/UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/utils/SmooksUtilsTest.java
@@ -1,121 +1,128 @@
-/*
-* ============LICENSE_START=======================================================
-* ONAP : DCAE
-* ================================================================================
-* Copyright 2018 TechMahindra
-*=================================================================================
-* 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=========================================================
-*/
-
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP : DCAE
+ * ================================================================================
+ * Copyright 2018-2019 TechMahindra
+ * ================================================================================
+ * 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.universalvesadapter.utils;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.nio.charset.StandardCharsets;
+
import org.junit.Test;
import org.milyn.Smooks;
-import org.onap.dcaegen2.ves.domain.ves7_0.VesEvent;
+import org.onap.dcaegen2.ves.domain.ves70.VesEvent;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.xml.sax.SAXException;
public class SmooksUtilsTest {
-
-
- VesEvent vesEvent;
- private static final Logger errorLogger = LoggerFactory.getLogger("errorLogger");
-
- @Test
- public void testGetTransformedObjectForInput() {
- StringBuffer incomingJsonString = new StringBuffer("{\n" + " \"rule-id\": \"12121\",\n"
- + " \"notification\": {\n" + " \"event-time\": \"2018-03-15T08:15:32.000Z\",\n"
- + " \"notification-id\": \"2541256\",\n" + " \"message\": {\n"
- + " \"topic\":\"resource\",\n"
- + " \"object-type\":\"onu\", \n"
- + " \"version\": \"v1\", \n"
- + " \"operation\": \"create\", \n"
- + " \"target\": \"ont/ont=23hk1231231232\", \n"
- + " \"content\": {\n" + " \"onu\": {\n"
- + " \"sn\": \"48575443FA637D1A\",\n"
- + " \"refParentNE\": \"550e8400-e29b-41d4-a716-446655440000\",\n"
- + " \"refParentNeNativeId\": \"FDN\",\n"
- + " \"refParentLTP\": \"8c0db89e-218c-4e18-b0de-7a6788b3dda4\",\n"
- + " \"refParentLTPNativeId\": \"FDN\",\n"
- + " \"onuId\": \"213\",\n"
- + " \"accessID\": \"HG65875420001\"\n" + " }\n"
- + " }\n" + " }\n" + " }\n" + "}");
- StringBuffer configFileData = new StringBuffer("<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n"
- + "<smooks-resource-list xmlns=\"http://www.milyn.org/xsd/smooks-1.1.xsd\" xmlns:jb=\"http://www.milyn.org/xsd/smooks/javabean-1.4.xsd\" xmlns:json=\"http://www.milyn.org/xsd/smooks/json-1.1.xsd\">\n"
- + " <json:reader rootName=\"vesevent\" keyWhitspaceReplacement=\"-\">\n"
- + " <json:keyMap>\n"
- + " <json:key from=\"date&amp;time\" to=\"date-and-time\" />\n"
- + " </json:keyMap>\n" + " </json:reader>\n"
- + " <jb:bean class=\"org.onap.dcaegen2.ves.domain.ves7_0.VesEvent\""
- + " beanId=\"vesEvent\" createOnElement=\"vesevent\">\n"
- + " <jb:wiring property=\"event\" beanIdRef=\"event\" />\n" + " </jb:bean>\n"
- + " <jb:bean class=\"org.onap.dcaegen2.ves.domain.ves7_0.Event\" "
- + "beanId=\"event\" createOnElement=\"vesevent\">\n"
- + " <jb:wiring property=\"commonEventHeader\" beanIdRef=\"commonEventHeader\" />\n"
- + " <jb:wiring property=\"pnfRegistrationFields\" beanIdRef=\"pnfRegistrationFields\" />\n"
- + " </jb:bean>\n"
- + " <jb:bean class=\"org.onap.dcaegen2.ves.domain.ves7_0.CommonEventHeader\""
- + " beanId=\"commonEventHeader\" createOnElement=\"vesevent\">\n"
- + "<jb:expression property=\"version\">"
- + "org.onap.dcaegen2.ves.domain.ves7_0.CommonEventHeader.Version._4_0_1</jb:expression> \n"
- + "<jb:expression property=\"eventType\">\"pnfRegistration\"</jb:expression>\n"
- + "<jb:expression property=\"vesEventListenerVersion\">"
- + "org.onap.dcaegen2.ves.domain.ves7_0.CommonEventHeader.VesEventListenerVersion._7_0_1</jb:expression>\n"
- + " <jb:expression property=\"eventId\" execOnElement=\"vesevent\">"
- + "\"registration_\"+commonEventHeader.ts1</jb:expression>\n"
- + "<jb:expression property=\"reportingEntityName\">\"VESMapper\"</jb:expression>\n"
- + " <jb:expression property=\"domain\">"
- + "org.onap.dcaegen2.ves.domain.ves7_0.CommonEventHeader.Domain.PNF_REGISTRATION</jb:expression>\n"
- + " <jb:expression property=\"eventName\" execOnElement=\"vesevent\">"
- + "commonEventHeader.domain</jb:expression>\n"
- + "<jb:value property=\"sequence\" data=\"0\" default=\"0\" decoder=\"Long\" />\n"
- + "<jb:expression property=\"lastEpochMicrosec\" execOnElement=\"vesevent\">"
- + "commonEventHeader.ts1</jb:expression>\n"
- + " <jb:expression property=\"startEpochMicrosec\" execOnElement=\"vesevent\">"
- + "commonEventHeader.ts1</jb:expression>\n" + " <jb:expression property=\"priority\">"
- + "org.onap.dcaegen2.ves.domain.ves7_0.CommonEventHeader.Priority.NORMAL</jb:expression>\n"
- + " <jb:value property=\"sourceName\" data=\"notification/message/target\" />\n"
- + " </jb:bean>\n"
- + " <jb:bean class=\"org.onap.dcaegen2.ves.domain.ves7_0.PnfRegistrationFields\""
- + " beanId=\"pnfRegistrationFields\" createOnElement=\"vesevent\">\n" + " \n"
- + " <jb:expression property=\"pnfRegistrationFieldsVersion\">"
- + "org.onap.dcaegen2.ves.domain.ves7_0.PnfRegistrationFields.PnfRegistrationFieldsVersion._2_0"
- + "</jb:expression>\n"
- + " <jb:value property=\"serialNumber\" data=\"notification/message/content/onu/sn\" />\n"
- + " \n" + " </jb:bean>\n" + "</smooks-resource-list>");
-
- Smooks smooks = null;
-
- try {
- // reading config file.. for now, looking at it as just one time operation
- if (null == smooks) {
-
- smooks = new Smooks(
- new ByteArrayInputStream(configFileData.toString().getBytes(StandardCharsets.UTF_8)));
- }
-
- vesEvent = SmooksUtils.getTransformedObjectForInput(smooks, incomingJsonString.toString());
- } catch (IOException | SAXException exception) {
- errorLogger.error("Error occurred : ", exception);
+
+
+ VesEvent vesEvent;
+ private static final Logger errorLogger = LoggerFactory.getLogger("errorLogger");
+
+ @Test
+ public void testGetTransformedObjectForInput() {
+ StringBuffer incomingJsonString = new StringBuffer("{\n" + " \"rule-id\": \"12121\",\n"
+ + " \"notification\": {\n"
+ + " \"event-time\": \"2018-03-15T08:15:32.000Z\",\n"
+ + " \"notification-id\": \"2541256\",\n" + " \"message\": {\n"
+ + " \"topic\":\"resource\",\n"
+ + " \"object-type\":\"onu\", \n"
+ + " \"version\": \"v1\", \n"
+ + " \"operation\": \"create\", \n"
+ + " \"target\": \"ont/ont=23hk1231231232\", \n"
+ + " \"content\": {\n" + " \"onu\": {\n"
+ + " \"sn\": \"48575443FA637D1A\",\n"
+ + " \"refParentNE\": \"550e8400-e29b-41d4-a716-446655440000\",\n"
+ + " \"refParentNeNativeId\": \"FDN\",\n"
+ + " \"refParentLTP\": \"8c0db89e-218c-4e18-b0de-7a6788b3dda4\",\n"
+ + " \"refParentLTPNativeId\": \"FDN\",\n"
+ + " \"onuId\": \"213\",\n"
+ + " \"accessID\": \"HG65875420001\"\n" + " }\n"
+ + " }\n" + " }\n" + " }\n" + "}");
+ StringBuffer configFileData =
+ new StringBuffer("<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n"
+ + "<smooks-resource-list xmlns=\"http://www.milyn.org/xsd/smooks-1.1.xsd\" xmlns:jb=\"http://www.milyn.org/xsd/smooks/javabean-1.4.xsd\" xmlns:json=\"http://www.milyn.org/xsd/smooks/json-1.1.xsd\">\n"
+ + " <json:reader rootName=\"vesevent\" keyWhitspaceReplacement=\"-\">\n"
+ + " <json:keyMap>\n"
+ + " <json:key from=\"date&amp;time\" to=\"date-and-time\" />\n"
+ + " </json:keyMap>\n" + " </json:reader>\n"
+ + " <jb:bean class=\"org.onap.dcaegen2.ves.domain.ves70.VesEvent\""
+ + " beanId=\"vesEvent\" createOnElement=\"vesevent\">\n"
+ + " <jb:wiring property=\"event\" beanIdRef=\"event\" />\n"
+ + " </jb:bean>\n"
+ + " <jb:bean class=\"org.onap.dcaegen2.ves.domain.ves70.Event\" "
+ + "beanId=\"event\" createOnElement=\"vesevent\">\n"
+ + " <jb:wiring property=\"commonEventHeader\" beanIdRef=\"commonEventHeader\" />\n"
+ + " <jb:wiring property=\"pnfRegistrationFields\" beanIdRef=\"pnfRegistrationFields\" />\n"
+ + " </jb:bean>\n"
+ + " <jb:bean class=\"org.onap.dcaegen2.ves.domain.ves70.CommonEventHeader\""
+ + " beanId=\"commonEventHeader\" createOnElement=\"vesevent\">\n"
+ + "<jb:expression property=\"version\">"
+ + "org.onap.dcaegen2.ves.domain.ves70.CommonEventHeader.Version._4_0_1</jb:expression> \n"
+ + "<jb:expression property=\"eventType\">\"pnfRegistration\"</jb:expression>\n"
+ + "<jb:expression property=\"vesEventListenerVersion\">"
+ + "org.onap.dcaegen2.ves.domain.ves70.CommonEventHeader.VesEventListenerVersion._7_0_1"
+ + "</jb:expression>\n"
+ + " <jb:expression property=\"eventId\" execOnElement=\"vesevent\">"
+ + "\"registration_\"+commonEventHeader.ts1</jb:expression>\n"
+ + "<jb:expression property=\"reportingEntityName\">\"VESMapper\"</jb:expression>\n"
+ + " <jb:expression property=\"domain\">"
+ + "org.onap.dcaegen2.ves.domain.ves70.CommonEventHeader.Domain.PNF_REGISTRATION"
+ + "</jb:expression>\n"
+ + " <jb:expression property=\"eventName\" execOnElement=\"vesevent\">"
+ + "commonEventHeader.domain</jb:expression>\n"
+ + "<jb:value property=\"sequence\" data=\"0\" default=\"0\" decoder=\"Long\" />\n"
+ + "<jb:expression property=\"lastEpochMicrosec\" execOnElement=\"vesevent\">"
+ + "commonEventHeader.ts1</jb:expression>\n"
+ + " <jb:expression property=\"startEpochMicrosec\" execOnElement=\"vesevent\">"
+ + "commonEventHeader.ts1</jb:expression>\n"
+ + " <jb:expression property=\"priority\">"
+ + "org.onap.dcaegen2.ves.domain.ves70.CommonEventHeader.Priority.NORMAL</jb:expression>\n"
+ + " <jb:value property=\"sourceName\" data=\"notification/message/target\" />\n"
+ + " </jb:bean>\n"
+ + " <jb:bean class=\"org.onap.dcaegen2.ves.domain.ves70.PnfRegistrationFields\""
+ + " beanId=\"pnfRegistrationFields\" createOnElement=\"vesevent\">\n"
+ + " \n"
+ + " <jb:expression property=\"pnfRegistrationFieldsVersion\">"
+ + "org.onap.dcaegen2.ves.domain.ves70.PnfRegistrationFields.PnfRegistrationFieldsVersion._2_0"
+ + "</jb:expression>\n"
+ + " <jb:value property=\"serialNumber\" data=\"notification/message/content/onu/sn\" />\n"
+ + " \n" + " </jb:bean>\n" + "</smooks-resource-list>");
+
+ Smooks smooks = null;
+
+ try {
+ // reading config file.. for now, looking at it as just one time operation
+ if (null == smooks) {
+
+ smooks = new Smooks(new ByteArrayInputStream(
+ configFileData.toString().getBytes(StandardCharsets.UTF_8)));
+ }
+
+ vesEvent =
+ SmooksUtils.getTransformedObjectForInput(smooks, incomingJsonString.toString());
+ } catch (IOException | SAXException exception) {
+ errorLogger.error("Error occurred : ", exception);
+ }
}
- }
}
-
- \ No newline at end of file
+