gerrit.onap Code Review - dcaegen2/services/mapper.git/blob

   1 /*
   2 * ============LICENSE_START=======================================================
   3 * ONAP : DCAE
   4 * ================================================================================
   5 * Copyright 2018 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 package org.onap.universalvesadapter.adapter;
  21
  22 import static org.junit.Assert.assertNotEquals;
  23 import static org.junit.Assert.assertNotNull;
  24
  25 import java.util.HashMap;
  26 import java.util.Map;
  27
  28 import org.junit.Before;
  29 import org.junit.Test;
  30 import org.junit.runner.RunWith;
  31 import org.mockito.InjectMocks;
  32 import org.mockito.Mock;
  33 import org.mockito.MockitoAnnotations;
  34 import org.onap.universalvesadapter.Application;
  35 import org.onap.universalvesadapter.exception.VesException;
  36 import org.onap.universalvesadapter.service.VESAdapterInitializer;
  37 import org.slf4j.Logger;
  38 import org.slf4j.LoggerFactory;
  39 import org.springframework.boot.test.context.SpringBootTest;
  40 import org.springframework.test.context.junit4.SpringRunner;
  41
  42
  43 @RunWith(SpringRunner.class)
  44 @SpringBootTest(classes=Application.class)
  45 public class UniversalEventAdapterTest  {
  46
  47     private final Logger eLOGGER = LoggerFactory.getLogger(this.getClass());
  48
  49     @Mock
  50     private VESAdapterInitializer vESAdapterInitializer;
  51
  52     @InjectMocks
  53     private UniversalEventAdapter universalVesAdapter;
  54
  55
  56     @Before
  57     public void init() {
  58         MockitoAnnotations.initMocks(this);
  59     }
  60
  61
  62         @Test
  63         public void testtransform()  {
  64         StringBuffer incomingJsonString = new StringBuffer("{ ")
  65                 .append("\"protocol version\":\"v2c\", ")
  66                 .append("\"notify OID\":\".1.3.6.1.4.1.1751.2.46.12.1.1\", ")
  67                 .append("\"cambria.partition\":\"dcae-snmp.client.research.att.com\", ")
  68                 .append("\"trap category\":\"UCSNMP-HEARTBEAT\", ")
  69                 .append("\"epoch_serno\": 15161177410000, ")
  70                 .append("\"community\":\"public\", ")
  71                 .append("\"time received\": 1516117741, ")
  72                 .append("\"agent name\":\"localhost\", ")
  73                 .append("\"agent address\":\"127.0.0.1\", ")
  74                 .append("\"community len\": 6, ")
  75                 .append("\"notify OID len\": 12, ")
  76                 .append("\"varbinds\": [{ ")
  77                 .append("    \"varbind_type\":\"octet\", ")
  78                 .append("    \"varbind_oid\":\".1.3.6.1.4.1.74.2.46.12.1.1.1\", ")
  79                 .append("    \"varbind_value\":\"ucsnmp heartbeat - ignore\" ")
  80                 .append(" }, { ")
  81                 .append("    \"varbind_type\":\"octet\", ")
  82                 .append("    \"varbind_oid\":\".1.3.6.1.4.1.74.2.46.12.1.1.2\", ")
  83                 .append("    \"varbind_value\":\"Tue Jan 16 10:49:01 EST 2018\" ")
  84                 .append(" }] ")
  85                 .append("}");
  86
  87         Map<String,String> testMap=new HashMap<String,String>();
  88         testMap.put("defaultSnmpMappingFile", "<?xml version=\"1.0\"?>\r\n" +
  89                         "<smooks-resource-list\r\n" +
  90                         "        xmlns=\"http://www.milyn.org/xsd/smooks-1.1.xsd\"\r\n" +
  91                         "        xmlns:json=\"http://www.milyn.org/xsd/smooks/json-1.1.xsd\"\r\n" +
  92                         "        xmlns:jb=\"http://www.milyn.org/xsd/smooks/javabean-1.4.xsd\">\r\n" +
  93                         "    <json:reader rootName=\"vesevent\"  keyWhitspaceReplacement=\"-\">\r\n" +
  94                         "    <json:keyMap>\r\n" +
  95                         "               <json:key from=\"date&amp;time\" to=\"date-and-time\" />\r\n" +
  96                         "           </json:keyMap>\r\n" +
  97                         "       </json:reader>\r\n" +
  98                         "   \r\n" +
  99                         "     <jb:bean class=\"org.onap.dcaegen2.ves.domain.VesEvent\" beanId=\"vesEvent\" createOnElement=\"vesevent\">\r\n" +
 100                         "       <jb:wiring property=\"event\" beanIdRef=\"event\"/>\r\n" +
 101                         "    </jb:bean>\r\n" +
 102                         " \r\n" +
 103                         "     <jb:bean class=\"org.onap.dcaegen2.ves.domain.Event\" beanId=\"event\" createOnElement=\"vesevent\">\r\n" +
 104                         "       <jb:wiring property=\"commonEventHeader\" beanIdRef=\"commonEventHeader\"/>\r\n" +
 105                         "       <jb:wiring property=\"faultFields\" beanIdRef=\"faultFields\"/>         \r\n" +
 106                         "       <!--<jb:wiring property=\"measurementsForVfScalingFields\" beanIdRef=\"measurementsForVfScalingFields\"/> -->           \r\n" +
 107                         "    </jb:bean>   \r\n" +
 108                         "    <!--<jb:bean class=\"org.onap.dcaegen2.ves.domain.MeasurementsForVfScalingFields\" beanId=\"measurementsForVfScalingFields\" createOnElement=\"simple\">\r\n" +
 109                         "       <jb:wiring property=\"additionalMeasurements\" beanIdRef=\"additionalMeasurements\"/>\r\n" +
 110                         "    </jb:bean>-->\r\n" +
 111                         "    \r\n" +
 112                         "    <jb:bean class=\"org.onap.dcaegen2.ves.domain.CommonEventHeader\" beanId=\"commonEventHeader\" createOnElement=\"vesevent\">\r\n" +
 113                         "               <jb:expression property=\"version\">\"3.0\"</jb:expression>\r\n" +
 114                         "               <jb:expression property=\"eventId\">\"XXXX\"</jb:expression>\r\n" +
 115                         "               <jb:expression property=\"reportingEntityName\">\"VesAdapter\"</jb:expression>\r\n" +
 116                         "               <jb:expression property=\"domain\">\"fault\"</jb:expression>\r\n" +
 117                         "               <jb:expression property=\"eventName\" execOnElement=\"vesevent\" >commonEventHeader.domain+\"_\"+commonEventHeader.reportingEntityName +\"_\"+ faultFields.alarmCondition;</jb:expression>\r\n" +
 118                         "       <jb:value property=\"sequence\" data=\"0\" default=\"0\" decoder=\"Long\"/>\r\n" +
 119                         "       <jb:value property=\"lastEpochMicrosec\" data=\"#/time-received\"  decoder=\"Double\" />\r\n" +
 120                         "       <jb:value property=\"startEpochMicrosec\" data=\"#/time-received\"  decoder=\"Double\"/>\r\n" +
 121                         "               <jb:expression property=\"priority\">\"Medium\"</jb:expression>\r\n" +
 122                         "       <jb:expression property=\"sourceName\">\"VesAdapter\"</jb:expression>\r\n" +
 123                         "    </jb:bean>   \r\n" +
 124                         "    \r\n" +
 125                         "    <jb:bean class=\"org.onap.dcaegen2.ves.domain.FaultFields\" beanId=\"faultFields\" createOnElement=\"vesevent\">\r\n" +
 126                         "       <jb:value property=\"alarmCondition\" data=\"#/trap-category\" />\r\n" +
 127                         "               <jb:expression property=\"eventSeverity\">\"MINOR\"</jb:expression>\r\n" +
 128                         "               <jb:expression property=\"eventSourceType\">\"SNMP Agent\"</jb:expression>\r\n" +
 129                         "       <jb:expression property=\"specificProblem\">\"SNMP Fault\"</jb:expression>\r\n" +
 130                         "       <jb:value property=\"faultFieldsVersion\" data=\"2.0\" default=\"2.0\" decoder=\"Double\" />\r\n" +
 131                         "       <jb:wiring property=\"alarmAdditionalInformation\" beanIdRef=\"alarmAdditionalInformationroot\"/>   \r\n" +
 132                         "               <jb:expression property=\"vfStatus\">\"Active\"</jb:expression>\r\n" +
 133                         "       \r\n" +
 134                         "    </jb:bean>  \r\n" +
 135                         "     <jb:bean class=\"java.util.ArrayList\" beanId=\"alarmAdditionalInformationroot\" createOnElement=\"vesevent\">\r\n" +
 136                         "       <jb:wiring beanIdRef=\"alarmAdditionalInformation\"/>\r\n" +
 137                         "    </jb:bean>\r\n" +
 138                         "    \r\n" +
 139                         "      <jb:bean class=\"org.onap.dcaegen2.ves.domain.AlarmAdditionalInformation\" beanId=\"alarmAdditionalInformation\" createOnElement=\"varbinds/element\">\r\n" +
 140                         "       <jb:value property=\"name\" data=\"#/varbind_oid\"/>\r\n" +
 141                         "        <jb:value property=\"value\" data=\"#/varbind_value\" />\r\n" +
 142                         "    </jb:bean>\r\n" +
 143                         "       <!--<jb:bean class=\"java.util.ArrayList\" beanId=\"additionalMeasurements\" createOnElement=\"simple\">\r\n" +
 144                         "       <jb:wiring beanIdRef=\"additionalMeasurement\"/>\r\n" +
 145                         "    </jb:bean>    \r\n" +
 146                         "    \r\n" +
 147                         "    <jb:bean class=\"org.onap.dcaegen2.ves.domain.AdditionalMeasurement\" beanId=\"additionalMeasurement\" createOnElement=\"varbinds/element\">\r\n" +
 148                         "       <jb:value property=\"name\" data=\"#/varbind_value\" />\r\n" +
 149                         "    </jb:bean>  -->  \r\n" +
 150                         "    \r\n" +
 151                         "</smooks-resource-list>");
 152         testMap.put(".1.3.6.1.4.1.1751.2.46.12", "<?xml version=\"1.0\"?>\r\n" +
 153                         "<smooks-resource-list\r\n" +
 154                         "        xmlns=\"http://www.milyn.org/xsd/smooks-1.1.xsd\"\r\n" +
 155                         "        xmlns:json=\"http://www.milyn.org/xsd/smooks/json-1.1.xsd\"\r\n" +
 156                         "        xmlns:jb=\"http://www.milyn.org/xsd/smooks/javabean-1.4.xsd\">\r\n" +
 157                         "    <json:reader rootName=\"vesevent\"  keyWhitspaceReplacement=\"-\">\r\n" +
 158                         "    <json:keyMap>\r\n" +
 159                         "               <json:key from=\"date&amp;time\" to=\"date-and-time\" />\r\n" +
 160                         "           </json:keyMap>\r\n" +
 161                         "       </json:reader>\r\n" +
 162                         "   \r\n" +
 163                         "     <jb:bean class=\"org.onap.dcaegen2.ves.domain.VesEvent\" beanId=\"vesEvent\" createOnElement=\"vesevent\">\r\n" +
 164                         "       <jb:wiring property=\"event\" beanIdRef=\"event\"/>\r\n" +
 165                         "    </jb:bean>\r\n" +
 166                         " \r\n" +
 167                         "     <jb:bean class=\"org.onap.dcaegen2.ves.domain.Event\" beanId=\"event\" createOnElement=\"vesevent\">\r\n" +
 168                         "       <jb:wiring property=\"commonEventHeader\" beanIdRef=\"commonEventHeader\"/>\r\n" +
 169                         "       <jb:wiring property=\"faultFields\" beanIdRef=\"faultFields\"/>         \r\n" +
 170                         "       <!--<jb:wiring property=\"measurementsForVfScalingFields\" beanIdRef=\"measurementsForVfScalingFields\"/> -->           \r\n" +
 171                         "    </jb:bean>   \r\n" +
 172                         "    <!--<jb:bean class=\"org.onap.dcaegen2.ves.domain.MeasurementsForVfScalingFields\" beanId=\"measurementsForVfScalingFields\" createOnElement=\"simple\">\r\n" +
 173                         "       <jb:wiring property=\"additionalMeasurements\" beanIdRef=\"additionalMeasurements\"/>\r\n" +
 174                         "    </jb:bean>-->\r\n" +
 175                         "    \r\n" +
 176                         "    <jb:bean class=\"org.onap.dcaegen2.ves.domain.CommonEventHeader\" beanId=\"commonEventHeader\" createOnElement=\"vesevent\">\r\n" +
 177                         "               <jb:expression property=\"version\">\"3.0\"</jb:expression>\r\n" +
 178                         "               <jb:expression property=\"eventId\">\"XXXX\"</jb:expression>\r\n" +
 179                         "               <jb:expression property=\"reportingEntityName\">\"VesAdapter\"</jb:expression>\r\n" +
 180                         "               <jb:expression property=\"domain\">\"fault\"</jb:expression>\r\n" +
 181                         "               <jb:expression property=\"eventName\" execOnElement=\"vesevent\" >commonEventHeader.domain+\"_\"+commonEventHeader.reportingEntityName +\"_\"+ faultFields.alarmCondition;</jb:expression>\r\n" +
 182                         "       <jb:value property=\"sequence\" data=\"0\" default=\"0\" decoder=\"Long\"/>\r\n" +
 183                         "       <jb:value property=\"lastEpochMicrosec\" data=\"#/time-received\"  decoder=\"Double\" />\r\n" +
 184                         "       <jb:value property=\"startEpochMicrosec\" data=\"#/time-received\"  decoder=\"Double\"/>\r\n" +
 185                         "               <jb:expression property=\"priority\">\"Medium\"</jb:expression>\r\n" +
 186                         "       <jb:expression property=\"sourceName\">\"VesAdapter\"</jb:expression>\r\n" +
 187                         "    </jb:bean>   \r\n" +
 188                         "    \r\n" +
 189                         "    <jb:bean class=\"org.onap.dcaegen2.ves.domain.FaultFields\" beanId=\"faultFields\" createOnElement=\"vesevent\">\r\n" +
 190                         "       <jb:value property=\"alarmCondition\" data=\"#/trap-category\" />\r\n" +
 191                         "               <jb:expression property=\"eventSeverity\">\"MINOR\"</jb:expression>\r\n" +
 192                         "               <jb:expression property=\"eventSourceType\">\"SNMP Agent\"</jb:expression>\r\n" +
 193                         "       <jb:expression property=\"specificProblem\">\"SNMP Fault\"</jb:expression>\r\n" +
 194                         "       <jb:value property=\"faultFieldsVersion\" data=\"2.0\" default=\"2.0\" decoder=\"Double\" />\r\n" +
 195                         "       <jb:wiring property=\"alarmAdditionalInformation\" beanIdRef=\"alarmAdditionalInformationroot\"/>   \r\n" +
 196                         "               <jb:expression property=\"vfStatus\">\"Active\"</jb:expression>\r\n" +
 197                         "       \r\n" +
 198                         "    </jb:bean>  \r\n" +
 199                         "     <jb:bean class=\"java.util.ArrayList\" beanId=\"alarmAdditionalInformationroot\" createOnElement=\"vesevent\">\r\n" +
 200                         "       <jb:wiring beanIdRef=\"alarmAdditionalInformation\"/>\r\n" +
 201                         "    </jb:bean>\r\n" +
 202                         "    \r\n" +
 203                         "      <jb:bean class=\"org.onap.dcaegen2.ves.domain.AlarmAdditionalInformation\" beanId=\"alarmAdditionalInformation\" createOnElement=\"varbinds/element\">\r\n" +
 204                         "       <jb:value property=\"name\" data=\"#/varbind_oid\"/>\r\n" +
 205                         "        <jb:value property=\"value\" data=\"#/varbind_value\" />\r\n" +
 206                         "    </jb:bean>\r\n" +
 207                         "       <!--<jb:bean class=\"java.util.ArrayList\" beanId=\"additionalMeasurements\" createOnElement=\"simple\">\r\n" +
 208                         "       <jb:wiring beanIdRef=\"additionalMeasurement\"/>\r\n" +
 209                         "    </jb:bean>    \r\n" +
 210                         "    \r\n" +
 211                         "    <jb:bean class=\"org.onap.dcaegen2.ves.domain.AdditionalMeasurement\" beanId=\"additionalMeasurement\" createOnElement=\"varbinds/element\">\r\n" +
 212                         "       <jb:value property=\"name\" data=\"#/varbind_value\" />\r\n" +
 213                         "    </jb:bean>  -->  \r\n" +
 214                         "    \r\n" +
 215                         "</smooks-resource-list>");
 216
 217         try {
 218
 219             VESAdapterInitializer.setMappingFiles(testMap);
 220                 String actualResult = universalVesAdapter.transform(incomingJsonString.toString(), "snmp");
 221             assertNotNull(actualResult);
 222             assertNotEquals("", actualResult);
 223         } catch (VesException exception) {
 224             eLOGGER.error("Error occurred : ", exception );
 225         }
 226         }
 227
 228
 229
 230
 231 }