UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/adapter/UniversalEventAdapterTest.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP : DCAE
   4  * ================================================================================
   5  * Copyright 2018-2019 TechMahindra
   6  * ================================================================================
   7  * Licensed under the Apache License, Version 2.0 (the "License");
   8  * you may not use this file except in compliance with the License.
   9  * You may obtain a copy of the License at
  10  *
  11  *      http://www.apache.org/licenses/LICENSE-2.0
  12  *
  13  * Unless required by applicable law or agreed to in writing, software
  14  * distributed under the License is distributed on an "AS IS" BASIS,
  15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16  * See the License for the specific language governing permissions and
  17  * limitations under the License.
  18  * ============LICENSE_END=========================================================
  19  */
  20
  21 package org.onap.universalvesadapter.adapter;
  22
  23 import static org.junit.Assert.assertNotEquals;
  24 import static org.junit.Assert.assertNotNull;
  25 import java.util.HashMap;
  26 import java.util.Map;
  27 import org.junit.Before;
  28 import org.junit.Test;
  29 import org.junit.runner.RunWith;
  30 import org.mockito.InjectMocks;
  31 import org.mockito.Mock;
  32 import org.mockito.MockitoAnnotations;
  33 import org.onap.universalvesadapter.Application;
  34 import org.onap.universalvesadapter.exception.VesException;
  35 import org.onap.universalvesadapter.service.VESAdapterInitializer;
  36 import org.onap.universalvesadapter.utils.CollectorConfigPropertyRetrieval;
  37 import org.powermock.api.mockito.PowerMockito;
  38 import org.powermock.core.classloader.annotations.PrepareForTest;
  39 import org.powermock.modules.junit4.PowerMockRunner;
  40 import org.slf4j.Logger;
  41 import org.slf4j.LoggerFactory;
  42 import org.springframework.boot.test.context.SpringBootTest;
  43
  44 @RunWith(PowerMockRunner.class)
  45 @SpringBootTest(classes = Application.class)
  46 public class UniversalEventAdapterTest {
  47
  48     private static final Logger errorLogger = LoggerFactory.getLogger("errorLogger");
  49
  50     @Mock
  51     private VESAdapterInitializer vesAdapterInitializer;
  52
  53     @InjectMocks
  54     private UniversalEventAdapter universalVesAdapter;
  55
  56     @Before
  57     public void init() {
  58         MockitoAnnotations.initMocks(this);
  59     }
  60
  61     @PrepareForTest({ CollectorConfigPropertyRetrieval.class })
  62     @Test
  63     public void testtransform() {
  64
  65         StringBuffer incomingJsonString = new StringBuffer("{\n"
  66                 + "    \"rule-id\": \"12121\",\n" + "    \"notification\": {\n"
  67                 + "        \"event-time\": \"2018-03-15T08:15:32.000Z\",\n"
  68                 + "        \"notification-id\":  \"2541256\",\n"
  69                 + "        \"message\":  {\n"
  70                 + "            \"topic\":\"resource\",\n"
  71                 + "            \"object-type\":\"onu\",               \n"
  72                 + "            \"version\": \"v1\",               \n"
  73                 + "            \"operation\": \"create\",   \n"
  74                 + "            \"target\": \"ont/ont=23hk1231231232\",   \n"
  75                 + "            \"content\":  {\n" + "                \"onu\":  {\n"
  76                 + "                    \"sn\":   \"48575443FA637D1A\",\n"
  77                 + "                    \"refParentNE\":  \"550e8400-e29b-41d4-a716-446655440000\",\n"
  78                 + "                    \"refParentNeNativeId\":  \"FDN\",\n"
  79                 + "                    \"refParentLTP\": \"8c0db89e-218c-4e18-b0de-7a6788b3dda4\",\n"
  80                 + "                    \"refParentLTPNativeId\": \"FDN\",\n"
  81                 + "                    \"onuId\": \"213\",\n"
  82                 + "                    \"accessID\": \"HG65875420001\"\n"
  83                 + "                }\n" + "            }\n" + "        }\n"
  84                 + "    }\n" + "}");
  85         Map<String, String> testMap = new HashMap<String, String>();
  86         testMap.put("defaultMappingFile-" + Thread.currentThread().getName(),
  87                 "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n"
  88                         + "<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"
  89                         + "   <json:reader rootName=\"vesevent\" keyWhitspaceReplacement=\"-\">\n"
  90                         + "      <json:keyMap>\n"
  91                         + "         <json:key from=\"date&amp;time\" to=\"date-and-time\" />\n"
  92                         + "      </json:keyMap>\n" + "   </json:reader>\n"
  93                         + "   <jb:bean class=\"org.onap.dcaegen2.ves.domain.ves70.VesEvent\""
  94                         + " beanId=\"vesEvent\" createOnElement=\"vesevent\">\n"
  95                         + "      <jb:wiring property=\"event\" beanIdRef=\"event\" />\n"
  96                         + "   </jb:bean>\n"
  97                         + "   <jb:bean class=\"org.onap.dcaegen2.ves.domain.ves70.Event\" "
  98                         + "beanId=\"event\" createOnElement=\"vesevent\">\n"
  99                         + "      <jb:wiring property=\"commonEventHeader\" beanIdRef=\"commonEventHeader\" />\n"
 100                         + "      <jb:wiring property=\"pnfRegistrationFields\" beanIdRef=\"pnfRegistrationFields\" />\n"
 101                         + "   </jb:bean>\n"
 102                         + "   <jb:bean class=\"org.onap.dcaegen2.ves.domain.ves70.CommonEventHeader\""
 103                         + " beanId=\"commonEventHeader\" createOnElement=\"vesevent\">\n"
 104                         + "<jb:expression property=\"version\">"
 105                         + "org.onap.dcaegen2.ves.domain.ves70.CommonEventHeader.Version._4_0_1</jb:expression> \n"
 106                         + "<jb:expression property=\"eventType\">\"pnfRegistration\"</jb:expression>\n"
 107                         + "<jb:expression property=\"vesEventListenerVersion\">"
 108                         + "org.onap.dcaegen2.ves.domain.ves70.CommonEventHeader.VesEventListenerVersion._7_0_1"
 109                         + "</jb:expression>\n"
 110                         + "       <jb:expression property=\"eventId\" execOnElement=\"vesevent\">"
 111                         + "\"registration_\"+commonEventHeader.ts1</jb:expression>\n"
 112                         + "<jb:expression property=\"reportingEntityName\">\"VESMapper\"</jb:expression>\n"
 113                         + "      <jb:expression property=\"domain\">"
 114                         + "org.onap.dcaegen2.ves.domain.ves70.CommonEventHeader.Domain.PNF_REGISTRATION"
 115                         + "</jb:expression>\n"
 116                         + "      <jb:expression property=\"eventName\" execOnElement=\"vesevent\">"
 117                         + "commonEventHeader.domain</jb:expression>\n"
 118                         + "<jb:value property=\"sequence\" data=\"0\" default=\"0\" decoder=\"Long\" />\n"
 119                         + "<jb:expression property=\"lastEpochMicrosec\" execOnElement=\"vesevent\">"
 120                         + "commonEventHeader.ts1</jb:expression>\n"
 121                         + "      <jb:expression property=\"startEpochMicrosec\" execOnElement=\"vesevent\">"
 122                         + "commonEventHeader.ts1</jb:expression>\n"
 123                         + "      <jb:expression property=\"priority\">"
 124                         + "org.onap.dcaegen2.ves.domain.ves70.CommonEventHeader.Priority.NORMAL</jb:expression>\n"
 125                         + "      <jb:value property=\"sourceName\" data=\"notification/message/target\" />\n"
 126                         + "   </jb:bean>\n"
 127                         + "   <jb:bean class=\"org.onap.dcaegen2.ves.domain.ves70.PnfRegistrationFields\""
 128                         + " beanId=\"pnfRegistrationFields\" createOnElement=\"vesevent\">\n"
 129                         + "     \n"
 130                         + "       <jb:expression property=\"pnfRegistrationFieldsVersion\">"
 131                         + "org.onap.dcaegen2.ves.domain.ves70.PnfRegistrationFields.PnfRegistrationFieldsVersion._2_0"
 132                         + "</jb:expression>\n"
 133                         + "      <jb:value property=\"serialNumber\" data=\"notification/message/content/onu/sn\" />\n"
 134                         + "      \n" + "   </jb:bean>\n"
 135                         + "</smooks-resource-list>");
 136
 137         try {
 138             vesAdapterInitializer.setMappingFiles(testMap);
 139
 140             String[] identifiertest = CollectorConfigPropertyRetrieval
 141                     .getProperyArray("identifier", "kvTest.json");
 142             PowerMockito.mockStatic(CollectorConfigPropertyRetrieval.class);
 143             PowerMockito.when(CollectorConfigPropertyRetrieval
 144                     .getProperyArray("identifier", null))
 145                     .thenReturn(identifiertest);
 146
 147             String actualResult = universalVesAdapter
 148                     .transform(incomingJsonString.toString());
 149             assertNotNull(actualResult);
 150             assertNotEquals("", actualResult);
 151         } catch (VesException exception) {
 152             errorLogger.error("Error occurred : {}", exception);
 153         }
 154     }
 155 }